diff --git a/network/processor/pbprocessor.go b/network/processor/pbprocessor.go index 8bf6c79..af8800d 100644 --- a/network/processor/pbprocessor.go +++ b/network/processor/pbprocessor.go @@ -92,7 +92,7 @@ func (slf *PBProcessor ) Marshal(msg interface{}) ([]byte, error){ var err error if pMsg.msg!=nil { - pMsg.rawMsg,err = proto.Marshal(pMsg.msg.(proto.Message)) + pMsg.rawMsg,err = proto.Marshal(pMsg.msg) if err != nil { return nil,err } diff --git a/rpc/rpchandler.go b/rpc/rpchandler.go index 7f19479..0798f08 100644 --- a/rpc/rpchandler.go +++ b/rpc/rpchandler.go @@ -245,6 +245,7 @@ func (slf *RpcHandler) HandlerRpcRequest(request *RpcRequest) { if request.requestHandle!=nil { request.requestHandle(nil, rerr) } + return } }else { if request.localRawParam!=nil { @@ -255,6 +256,7 @@ func (slf *RpcHandler) HandlerRpcRequest(request *RpcRequest) { if request.requestHandle!=nil { request.requestHandle(nil, rerr) } + return } }else { iparam = request.localParam