Home
last modified time | relevance | path

Searched refs:host_port (Results 1 – 25 of 76) sorted by relevance

1234

/external/cronet/net/base/
Dhost_mapping_rules_unittest.cc25 HostPortPair host_port("test", 1234); in TEST() local
26 EXPECT_FALSE(rules.RewriteHost(&host_port)); in TEST()
27 EXPECT_EQ("test", host_port.host()); in TEST()
28 EXPECT_EQ(1234u, host_port.port()); in TEST()
30 host_port = HostPortPair("chrome.net", 80); in TEST()
31 EXPECT_TRUE(rules.RewriteHost(&host_port)); in TEST()
32 EXPECT_EQ("bar", host_port.host()); in TEST()
33 EXPECT_EQ(60u, host_port.port()); in TEST()
35 host_port = HostPortPair("crack.com", 80); in TEST()
36 EXPECT_TRUE(rules.RewriteHost(&host_port)); in TEST()
[all …]
Dhost_mapping_rules.cc45 bool HostMappingRules::RewriteHost(HostPortPair* host_port) const { in RewriteHost()
55 if (!base::MatchPattern(host_port->host(), map_rule.hostname_pattern)) { in RewriteHost()
56 std::string host_port_string = host_port->ToString(); in RewriteHost()
63 if (base::MatchPattern(host_port->host(), in RewriteHost()
68 host_port->set_host(map_rule.replacement_hostname); in RewriteHost()
70 host_port->set_port(static_cast<uint16_t>(map_rule.replacement_port)); in RewriteHost()
/external/cronet/build/fuchsia/test/
Dtest_server.py22 def port_forward(host_port_pair: str, host_port: int) -> int:
37 '0:localhost:%d' % host_port,
53 host_port, parsed_port)
71 _, host_port = p
72 self._port_mapping[host_port] = \
73 port_forward(self._host_port_pair, host_port)
75 def GetDevicePortForHostPort(self, host_port: int) -> int:
76 return self._port_mapping[host_port]
79 for host_port, entry in self._port_mapping.items():
84 '0:localhost:%d' % host_port
[all …]
/external/angle/build/fuchsia/test/
Dtest_server.py22 def port_forward(host_port_pair: str, host_port: int) -> int:
37 '0:localhost:%d' % host_port,
53 host_port, parsed_port)
71 _, host_port = p
72 self._port_mapping[host_port] = \
73 port_forward(self._host_port_pair, host_port)
75 def GetDevicePortForHostPort(self, host_port: int) -> int:
76 return self._port_mapping[host_port]
79 for host_port, entry in self._port_mapping.items():
84 '0:localhost:%d' % host_port
[all …]
/external/python/mobly/mobly/controllers/android_device_lib/
Dsnippet_client_v2.py120 self.host_port = None
344 if not self.host_port:
345 self.host_port = utils.get_available_host_port()
363 'of %s through host port %d.', self.package, self.host_port)
364 self._conn = socket.create_connection(('localhost', self.host_port),
371 self._conn = socket.create_connection(('127.0.0.1', self.host_port),
529 self.host_port, self.device_port, self.uid,
533 host_port, argument
553 self.host_port = host_port
595 if self.host_port:
[all …]
Dsnippet_client.py201 self.host_port = utils.get_available_host_port()
202 self._adb.forward(['tcp:%d' % self.host_port, 'tcp:%d' % self.device_port])
208 time.perf_counter() - start_time, self.host_port)
226 self.host_port = port or utils.get_available_host_port()
227 self._adb.forward(['tcp:%d' % self.host_port, 'tcp:%d' % self.device_port])
236 'device port %s') % (self.package, self.host_port, self.device_port))
266 event_client.host_port = self.host_port
278 self._event_client.host_port = None
287 self._event_client.host_port = self.host_port
Dsl4a_client.py99 self.host_port = port or utils.get_available_host_port()
134 self._adb.forward(['tcp:%d' % self.host_port, 'tcp:%d' % self.device_port])
152 (self.app_name, self._adb.serial, self.host_port, self.device_port))
157 event_client.host_port = self.host_port
Djsonrpc_client_base.py116 self.host_port = None
206 self._conn = socket.create_connection(('localhost', self.host_port),
214 self._conn = socket.create_connection(('127.0.0.1', self.host_port),
253 if self.host_port:
254 self._ad.adb.forward(['--remove', 'tcp:%d' % self.host_port])
255 self.host_port = None
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dparse_address.cc132 const char* host_port = uri->path; in grpc_parse_ipv4() local
133 if (*host_port == '/') ++host_port; in grpc_parse_ipv4()
134 return grpc_parse_ipv4_hostport(host_port, resolved_addr, in grpc_parse_ipv4()
216 const char* host_port = uri->path; in grpc_parse_ipv6() local
217 if (*host_port == '/') ++host_port; in grpc_parse_ipv6()
218 return grpc_parse_ipv6_hostport(host_port, resolved_addr, in grpc_parse_ipv6()
/external/grpc-grpc/examples/android/helloworld/app/src/main/cpp/
Dgrpc-helloworld.cc51 char host_port[host_port_buf_size]; in StartServer() local
52 snprintf(host_port, host_port_buf_size, "0.0.0.0:%d", port); in StartServer()
57 builder.AddListeningPort(host_port, grpc::InsecureServerCredentials()); in StartServer()
119 char host_port[host_port_buf_size]; in Java_io_grpc_helloworldexample_cpp_HelloworldActivity_sayHello() local
120 snprintf(host_port, host_port_buf_size, "%s:%d", host.c_str(), port); in Java_io_grpc_helloworldexample_cpp_HelloworldActivity_sayHello()
123 grpc::CreateChannel(host_port, grpc::InsecureChannelCredentials())); in Java_io_grpc_helloworldexample_cpp_HelloworldActivity_sayHello()
/external/python/mobly/tests/mobly/controllers/android_device_lib/
Dsnippet_client_v2_test.py162 self.assertIs(self.client.host_port, None)
256 self.assertIsNone(event_client.host_port, None)
335 self.assertIsNone(event_client.host_port, None)
592 self.client.host_port = 12345
604 self.assertIs(self.client.host_port, None)
617 self.client.host_port = 12345
629 self.assertIs(self.client.host_port, None)
641 self.client.host_port = 12345
652 self.assertIs(self.client.host_port, None)
666 self.client.host_port = 12345
[all …]
Dsnippet_client_test.py78 client.host_port = 123 # normally picked by start_app_and_connect
87 self.assertEqual(123, callback._event_client.host_port)
101 client.host_port = 123 # normally picked by start_app_and_connect
108 self.assertEqual(123, client.host_port)
110 self.assertEqual(123, callback._event_client.host_port)
115 self.assertEqual(321, client.host_port)
117 self.assertEqual(321, callback._event_client.host_port)
123 self.assertEqual(789, client.host_port)
125 self.assertEqual(789, callback._event_client.host_port)
170 client.host_port = 1
[all …]
/external/chromium-trace/catapult/devil/devil/android/
Dforwarder.py151 str(host_port)
152 ] for device_port, host_port in port_pairs]
193 host_port = int(match.groupdict()['host_port'])
195 instance._device_to_host_port_map[serial_with_port] = host_port
196 instance._host_to_device_port_map[host_port] = serial_with_port
198 host_port)
245 for device_serial_and_port, host_port in device_map.items():
249 del host_map[host_port]
256 def DevicePortForHostPort(host_port): argument
260 None)._host_to_device_port_map.get(host_port)
[all …]
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_channel.cc49 Status ValidateHostPortPair(const string& host_port) { in ValidateHostPortPair() argument
51 if (host_port.substr(0, bns_prefix.length()) == bns_prefix) { in ValidateHostPortPair()
55 auto colon_index = host_port.find_last_of(':'); in ValidateHostPortPair()
56 if (!strings::safe_strtou32(host_port.substr(colon_index + 1), &port) || in ValidateHostPortPair()
57 host_port.substr(0, colon_index).find('/') != string::npos) { in ValidateHostPortPair()
58 return errors::InvalidArgument("Could not interpret \"", host_port, in ValidateHostPortPair()
316 const string host_port = TranslateTask(target); in FindChannelOnce() local
317 if (host_port.empty()) { in FindChannelOnce()
320 auto chan_ptr = channel_func_(host_port); in FindChannelOnce()
322 << " host_port: " << host_port << " target : " << target in FindChannelOnce()
Dgrpc_server_lib.cc349 string& host_port = host_ports[task.first]; in ParseChannelSpec() local
350 if (!host_port.empty()) { in ParseChannelSpec()
353 task.first, "\": ", host_port, " and ", in ParseChannelSpec()
357 host_port = strings::StrCat(host_name_, ":", bound_port_); in ParseChannelSpec()
359 host_port = task.second; in ParseChannelSpec()
391 const string host_port = channel_cache->TranslateTask(name_prefix); in WorkerCacheFactory() local
394 auto colon_index = host_port.find_last_of(':'); in WorkerCacheFactory()
395 if (!strings::safe_strto32(host_port.substr(colon_index + 1), in WorkerCacheFactory()
398 host_port, "\"."); in WorkerCacheFactory()
/external/grpc-grpc/test/cpp/interop/
Dclient_helper.cc85 char host_port[host_port_buf_size]; in CreateChannelForTestCase() local
86 snprintf(host_port, host_port_buf_size, "%s:%d", FLAGS_server_host.c_str(), in CreateChannelForTestCase()
109 return CreateTestChannel(host_port, FLAGS_server_host_override, in CreateChannelForTestCase()
112 return CreateTestChannel(host_port, FLAGS_custom_credentials_type, creds); in CreateChannelForTestCase()
/external/angle/build/util/lib/common/
Dchrome_test_server_spawner.py65 def GetDevicePortForHostPort(self, host_port): argument
67 return host_port
107 self.host_port = 0
109 assert isinstance(self.host_port, int)
162 self.host_port = parsed_server_data['port']
165 return self.port_forwarder.WaitPortNotAvailable(self.host_port)
260 port_map = [(0, self.host_port)]
266 self.port_forwarder.GetDevicePortForHostPort(self.host_port)
368 (new_server.forwarder_device_port, new_server.host_port))
/external/cronet/build/util/lib/common/
Dchrome_test_server_spawner.py64 def GetDevicePortForHostPort(self, host_port): argument
66 return host_port
106 self.host_port = 0
108 assert isinstance(self.host_port, int)
161 self.host_port = parsed_server_data['port']
164 return self.port_forwarder.WaitPortNotAvailable(self.host_port)
259 port_map = [(0, self.host_port)]
265 self.port_forwarder.GetDevicePortForHostPort(self.host_port)
367 (new_server.forwarder_device_port, new_server.host_port))
/external/autotest/server/hosts/
Dabstract_ssh.py192 def host_port(self): member in AbstractSSHHost
249 self.host_port)
885 self.host_port)
894 logging.debug('Host %s is now up', self.host_port)
899 self.host_port, e,
906 self.host_port, int(timeout + time.time() - end_time))
950 self.host_port, old_boot_id)
972 self.host_port)
980 'have rebooted', self.host_port, new_boot_id)
1008 logging.info('Pinging host %s', self.host_port)
[all …]
/external/tensorflow/tensorflow/python/profiler/internal/
Dprofiler_pywrap_impl.cc53 tensorflow::Status ValidateHostPortPair(absl::string_view host_port) { in ValidateHostPortPair() argument
55 std::vector<absl::string_view> parts = absl::StrSplit(host_port, ':'); in ValidateHostPortPair()
61 "Could not interpret \"", host_port, "\" as a host-port pair."); in ValidateHostPortPair()
77 for (absl::string_view host_port : options.service_addresses()) { in ValidateOptions() local
78 TF_RETURN_IF_ERROR(ValidateHostPortPair(host_port)); in ValidateOptions()
/external/grpc-grpc/src/core/lib/iomgr/
Dtcp_client_cfstream.cc146 char *host_port, *host_string, *port_string; in ParseResolvedAddress() local
147 grpc_sockaddr_to_string(&host_port, addr, 1); in ParseResolvedAddress()
148 gpr_split_host_port(host_port, &host_string, &port_string); in ParseResolvedAddress()
152 gpr_free(host_port); in ParseResolvedAddress()
/external/grpc-grpc/src/android/test/interop/app/src/main/cpp/
Dgrpc-interop.cc38 char host_port[host_port_buf_size]; in GetClient() local
39 snprintf(host_port, host_port_buf_size, "%s:%d", host, port); in GetClient()
49 std::bind(grpc::CreateChannel, host_port, credentials); in GetClient()
/external/autotest/server/cros/tradefed/
Dadb.py88 host_port = get_adb_target(host)
89 ret = ('-s', host_port)
Dpush_arc_image.py93 arc_version, host.host_port))
102 host.host_port,
/external/ot-br-posix/third_party/Simple-web-server/repo/
Dclient_http.hpp192 … ClientBase(const std::string& host_port, unsigned short default_port) : resolver(io_service) { in ClientBase() argument
193 auto parsed_host_port=parse_host_port(host_port, default_port); in ClientBase()
198 …std::pair<std::string, unsigned short> parse_host_port(const std::string &host_port, unsigned shor… in parse_host_port() argument
200 size_t host_end=host_port.find(':'); in parse_host_port()
202 parsed_host_port.first=host_port; in parse_host_port()
206 parsed_host_port.first=host_port.substr(0, host_end); in parse_host_port()
207 … parsed_host_port.second=static_cast<unsigned short>(stoul(host_port.substr(host_end+1))); in parse_host_port()

1234