Lines Matching defs:addrConn
1113 type addrConn struct { struct
1114 ctx context.Context
1115 cancel context.CancelFunc
1117 cc *ClientConn
1118 addrs []resolver.Address
1119 dopts dialOptions
1120 events trace.EventLog
1121 acbw balancer.SubConn
1123 mu sync.Mutex
1124 curAddr resolver.Address
1125 reconnectIdx int // The index in addrs list to start reconnecting from.
1126 state connectivity.State
1129 ready chan struct{}
1130 transport transport.ClientTransport
1133 tearDownErr error
1135 connectRetryNum int
1138 backoffDeadline time.Time
1141 connectDeadline time.Time
1143 channelzID int64 // channelz unique identification number
1144 czmu sync.RWMutex
1145 callsStarted int64
1146 callsSucceeded int64
1147 callsFailed int64
1148 lastCallStartedTime time.Time
1153 func (ac *addrConn) adjustParams(r transport.GoAwayReason) {
1167 func (ac *addrConn) printf(format string, a ...interface{}) {
1175 func (ac *addrConn) errorf(format string, a ...interface{}) {
1194 func (ac *addrConn) resetTransport() error {
1263 …onnectDeadline time.Time, addrs []resolver.Address, copts transport.ConnectOptions) (bool, error) {
1372 func (ac *addrConn) transportMonitor() {
1452 …ddrConn) wait(ctx context.Context, hasBalancer, failfast bool) (transport.ClientTransport, error) {
1493 func (ac *addrConn) getReadyTransport() (transport.ClientTransport, bool) {
1517 func (ac *addrConn) tearDown(err error) {
1548 func (ac *addrConn) getState() connectivity.State {
1554 func (ac *addrConn) getCurAddr() (ret resolver.Address) {
1561 func (ac *addrConn) ChannelzMetric() *channelz.ChannelInternalMetric {
1578 func (ac *addrConn) incrCallsStarted() {
1585 func (ac *addrConn) incrCallsSucceeded() {
1591 func (ac *addrConn) incrCallsFailed() {