diff --git a/src/server/cluster/Cluster.go b/src/server/cluster/Cluster.go index 400125eb..e6a12c53 100644 --- a/src/server/cluster/Cluster.go +++ b/src/server/cluster/Cluster.go @@ -30,7 +30,7 @@ func Init() { server = new(network.TCPServer) server.Addr = conf.Server.ListenAddr server.MaxConnNum = int(math.MaxInt32) - server.PendingWriteNum = 1 << 20 + server.PendingWriteNum = 1 << 14 server.LenMsgLen = 4 server.MaxMsgLen = 4096 server.NewAgent = newServerAgent diff --git a/src/server/cluster/cluster_func.go b/src/server/cluster/cluster_func.go index fdba8540..d02bdce9 100644 --- a/src/server/cluster/cluster_func.go +++ b/src/server/cluster/cluster_func.go @@ -91,7 +91,7 @@ func connectRemote(RemoteAddr string, ConnType int, ConnLabel string) error { client := new(network.TCPClient) client.Addr = RemoteAddr client.ConnNum = 1 - client.PendingWriteNum = 1 << 20 + client.PendingWriteNum = 1 << 14 client.LenMsgLen = 4 client.MaxMsgLen = 4096 client.NewAgent = newAgent