From 9e74d2bf2a9ec6b57a543901093d6879ac629aa2 Mon Sep 17 00:00:00 2001
From: duanhf2012 <boyce@atbc.com>
Date: Tue, 31 Mar 2020 16:26:04 +0800
Subject: [PATCH] =?UTF-8?q?rpc=E6=8E=A5=E5=8F=A3=E8=B0=83=E7=94=A8?=
 =?UTF-8?q?=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 rpc/client.go     | 1 +
 rpc/rpchandler.go | 2 ++
 2 files changed, 3 insertions(+)

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