This commit is contained in:
iamqizhao 2016-05-12 17:43:51 -07:00
commit f93b6bbfb5
1 changed files with 4 additions and 1 deletions

View File

@ -616,7 +616,10 @@ func (ac *addrConn) resetTransport(closeTransport bool) error {
return ErrClientConnTimeout
}
closeTransport = false
time.Sleep(sleepTime)
select {
case <-time.After(sleepTime):
case <-cc.shutdownChan:
}
retries++
grpclog.Printf("grpc: addrConn.resetTransport failed to create client transport: %v; Reconnecting to %q", err, ac.addr)
continue