diff --git a/socket/readwrite.go b/socket/readwrite.go index b7e2308..b2cc7d5 100644 --- a/socket/readwrite.go +++ b/socket/readwrite.go @@ -4,6 +4,8 @@ import ( "fmt" "io" "time" + + logging "git.loafle.net/commons/logging-go" ) func connReadHandler(readWriteHandler ReadWriteHandler, conn Conn, stopChan <-chan struct{}, doneChan chan<- error, readChan chan<- []byte) { @@ -53,6 +55,7 @@ func connReadHandler(readWriteHandler ReadWriteHandler, conn Conn, stopChan <-ch if IsUnexpectedCloseError(err, CloseGoingAway, CloseAbnormalClosure) { err = fmt.Errorf("Read error %v", err) } + logging.Logger().Debug(err) return } @@ -91,11 +94,13 @@ func connWriteHandler(readWriteHandler ReadWriteHandler, conn Conn, stopChan <-c wc, err = conn.NextWriter(TextMessage) if err != nil { + logging.Logger().Debug(err) return } wc.Write(message) if err = wc.Close(); nil != err { + logging.Logger().Debug(err) return } case <-ticker.C: @@ -105,6 +110,7 @@ func connWriteHandler(readWriteHandler ReadWriteHandler, conn Conn, stopChan <-c conn.SetWriteDeadline(time.Time{}) } if err = conn.WriteMessage(PingMessage, nil); nil != err { + logging.Logger().Debug(err) return } case <-stopChan: