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

优化RPC异步调用

Browse Source
This commit is contained in:
lifeiyi
2021-01-05 18:23:50 +08:00
parent d84d5c60bd
commit a282c7c268
2 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
rpc/rpchandler.go
View File

@@ -235,8 +235,11 @@ func (handler *RpcHandler) HandlerRpcRequest(request *RpcRequest) {
request.requestHandle(nil,rpcErr) request.requestHandle(nil,rpcErr)
} }
} }
if request.requestHandle == nil {
ReleaseRpcRequest(request)
}
}() }()
defer ReleaseRpcRequest(request)
if request.inputArgs!=nil { if request.inputArgs!=nil {
defer request.inputArgs.DoGc() defer request.inputArgs.DoGc()
} }

1
rpc/server.go
View File

@@ -164,6 +164,7 @@ func (agent *RpcAgent) Run() {
if req.RpcRequestData.IsNoReply()==false { if req.RpcRequestData.IsNoReply()==false {
req.requestHandle = func(Returns interface{},Err RpcError){ req.requestHandle = func(Returns interface{},Err RpcError){
agent.WriteResponse(processor,req.RpcRequestData.GetServiceMethod(),req.RpcRequestData.GetSeq(),Returns,Err) agent.WriteResponse(processor,req.RpcRequestData.GetServiceMethod(),req.RpcRequestData.GetSeq(),Returns,Err)
ReleaseRpcRequest(req)
} }
} }