force control channel for nodelay

Musixal · Nov 26, 2024 · 45fdd76 · 45fdd76
1 parent ae2b478
commit 45fdd76
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/internal/server/transport/tcpmux.go b/internal/server/transport/tcpmux.go
@@ -205,6 +205,16 @@ func (s *TcpMuxTransport) channelHandshake() {
 				continue
 			}
 
+			//FORCE CONTROL CHANNEL TO BE TCP_NODELAY
+			tcpConn, ok := conn.(*net.TCPConn)
+			if !ok {
+				conn.Close()
+				continue
+			}
+			if err := tcpConn.SetNoDelay(true); err != nil {
+				s.logger.Warnf("failed to set TCP_NODELAY for Control Channel %s: %v", tcpConn.RemoteAddr().String(), err)
+			}
+
 			s.controlChannel = conn
 
 			s.logger.Info("control channel successfully established.")