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

  /external/syzkaller/vendor/google.golang.org/grpc/balancer/base/
base.go 22 // The base balancer creates a new SubConn for each resolved address. The
41 // used by gRPC to pick a SubConn.
42 Build(readySCs map[resolver.Address]balancer.SubConn) balancer.Picker
balancer.go 39 subConns: make(map[resolver.Address]balancer.SubConn),
40 scStates: make(map[balancer.SubConn]connectivity.State),
43 // ErrNoSubConnAvailable, because when state of a SubConn changes, we
60 subConns map[resolver.Address]balancer.SubConn
61 scStates map[balancer.SubConn]connectivity.State
79 grpclog.Warningf("base.baseBalancer: failed to create new SubConn: %v", err)
107 readySCs := make(map[resolver.Address]balancer.SubConn)
109 // Filter out all ready SCs from full subConn map.
118 func (b *baseBalancer) HandleSubConnStateChange(sc balancer.SubConn, s connectivity.State) {
119 grpclog.Infof("base.baseBalancer: handle SubConn state change: %p, %v", sc, s
    [all...]
  /external/syzkaller/vendor/google.golang.org/grpc/balancer/roundrobin/
roundrobin.go 48 func (*rrPickerBuilder) Build(readySCs map[resolver.Address]balancer.SubConn) balancer.Picker {
50 var scs []balancer.SubConn
62 // selection from it and return the selected SubConn.
63 subConns []balancer.SubConn
69 func (p *rrPicker) Pick(ctx context.Context, opts balancer.PickOptions) (balancer.SubConn, func(balancer.DoneInfo), error) {
  /external/syzkaller/vendor/google.golang.org/grpc/balancer/
balancer.go 59 // SubConn represents a gRPC sub connection.
77 type SubConn interface {
78 // UpdateAddresses updates the addresses used in this SubConn.
84 // This will trigger a state transition for the SubConn.
86 // Connect starts the connecting for this SubConn.
90 // NewSubConnOptions contains options to create new SubConn.
100 // NewSubConn is called by balancer to create a new SubConn.
102 // Behaviors of the SubConn can be controlled by options.
103 NewSubConn([]resolver.Address, NewSubConnOptions) (SubConn, error)
104 // RemoveSubConn removes the SubConn from ClientConn
    [all...]
  /external/syzkaller/vendor/google.golang.org/grpc/
pickfirst.go 48 sc balancer.SubConn
70 func (b *pickfirstBalancer) HandleSubConnStateChange(sc balancer.SubConn, s connectivity.State) {
96 sc balancer.SubConn
99 func (p *picker) Pick(ctx context.Context, opts balancer.PickOptions) (balancer.SubConn, func(balancer.DoneInfo), error) {
balancer_v1_wrapper.go 56 conns: make(map[resolver.Address]balancer.SubConn),
57 connSt: make(map[balancer.SubConn]*scState),
84 conns map[resolver.Address]balancer.SubConn
85 connSt map[balancer.SubConn]*scState
129 oldSC balancer.SubConn
165 // For pickfirst, there should be only one SubConn, so the
167 // and picking should all happen on that only SubConn.
185 del []balancer.SubConn // Connections need to tear down.
232 func (bw *balancerWrapper) HandleSubConnStateChange(sc balancer.SubConn, s connectivity.State) {
288 func (bw *balancerWrapper) Pick(ctx context.Context, opts balancer.PickOptions) (balancer.SubConn, func(balancer.DoneInfo), error)
    [all...]
balancer_conn_wrappers.go 31 // scStateUpdate contains the subConn and the new state it changed to.
33 sc balancer.SubConn
163 func (ccb *ccBalancerWrapper) handleSubConnStateChange(sc balancer.SubConn, s connectivity.State) {
164 // When updating addresses for a SubConn, if the address in use is not in
191 func (ccb *ccBalancerWrapper) NewSubConn(addrs []resolver.Address, opts balancer.NewSubConnOptions) (balancer.SubConn, error) {
193 return nil, fmt.Errorf("grpc: cannot create SubConn with empty address list")
212 func (ccb *ccBalancerWrapper) RemoveSubConn(sc balancer.SubConn) {
245 // It implements balancer.SubConn interface.
clientconn.go 846 func (cc *ClientConn) handleSubConnStateChange(sc balancer.SubConn, s connectivity.State) {
882 // removeAddrConn removes the addrConn in the subConn from clientConn.
    [all...]

Completed in 1352 milliseconds