| /external/rust/crates/grpcio-sys/grpc/third_party/cares/cares/ |
| D | ares_options.c | 32 struct ares_addr_node **servers) in ares_get_servers() argument
63 srvr_curr->family = channel->servers[i].addr.family; in ares_get_servers()
65 memcpy(&srvr_curr->addrV4, &channel->servers[i].addr.addrV4, in ares_get_servers()
68 memcpy(&srvr_curr->addrV6, &channel->servers[i].addr.addrV6, in ares_get_servers()
81 *servers = srvr_head; in ares_get_servers()
87 struct ares_addr_port_node **servers) in ares_get_servers_ports() argument
118 srvr_curr->family = channel->servers[i].addr.family; in ares_get_servers_ports()
119 srvr_curr->udp_port = ntohs((unsigned short)channel->servers[i].addr.udp_port); in ares_get_servers_ports()
120 srvr_curr->tcp_port = ntohs((unsigned short)channel->servers[i].addr.tcp_port); in ares_get_servers_ports()
122 memcpy(&srvr_curr->addrV4, &channel->servers[i].addr.addrV4, in ares_get_servers_ports()
[all …]
|
| D | ares_init.c | 76 static int config_nameserver(struct server_state **servers, int *nservers,
163 channel->servers = NULL; in ares_init_options()
238 if (channel->servers) in ares_init_options()
239 ares_free(channel->servers); in ares_init_options()
267 struct ares_addr_port_node *servers; in ares_dup() local
308 if ((src->servers[i].addr.family != AF_INET) || in ares_dup()
309 (src->servers[i].addr.udp_port != 0) || in ares_dup()
310 (src->servers[i].addr.tcp_port != 0)) { in ares_dup()
316 rc = ares_get_servers_ports(src, &servers); in ares_dup()
322 rc = ares_set_servers_ports(*dest, servers); in ares_dup()
[all …]
|
| D | ares_destroy.c | 29 if(options->servers) in ares_destroy_options()
30 ares_free(options->servers); in ares_destroy_options()
101 if (channel->servers) in ares__destroy_servers_state()
105 server = &channel->servers[i]; in ares__destroy_servers_state()
109 ares_free(channel->servers); in ares__destroy_servers_state()
110 channel->servers = NULL; in ares__destroy_servers_state()
|
| D | ares.h | 264 struct in_addr *servers; member
645 struct ares_addr_node *servers);
647 struct ares_addr_port_node *servers);
651 const char* servers);
653 const char* servers);
656 struct ares_addr_node **servers);
658 struct ares_addr_port_node **servers);
|
| /external/autotest/site_utils/ |
| D | server_manager_utils.py | 50 servers = server_models.Server.objects.filter(
54 if not servers:
81 def format_servers(servers): argument
97 return '\n'.join(str(server) for server in servers)
100 def format_servers_json(servers): argument
107 for server in servers:
124 def format_servers_nameonly(servers): argument
130 return '\n'.join(s.hostname for s in servers)
208 servers = get_servers(role=server_models.ServerRole.ROLE.DRONE,
210 return [s.hostname for s in servers]
[all …]
|
| D | sync_cloudsql_access.py | 86 servers = [s['hostname'] for s in rpc.run('get_servers')
90 servers.extend(extra_servers.split(','))
95 servers.extend(tko_servers.split(','))
96 print('Adding servers %s to access list for projects %s' % (servers,
100 for name in servers:
|
| D | server_manager.py | 69 servers = server_models.Server.objects.filter(
71 if len(servers) >= 1:
74 (role, servers[0].hostname, role))
152 servers = server_models.Server.objects.filter(
155 if len(servers) == 1:
158 'role.' % (role.role, servers[0].hostname))
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AutoConfiguredLoadBalancerFactoryTest.java | 115 final List<EquivalentAddressGroup> servers = in handleResolvedAddressGroups_keepOldBalancer() local
121 assertThat(addrs).isEqualTo(servers); in handleResolvedAddressGroups_keepOldBalancer()
134 lb.handleResolvedAddressGroups(servers, Attributes.EMPTY); in handleResolvedAddressGroups_keepOldBalancer()
147 final List<EquivalentAddressGroup> servers = in handleResolvedAddressGroups_shutsDownOldBalancer() local
155 assertThat(addrs).isEqualTo(servers); in handleResolvedAddressGroups_shutsDownOldBalancer()
186 lb.handleResolvedAddressGroups(servers, serviceConfigAttrs); in handleResolvedAddressGroups_shutsDownOldBalancer()
195 List<EquivalentAddressGroup> servers = in decideLoadBalancerFactory_noBalancerAddresses_noServiceConfig_pickFirst() local
199 AutoConfiguredLoadBalancer.decideLoadBalancerFactory(servers, serviceConfig); in decideLoadBalancerFactory_noBalancerAddresses_noServiceConfig_pickFirst()
207 List<EquivalentAddressGroup> servers = in decideLoadBalancerFactory_oneBalancer_noServiceConfig_grpclb() local
213 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/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/webrtc/pc/ |
| D | ice_server_parsing_unittest.cc | 57 PeerConnectionInterface::IceServers servers; in ParseUrl() local
64 servers.push_back(server); in ParseUrl()
65 return webrtc::ParseIceServers(servers, &stun_servers_, &turn_servers_) == in ParseUrl()
220 PeerConnectionInterface::IceServers servers; in TEST_F() local
226 servers.push_back(server); in TEST_F()
228 webrtc::ParseIceServers(servers, &stun_servers_, &turn_servers_)); in TEST_F()
236 PeerConnectionInterface::IceServers servers; in TEST_F() local
242 servers.push_back(server); in TEST_F()
244 webrtc::ParseIceServers(servers, &stun_servers_, &turn_servers_)); in TEST_F()
|
| D | peer_connection_factory_unittest.cc | 274 config.servers.push_back(ice_server); in TEST_F()
278 config.servers.push_back(ice_server); in TEST_F()
282 config.servers.push_back(ice_server); in TEST_F()
313 config.servers.push_back(ice_server); in TEST_F()
338 config.servers.push_back(ice_server); in TEST_F()
342 config.servers.push_back(ice_server); in TEST_F()
364 config.servers.push_back(ice_server); in TEST_F()
384 config.servers.push_back(ice_server); in TEST_F()
388 config.servers.push_back(ice_server); in TEST_F()
392 config.servers.push_back(ice_server); in TEST_F()
[all …]
|
| /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/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/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | load_balancer_api.cc | 118 const grpc_lb_v1_Server* const* servers = in ParseServerList() local
125 upb_strview address = grpc_lb_v1_Server_ip_address(servers[i]); in ParseServerList()
132 cur.port = grpc_lb_v1_Server_port(servers[i]); in ParseServerList()
133 upb_strview token = grpc_lb_v1_Server_load_balance_token(servers[i]); in ParseServerList()
143 cur.drop = grpc_lb_v1_Server_drop(servers[i]); in ParseServerList()
|
| /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 Schannel 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/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/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/rust/crates/grpcio-sys/grpc/src/core/lib/channel/ |
| D | channelz_registry.cc | 125 absl::InlinedVector<RefCountedPtr<BaseNode>, 10> servers; in InternalGetServers() local
141 if (servers.size() == kPaginationLimit) { in InternalGetServers()
145 servers.emplace_back(std::move(node_ref)); in InternalGetServers()
150 if (!servers.empty()) { in InternalGetServers()
153 for (size_t i = 0; i < servers.size(); ++i) { in InternalGetServers()
154 array.emplace_back(servers[i]->RenderJson()); in InternalGetServers()
|
| /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/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | AutoConfiguredLoadBalancerFactory.java | 107 List<EquivalentAddressGroup> servers, Attributes attributes) { in handleResolvedAddressGroups() argument
111 newlbf = decideLoadBalancerFactory(servers, configMap); in handleResolvedAddressGroups()
137 getDelegate().handleResolvedAddressGroups(servers, attributes); in handleResolvedAddressGroups()
188 List<EquivalentAddressGroup> servers, @Nullable Map<String, Object> config) { in decideLoadBalancerFactory() argument
191 for (EquivalentAddressGroup s : servers) { in decideLoadBalancerFactory()
|
| /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
|