From ab4635c6c7c513842539a4888cfe1ebfa4e8e324 Mon Sep 17 00:00:00 2001 From: boyce Date: Wed, 23 Dec 2020 10:32:12 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96rpc=E9=94=99=E8=AF=AF?= =?UTF-8?q?=E8=BF=94=E5=9B=9E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- rpc/rpchandler.go | 1 - rpc/server.go | 4 +--- 2 files changed, 1 insertion(+), 4 deletions(-) diff --git a/rpc/rpchandler.go b/rpc/rpchandler.go index 03daf39..8191d5e 100644 --- a/rpc/rpchandler.go +++ b/rpc/rpchandler.go @@ -559,7 +559,6 @@ func (handler *RpcHandler) CastGo(serviceMethod string,args interface{}) { handler.goRpc(nil,true,0,serviceMethod,args) } -//RawGoNode(rpcProcessorType RpcProcessorType,nodeId int,serviceName string,rpcMethodId uint32,args IRawInputArgs) error func (handler *RpcHandler) RawGoNode(rpcProcessorType RpcProcessorType,nodeId int,rpcMethodId uint32,serviceName string,args IRawInputArgs) error { processor := GetProcessor(uint8(rpcProcessorType)) var pClientList [maxClusterNode]*Client diff --git a/rpc/server.go b/rpc/server.go index 9513ce9..ab732f0 100644 --- a/rpc/server.go +++ b/rpc/server.go @@ -81,12 +81,10 @@ func (server *Server) Start(listenAddr string) { func (agent *RpcAgent) OnDestroy() {} -func (agent *RpcAgent) WriteResponse(processor IRpcProcessor,serviceMethod string,seq uint64,reply interface{},err RpcError) { +func (agent *RpcAgent) WriteResponse(processor IRpcProcessor,serviceMethod string,seq uint64,reply interface{},rpcError RpcError) { var mReply []byte - var rpcError RpcError var errM error - if reply!=nil { mReply,errM = processor.Marshal(reply) if errM != nil {