Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-02-04 06:54:45 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

关闭套接字接口

Browse Source
This commit is contained in:
boyce
2020-02-11 15:53:35 +08:00
parent b2f7b18aaa
commit f9d6029307
2 changed files with 17 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
network/tcpsocketserver.go
View File

@@ -115,6 +115,16 @@ func (slf *TcpSocketServer) listenServer(){
} }
} }
func (slf *TcpSocketServer) Close(clientid uint64) error {
pClient := slf.mapClient.Get(clientid)
if pClient == nil {
return fmt.Errorf("clientid %d is not in connect pool.",clientid)
}
pClient.(*SClient).Close()
return nil
}
func (slf *TcpSocketServer) SendMsg(clientid uint64,packtype uint16,message proto.Message) error{ func (slf *TcpSocketServer) SendMsg(clientid uint64,packtype uint16,message proto.Message) error{
pClient := slf.mapClient.Get(clientid) pClient := slf.mapClient.Get(clientid)
if pClient == nil { if pClient == nil {

8
sysservice/tcpsocketpbservice.go
View File

@@ -153,4 +153,10 @@ func GetTcpSocketPbService(serviceName string) *TcpSocketPbService{
func (slf *TcpSocketPbService) SendMsg(clientid uint64,packtype uint16,message proto.Message) error{ func (slf *TcpSocketPbService) SendMsg(clientid uint64,packtype uint16,message proto.Message) error{
return slf.tcpsocketserver.SendMsg(clientid,packtype,message) return slf.tcpsocketserver.SendMsg(clientid,packtype,message)
} }
func (slf *TcpSocketPbService) Close(clientid uint64) error{
return slf.tcpsocketserver.Close(clientid)
}