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

超时时间设为30秒

Browse Source
This commit is contained in:
boyce
2019-07-29 20:50:24 +08:00
parent 716a8e0946
commit 05c5f0a935
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
rpc/client.go
View File

@@ -347,9 +347,9 @@ func (client *Client) Call(serviceMethod string, args interface{}, reply interfa
select { select {
case call := <-client.Go(serviceMethod, args, reply, make(chan *Call, 1), false).Done: case call := <-client.Go(serviceMethod, args, reply, make(chan *Call, 1), false).Done:
return call.Error return call.Error
case <-time.After(15 * time.Second): case <-time.After(30 * time.Second):
} }
//call := <-client.Go(serviceMethod, args, reply, make(chan *Call, 1)).Done //call := <-client.Go(serviceMethod, args, reply, make(chan *Call, 1)).Done
return errors.New(fmt.Sprintf("Call RPC %s is time out 10s", serviceMethod)) return errors.New(fmt.Sprintf("Call RPC %s is time out 30s", serviceMethod))
} }