From 1acbe9c4753c5e58a74bef49736fae028616d900 Mon Sep 17 00:00:00 2001 From: Zack Scholl Date: Sat, 22 Sep 2018 09:48:22 -0700 Subject: [PATCH] relay log more --- src/relay/conn.go | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/src/relay/conn.go b/src/relay/conn.go index a9eb25db..0e2d3f5b 100644 --- a/src/relay/conn.go +++ b/src/relay/conn.go @@ -81,14 +81,19 @@ func (s *subscription) writePump() { select { case message, ok := <-c.send: if !ok { - c.write(websocket.CloseMessage, []byte{}) + err := c.write(websocket.CloseMessage, []byte{}) + if err != nil { + log.Debug(err) + } return } if err := c.write(message.messageType, message.data); err != nil { + log.Debug(err) return } case <-ticker.C: if err := c.write(websocket.PingMessage, []byte{}); err != nil { + log.Debug(err) return } } @@ -99,7 +104,7 @@ func (s *subscription) writePump() { func serveWs(w http.ResponseWriter, r *http.Request) { ws, err := upgrader.Upgrade(w, r, nil) if err != nil { - log.Error(err) + log.Debug(err) return } vals := r.URL.Query()