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

判断rpc连接状态

Browse Source
This commit is contained in:
duanhf2012
2020-04-02 21:46:13 +08:00
parent 3ff1c75232
commit 060fb6d34c
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
rpc/client.go
View File

@@ -122,6 +122,11 @@ func (slf *Client) Go(noReply bool,serviceMethod string, args interface{},reply
return call return call
} }
if slf.conn == nil {
call.Err = fmt.Errorf("call %s is fail,rpc client is disconnect.",serviceMethod)
return call
}
err = slf.conn.WriteMsg(bytes) err = slf.conn.WriteMsg(bytes)
if err != nil { if err != nil {
call.Err = err call.Err = err