fix reusing buffers from hijack

centrifugal · Mar 14, 2017 · 2e9a720 · 2e9a720 · FZambia · Mar 14, 2017
1 parent 56f7e37
commit 2e9a720
Showing 1 changed file with 2 additions and 13 deletions.
diff --git a/libcentrifugo/server/httpserver/handlers.go b/libcentrifugo/server/httpserver/handlers.go
@@ -113,12 +113,8 @@ func (s *HTTPServer) runHTTPServer() error {
 	wsWriteBufferSize := s.config.WebsocketWriteBufferSize
 	s.RUnlock()
 
-	if wsReadBufferSize > 0 {
-		sockjs.WebSocketReadBufSize = wsReadBufferSize
-	}
-	if wsWriteBufferSize > 0 {
-		sockjs.WebSocketWriteBufSize = wsWriteBufferSize
-	}
+	sockjs.WebSocketReadBufSize = wsReadBufferSize
+	sockjs.WebSocketWriteBufSize = wsWriteBufferSize
 
 	sockjsOpts := sockjs.DefaultOptions
 
@@ -367,13 +363,6 @@ func (s *HTTPServer) RawWebsocketHandler(w http.ResponseWriter, r *http.Request)
 	wsWriteBufferSize := s.config.WebsocketWriteBufferSize
 	s.RUnlock()
 
-	if wsReadBufferSize == 0 {
-		wsReadBufferSize = sockjs.WebSocketReadBufSize
-	}
-	if wsWriteBufferSize == 0 {
-		wsWriteBufferSize = sockjs.WebSocketWriteBufSize
-	}
-
 	upgrader := websocket.Upgrader{
 		ReadBufferSize:    wsReadBufferSize,
 		WriteBufferSize:   wsWriteBufferSize,