@ -89,8 +89,7 @@ func Dial(target string, opts ...DialOption) (*ClientConn, error) {
|
|||||||
for _, opt := range opts {
|
for _, opt := range opts {
|
||||||
opt(&cc.dopts)
|
opt(&cc.dopts)
|
||||||
}
|
}
|
||||||
err := cc.resetTransport(false)
|
if err := cc.resetTransport(false); err != nil {
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
cc.shutdownChan = make(chan struct{})
|
cc.shutdownChan = make(chan struct{})
|
||||||
@ -163,8 +162,7 @@ func (cc *ClientConn) transportMonitor() {
|
|||||||
case <-cc.shutdownChan:
|
case <-cc.shutdownChan:
|
||||||
return
|
return
|
||||||
case <-cc.transport.Error():
|
case <-cc.transport.Error():
|
||||||
err := cc.resetTransport(true)
|
if err := cc.resetTransport(true); err != nil {
|
||||||
if err != nil {
|
|
||||||
// The channel is closing.
|
// The channel is closing.
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user