| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| H A D | ylong_tokio_udp.rs | 85 let port = 8081; in ylong_udp_send_recv()
91 + &*(port + 2 * i).to_string()) in ylong_udp_send_recv()
95 + &*(port + 2 * i + 1).to_string()) in ylong_udp_send_recv()
132 let port = 8121; in tokio_udp_send_recv()
137 let sender_addr = basic_addr.to_owned() + &*(port + 2 * i).to_string(); in tokio_udp_send_recv()
138 let receiver_addr = basic_addr.to_owned() + &*(port + 2 * i + 1).to_string(); in tokio_udp_send_recv()
172 let port = 8141; in ylong_udp_send_to_recv_from()
178 + &*(port + 2 * i).to_string()) in ylong_udp_send_to_recv_from()
182 + &*(port + 2 * i + 1).to_string()) in ylong_udp_send_to_recv_from()
215 let port in tokio_udp_send_to_recv_from()
[all...] |
| H A D | ylong_tokio_tcp.rs | 24 ($runtime: expr, $bench: ident, $server: ident, $client: ident, $port: literal, $task_num: literal, $loop_num: literal, $buf_size: literal) => {
58 let port = $port;
62 let addr = basic_addr.to_owned() + &*(port + i).to_string();
76 ($bench: ident, $server: ident, $client: ident, $port: literal, $task_num: literal, $loop_num: literal, $buf_size: literal) => {
110 let port = $port;
114 let addr = (basic_addr.to_owned() + &*(port + i).to_string())
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/common/ |
| H A D | mod.rs | 29 pub port: u16,
45 pub port: u16,
125 let tcp_listener = std::net::TcpListener::bind("127.0.0.1:0").expect("server bind port failed !");
127 let port = addr.port();
154 port,
164 let mut port = 10000; variables
166 let addr = std::net::SocketAddr::from(([127, 0, 0, 1], port));
170 port += 1;
171 if port
[all...] |
| H A D | async_utils.rs | 339 .url(format!("{}:{}", $host, $handle.port).as_str())
|
| H A D | sync_utils.rs | 340 Port: $handle.port,
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | normalizer.rs | 81 let port;
83 if let Some(req_port) = uri.port().and_then(|port| port.as_u16().ok()) {
84 port = req_port;
87 Scheme::HTTPS => port = 443,
88 Scheme::HTTP => port = 80,
94 new_uri = new_uri.authority(format!("{}:{}", host.as_str(), port).as_bytes());
189 let host_value = match (uri.host(), uri.port()) {
190 (Some(host), Some(port))
[all...] |
| H A D | alt_svc.rs | 36 pub(crate) port: Port,
55 // the first value_it is alpn="[host]:port" in parse_alt_svc()
63 let (host, port) = if index == 0 { in parse_alt_svc()
93 port, in parse_alt_svc()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/request/uri/ |
| H A D | mod.rs | 69 /// assert_eq!(uri.port().unwrap().as_str(), "80");
146 /// assert_eq!(authority.port().unwrap().as_str(), "80");
178 /// assert_eq!(uri.port().unwrap().as_str(), "80");
180 pub fn port(&self) -> Option<&Port> { in port() functions
181 self.authority.as_ref().and_then(|auth| auth.port()) in port()
337 if let Some(port) = self.port() { in to_string()
339 builder.push_str(port.as_str()); in to_string()
589 /// Returns the default port of current uri `Scheme`.
635 port
687 pub fn port(&self) -> Option<&Port> { port() functions
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/ |
| H A D | sdv_async_http2.rs | 31 pub port: u16,
103 std::net::TcpListener::bind("127.0.0.1:0").expect("server bind port failed !");
107 let port = addr.port();
136 port,
177 .url(format!("{}:{}", "127.0.0.1", handle.port).as_str()) in sdv_async_h2_client_send_request()
257 .url(format!("{}:{}", "127.0.0.1", handle.port).as_str()) in sdv_async_h2_client_send_request_concurrently()
|
| H A D | sdv_async_https_pinning.rs | 76 format!("https://127.0.0.1:{}", handle.port).as_str(), in sdv_client_public_key_pinning()
125 format!("https://127.0.0.1:{}", handle.port).as_str(), in sdv_client_public_key_pinning()
254 format!("https://127.0.0.1:{}", handle.port).as_str(), in sdv_client_public_key_pinning_error()
274 .url(format!("{}:{}", "127.0.0.1", handle.port).as_str()) in sdv_client_public_key_pinning_error()
|
| /commonlibrary/ets_utils/js_api_module/uri/ |
| H A D | js_uri.cpp | 117 pos = data_.find("//"); // userInfo path host port ipv4 or ipv6
in AnalysisUri()
236 uriData_.port = -1;
in AnalysisHost()
266 // find port
in AnalysisHostAndPath()
304 std::string port = data_.substr(pos + 1);
in AnalysisPort() local
305 if (!CheckCharacter(port, g_rulePort, true)) {
in AnalysisPort()
306 errStr_ = "port does not conform to the rule";
in AnalysisPort()
308 } else if (CheckCharacter(port, g_ruleDigit, false)) {
in AnalysisPort()
309 if (port.size() == 0 || port.size() > 10) { // 10:The maximum number of bits for int value
in AnalysisPort()
312 double tempPort = std::strtod(port in AnalysisPort()
[all...] |
| H A D | js_uri.h | 30 int port = -1;
member
133 * Gets the hostname portion of the URI without a port.
138 * Gets the hostname portion of the URI without a port.
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/ |
| H A D | socket_addr.rs | 37 sin_port: addr.port().to_be(),
59 sin6_port: addr.port().to_be(),
|
| /commonlibrary/ets_utils/js_api_module/url/ |
| H A D | js_url.cpp | 311 if (input.size() >= 6) { //6:Maximum port number size
in AnalysisPort()
316 const int maxPort = 65535; // 65535:Maximum port number
in AnalysisPort()
324 urlinfo.port = -1;
in AnalysisPort()
329 urlinfo.port = it;
in AnalysisPort()
885 std::string port = strHost.substr(pos + 1);
in AnalyHostPath() local
887 AnalysisPort(port, urlinfo, flags);
in AnalyHostPath()
933 std::string port = strHost.substr(pos + 1);
in AnalysisNoDefaultProtocol() local
935 AnalysisPort(port, urlinfo, flags);
in AnalysisNoDefaultProtocol()
970 std::string port = strHost.substr(pos + 1);
in AnalysisOnlyHost() local
972 AnalysisPort(port, urlinf in AnalysisOnlyHost()
1022 std::string port = strHost.substr(pos + 1); ParsingHostAndPath() local
1526 SplitString(const std::string& input, std::string& strHost, std::string& port) SplitString() argument
1548 std::string port = ""; SetHost() local
1588 std::string port = input; SetPort() local
[all...] |
| H A D | js_url.h | 49 int port = -1;
member
135 * Gets the host name portion of the URL��not include the port.
140 * Sets the host name portion of the URL��not include the port.
147 * Sets the username name portion of the URL��not include the port.
154 * Sets the password portion of the URL��not include the port.
161 * Sets the scheme portion of the URL��not include the port.
168 * Sets the fragment portion of the URL��not include the port.
175 * Sets the search portion of the URL��not include the port.
182 * Sets the host portion of the URL��not include the port.
189 * Sets the port portio
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| H A D | socket_addr.rs | 45 sin_port: addr.port().to_be(),
71 sin6_port: addr.port().to_be(),
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| H A D | ylong_runtime_tcp.rs | 55 let port = 8181; in ylong_tcp_send_recv()
58 let addr = (basic_addr.to_owned() + &*(port + i).to_string()) in ylong_tcp_send_recv()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/verify/ |
| H A D | pinning.rs | 29 /// The map key is server authority(host:port), value is Base64(sha256(Server's
97 let auth = match (parsed.host(), parsed.port()) { in add()
101 (Some(host), Some(port)) => { in add()
102 format!("{}:{}", host.as_str(), port.as_str()) in add()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| H A D | mod.rs | 272 let port = uri.port().unwrap().as_u16().unwrap(); in connect()
335 (host, port), in connect()
346 https_connect(config, addr, stream, is_proxy, auth, (host, port)).await in connect()
360 (host, port): (String, u16),
377 tcp = tunnel(tcp, &host, port, auth)
416 port: u16,
423 "CONNECT {host}:{port} HTTP/1.1\r\nHost: {host}:{port}\r\n"
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/ |
| H A D | happy_eyeballs.rs | 266 let _server_v6_listener = TcpListener::bind(format!("[::1]:{}", server_v4_addr.port())) in ut_happy_eyeballs_connect()
315 .map(|ip| (*ip, server_v4_addr.port()).into()) in ut_happy_eyeballs_connect()
|