Merge pull request #680 from heyitsanthony/client-retry-wakeup-shutdown
Interrupt retry Sleep() on client connection shutdown
This commit is contained in:
@ -491,7 +491,10 @@ func (cc *Conn) resetTransport(closeTransport bool) error {
|
||||
return ErrClientConnTimeout
|
||||
}
|
||||
closeTransport = false
|
||||
time.Sleep(sleepTime)
|
||||
select {
|
||||
case <-time.After(sleepTime):
|
||||
case <-cc.shutdownChan:
|
||||
}
|
||||
retries++
|
||||
grpclog.Printf("grpc: Conn.resetTransport failed to create client transport: %v; Reconnecting to %q", err, cc.target)
|
||||
continue
|
||||
|
Reference in New Issue
Block a user