HomeSort by relevance Sort by last modified time
    Searched refs:acBalancerWrapper (Results 1 - 2 of 2) sorted by null

  /external/syzkaller/vendor/google.golang.org/grpc/
balancer_conn_wrappers.go 102 subConns map[*acBalancerWrapper]struct{}
111 subConns: make(map[*acBalancerWrapper]struct{}),
204 acbw := &acBalancerWrapper{ac: ac}
213 acbw, ok := sc.(*acBalancerWrapper)
244 // acBalancerWrapper is a wrapper on top of ac for balancers.
246 type acBalancerWrapper struct {
251 func (acbw *acBalancerWrapper) UpdateAddresses(addrs []resolver.Address) {
277 grpclog.Warningf("acBalancerWrapper: UpdateAddresses: failed to newAddrConn: %v", err)
290 func (acbw *acBalancerWrapper) Connect() {
296 func (acbw *acBalancerWrapper) getAddrConn() *addrConn
    [all...]
picker_wrapper.go 109 func doneChannelzWrapper(acw *acBalancerWrapper, done func(balancer.DoneInfo)) func(balancer.DoneInfo) {
204 acw, ok := subConn.(*acBalancerWrapper)
206 grpclog.Infof("subconn returned from pick is not *acBalancerWrapper")
239 acw *acBalancerWrapper
267 func (ss *stickyStore) put(mdKey, stickyKey string, acw *acBalancerWrapper) {

Completed in 310 milliseconds