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

revert some unnecessary changes

Browse Source
This commit is contained in:
iamqizhao
2015-08-03 13:18:25 -07:00
parent 8fc68cd569
commit cf1376e56b
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
clientconn.go
View File

@ -241,16 +241,16 @@ func (cc *ClientConn) WaitForStateChange(timeout time.Duration, sourceState Conn
return false return false
} }
done := make(chan struct{}) done := make(chan struct{})
go func(expired *bool) { go func() {
select { select {
case <-time.After(timeout-time.Since(start)): case <-time.After(timeout-time.Since(start)):
cc.mu.Lock() cc.mu.Lock()
*expired = true expired = true
cc.stateCV.Broadcast() cc.stateCV.Broadcast()
cc.mu.Unlock() cc.mu.Unlock()
case <-done: case <-done:
} }
}(&expired) }()
defer close(done) defer close(done)
for sourceState == cc.state { for sourceState == cc.state {
cc.stateCV.Wait() cc.stateCV.Wait()