Lines Matching refs:addrConn
463 conns: make(map[*addrConn]struct{}),
612 // those to balancer. Balancer creates new addrConn. addrConn fails to
695 conns map[*addrConn]struct{}
858 // newAddrConn creates an addrConn for addrs and adds it to cc.conns.
861 func (cc *ClientConn) newAddrConn(addrs []resolver.Address) (*addrConn, error) {
862 ac := &addrConn{
882 // removeAddrConn removes the addrConn in the subConn from clientConn.
884 func (cc *ClientConn) removeAddrConn(ac *addrConn, err error) {
934 // TODO(bar) Move this to the addrConn section.
936 func (ac *addrConn) connect() error {
971 func (ac *addrConn) tryUpdateAddrs(addrs []resolver.Address) bool {
974 grpclog.Infof("addrConn: tryUpdateAddrs curAddr: %v, addrs: %v", ac.curAddr, addrs)
987 grpclog.Infof("addrConn: tryUpdateAddrs curAddrFound: %v", curAddrFound)
1112 // addrConn is a network connection to a given address.
1113 type addrConn struct {
1132 // The reason this addrConn is torn down.
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 {
1215 // or this is the first time this addrConn is trying to establish a
1263 func (ac *addrConn) createTransport(connectRetryNum, ridx int, backoffDeadline, connectDeadline time.Time, addrs []resolver.Address, copts transport.ConnectOptions) (bool, error) {
1304 grpclog.Warningf("grpc: addrConn.createTransport failed to connect to %v. Err :%v. Reconnecting...", addr, err)
1312 grpclog.Warningf("grpc: addrConn.createTransport failed to receive server preface before deadline.")
1372 func (ac *addrConn) transportMonitor() {
1411 grpclog.Warningf("grpc: addrConn.transportMonitor didn't get server preface after waiting. Closing the new transport now.")
1440 grpclog.Warningf("grpc: addrConn.transportMonitor exits due to: %v", err)
1452 func (ac *addrConn) wait(ctx context.Context, hasBalancer, failfast bool) (transport.ClientTransport, error) {
1493 func (ac *addrConn) getReadyTransport() (transport.ClientTransport, bool) {
1512 // tearDown starts to tear down the addrConn.
1514 // some edge cases (e.g., the caller opens and closes many addrConn's in a
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() {
