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

新增网络层buff内存池回收接口

Browse Source
This commit is contained in:
boyce
2020-12-24 11:19:55 +08:00
parent 73be7dcedf
commit 11b214b445
2 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
network/tcp_server.go
View File

@@ -68,6 +68,10 @@ func (server *TCPServer) SetNetMempool(mempool INetMempool){
server.msgParser.INetMempool = mempool server.msgParser.INetMempool = mempool
} }
func (server *TCPServer) GetNetMempool() INetMempool{
return server.msgParser.INetMempool
}
func (server *TCPServer) run() { func (server *TCPServer) run() {
server.wgLn.Add(1) server.wgLn.Add(1)
defer server.wgLn.Done() defer server.wgLn.Done()

8
sysservice/tcpservice/tcpservice.go
View File

@@ -275,3 +275,11 @@ func (tcpService *TcpService) GetConnNum() int {
func (server *TcpService) SetNetMempool(mempool network.INetMempool){ func (server *TcpService) SetNetMempool(mempool network.INetMempool){
server.tcpServer.SetNetMempool(mempool) server.tcpServer.SetNetMempool(mempool)
} }
func (server *TcpService) GetNetMempool() network.INetMempool{
return server.tcpServer.GetNetMempool()
}
func (server *TcpService) ReleaseNetMem(byteBuff []byte) {
server.tcpServer.GetNetMempool().ReleaseByteSlice(byteBuff)
}