From e4be36a4345cad4e645689e06d7249531cecbc00 Mon Sep 17 00:00:00 2001 From: flswld Date: Sat, 11 Feb 2023 21:31:10 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=BC=82=E5=B8=B8=E5=9C=A8?= =?UTF-8?q?=E7=BA=BF=E6=95=B0=E9=87=8F=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- gate/net/kcp_connect_manager.go | 1 + gate/net/session.go | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/gate/net/kcp_connect_manager.go b/gate/net/kcp_connect_manager.go index 36e3e376..d3d70281 100644 --- a/gate/net/kcp_connect_manager.go +++ b/gate/net/kcp_connect_manager.go @@ -150,6 +150,7 @@ func (k *KcpConnectManager) acceptHandle(listener *kcp.Listener) { } conn.SetACKNoDelay(true) conn.SetWriteDelay(false) + atomic.AddInt32(&CLIENT_CONN_NUM, 1) logger.Info("client connect, convId: %v", convId) kcpRawSendChan := make(chan *ProtoMsg, 1000) session := &Session{ diff --git a/gate/net/session.go b/gate/net/session.go index 6e1f3c61..5409ab8d 100644 --- a/gate/net/session.go +++ b/gate/net/session.go @@ -377,7 +377,7 @@ func (k *KcpConnectManager) getPlayerToken(req *proto.GetPlayerTokenReq, session // 封号通知 return loginFailRsp(int32(proto.Retcode_RET_BLACK_UID), true, tokenVerifyRsp.ForbidEndTime) } - clientConnNum := atomic.AddInt32(&CLIENT_CONN_NUM, 1) + clientConnNum := atomic.LoadInt32(&CLIENT_CONN_NUM) if clientConnNum > MaxClientConnNumLimit { logger.Error("gate conn num limit, uid: %v", uid) return loginFailRsp(int32(proto.Retcode_RET_MAX_PLAYER), false, 0)