Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-02-04 06:54:45 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

修改rpc超时默认时间为15s

Browse Source
This commit is contained in:
boyce
2020-07-11 16:47:49 +08:00
parent 0fd154fc7f
commit 564e76302d
3 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
rpc/client.go
View File

@@ -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

4
rpc/rpchandler.go
View File

@@ -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{}

2
rpc/server.go
View File

@@ -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()