From 729bcfdc948c54702783bd7895a0078081388fcd Mon Sep 17 00:00:00 2001 From: jmank88 Date: Wed, 8 Sep 2021 15:46:49 -0500 Subject: [PATCH] rpc: set websocket read deadline after Ping --- rpc/websocket.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/rpc/websocket.go b/rpc/websocket.go index afeb4c2081b84..5e3ff49ce5acd 100644 --- a/rpc/websocket.go +++ b/rpc/websocket.go @@ -37,6 +37,7 @@ const ( wsWriteBuffer = 1024 wsPingInterval = 60 * time.Second wsPingWriteTimeout = 5 * time.Second + wsPongTimeout = 30 * time.Second wsMessageSizeLimit = 15 * 1024 * 1024 ) @@ -287,6 +288,7 @@ func (wc *websocketCodec) pingLoop() { wc.jsonCodec.encMu.Lock() wc.conn.SetWriteDeadline(time.Now().Add(wsPingWriteTimeout)) wc.conn.WriteMessage(websocket.PingMessage, nil) + wc.conn.SetReadDeadline(time.Now().Add(wsPongTimeout)) wc.jsonCodec.encMu.Unlock() timer.Reset(wsPingInterval) }