Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-02-28 01:44:47 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

同步代码

Browse Source
This commit is contained in:
duanhf2012
2020-02-24 17:18:03 +08:00
parent 751d932f90
commit 5680712396
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
sysservice/tcpsocketpbservice.go
View File

@@ -110,21 +110,21 @@ func (slf *TcpSocketPbService) OnExceptMsg (pClient *network.SClient,pPack *netw
}else{ }else{
pClient.Close() pClient.Close()
//记录日志 //记录日志
service.GetLogger().Printf(service.LEVER_WARN, "OnExceptMsg packtype %d,error %+v",pPack.PackType(),err) service.GetLogger().Printf(service.LEVER_WARN, "OnExceptMsg packtype %d,error %+v",pPack.PackType,err)
} }
} }
func (slf *TcpSocketPbService) OnRecvMsg(pClient *network.SClient, pPack *network.MsgBasePack){ func (slf *TcpSocketPbService) OnRecvMsg(pClient *network.SClient, pPack *network.MsgBasePack){
if info, ok := slf.mapMsg[pPack.PackType()]; ok { if info, ok := slf.mapMsg[pPack.PackType]; ok {
msg := reflect.New(info.msgType.Elem()).Interface() msg := reflect.New(info.msgType.Elem()).Interface()
tmp := msg.(proto.Message) tmp := msg.(proto.Message)
err := proto.Unmarshal(pPack.Body(), tmp) err := proto.Unmarshal(pPack.Body, tmp)
if err != nil { if err != nil {
slf.OnExceptMsg(pClient,pPack,err) slf.OnExceptMsg(pClient,pPack,err)
return return
} }
info.msgHandler(pClient.GetId(),pPack.PackType(), msg.(proto.Message)) info.msgHandler(pClient.GetId(),pPack.PackType, msg.(proto.Message))
return return
} }