opensource/grpc-go
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add a shortcut logic

Browse Source
This commit is contained in:
iamqizhao
2015-08-03 11:29:27 -07:00
parent 494b40089f
commit 08b3e19185
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
clientconn.go
View File

@ -238,6 +238,9 @@ func (cc *ClientConn) WaitForStateChange(timeout time.Duration, sourceState Conn
} }
done := make(chan struct{}) done := make(chan struct{})
expired := timeout <= time.Since(start) expired := timeout <= time.Since(start)
if expired {
return false
}
go func() { go func() {
select { select {
case <-time.After(timeout-time.Since(start)): case <-time.After(timeout-time.Since(start)):