diff --git a/rpc/client.go b/rpc/client.go index 4c0501f..69c2bfb 100644 --- a/rpc/client.go +++ b/rpc/client.go @@ -23,6 +23,7 @@ type Client struct { func (slf *Client) NewClientAgent(conn *network.TCPConn) network.Agent { slf.conn = conn + slf.pending = map[uint64]*Call{} return slf } diff --git a/rpc/rpchandler.go b/rpc/rpchandler.go index c62902c..fa74232 100644 --- a/rpc/rpchandler.go +++ b/rpc/rpchandler.go @@ -258,6 +258,7 @@ func (slf *RpcHandler) goRpc(bCast bool,nodeId int,serviceMethod string,mutiCoro if pCall.Err!=nil { err = pCall.Err } + continue } //跨node调用 @@ -265,6 +266,7 @@ func (slf *RpcHandler) goRpc(bCast bool,nodeId int,serviceMethod string,mutiCoro if pCall.Err!=nil { err = pCall.Err } + } return err