| /external/autotest/site_utils/ |
| D | deploy_server.py | 20 def _filter_servers(servers): argument
23 for s in servers:
52 servers = rpc.run('get_servers')
54 return {s['hostname'] for s in _filter_servers(servers)}
110 def _update_in_parallel(servers, extra_args=[]): argument
130 results = pool.map_async(do_server, servers)
135 server_names = set([s[0] for s in servers])
137 incomplete_servers = sorted(set(servers) - set(finished_servers))
140 (len(servers), len(incomplete_servers), incomplete_servers))
170 servers = options.servers
[all …]
|
| D | server_manager_utils.py | 46 servers = server_models.Server.objects.filter(
50 if not servers:
77 def format_servers(servers): argument
93 return '\n'.join(str(server) for server in servers)
96 def format_servers_json(servers): argument
103 for server in servers:
120 def format_servers_nameonly(servers): argument
126 return '\n'.join(s.hostname for s in servers)
129 def _get_servers_by_role(servers): argument
137 for server in servers:
[all …]
|
| D | sync_cloudsql_access.py | 82 servers = [s['hostname'] for s in rpc.run('get_servers')
86 servers.extend(extra_servers.split(','))
91 servers.extend(tko_servers.split(','))
92 print 'Adding servers %s to access list for projects %s' % (servers,
96 for name in servers:
|
| D | server_manager.py | 64 servers = server_models.Server.objects.filter(
66 if len(servers) >= 1:
69 (role, servers[0].hostname, role))
147 servers = server_models.Server.objects.filter(
150 if len(servers) == 1:
153 'role.' % (role.role, servers[0].hostname))
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AutoConfiguredLoadBalancerFactoryTest.java | 111 final List<EquivalentAddressGroup> servers = in handleResolvedAddressGroups_keepOldBalancer() local
117 assertThat(addrs).isEqualTo(servers); in handleResolvedAddressGroups_keepOldBalancer()
130 lb.handleResolvedAddressGroups(servers, Attributes.EMPTY); in handleResolvedAddressGroups_keepOldBalancer()
143 final List<EquivalentAddressGroup> servers = in handleResolvedAddressGroups_shutsDownOldBalancer() local
151 assertThat(addrs).isEqualTo(servers); in handleResolvedAddressGroups_shutsDownOldBalancer()
182 lb.handleResolvedAddressGroups(servers, serviceConfigAttrs); in handleResolvedAddressGroups_shutsDownOldBalancer()
191 List<EquivalentAddressGroup> servers = in decideLoadBalancerFactory_noBalancerAddresses_noServiceConfig_pickFirst() local
195 AutoConfiguredLoadBalancer.decideLoadBalancerFactory(servers, serviceConfig); in decideLoadBalancerFactory_noBalancerAddresses_noServiceConfig_pickFirst()
203 List<EquivalentAddressGroup> servers = in decideLoadBalancerFactory_oneBalancer_noServiceConfig_grpclb() local
209 servers, serviceConfig); in decideLoadBalancerFactory_oneBalancer_noServiceConfig_grpclb()
[all …]
|
| D | ManagedChannelImplIdlenessTest.java | 97 private final List<EquivalentAddressGroup> servers = Lists.newArrayList(); field in ManagedChannelImplIdlenessTest
156 servers.add(new EquivalentAddressGroup(addrs)); in setUp()
186 nameResolverListenerCaptor.getValue().onAddresses(servers, Attributes.EMPTY); in newCallExitsIdleness()
187 verify(mockLoadBalancer).handleResolvedAddressGroups(servers, Attributes.EMPTY); in newCallExitsIdleness()
252 final EquivalentAddressGroup addressGroup = servers.get(1); in realTransportsHoldsOffIdleness()
304 Subchannel subchannel = helper.createSubchannel(servers.get(0), Attributes.EMPTY); in updateSubchannelAddresses_newAddressConnects()
310 helper.updateSubchannelAddresses(subchannel, servers.get(1)); in updateSubchannelAddresses_newAddressConnects()
324 Subchannel subchannel = helper.createSubchannel(servers.get(0), Attributes.EMPTY); in updateSubchannelAddresses_existingAddressDoesNotConnect()
330 List<SocketAddress> changedList = new ArrayList<>(servers.get(0).getAddresses()); in updateSubchannelAddresses_existingAddressDoesNotConnect()
361 ManagedChannel oob = helper.createOobChannel(servers.get(0), "oobauthority"); in oobTransportDoesNotAffectIdleness()
[all …]
|
| /external/grpc-grpc/test/cpp/grpclb/ |
| D | grpclb_api_test.cc | 109 EXPECT_TRUE(c_serverlist->servers[0]->has_ip_address); in TEST_F()
110 EXPECT_EQ(PackedStringToIp(c_serverlist->servers[0]->ip_address), in TEST_F()
112 EXPECT_EQ(c_serverlist->servers[0]->port, 12345); in TEST_F()
113 EXPECT_STREQ(c_serverlist->servers[0]->load_balance_token, "rate_limting"); in TEST_F()
114 EXPECT_TRUE(c_serverlist->servers[0]->drop); in TEST_F()
115 EXPECT_TRUE(c_serverlist->servers[1]->has_ip_address); in TEST_F()
117 EXPECT_EQ(PackedStringToIp(c_serverlist->servers[1]->ip_address), "10.0.0.1"); in TEST_F()
118 EXPECT_EQ(c_serverlist->servers[1]->port, 54321); in TEST_F()
119 EXPECT_STREQ(c_serverlist->servers[1]->load_balance_token, "load_balancing"); in TEST_F()
120 EXPECT_TRUE(c_serverlist->servers[1]->drop); in TEST_F()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | load_balancer_api.cc | 60 dec_arg->serverlist->servers[dec_arg->decoding_idx++] = server; in decode_serverlist()
198 res.server_list.servers.funcs.decode = count_serverlist; in grpc_grpclb_response_parse_serverlist()
199 res.server_list.servers.arg = sl; in grpc_grpclb_response_parse_serverlist()
208 sl->servers = static_cast<grpc_grpclb_server**>( in grpc_grpclb_response_parse_serverlist()
213 res.server_list.servers.funcs.decode = decode_serverlist; in grpc_grpclb_response_parse_serverlist()
214 res.server_list.servers.arg = &decode_arg; in grpc_grpclb_response_parse_serverlist()
231 gpr_free(serverlist->servers[i]); in grpc_grpclb_destroy_serverlist()
233 gpr_free(serverlist->servers); in grpc_grpclb_destroy_serverlist()
242 copy->servers = static_cast<grpc_grpclb_server**>( in grpc_grpclb_serverlist_copy()
245 copy->servers[i] = static_cast<grpc_grpclb_server*>( in grpc_grpclb_serverlist_copy()
[all …]
|
| /external/webrtc/talk/app/webrtc/ |
| D | peerconnectionfactory_unittest.cc | 176 config.servers.push_back(ice_server); in TEST_F()
179 config.servers.push_back(ice_server); in TEST_F()
182 config.servers.push_back(ice_server); in TEST_F()
212 config.servers.push_back(ice_server); in TEST_F()
237 config.servers.push_back(ice_server); in TEST_F()
241 config.servers.push_back(ice_server); in TEST_F()
262 config.servers.push_back(ice_server); in TEST_F()
281 config.servers.push_back(ice_server); in TEST_F()
284 config.servers.push_back(ice_server); in TEST_F()
287 config.servers.push_back(ice_server); in TEST_F()
[all …]
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | PickFirstLoadBalancerTest.java | 61 private List<EquivalentAddressGroup> servers = Lists.newArrayList(); field in PickFirstLoadBalancerTest
83 servers.add(new EquivalentAddressGroup(addr)); in setUp()
103 loadBalancer.handleResolvedAddressGroups(servers, affinity); in pickAfterResolved()
105 verify(mockHelper).createSubchannel(eq(servers), attrsCaptor.capture()); in pickAfterResolved()
117 loadBalancer.handleResolvedAddressGroups(servers, affinity); in pickAfterResolvedAndUnchanged()
119 loadBalancer.handleResolvedAddressGroups(servers, affinity); in pickAfterResolvedAndUnchanged()
141 loadBalancer.handleResolvedAddressGroups(servers, affinity); in pickAfterResolvedAndChanged()
142 inOrder.verify(mockHelper).createSubchannel(eq(servers), any(Attributes.class)); in pickAfterResolvedAndChanged()
163 loadBalancer.handleResolvedAddressGroups(servers, affinity); in pickAfterStateChangeAfterResolution()
208 loadBalancer.handleResolvedAddressGroups(servers, affinity); in nameResolutionSuccessAfterError()
[all …]
|
| D | InternalChannelzTest.java | 123 ServerList servers = channelz.getServers(/*fromId=*/ 0, /*maxPageSize=*/ 1); in getServers_empty() local
124 assertTrue(servers.end); in getServers_empty()
125 assertThat(servers.servers).isEmpty(); in getServers_empty()
134 assertThat(page.servers).containsExactly(server1); in getServers_onePage()
145 assertThat(page.servers).containsExactly(server1, server2); in getServers_onePage_multi()
156 assertThat(page1.servers).containsExactly(server1); in getServers_paginate()
160 assertThat(page2.servers).containsExactly(server2); in getServers_paginate()
170 assertThat(page.servers).isEmpty(); in getServers_remove()
180 assertThat(page.servers).containsExactly(server1); in getServers_addAfterLastPage()
189 assertThat(page.servers).containsExactly(server2); in getServers_addAfterLastPage()
|
| /external/tensorflow/tensorflow/contrib/kafka/kernels/ |
| D | kafka_dataset_ops.cc | 39 std::string servers = ""; in MakeDataset() local
41 ParseScalarArgument<std::string>(ctx, "servers", &servers)); in MakeDataset()
51 *output = new Dataset(ctx, std::move(topics), servers, group, eof, timeout); in MakeDataset()
58 const string& servers, const string& group, const bool eof, in Dataset() argument
62 servers_(servers), in Dataset()
92 Node* servers = nullptr; in AsGraphDefInternal() local
93 TF_RETURN_IF_ERROR(b->AddScalar(servers_, &servers)); in AsGraphDefInternal()
101 b->AddDataset(this, {topics, servers, group, eof, timeout}, output)); in AsGraphDefInternal()
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | driver.cc | 271 std::vector<ServerData> servers(num_servers); in RunScenario() local
279 servers[i].stub = WorkerService::NewStub(CreateChannel( in RunScenario()
283 servers[i].stub = WorkerService::NewStub( in RunScenario()
295 servers[i].stream = servers[i].stub->RunServer(alloc_context(&contexts)); in RunScenario()
296 if (!servers[i].stream->Write(args)) { in RunScenario()
300 if (!servers[i].stream->Read(&init_status)) { in RunScenario()
407 auto server = &servers[i]; in RunScenario()
419 auto server = &servers[i]; in RunScenario()
494 auto server = &servers[i]; in RunScenario()
503 auto server = &servers[i]; in RunScenario()
[all …]
|
| /external/curl/docs/ |
| D | SSL-PROBLEMS.md | 31 Some broken servers fail to support the protocol negotiation properly that
32 SSL servers are supposed to handle. This may cause the connection to fail
43 Clients give servers a list of ciphers to select from. If the list doesn't
56 WinSSL in Windows XP is not able to connect to servers that no longer
67 to mitigate this attack, it turned out that some broken servers out there in
70 To make such broken servers work, the --ssl-allow-beast option was
73 servers.
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | AutoConfiguredLoadBalancerFactory.java | 84 List<EquivalentAddressGroup> servers, Attributes attributes) { in handleResolvedAddressGroups() argument
88 newlbf = decideLoadBalancerFactory(servers, configMap); in handleResolvedAddressGroups()
106 getDelegate().handleResolvedAddressGroups(servers, attributes); in handleResolvedAddressGroups()
157 List<EquivalentAddressGroup> servers, @Nullable Map<String, Object> config) { in decideLoadBalancerFactory() argument
160 for (EquivalentAddressGroup s : servers) { in decideLoadBalancerFactory()
|
| /external/grpc-grpc/test/cpp/naming/utils/ |
| D | dns_resolver.py | 42 servers = [(args.server_host, args.server_port)]
43 resolver = client.Resolver(servers=servers)
|
| /external/grpc-grpc/src/core/lib/channel/ |
| D | channelz_registry.cc | 119 InlinedVector<BaseNode*, 10> servers; in InternalGetServers() local
128 servers.push_back(entities_[i]); in InternalGetServers()
131 if (!servers.empty()) { in InternalGetServers()
135 for (size_t i = 0; i < servers.size(); ++i) { in InternalGetServers()
136 grpc_json* server_json = servers[i]->RenderJson(); in InternalGetServers()
|
| /external/curl/lib/ |
| D | pipeline.c | 262 CURLMcode Curl_pipeline_set_server_blacklist(char **servers, in Curl_pipeline_set_server_blacklist() argument
269 if(servers) { in Curl_pipeline_set_server_blacklist()
273 while(*servers) { in Curl_pipeline_set_server_blacklist()
275 size_t len = strlen(*servers); in Curl_pipeline_set_server_blacklist()
282 strcpy(n->server_name, *servers); in Curl_pipeline_set_server_blacklist()
285 servers++; in Curl_pipeline_set_server_blacklist()
|
| /external/syzkaller/vendor/google.golang.org/grpc/internal/channelz/ |
| D | funcs.go | 84 servers: make(map[int64]*server),
237 servers map[int64]*server member
247 c.servers[id] = s
307 if v, ok = c.servers[id]; ok {
344 if _, ok = c.servers[id]; ok {
345 delete(c.servers, id)
417 l := len(c.servers)
420 for k := range c.servers {
432 if svr, ok := c.servers[v]; ok {
461 if svr, ok = c.servers[id]; !ok {
|
| /external/curl/tests/server/ |
| D | CMakeLists.txt | 22 # Test servers simply are standalone programs that do not use libcurl
23 # library. For convenience and to ease portability of these servers,
25 # to build the servers. In order to achieve proper linkage of these
26 # files on Win32 targets it is necessary to build the test servers
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerTest.java | 93 private List<EquivalentAddressGroup> servers = Lists.newArrayList(); field in RoundRobinLoadBalancerTest
117 servers.add(eag); in setUp()
146 loadBalancer.handleResolvedAddressGroups(servers, affinity); in pickAfterResolved()
256 loadBalancer.handleResolvedAddressGroups(servers, Attributes.EMPTY); in pickAfterStateChange()
335 loadBalancer.handleResolvedAddressGroups(servers, affinity); in nameResolutionErrorWithActiveChannels()
365 loadBalancer.handleResolvedAddressGroups(servers, Attributes.EMPTY); in subchannelStateIsolation()
404 loadBalancer.handleResolvedAddressGroups(servers, Attributes.EMPTY); in noStickinessEnabled_withStickyHeader()
437 loadBalancer.handleResolvedAddressGroups(servers, attributes); in stickinessEnabled_withoutStickyHeader()
469 loadBalancer.handleResolvedAddressGroups(servers, attributes); in stickinessEnabled_withStickyHeader()
499 loadBalancer.handleResolvedAddressGroups(servers, attributes); in stickinessEnabled_withDifferentStickyHeaders()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/proto/grpc/lb/v1/ |
| D | load_balancer.pb.c | 52 …PB_FIELD( 1, MESSAGE , REPEATED, CALLBACK, FIRST, grpc_lb_v1_ServerList, servers, servers, &grpc_…
74 …t_stats_report_interval) < 65536 && pb_membersize(grpc_lb_v1_ServerList, servers) < 65536), YOU_MU…
85 …ent_stats_report_interval) < 256 && pb_membersize(grpc_lb_v1_ServerList, servers) < 256), YOU_MUST…
|
| /external/grpc-grpc/doc/ |
| D | load-balancing.md | 15 all servers.
36 Random, etc) used to select servers from a list. In this model, a list of
37 servers would be either statically configured in the client, provided by the
50 list of servers to the client.
63 servers to collect load and health information.
73 servers to which the client should send requests. The balancer will update
77 with the backend servers to collect load and health information.
93 with an up-to-date list of servers.
135 2. The gRPC servers to which the load balancer is directing the client
144 to the servers in the order in which they were returned by the load
|
| /external/tcpdump/tests/ |
| D | dhcpv6-mud.out | 1 …01) (reconfigure-accept) (option-request DNS-server DNS-search-list SNTP-servers Client-FQDN opt_8…
2 …01) (reconfigure-accept) (option-request DNS-server DNS-search-list SNTP-servers Client-FQDN opt_8…
3 …01) (reconfigure-accept) (option-request DNS-server DNS-search-list SNTP-servers Client-FQDN opt_8…
4 …01) (reconfigure-accept) (option-request DNS-server DNS-search-list SNTP-servers Client-FQDN opt_8…
5 …01) (reconfigure-accept) (option-request DNS-server DNS-search-list SNTP-servers Client-FQDN opt_8…
|
| /external/webrtc/webrtc/examples/objc/AppRTCDemo/ |
| D | RTCICEServer+JSON.m | 36 NSMutableArray *servers = [NSMutableArray arrayWithCapacity:uris.count];
42 [servers addObject:server];
44 return servers;
|