Fix ping2
This commit is contained in:
@@ -12,7 +12,7 @@
|
||||
type cmpWbsCliStruct struct {
|
||||
W http.ResponseWriter
|
||||
Connect *websocket.Conn
|
||||
Mutex sync.Mutex
|
||||
Mutex *sync.Mutex
|
||||
HostPort string
|
||||
}
|
||||
|
||||
@@ -51,7 +51,7 @@
|
||||
var cmpWbsCli cmpWbsCliStruct = cmpWbsCliStruct{
|
||||
w,
|
||||
conn,
|
||||
Mutex,
|
||||
&Mutex,
|
||||
HostPort,
|
||||
}
|
||||
|
||||
@@ -132,14 +132,14 @@
|
||||
func (app *App) HttpWebSockSendRawTo(cmpWbsCli cmpWbsCliStruct, raw map[string]interface{}) {
|
||||
var err error
|
||||
|
||||
app.Log("LOCK")
|
||||
// app.Log("LOCK")
|
||||
|
||||
cmpWbsCli.Mutex.Lock()
|
||||
|
||||
defer cmpWbsCli.Mutex.Unlock()
|
||||
|
||||
err = cmpWbsCli.Connect.WriteJSON(raw)
|
||||
|
||||
cmpWbsCli.Mutex.Unlock()
|
||||
|
||||
if err != nil {
|
||||
app.Log(err)
|
||||
return
|
||||
|
@@ -78,31 +78,6 @@
|
||||
}, nil
|
||||
}
|
||||
|
||||
|
||||
func (app *App) copyAndCapture(r io.Reader, strWin string) ([]byte, error) {
|
||||
var out []byte
|
||||
buf := make([]byte, 1024, 1024)
|
||||
for {
|
||||
n, err := r.Read(buf[:])
|
||||
if n > 0 {
|
||||
d := buf[:n]
|
||||
out = append(out, d...)
|
||||
str := strings.Trim(string(d), "\n\r")
|
||||
|
||||
app.Log("Std: %s", str)
|
||||
|
||||
app.Ping2SendStr(str)
|
||||
}
|
||||
if err != nil {
|
||||
// Read returns io.EOF at the end of file, which is not an error for us
|
||||
if err == io.EOF {
|
||||
err = nil
|
||||
}
|
||||
return out, err
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func (app *App) Ping2SendObj(obj map[string]interface{}) (error) {
|
||||
if app.CliCur == nil {
|
||||
app.Log("No cli")
|
||||
@@ -113,14 +88,14 @@ func (app *App) copyAndCapture(r io.Reader, strWin string) ([]byte, error) {
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
/*
|
||||
func (app *App) Ping2SendStr(str string) (error) {
|
||||
return app.Ping2SendObj(map[string]interface{}{
|
||||
"data" : "stdout",
|
||||
"string": str,
|
||||
})
|
||||
}
|
||||
|
||||
*/
|
||||
|
||||
|
||||
|
||||
@@ -136,7 +111,11 @@ func (app *App) ping2Capture(r io.Reader, strWin string) ([]byte, error) {
|
||||
|
||||
app.Log("Std: %s", str)
|
||||
|
||||
app.Ping2SendStr(str)
|
||||
app.Ping2SendObj(map[string]interface{}{
|
||||
"data" : "stdout",
|
||||
"win" : strWin,
|
||||
"string": str,
|
||||
})
|
||||
}
|
||||
if err != nil {
|
||||
// Read returns io.EOF at the end of file, which is not an error for us
|
||||
|
Reference in New Issue
Block a user