diff --git a/network/tcp_client.go b/network/tcp_client.go index e800c24..7a2e977 100644 --- a/network/tcp_client.go +++ b/network/tcp_client.go @@ -72,7 +72,10 @@ func (client *TCPClient) init() { func (client *TCPClient) dial() net.Conn { for { conn, err := net.Dial("tcp", client.Addr) - if err == nil || client.closeFlag { + if client.closeFlag { + return conn + } else if err == nil && conn != nil { + conn.(*net.TCPConn).SetNoDelay(true) return conn } diff --git a/network/tcp_server.go b/network/tcp_server.go index 14bf138..9040e7f 100644 --- a/network/tcp_server.go +++ b/network/tcp_server.go @@ -95,6 +95,7 @@ func (server *TCPServer) run() { } return } + conn.(*net.TCPConn).SetNoDelay(true) tempDelay = 0 server.mutexConns.Lock()