From 564e76302dd3c7ac93092a46609a3c54138b0b96 Mon Sep 17 00:00:00 2001
From: boyce <boyce@atbc.com>
Date: Sat, 11 Jul 2020 16:47:49 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9rpc=E8=B6=85=E6=97=B6?=
 =?UTF-8?q?=E9=BB=98=E8=AE=A4=E6=97=B6=E9=97=B4=E4=B8=BA15s?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 rpc/client.go     | 4 ++--
 rpc/rpchandler.go | 4 ++--
 rpc/server.go     | 2 +-
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/rpc/client.go b/rpc/client.go
index 7dc884c..46f00f3 100644
--- a/rpc/client.go
+++ b/rpc/client.go
@@ -36,10 +36,10 @@ func (slf *Client) NewClientAgent(conn *network.TCPConn) network.Agent {
 func (slf *Client) Connect(addr string) error {
 	slf.Addr = addr
 	slf.maxCheckCallRpcCount = 100
-	slf.callRpcTimerout = 10*time.Second
+	slf.callRpcTimerout = 15*time.Second
 	slf.ConnNum = 1
 	slf.ConnectInterval = time.Second*2
-	slf.PendingWriteNum = 10000
+	slf.PendingWriteNum = 2000000
 	slf.AutoReconnect = true
 	slf.LenMsgLen = 2
 	slf.MinMsgLen = 2
diff --git a/rpc/rpchandler.go b/rpc/rpchandler.go
index 554a3eb..f8f8e8b 100644
--- a/rpc/rpchandler.go
+++ b/rpc/rpchandler.go
@@ -80,8 +80,8 @@ func (slf *RpcHandler) GetRpcHandler() IRpcHandler{
 }
 
 func (slf *RpcHandler) InitRpcHandler(rpcHandler IRpcHandler,getClientFun FuncRpcClient,getServerFun FuncRpcServer) {
-	slf.callRequest = make(chan *RpcRequest,100000)
-	slf.callResponeCallBack = make(chan *Call,100000)
+	slf.callRequest = make(chan *RpcRequest,1000000)
+	slf.callResponeCallBack = make(chan *Call,1000000)
 
 	slf.rpcHandler = rpcHandler
 	slf.mapfunctons = map[string]RpcMethodInfo{}
diff --git a/rpc/server.go b/rpc/server.go
index 1352672..9ab575a 100644
--- a/rpc/server.go
+++ b/rpc/server.go
@@ -40,7 +40,7 @@ func (slf *Server) Start(listenAddr string) {
 	slf.rpcserver.MinMsgLen = 2
 	slf.rpcserver.MaxMsgLen = math.MaxUint16
 	slf.rpcserver.MaxConnNum = 10000
-	slf.rpcserver.PendingWriteNum = 10000
+	slf.rpcserver.PendingWriteNum = 2000000
 	slf.rpcserver.NewAgent =slf.NewAgent
 	slf.rpcserver.LittleEndian = LittleEndian
 	slf.rpcserver.Start()