|
@@ -18,6 +18,7 @@ import (
|
|
"fmt"
|
|
"fmt"
|
|
"io"
|
|
"io"
|
|
"log"
|
|
"log"
|
|
|
|
+ "net"
|
|
"net/http"
|
|
"net/http"
|
|
"reflect"
|
|
"reflect"
|
|
"runtime"
|
|
"runtime"
|
|
@@ -207,13 +208,13 @@ func (s *Session) listen(wsConn *websocket.Conn, listening <-chan interface{}) {
|
|
neterr, ok := err.(net.Error)
|
|
neterr, ok := err.(net.Error)
|
|
if ok {
|
|
if ok {
|
|
if neterr.Timeout() {
|
|
if neterr.Timeout() {
|
|
- v.log(LogDebug, "neterr udp timeout error")
|
|
|
|
|
|
+ s.log(LogDebug, "neterr udp timeout error")
|
|
}
|
|
}
|
|
|
|
|
|
if neterr.Temporary() {
|
|
if neterr.Temporary() {
|
|
- v.log(LogDebug, "neterr udp tempoary error")
|
|
|
|
|
|
+ s.log(LogDebug, "neterr udp tempoary error")
|
|
}
|
|
}
|
|
- v.log(LogDebug, "neterr udp error %s", neterr.Error())
|
|
|
|
|
|
+ s.log(LogDebug, "neterr udp error %s", neterr.Error())
|
|
}
|
|
}
|
|
|
|
|
|
s.log(LogWarning, "error reading from gateway %s websocket, %s", s.gateway, err)
|
|
s.log(LogWarning, "error reading from gateway %s websocket, %s", s.gateway, err)
|