From d326a8c4cfc6831e9bc9af82389cbbe037baca2e Mon Sep 17 00:00:00 2001 From: hahwu <31872165+hahwu@users.noreply.github.com> Date: Tue, 30 Dec 2025 16:43:07 +0800 Subject: [PATCH] =?UTF-8?q?=E8=BF=9E=E6=8E=A5=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/server/cluster/Cluster.go | 2 +- src/server/cluster/cluster_func.go | 2 +- src/server/conf/conf.go | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) 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