()
| 1669 | } |
| 1670 | |
| 1671 | func (ac *addrConn) resetConnectBackoff() { |
| 1672 | ac.mu.Lock() |
| 1673 | close(ac.resetBackoff) |
| 1674 | ac.backoffIdx = 0 |
| 1675 | ac.resetBackoff = make(chan struct{}) |
| 1676 | ac.mu.Unlock() |
| 1677 | } |
| 1678 | |
| 1679 | // getReadyTransport returns the transport if ac's state is READY or nil if not. |
| 1680 | func (ac *addrConn) getReadyTransport() transport.ClientTransport { |
no test coverage detected