| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | lb_policy_factory.cc | 33 grpc_lb_addresses* addresses = in grpc_lb_addresses_create() local
35 addresses->num_addresses = num_addresses; in grpc_lb_addresses_create()
36 addresses->user_data_vtable = user_data_vtable; in grpc_lb_addresses_create()
38 addresses->addresses = in grpc_lb_addresses_create()
40 return addresses; in grpc_lb_addresses_create()
43 grpc_lb_addresses* grpc_lb_addresses_copy(const grpc_lb_addresses* addresses) { in grpc_lb_addresses_copy() argument
45 addresses->num_addresses, addresses->user_data_vtable); in grpc_lb_addresses_copy()
46 memcpy(new_addresses->addresses, addresses->addresses, in grpc_lb_addresses_copy()
47 sizeof(grpc_lb_address) * addresses->num_addresses); in grpc_lb_addresses_copy()
48 for (size_t i = 0; i < addresses->num_addresses; ++i) { in grpc_lb_addresses_copy()
[all …]
|
| D | lb_policy_factory.h | 59 grpc_lb_address* addresses; member
70 grpc_lb_addresses* grpc_lb_addresses_copy(const grpc_lb_addresses* addresses);
75 void grpc_lb_addresses_set_address(grpc_lb_addresses* addresses, size_t index,
83 bool grpc_lb_addresses_set_address_from_uri(grpc_lb_addresses* addresses,
94 void grpc_lb_addresses_destroy(grpc_lb_addresses* addresses);
98 const grpc_lb_addresses* addresses);
106 const grpc_lb_addresses& addresses);
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | resolve_address_windows.cc | 51 grpc_resolved_addresses** addresses; member
56 grpc_resolved_addresses** addresses) { in windows_blocking_resolve_address() argument
101 (*addresses) = in windows_blocking_resolve_address()
103 (*addresses)->naddrs = 0; in windows_blocking_resolve_address()
105 (*addresses)->naddrs++; in windows_blocking_resolve_address()
107 (*addresses)->addrs = (grpc_resolved_address*)gpr_malloc( in windows_blocking_resolve_address()
108 sizeof(grpc_resolved_address) * (*addresses)->naddrs); in windows_blocking_resolve_address()
111 memcpy(&(*addresses)->addrs[i].addr, resp->ai_addr, resp->ai_addrlen); in windows_blocking_resolve_address()
112 (*addresses)->addrs[i].len = resp->ai_addrlen; in windows_blocking_resolve_address()
117 for (i = 0; i < (*addresses)->naddrs; i++) { in windows_blocking_resolve_address()
[all …]
|
| D | resolve_address_posix.cc | 47 grpc_resolved_addresses** addresses) { in posix_blocking_resolve_address() argument
59 return grpc_resolve_unix_domain_address(name + 5, addresses); in posix_blocking_resolve_address()
64 return grpc_resolve_vsock_address(name + 6, addresses); in posix_blocking_resolve_address()
124 *addresses = static_cast<grpc_resolved_addresses*>( in posix_blocking_resolve_address()
126 (*addresses)->naddrs = 0; in posix_blocking_resolve_address()
128 (*addresses)->naddrs++; in posix_blocking_resolve_address()
130 (*addresses)->addrs = static_cast<grpc_resolved_address*>( in posix_blocking_resolve_address()
131 gpr_malloc(sizeof(grpc_resolved_address) * (*addresses)->naddrs)); in posix_blocking_resolve_address()
134 memcpy(&(*addresses)->addrs[i].addr, resp->ai_addr, resp->ai_addrlen); in posix_blocking_resolve_address()
135 (*addresses)->addrs[i].len = resp->ai_addrlen; in posix_blocking_resolve_address()
|
| D | resolve_address.h | 58 grpc_resolved_addresses** addresses);
61 grpc_resolved_addresses** addresses);
72 grpc_resolved_addresses** addresses);
75 void grpc_resolved_addresses_destroy(grpc_resolved_addresses* addresses);
81 grpc_resolved_addresses** addresses);
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | resolve_address_windows.cc | 55 grpc_resolved_addresses** addresses; member
59 grpc_resolved_addresses** addresses) { in windows_blocking_resolve_address() argument
100 (*addresses) = in windows_blocking_resolve_address()
102 (*addresses)->naddrs = 0; in windows_blocking_resolve_address()
104 (*addresses)->naddrs++; in windows_blocking_resolve_address()
106 (*addresses)->addrs = (grpc_resolved_address*)gpr_malloc( in windows_blocking_resolve_address()
107 sizeof(grpc_resolved_address) * (*addresses)->naddrs); in windows_blocking_resolve_address()
110 memcpy(&(*addresses)->addrs[i].addr, resp->ai_addr, resp->ai_addrlen); in windows_blocking_resolve_address()
111 (*addresses)->addrs[i].len = resp->ai_addrlen; in windows_blocking_resolve_address()
128 grpc_blocking_resolve_address(r->name, r->default_port, r->addresses); in do_request_thread()
[all …]
|
| D | resolve_address.cc | 33 grpc_resolved_addresses** addresses) { in grpc_resolve_address() argument
35 addr, default_port, interested_parties, on_done, addresses); in grpc_resolve_address()
38 void grpc_resolved_addresses_destroy(grpc_resolved_addresses* addresses) { in grpc_resolved_addresses_destroy() argument
39 if (addresses != nullptr) { in grpc_resolved_addresses_destroy()
40 gpr_free(addresses->addrs); in grpc_resolved_addresses_destroy()
42 gpr_free(addresses); in grpc_resolved_addresses_destroy()
47 grpc_resolved_addresses** addresses) { in grpc_blocking_resolve_address() argument
49 addresses); in grpc_blocking_resolve_address()
|
| D | unix_sockets_posix.cc | 46 const char* name, grpc_resolved_addresses** addresses) { in grpc_resolve_unix_domain_address() argument
47 *addresses = static_cast<grpc_resolved_addresses*>( in grpc_resolve_unix_domain_address()
49 (*addresses)->naddrs = 1; in grpc_resolve_unix_domain_address()
50 (*addresses)->addrs = static_cast<grpc_resolved_address*>( in grpc_resolve_unix_domain_address()
52 return grpc_core::UnixSockaddrPopulate(name, (*addresses)->addrs); in grpc_resolve_unix_domain_address()
56 const absl::string_view name, grpc_resolved_addresses** addresses) { in grpc_resolve_unix_abstract_domain_address() argument
57 *addresses = static_cast<grpc_resolved_addresses*>( in grpc_resolve_unix_abstract_domain_address()
59 (*addresses)->naddrs = 1; in grpc_resolve_unix_abstract_domain_address()
60 (*addresses)->addrs = static_cast<grpc_resolved_address*>( in grpc_resolve_unix_abstract_domain_address()
62 return grpc_core::UnixAbstractSockaddrPopulate(name, (*addresses)->addrs); in grpc_resolve_unix_abstract_domain_address()
|
| D | resolve_address.h | 56 grpc_resolved_addresses** addresses);
59 grpc_resolved_addresses** addresses);
70 grpc_resolved_addresses** addresses);
73 void grpc_resolved_addresses_destroy(grpc_resolved_addresses* addresses);
79 grpc_resolved_addresses** addresses);
|
| D | resolve_address_posix.cc | 47 grpc_resolved_addresses** addresses) { in posix_blocking_resolve_address() argument
115 *addresses = static_cast<grpc_resolved_addresses*>( in posix_blocking_resolve_address()
117 (*addresses)->naddrs = 0; in posix_blocking_resolve_address()
119 (*addresses)->naddrs++; in posix_blocking_resolve_address()
121 (*addresses)->addrs = static_cast<grpc_resolved_address*>( in posix_blocking_resolve_address()
122 gpr_malloc(sizeof(grpc_resolved_address) * (*addresses)->naddrs)); in posix_blocking_resolve_address()
125 memcpy(&(*addresses)->addrs[i].addr, resp->ai_addr, resp->ai_addrlen); in posix_blocking_resolve_address()
126 (*addresses)->addrs[i].len = resp->ai_addrlen; in posix_blocking_resolve_address()
|
| /external/clang/test/CodeGenObjC/ |
| D | local-static-block.m | 7 static NSArray *(^ArrayRecurs)(NSArray *addresses, unsigned long level) = ^(NSArray *addresses, un…
9 for(id rawAddress in addresses)
24 …static NSArray *(^ArrayRecurs)(NSArray *addresses, unsigned long level) = ^(NSArray *addresses, u…
26 for(id rawAddress in addresses)
36 …static NSArray *(^ArrayRecurs)(NSArray *addresses, unsigned long level) = ^(NSArray *addresses, u…
38 for(id rawAddress in addresses)
51 …static NSArray *(^ArrayRecurs)(NSArray *addresses, unsigned long level) = ^(NSArray *addresses, u…
53 for(id rawAddress in addresses)
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/http/ |
| D | FakeDns.java | 30 private List<InetAddress> addresses = Collections.emptyList(); field in FakeDns
33 public FakeDns addresses(List<InetAddress> addresses) { in addresses() argument
34 this.addresses = new ArrayList<>(addresses); in addresses()
40 this.addresses = Collections.emptyList(); in unknownHost()
45 return addresses.get(index); in address()
50 if (addresses.isEmpty()) throw new UnknownHostException(); in lookup()
51 return addresses; in lookup()
|
| /external/llvm-project/clang/test/CodeGenObjC/ |
| D | local-static-block.m | 11 static NSArray *(^ArrayRecurs)(NSArray *addresses, unsigned long level) = ^(NSArray *addresses, un…
13 for(id rawAddress in addresses)
28 …static NSArray *(^ArrayRecurs)(NSArray *addresses, unsigned long level) = ^(NSArray *addresses, u…
30 for(id rawAddress in addresses)
40 …static NSArray *(^ArrayRecurs)(NSArray *addresses, unsigned long level) = ^(NSArray *addresses, u…
42 for(id rawAddress in addresses)
66 …static NSArray *(^ArrayRecurs)(NSArray *addresses, unsigned long level) = ^(NSArray *addresses, u…
68 for(id rawAddress in addresses)
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | grpclb_channel_secure.cc | 45 grpc_lb_addresses* addresses) { in CreateTargetAuthorityTable() argument
48 sizeof(*target_authority_entries) * addresses->num_addresses)); in CreateTargetAuthorityTable()
49 for (size_t i = 0; i < addresses->num_addresses; ++i) { in CreateTargetAuthorityTable()
52 &addr_str, &addresses->addresses[i].address, true) > 0); in CreateTargetAuthorityTable()
55 gpr_strdup(addresses->addresses[i].balancer_name)); in CreateTargetAuthorityTable()
59 TargetAuthorityTable::Create(addresses->num_addresses, in CreateTargetAuthorityTable()
78 grpc_lb_addresses* addresses = in grpc_lb_policy_grpclb_modify_lb_channel_args() local
81 target_authority_table = grpc_core::CreateTargetAuthorityTable(addresses); in grpc_lb_policy_grpclb_modify_lb_channel_args()
|
| /external/webrtc/rtc_base/ |
| D | net_helpers.cc | 38 std::vector<IPAddress>* addresses) { in ResolveHostname() argument
44 if (!addresses) { in ResolveHostname()
47 addresses->clear(); in ResolveHostname()
78 addresses->push_back(ip); in ResolveHostname()
102 std::vector<IPAddress> addresses; in Start() local
104 ResolveHostname(addr.hostname().c_str(), addr.family(), &addresses); in Start()
106 std::move(flag), [this, error, addresses = std::move(addresses)] { in Start()
108 ResolveDone(std::move(addresses), error); in Start()
144 const std::vector<IPAddress>& AsyncResolver::addresses() const { in addresses() function in rtc::AsyncResolver
150 void AsyncResolver::ResolveDone(std::vector<IPAddress> addresses, int error) { in ResolveDone() argument
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | resolver.cc | 50 addresses = other.addresses; in Result()
57 addresses = std::move(other.addresses); in Result()
66 addresses = other.addresses; in operator =()
76 addresses = std::move(other.addresses); in operator =()
|
| D | lb_policy.cc | 58 addresses = other.addresses; in UpdateArgs()
64 addresses = std::move(other.addresses); in UpdateArgs()
73 addresses = other.addresses; in operator =()
82 addresses = std::move(other.addresses); in operator =()
|
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | BackendAddressGroup.java | 25 private final EquivalentAddressGroup addresses; field in BackendAddressGroup
29 BackendAddressGroup(EquivalentAddressGroup addresses, @Nullable String token) { in BackendAddressGroup() argument
30 this.addresses = checkNotNull(addresses, "addresses"); in BackendAddressGroup()
35 return addresses; in getAddresses()
45 return "[addrs=" + addresses + " token=" + token + "]"; in toString()
|
| D | LbAddressGroup.java | 27 private final EquivalentAddressGroup addresses; field in LbAddressGroup
30 LbAddressGroup(EquivalentAddressGroup addresses, String authority) { in LbAddressGroup() argument
31 this.addresses = checkNotNull(addresses, "addresses"); in LbAddressGroup()
36 return addresses; in getAddresses()
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | grpclb_end2end_test.cc | 388 std::vector<AddressData> addresses; in SetNextResolutionAllBalancers() local
390 addresses.emplace_back(AddressData{balancer_servers_[i].port_, true, ""}); in SetNextResolutionAllBalancers()
392 SetNextResolution(addresses); in SetNextResolutionAllBalancers()
491 grpc_lb_addresses* addresses = in CreateLbAddressesFromAddressDataList() local
499 addresses, i, lb_uri, address_data[i].is_balancer, in CreateLbAddressesFromAddressDataList()
504 return addresses; in CreateLbAddressesFromAddressDataList()
509 grpc_lb_addresses* addresses = in SetNextResolution() local
511 grpc_arg fake_addresses = grpc_lb_addresses_create_channel_arg(addresses); in SetNextResolution()
514 grpc_lb_addresses_destroy(addresses); in SetNextResolution()
520 grpc_lb_addresses* addresses = in SetNextReresolutionResponse() local
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/sockaddr/ |
| D | sockaddr_resolver.cc | 48 SockaddrResolver(ServerAddressList addresses, ResolverArgs args);
60 SockaddrResolver::SockaddrResolver(ServerAddressList addresses, in SockaddrResolver() argument
63 addresses_(std::move(addresses)), in SockaddrResolver()
72 result.addresses = std::move(addresses_); in StartLocked()
85 ServerAddressList* addresses) { in ParseUri() argument
100 if (addresses != nullptr) { in ParseUri()
101 addresses->emplace_back(addr, nullptr /* args */); in ParseUri()
109 ServerAddressList addresses; in CreateSockaddrResolver() local
110 if (!ParseUri(args.uri, parse, &addresses)) return nullptr; in CreateSockaddrResolver()
112 return MakeOrphanable<SockaddrResolver>(std::move(addresses), in CreateSockaddrResolver()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/resolver/sockaddr/ |
| D | sockaddr_resolver.cc | 48 SockaddrResolver(const ResolverArgs& args, grpc_lb_addresses* addresses);
73 grpc_lb_addresses* addresses) in SockaddrResolver() argument
75 addresses_(addresses), in SockaddrResolver()
130 grpc_lb_addresses* addresses = grpc_lb_addresses_create( in CreateSockaddrResolver() local
133 for (size_t i = 0; i < addresses->num_addresses; i++) { in CreateSockaddrResolver()
137 if (!parse(&ith_uri, &addresses->addresses[i].address)) { in CreateSockaddrResolver()
146 grpc_lb_addresses_destroy(addresses); in CreateSockaddrResolver()
150 return OrphanablePtr<Resolver>(New<SockaddrResolver>(args, addresses)); in CreateSockaddrResolver()
|
| /external/autotest/client/site_tests/network_Ipv6SimpleNegotiation/ |
| D | network_Ipv6SimpleNegotiation.py | 39 addresses = {}
44 addresses[parts[1]] = parts[2:]
45 return addresses
90 addresses = self._get_ip6_addresses()
91 logging.info('Got addresses %r', addresses)
92 global_addresses = [key for key in addresses
93 if 'global' in addresses[key]]
122 local_address_count = len(addresses) - len(global_addresses)
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/ |
| D | subchannel_list.h | 236 const grpc_lb_addresses* addresses, grpc_combiner* combiner,
487 const grpc_lb_addresses* addresses, grpc_combiner* combiner, in SubchannelList() argument
497 tracer_->name(), policy, this, addresses->num_addresses); in SubchannelList()
499 subchannels_.reserve(addresses->num_addresses); in SubchannelList()
506 for (size_t i = 0; i < addresses->num_addresses; i++) { in SubchannelList()
508 GPR_ASSERT(!addresses->addresses[i].is_balancer); in SubchannelList()
511 grpc_create_subchannel_address_arg(&addresses->addresses[i].address); in SubchannelList()
523 grpc_sockaddr_to_uri(&addresses->addresses[i].address); in SubchannelList()
534 grpc_sockaddr_to_uri(&addresses->addresses[i].address); in SubchannelList()
542 subchannels_.emplace_back(this, addresses->user_data_vtable, in SubchannelList()
[all …]
|
| /external/python/cpython3/Lib/test/test_email/ |
| D | test_headerregistry.py | 1226 self.assertEqual([a], list(h.groups[0].addresses))
1227 self.assertEqual([a], list(h.addresses))
1242 self.assertEqual(h.groups[0].addresses, h.addresses)
1244 self.assertEqual(len(h.addresses), 1)
1245 a = h.addresses[0]
1258 self.assertEqual(len(h.addresses), 3)
1260 self.assertEqual(h.groups[i].addresses[0], h.addresses[i])
1261 self.assertEqual(str(h.addresses[0]), 'Fred <dinsdale@python.org>')
1262 self.assertEqual(str(h.addresses[1]), 'foo@example.com')
1263 self.assertEqual(str(h.addresses[2]),
[all …]
|