diff --git a/src/server/cluster/Cluster.go b/src/server/cluster/Cluster.go index 053909e5..400125eb 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 = conf.PendingWriteNum + server.PendingWriteNum = 1 << 20 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 5f6d63d8..fdba8540 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 = conf.PendingWriteNum + client.PendingWriteNum = 1 << 20 client.LenMsgLen = 4 client.MaxMsgLen = 4096 client.NewAgent = newAgent diff --git a/src/server/conf/conf.go b/src/server/conf/conf.go index b66d324d..eac00ff8 100644 --- a/src/server/conf/conf.go +++ b/src/server/conf/conf.go @@ -10,8 +10,8 @@ var ( LogFlag = log.LstdFlags | log.Lmicroseconds // gate conf - PendingWriteNum = 1 << 20 // 1M - MaxMsgLen uint32 = 65536 // 16KB + PendingWriteNum = 65536 // 1M + MaxMsgLen uint32 = 65536 // 16KB HTTPTimeout = 10 * time.Second LenMsgLen = 2 LittleEndian = false