diff --git a/network/tcpsocketserver.go b/network/tcpsocketserver.go index 762927e..9c34c73 100644 --- a/network/tcpsocketserver.go +++ b/network/tcpsocketserver.go @@ -19,7 +19,6 @@ type ITcpSocketServerReciver interface { OnConnected(pClient *SClient) OnDisconnect(pClient *SClient) OnRecvMsg(pClient *SClient, pPack *MsgBasePack) - VerifyPackType(packtype uint16) bool } @@ -175,7 +174,7 @@ func (slf *SClient) listendata(){ fillsize,bfillRet,fillhead := pack.FillData(buff,buffDataSize) //提交校验头 if fillhead == true { - if pack.PackSize>slf.tcpserver.MaxRecvPackSize || slf.tcpserver.iReciver.VerifyPackType(pack.PackType) == false { + if pack.PackSize>slf.tcpserver.MaxRecvPackSize { service.GetLogger().Printf(service.LEVER_WARN, "VerifyPackType error clent id %d is disconnect %d,%d",slf.id,pack.PackType, pack.PackSize) return } diff --git a/sysservice/tcpsocketpbservice.go b/sysservice/tcpsocketpbservice.go index 4a3f8d0..f0be692 100644 --- a/sysservice/tcpsocketpbservice.go +++ b/sysservice/tcpsocketpbservice.go @@ -114,10 +114,7 @@ func (slf *TcpSocketPbService) OnDisconnect(pClient *network.SClient){ slf.disconnEvent(pClient.GetId()) } } -func (slf *TcpSocketPbService) VerifyPackType(packtype uint16) bool{ - _,ok := slf.mapMsg[packtype] - return ok -} + func (slf *MsgProcessor) Handle(pClient *network.SClient,pPack *network.MsgBasePack){ if info, ok := slf.mapMsg[pPack.PackType]; ok {