From c803b9b9ad2a9e9e0aa7d07a933fba86da039b8e Mon Sep 17 00:00:00 2001 From: duanhf2012 <6549168@qq.com> Date: Fri, 22 Sep 2023 16:29:31 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96tcpservice?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sysservice/tcpservice/tcpservice.go | 11 +---------- 1 file changed, 1 insertion(+), 10 deletions(-) diff --git a/sysservice/tcpservice/tcpservice.go b/sysservice/tcpservice/tcpservice.go index 81af4db..c5cd425 100644 --- a/sysservice/tcpservice/tcpservice.go +++ b/sysservice/tcpservice/tcpservice.go @@ -53,18 +53,9 @@ type Client struct { } func (tcpService *TcpService) genId() uint64 { - if node.GetNodeId()>MaxNodeId{ - panic("nodeId exceeds the maximum!") - } - newSeed := atomic.AddUint32(&seed,1) % MaxSeed nowTime := uint64(time.Now().Unix())%MaxTime - return (uint64(node.GetNodeId())<<50)|(nowTime<<19)|uint64(newSeed) -} - - -func GetNodeId(agentId uint64) int { - return int(agentId>>50) + return (uint64(node.GetNodeId()%MaxNodeId)<<50)|(nowTime<<19)|uint64(newSeed) } func (tcpService *TcpService) OnInit() error{