Home
last modified time | relevance | path

Searched +full:- +full:- +full:connect +full:- +full:timeout (Results 1 – 25 of 1048) sorted by relevance

12345678910>>...42

/external/python/cpython3/Lib/test/
Dtest_timeout.py1 """Unit tests for socket timeout feature."""
17 We must perform name resolution before timeout tests, otherwise it will be
18 performed by connect().
37 "timeout not disabled by default")
73 self.assertRaises(ValueError, self.sock.settimeout, -1)
74 self.assertRaises(ValueError, self.sock.settimeout, -1)
75 self.assertRaises(ValueError, self.sock.settimeout, -1.0)
118 def _sock_operation(self, count, timeout, method, *args): argument
123 within `timeout` + self.fuzz seconds.
125 self.sock.settimeout(timeout)
[all …]
Dtest_ftplib.py32 TIMEOUT = support.LOOPBACK_TIMEOUT variable
33 DEFAULT_ENCODING = 'utf-8'
37 LIST_DATA = 'foo\r\nbar\r\n non-ascii char \xAE\r\n'
38 NLST_DATA = 'foo\r\nbar\r\n non-ascii char \xAE\r\n'
42 "type=OS.unix=chr-13/29;perm=;unique==keVO1+5G4; device\r\n"
43 "type=OS.unix=blk-11/108;perm=;unique==keVO1+6G4; block\r\n"
46 "type=dir;perm=;unique==keVO1+1t2; no-exec\r\n"
54 "type=dir;perm=cpmel;unique==SGP1; dir \xAE non-ascii char\r\n"
55 "type=file;perm=r;unique==SGP2; file \xAE non-ascii char\r\n")
59 # bpo-44359: Silently ignore socket errors. Such errors occur when a client
[all …]
/external/curl/docs/cmdline-opts/
Dconnect-timeout.md1 ---
3 SPDX-License-Identifier: curl
4 Long: connect-timeout
6 Help: Maximum time allowed to connect
7 Category: connection timeout
10 See-also:
11 - max-time
13 - --connect-timeout 20 $URL
14 - --connect-timeout 3.14 $URL
15 ---
[all …]
/external/curl/tests/unit/
Dunit1303.c21 * SPDX-License-Identifier: curl
27 #include "connect.h"
52 that we aren't zero-based */
58 #define TIMEOUTS(x,y) testdata->set.timeout = x; \
59 testdata->set.connecttimeout = y
65 * 0/1 during connect
89 {BASE + 10, 0, 10000, 8000, FALSE, -1, "timeout is -1, expired"},
90 {BASE + 12, 0, 10000, 8000, FALSE, -2000, "-2000, overdue 2 seconds"},
95 {BASE + 8, 0, 10000, 8000, TRUE, -1, "timeout is -1, expired"},
96 {BASE + 10, 0, 10000, 8000, TRUE, -2000, "-2000, overdue 2 seconds"},
[all …]
/external/jsoup/src/test/java/org/jsoup/integration/
DConnectIT.java22 …* Failsafe integration tests for Connect methods. These take a bit longer to run, so included as I…
28 // todo - implement in interruptable channels, so it's immediate in canInterruptBodyStringRead()
30 Thread runner = new Thread(() -> { in canInterruptBodyStringRead()
32 Connection.Response res = Jsoup.connect(SlowRider.Url) in canInterruptBodyStringRead()
33 .timeout(15 * 1000) in canInterruptBodyStringRead()
54 // todo - implement in interruptable channels, so it's immediate in canInterruptDocumentRead()
56 Thread runner = new Thread(() -> { in canInterruptDocumentRead()
58 Connection.Response res = Jsoup.connect(SlowRider.Url) in canInterruptDocumentRead()
59 .timeout(15 * 1000) in canInterruptDocumentRead()
80 Thread runner = new Thread(() -> { in canInterruptThenJoinASpawnedThread()
[all …]
/external/autotest/client/cros/chameleon/
Dchameleon_bluetooth_audio.py3 # Use of this source code is governed by a BSD-style license that can be
24 # Set the timeout to 90 seconds so device can take more trials to reconnect.
33 timeout=_SEARCH_TIMEOUT): argument
34 """Controls Cros device to connect to bluetooth module on audio board.
40 @param timeout: Timeout in seconds to search for bluetooth module.
42 @raises: ChameleonBluetoothAudioError if Cros device fails to connect to
69 found_device = utils.wait_for_value(_find_device, True, timeout_sec=timeout)
96 timeout=_CONNECT_TIMEOUT): argument
97 """Controls Cros device to connect to bluetooth module on audio board.
103 @param timeout: Timeout in seconds to connect bluetooth module.
[all …]
/external/tensorflow/tensorflow/compiler/xla/pjrt/distributed/
Dclient.cc7 http://www.apache.org/licenses/LICENSE-2.0
52 xla::Status Connect() override;
57 std::string key, absl::Duration timeout) override;
60 absl::Duration timeout) override;
75 // The client has not yet connected to the server, i.e., had a Connect()
99 // A unique session ID, assigned by the server during Connect().
119 xla::Status Connect() override;
124 std::string key, absl::Duration timeout) override;
127 absl::Duration timeout) override;
177 xla::Status DistributedRuntimeClientImpl::Connect() { in Connect() function in xla::DistributedRuntimeClientImpl
[all …]
Dclient.h7 http://www.apache.org/licenses/LICENSE-2.0
40 int32_t node_id = -1;
45 // RPC timeout used for RPC that don't have their own timeouts.
48 // Time period for which Connect() should be retried. The client will keep
50 // individual Connect() RPC fails. May be zero, in which case Connect() will
54 // How long to wait for all nodes to call Shutdown(). If the timeout
62 // How many failed heartbeat RPCs may fail due to a possibly-ephemeral
70 // Exposed so tests can override this behavior to something non-fatal.
99 // Not thread-safe, i.e., calls to Connect()/Shutdown()/EnumerateDevices()
101 virtual xla::Status Connect() = 0;
[all …]
/external/autotest/client/cros/scripts/
Dwifi4 # Use of this source code is governed by a BSD-style license that can be
40 print(cmd, 'connect <ssid> [passphrase] [security]')
44 print(cmd, 'disconnect <ssid> [timeout seconds]')
46 print(cmd, 'connect_with_props <ssid> <timeout seconds>')
71 def connect(ssid, security, credentials, save_credentials, timeout=15): function
72 """Attempt to connect to a WiFi network.
74 Blocks until we connect successfully to a WiFi network described
77 @param ssid string Name of the network to connect to.
78 @param security string security type of the network to connect to.
90 discovery_timeout_seconds=timeout,
[all …]
/external/ksoap2/ksoap2-j2se/src/main/java/org/ksoap2/transport/
DHttpsServiceConnectionSE.java27 * @see "http://stackoverflow.com/questions/2820284/ssl-on-android-strange-issue"
28 * @see "http://stackoverflow.com/questions/2899079/custom-ssl-handling-stopped-working-on
29 * -android-2-2-froyo"
44 * @param port the http port to connect on
47 * @param timeout the timeout for the connection in milliseconds
49 public HttpsServiceConnectionSE(String host, int port, String file, int timeout) in HttpsServiceConnectionSE() argument
51 this(null, host, port, file, timeout); in HttpsServiceConnectionSE()
59 * @param port the http port to connect on
62 * @param timeout the timeout for the connection in milliseconds
64 public HttpsServiceConnectionSE(Proxy proxy, String host, int port, String file, int timeout) in HttpsServiceConnectionSE() argument
[all …]
/external/oj-libjdwp/src/share/classes/com/sun/jdi/connect/spi/
DTransportService.java19 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
26 package com.sun.jdi.connect.spi;
29 import com.sun.jdi.connect.TransportTimeoutException;
36 * that has a zero-argument constructor and implements the abstract
38 * used by a {@link com.sun.jdi.connect.Transport} for
46 * <a href="../../../../../../../../../technotes/guides/jpda/jdwp-spec.html">
115 * Tell whether or not this transport service supports a timeout
119 * service supports attaching with a timeout.
127 * timeout while waiting for a target VM to connect.
130 * service supports timeout while waiting for
[all …]
/external/python/cpython3/Doc/library/
Dftplib.rst1 :mod:`!ftplib` --- FTP protocol client
13 --------------
22 The default encoding is UTF-8, following :rfc:`2640`.
24 .. include:: ../includes/wasm-notavail.rst
29 >>> ftp = FTP('ftp.us.debian.org') # connect to host, default port
35 -rw-rw-r-- 1 1176 1176 1063 Jun 15 10:18 README
37 drwxr-sr-x 5 1176 1176 4096 Dec 19 2000 pool
38 drwxr-sr-x 4 1176 1176 4096 Nov 17 2008 project
39 drwxr-xr-x 3 1176 1176 4096 Oct 10 2012 tools
48 .. _ftplib-reference:
[all …]
/external/python/mobly/tests/mobly/controllers/android_device_lib/
Djsonrpc_client_base_test.py7 # http://www.apache.org/licenses/LICENSE-2.0
35 """Test socket timeout with io error
43 client.connect()
47 """Test socket timeout
49 Test that a timeout exception will be raised if the socket gives a
50 timeout.
52 mock_create_connection.side_effect = socket.timeout
53 with self.assertRaises(socket.timeout):
55 client.connect()
70 client.connect()
[all …]
/external/python/bumble/bumble/transport/grpc_protobuf/
Demulated_bluetooth_pb2_grpc.py2 """Client and server classes corresponding to protobuf-defined services."""
63 """Connect device to link layer. This will establish a direct connection
66 - Each connection creates a new device and attaches it to the link layer
67 - Link Layer packets are transmitted directly to the phy
71 This is used to directly connect various android emulators together.
72 For example a wear device can connect to an android emulator through
80 """Connect device to link layer. This will establish a direct connection
83 - Each connection creates a new device and attaches it to the link layer
84 - Link Layer packets are transmitted directly to the phy
88 This is used to directly connect various android emulators together.
[all …]
/external/rust/android-crates-io/crates/hyper-timeout/
DREADME.md1 …![crates.io](https://img.shields.io/crates/v/hyper-timeout.svg)](https://crates.io/crates/hyper-ti…
3 # hyper-timeout
5 A connect, read and write timeout aware connector to be used with hyper `Client`.
9 … timeouts. There is a way to do general timeouts, but no easy way to get connect, read and write s…
13 There is a `TimeoutConnector` that implements the `hyper::Connect` trait. This connector wraps arou…
15 **Note:** In hyper 0.11, a read or write timeout will return a _broken pipe_ error because of the w…
31 hyper-timeout = "0.4"
39 …* Apache License, Version 2.0 ([LICENSE-APACHE](LICENSE-APACHE) or http://www.apache.org/licenses/…
40 * MIT license ([LICENSE-MIT](LICENSE-MIT) or http://opensource.org/licenses/MIT)
46 for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as a…
/external/cronet/tot/net/socket/
Dtcp_client_socket_unittest.cc2 // Use of this source code is governed by a BSD-style license that can be
41 // more grep-able.
75 base::PowerMonitor::GetInstance()->ShutdownForTesting(); in ~TCPClientSocketTest()
89 ASSERT_THAT(server_socket->Listen(IPEndPoint(local_address, 0), 1, in CreateConnectedSockets()
93 ASSERT_THAT(server_socket->GetLocalAddress(&server_address), IsOk()); in CreateConnectedSockets()
98 EXPECT_THAT((*client_socket)->Bind(IPEndPoint(local_address, 0)), IsOk()); in CreateConnectedSockets()
101 EXPECT_THAT((*client_socket)->GetLocalAddress(&local_address_result), in CreateConnectedSockets()
106 int connect_result = (*client_socket)->Connect(connect_callback.callback()); in CreateConnectedSockets()
110 server_socket->Accept(accepted_socket, accept_callback.callback()); in CreateConnectedSockets()
116 EXPECT_TRUE((*client_socket)->IsConnected()); in CreateConnectedSockets()
[all …]
/external/cronet/stable/net/socket/
Dtcp_client_socket_unittest.cc2 // Use of this source code is governed by a BSD-style license that can be
41 // more grep-able.
75 base::PowerMonitor::GetInstance()->ShutdownForTesting(); in ~TCPClientSocketTest()
89 ASSERT_THAT(server_socket->Listen(IPEndPoint(local_address, 0), 1, in CreateConnectedSockets()
93 ASSERT_THAT(server_socket->GetLocalAddress(&server_address), IsOk()); in CreateConnectedSockets()
98 EXPECT_THAT((*client_socket)->Bind(IPEndPoint(local_address, 0)), IsOk()); in CreateConnectedSockets()
101 EXPECT_THAT((*client_socket)->GetLocalAddress(&local_address_result), in CreateConnectedSockets()
106 int connect_result = (*client_socket)->Connect(connect_callback.callback()); in CreateConnectedSockets()
110 server_socket->Accept(accepted_socket, accept_callback.callback()); in CreateConnectedSockets()
116 EXPECT_TRUE((*client_socket)->IsConnected()); in CreateConnectedSockets()
[all …]
/external/toybox/lib/
Dnet.c15 if (-1 == setsockopt(fd, level, opt, val, len)) perror_exit("setsockopt"); in xsetsockopt()
43 int fd = -1, one = 1; in xconnbind()
45 // Try all the returned addresses. Report errors if last entry can't connect. in xconnbind()
46 for (ai = ai_arg; ai; ai = ai->ai_next) { in xconnbind()
47 fd = (ai->ai_next ? socket : xsocket)(ai->ai_family, ai->ai_socktype, in xconnbind()
48 ai->ai_protocol); in xconnbind()
50 if (!(dobind ? bind : connect)(fd, ai->ai_addr, ai->ai_addrlen)) break; in xconnbind()
51 else if (!ai->ai_next) perror_exit_raw(dobind ? "bind" : "connect"); in xconnbind()
77 if (connect(fd, sa, len)) perror_exit("connect"); in xconnect()
80 int xpoll(struct pollfd *fds, int nfds, int timeout) in xpoll() argument
[all …]
/external/cronet/tot/net/http/
Dhttp_proxy_connect_job_unittest.cc2 // Use of this source code is governed by a BSD-style license that can be
77 const char kHttpsNestedProxyHost[] = "last-hop-https-proxy.example.test";
88 // TODO(crbug.com/365771838): Add tests for non-ip protection nested proxy
105 << arg->session_key().proxy_chain().ToDebugString();
106 return arg->session_key().proxy_chain() == proxy_chain;
132 std::make_unique<StaticHttpUserAgentSettings>("*", "test-ua"); in HttpProxyConnectJobTestBase()
142 base::FieldTrialParamAssociator::GetInstance()->ClearAllParamsForTesting(); in ~HttpProxyConnectJobTestBase()
150 session_->CreateCommonConnectJobParams()); in InitCommonConnectJobParams()
153 common_connect_job_params_->proxy_delegate = proxy_delegate_.get(); in InitCommonConnectJobParams()
154 common_connect_job_params_->network_quality_estimator = in InitCommonConnectJobParams()
[all …]
/external/cronet/stable/net/http/
Dhttp_proxy_connect_job_unittest.cc2 // Use of this source code is governed by a BSD-style license that can be
77 const char kHttpsNestedProxyHost[] = "last-hop-https-proxy.example.test";
88 // TODO(crbug.com/365771838): Add tests for non-ip protection nested proxy
105 << arg->session_key().proxy_chain().ToDebugString();
106 return arg->session_key().proxy_chain() == proxy_chain;
132 std::make_unique<StaticHttpUserAgentSettings>("*", "test-ua"); in HttpProxyConnectJobTestBase()
142 base::FieldTrialParamAssociator::GetInstance()->ClearAllParamsForTesting(); in ~HttpProxyConnectJobTestBase()
150 session_->CreateCommonConnectJobParams()); in InitCommonConnectJobParams()
153 common_connect_job_params_->proxy_delegate = proxy_delegate_.get(); in InitCommonConnectJobParams()
154 common_connect_job_params_->network_quality_estimator = in InitCommonConnectJobParams()
[all …]
/external/autotest/client/cros/networking/
Dwifi_proxy.py3 # Use of this source code is governed by a BSD-style license that can be
56 @param ssid string name of network to connect to.
112 Connect to a WiFi network with the given association parameters.
114 @param ssid string name of network to connect to.
123 @param discovery_timeout_seconds float timeout for service discovery.
124 @param association_timeout_seconds float timeout for service
126 @param configuration_timeout_seconds float timeout for DHCP
138 logging.info('Attempting to connect to %s', ssid)
140 discovery_time = -1.0
141 association_time = -1.0
[all …]
/external/python/mobly/mobly/controllers/android_device_lib/
Dadb.py7 # http://www.apache.org/licenses/LICENSE-2.0
46 # The regex pattern indicating the `adb connect` command did not fail.
91 timeout: float, the number of seconds passed before timing out.
97 def __init__(self, cmd, timeout, serial=''): argument
100 self.timeout = timeout
106 self.timeout,
117 clean_out = out.decode('utf-8').strip()
134 out = AdbProxy().forward('--list')
135 clean_lines = str(out, 'utf-8').strip().split('\n')
148 For syntactic reasons, the '-' in adb commands need to be replaced with
[all …]
/external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/mqtt/
DMqttConnectionConfig.java4 * SPDX-License-Identifier: Apache-2.0.
17 * Encapsulates all per-mqtt-connection configuration
67 * Configures the connection-related callbacks for a connection
76 * Queries the connection-related callbacks for a connection
106 * @param endpoint The IoT endpoint to connect to
122 * Configures the port to connect to.
124 * @param port The port to connect to. Usually 8883 for MQTT, or 443 for websockets
131 * Queries the port to connect to.
133 * @return The port to connect to
179 * @deprecated Configures MQTT keep-alive via PING messages. Note that this is not TCP
[all …]
/external/aws-sdk-java-v2/.changes/2.23.x/
D2.23.8.json3 "date": "2024-01-22",
15 "description": "Fix FIPS Endpoints in aws-us-gov."
21 … "description": "Doc-only update around removing AL1 from list of available AMIs for Cloud9"
37 "category": "Amazon Connect Cases",
45 …Timeout to ECS Service Connect. TLS facilitates privacy and data security for inter-service commun…
/external/rust/android-crates-io/crates/tonic/src/transport/channel/
Dendpoint.rs22 pub(crate) timeout: Option<Duration>, field
44 pub fn new<D>(dst: D) -> Result<Self, Error> in new()
63 pub fn from_static(s: &'static str) -> Self { in from_static()
74 pub fn from_shared(s: impl Into<Bytes>) -> Result<Self, Error> { in from_shared()
79 /// Set a custom user-agent header.
81 /// `user_agent` will be prepended to Tonic's default user-agent string (`tonic/x.x.x`).
88 /// // user-agent: "Greeter tonic/x.x.x"
90 pub fn user_agent<T>(self, user_agent: T) -> Result<Self, Error> in user_agent()
115 pub fn origin(self, origin: Uri) -> Self { in origin()
122 /// Apply a timeout to each request.
[all …]

12345678910>>...42