diff --git a/rpc/server.go b/rpc/server.go index 52e4bb9..eb7ee88 100644 --- a/rpc/server.go +++ b/rpc/server.go @@ -179,9 +179,10 @@ func (agent *RpcAgent) Run() { rErr := "Call Rpc "+req.RpcRequestData.GetServiceMethod()+" Param error "+err.Error() if req.requestHandle!=nil { req.requestHandle(nil, RpcError(rErr)) + }else{ + ReleaseRpcRequest(req) } log.SError(rErr) - ReleaseRpcRequest(req) continue }