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

增加rpc client状态判断

Browse Source
This commit is contained in:
boyce
2019-04-20 11:51:02 +08:00
parent 49545403b1
commit a900f32730
2 changed files with 30 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
rpc/client.go
View File

@@ -70,6 +70,12 @@ type ClientCodec interface {
Close() error
}
func (client *Client) IsClosed() bool {
client.reqMutex.Lock()
defer client.reqMutex.Unlock()
return client.shutdown || client.closing
}
func (client *Client) send(call *Call, queueMode bool) {
client.reqMutex.Lock()
defer client.reqMutex.Unlock()