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 {