| /external/owasp/sanitizer/src/tests/org/owasp/html/ |
| D | TagBalancingHtmlStreamRendererTest.java | 45 TagBalancingHtmlStreamEventReceiver balancer; field in TagBalancingHtmlStreamRendererTest
50 balancer = new TagBalancingHtmlStreamEventReceiver( in setUp()
60 balancer.openDocument(); in testTagBalancing()
61 balancer.openTag("html", ImmutableList.<String>of()); in testTagBalancing()
62 balancer.openTag("head", ImmutableList.<String>of()); in testTagBalancing()
63 balancer.openTag("title", ImmutableList.<String>of()); in testTagBalancing()
64 balancer.text("Hello, <<World>>!"); in testTagBalancing()
66 balancer.closeTag("TITLE"); in testTagBalancing()
67 balancer.closeTag("head"); in testTagBalancing()
68 balancer.openTag("body", ImmutableList.<String>of()); in testTagBalancing()
[all …]
|
| /external/syzkaller/vendor/google.golang.org/grpc/ |
| D | pickfirst.go | 32 func newPickfirstBuilder() balancer.Builder {
38 func (*pickfirstBuilder) Build(cc balancer.ClientConn, opt balancer.BuildOptions) balancer.Balancer…
47 cc balancer.ClientConn
48 sc balancer.SubConn
57 b.sc, err = b.cc.NewSubConn(addrs, balancer.NewSubConnOptions{})
70 func (b *pickfirstBalancer) HandleSubConnStateChange(sc balancer.SubConn, s connectivity.State) {
85 b.cc.UpdateBalancerState(s, &picker{err: balancer.ErrNoSubConnAvailable})
87 b.cc.UpdateBalancerState(s, &picker{err: balancer.ErrTransientFailure})
96 sc balancer.SubConn
99 func (p *picker) Pick(ctx context.Context, opts balancer.PickOptions) (balancer.SubConn, func(balan…
[all …]
|
| D | balancer_v1_wrapper.go | 38 func (bwb *balancerWrapperBuilder) Build(cc balancer.ClientConn, opts balancer.BuildOptions) balanc…
51 balancer: bwb.b,
56 conns: make(map[resolver.Address]balancer.SubConn),
57 connSt: make(map[balancer.SubConn]*scState),
58 csEvltr: &balancer.ConnectivityStateEvaluator{},
77 balancer Balancer // The v1 balancer. member
80 cc balancer.ClientConn
84 conns map[resolver.Address]balancer.SubConn
85 connSt map[balancer.SubConn]*scState
93 csEvltr *balancer.ConnectivityStateEvaluator
[all …]
|
| D | balancer_conn_wrappers.go | 33 sc balancer.SubConn
96 balancer balancer.Balancer member
105 func newCCBalancerWrapper(cc *ClientConn, b balancer.Builder, bopts balancer.BuildOptions) *ccBalan…
114 ccb.balancer = b.Build(ccb, bopts)
127 ccb.balancer.Close()
131 ccb.balancer.HandleSubConnStateChange(t.sc, t.state)
135 ccb.balancer.Close()
139 ccb.balancer.HandleResolvedAddrs(t.addrs, t.err)
145 ccb.balancer.Close()
163 func (ccb *ccBalancerWrapper) handleSubConnStateChange(sc balancer.SubConn, s connectivity.State) {
[all …]
|
| D | picker_wrapper.go | 43 picker balancer.Picker
96 func (bp *pickerWrapper) updatePicker(p balancer.Picker) {
109 func doneChannelzWrapper(acw *acBalancerWrapper, done func(balancer.DoneInfo)) func(balancer.DoneIn…
114 return func(b balancer.DoneInfo) {
133 …ick(ctx context.Context, failfast bool, opts balancer.PickOptions) (transport.ClientTransport, fun…
156 p balancer.Picker
191 case balancer.ErrNoSubConnAvailable:
193 case balancer.ErrTransientFailure:
|
| D | clientconn.go | 113 balancerBuilder balancer.Builder
244 builder := balancer.Get(balancerName)
597 cc.balancerBuildOpts = balancer.BuildOptions{
688 balancerBuildOpts balancer.BuildOptions
836 builder := balancer.Get(name)
846 func (cc *ClientConn) handleSubConnStateChange(sc balancer.SubConn, s connectivity.State) {
1015 …rt(ctx context.Context, failfast bool) (transport.ClientTransport, func(balancer.DoneInfo), error)…
1016 t, done, err := cc.blockingpicker.pick(ctx, failfast, balancer.PickOptions{})
1121 acbw balancer.SubConn
|
| D | stream.go | 260 done func(balancer.DoneInfo)
280 done(balancer.DoneInfo{Err: err})
364 done func(balancer.DoneInfo)
599 a.done(balancer.DoneInfo{
|
| /external/syzkaller/vendor/google.golang.org/grpc/balancer/base/ |
| D | balancer.go | 34 func (bb *baseBuilder) Build(cc balancer.ClientConn, opt balancer.BuildOptions) balancer.Balancer {
39 subConns: make(map[resolver.Address]balancer.SubConn),
40 scStates: make(map[balancer.SubConn]connectivity.State),
45 picker: NewErrPicker(balancer.ErrNoSubConnAvailable),
54 cc balancer.ClientConn
60 subConns map[resolver.Address]balancer.SubConn
61 scStates map[balancer.SubConn]connectivity.State
62 picker balancer.Picker
77 sc, err := b.cc.NewSubConn([]resolver.Address{a}, balancer.NewSubConnOptions{})
104 b.picker = NewErrPicker(balancer.ErrTransientFailure)
[all …]
|
| D | base.go | 42 Build(readySCs map[resolver.Address]balancer.SubConn) balancer.Picker
47 func NewBalancerBuilder(name string, pb PickerBuilder) balancer.Builder {
|
| /external/syzkaller/vendor/google.golang.org/grpc/balancer/roundrobin/ |
| D | roundrobin.go | 38 func newBuilder() balancer.Builder {
43 balancer.Register(newBuilder())
48 func (*rrPickerBuilder) Build(readySCs map[resolver.Address]balancer.SubConn) balancer.Picker {
50 var scs []balancer.SubConn
63 subConns []balancer.SubConn
69 …unc (p *rrPicker) Pick(ctx context.Context, opts balancer.PickOptions) (balancer.SubConn, func(bal…
71 return nil, nil, balancer.ErrNoSubConnAvailable
|
| /external/grpc-grpc/doc/ |
| D | load-balancing.md | 38 name resolution system, an external load balancer, etc. In any case, the client
57 balancer. The client relies on the load balancer to provide _load
59 should send requests. The balancer updates the server list as needed
61 issues. The load balancer will make any necessary complex decisions and
62 inform the client. The load balancer may communicate with the backend
72 a load balancer to provide load balancing configuration and the list of
73 servers to which the client should send requests. The balancer will update
75 unavailability or health issues. The load balancer will make any necessary
76 complex decisions and inform the client. The load balancer may communicate
81 The load balancer may be separate from the actual server backends and a
[all …]
|
| D | naming.md | 71 the address to use to contact the server directly) or a balancer
74 - The name of the balancer, if the address is a balancer address.
|
| D | environment_variables.md | 53 - glb - traces the grpclb load balancer
|
| D | service_config.md | 23 // Note that if the resolver returns at least one balancer address (as
|
| /external/owasp/sanitizer/src/main/org/owasp/html/ |
| D | HtmlSanitizer.java | 105 TagBalancingHtmlStreamEventReceiver balancer in sanitize() local
126 balancer.setNestingLimit(256); in sanitize()
128 balancer.openDocument(); in sanitize()
138 balancer.text( in sanitize()
142 balancer.text(Encoding.stripBannedCodeunits( in sanitize()
147 balancer.closeTag(HtmlLexer.canonicalName( in sanitize()
185 balancer.openTag( in sanitize()
198 balancer.closeDocument(); in sanitize()
|
| /external/grpc-grpc/src/proto/grpc/lb/v1/ |
| D | load_reporter.proto | 45 // the load balancer.
50 // This message should be sent on the first response to the load balancer.
65 // Initial response returns the Load balancer ID. This must be plain text
97 // tag is that part of the load balancer token after removing the load
98 // balancer id. Empty is equivalent to non-existent tag.
120 // when the balancer process the load report.
122 // The number of calls in progress (instantaneously) per load balancer id.
145 // could not be reported to the originating balancer either since the balancer
150 // balancer.
178 // The load_key from the initial_request from the originating balancer.
|
| D | load_balancer.proto | 26 option go_package = "google.golang.org/grpc/balancer/grpclb/grpc_lb_v1";
38 // This message should be sent on the first request to the load balancer.
41 // The client stats should be periodically reported to the load balancer
51 // to the balancer.
94 // Contains the list of servers selected by the load balancer. The client
109 // to the load balancer. Stats should only be reported when the duration is
115 // Contains a list of servers selected by the load balancer. The list will
|
| /external/grpc-grpc-java/grpclb/src/main/proto/grpc/lb/v1/ |
| D | load_balancer.proto | 26 option go_package = "google.golang.org/grpc/balancer/grpclb/grpc_lb_v1";
38 // This message should be sent on the first request to the load balancer.
41 // The client stats should be periodically reported to the load balancer
51 // to the balancer.
94 // Contains the list of servers selected by the load balancer. The client
109 // to the load balancer. Stats should only be reported when the duration is
115 // Contains a list of servers selected by the load balancer. The list will
|
| /external/syzkaller/vendor/google.golang.org/api/option/ |
| D | option.go | 150 balancer := grpc.RoundRobin(internal.NewPoolResolver(int(w), o))
151 o.GRPCDialOpts = append(o.GRPCDialOpts, grpc.WithBalancer(balancer))
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 175 private GrpclbLoadBalancer balancer; field in GrpclbLoadBalancerTest
255 balancer = new GrpclbLoadBalancer( in setUp()
267 if (balancer != null) { in tearDown()
271 balancer.shutdown(); in tearDown()
712 balancer.shutdown(); in acquireAndReleaseScheduledExecutor()
1032 balancer.shutdown(); in grpclbWorking()
1495 balancer.handleSubchannelState(subchannel, newState); in deliverSubchannelState()
1504 balancer.handleNameResolutionError(error); in deliverNameResolutionError()
1514 balancer.handleResolvedAddressGroups(addrs, attrs); in deliverResolvedAddresses()
1520 return balancer.getGrpclbState().getLoadRecorder(); in getLoadRecorder()
|
| /external/iptables/extensions/ |
| D | libipt_CLUSTERIP.man | 2 a certain IP and MAC address without an explicit load balancer in front of
|
| /external/syzkaller/vendor/google.golang.org/grpc/balancer/ |
| D | balancer.go | 21 package balancer package
|
| /external/bcc/tools/ |
| D | solisten_example.txt | 7 It can be used to dynamically update a load balancer as a program is actually
|
| /external/autotest/site_utils/ |
| D | balance_pools.py | 673 def balancer(pool, labels): function
690 balancer,
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | grpclb_end2end_test.cc | 427 for (const auto& balancer : balancers_) { in WaitForLoadReports() local
428 client_stats += balancer->WaitForLoadReport(); in WaitForLoadReports()
|