Home
last modified time | relevance | path

Searched refs:connection (Results 1 – 25 of 74) sorted by relevance

123

/tools/test/connectivity/acts/framework/tests/controllers/sl4a_lib/
Drpc_connection_test.py70 connection = self.mock_rpc_connection()
71 connection._initiate_handshake = pass_on_init
72 connection.open()
85 connection = self.mock_rpc_connection(uid=1)
86 connection._initiate_handshake = pass_on_continue
87 connection.open()
95 connection = self.mock_rpc_connection()
96 connection._initiate_handshake(
99 self.assertEqual(connection.uid, 1)
107 connection = self.mock_rpc_connection(MOCK_RESP_UNKNOWN_UID)
[all …]
Drpc_client_test.py66 for connection in working_connections + free_connections:
67 self.assertTrue(connection.close.called)
92 connection = client._get_free_connection()
94 self.assertEqual(connection, expected_connection)
177 connection = mock.Mock()
178 client._working_connections = [connection]
180 client._release_working_connection(connection)
182 self.assertTrue(connection in client._free_connections)
183 self.assertFalse(connection in client._working_connections)
/tools/tradefederation/core/src/com/android/tradefed/device/internal/
DDeviceSnapshotFeature.java25 import com.android.tradefed.device.connection.AbstractConnection;
26 import com.android.tradefed.device.connection.AdbSshConnection;
95 AbstractConnection connection = mTestInformation.getDevice().getConnection(); in execute() local
98 || (connection instanceof AdbSshConnection)) { in execute()
99 GceAvdInfo info = getAvdInfo(mTestInformation.getDevice(), connection); in execute()
109 restoreSnapshot(responseBuilder, connection, user, offset, snapshotId); in execute()
111 snapshot(responseBuilder, connection, user, offset, snapshotId); in execute()
119 connection != null in execute()
120 ? connection.getClass().getSimpleName() in execute()
141 AbstractConnection connection, in snapshot() argument
[all …]
DDeviceResetFeature.java27 import com.android.tradefed.device.connection.AbstractConnection;
28 import com.android.tradefed.device.connection.AdbSshConnection;
100 AbstractConnection connection = mTestInformation.getDevice().getConnection(); in execute() local
102 || (connection instanceof AdbSshConnection)) { in execute()
103 GceAvdInfo info = getAvdInfo(mTestInformation.getDevice(), connection); in execute()
110 CommandResult powerwashResult = powerwash(connection, user, offset); in execute()
169 private GceAvdInfo getAvdInfo(ITestDevice device, AbstractConnection connection) { in getAvdInfo() argument
170 if (connection instanceof AdbSshConnection) { in getAvdInfo()
171 return ((AdbSshConnection) connection).getAvdInfo(); in getAvdInfo()
176 private CommandResult powerwash(AbstractConnection connection, String user, Integer offset) in powerwash() argument
[all …]
/tools/test/connectivity/acts/framework/acts/controllers/sl4a_lib/
Drpc_client.py180 for connection in connections:
182 'Closing connection over ports %s' % connection.ports)
183 connection.close()
217 def _release_working_connection(self, connection): argument
228 self._working_connections.remove(connection)
229 self._free_connections.append(connection)
249 connection = self._get_free_connection()
250 ticket = connection.get_new_ticket()
253 connection.set_timeout(timeout)
259 connection.send_request(request)
[all …]
Dsl4a_manager.py126 def diagnose_failure(self, session, connection): argument
131 self.error_reporter.create_error_report(self, session, connection)
Dsl4a_session.py175 def diagnose_failure(self, connection): argument
177 self._on_error_callback(self, connection)
/tools/tradefederation/core/common_util/com/android/tradefed/util/net/
DHttpHelper.java161 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in createConnection() local
162 connection.setRequestMethod(method); in createConnection()
164 connection.setRequestProperty("Content-Type", contentType); in createConnection()
166 connection.setDoInput(true); in createConnection()
167 connection.setDoOutput(true); in createConnection()
168 connection.setConnectTimeout(getOpTimeout()); // timeout for establishing the connection in createConnection()
169 connection.setReadTimeout(getOpTimeout()); // timeout for receiving a read() response in createConnection()
170 connection.setRequestProperty("User-Agent", in createConnection()
172 return connection; in createConnection()
/tools/test/connectivity/acts_tests/tests/google/bt/power/
DSetupBTPairingTest.py58 connection, client_address = sock.accept()
64 if connection is not None:
65 connection.close()
/tools/test/connectivity/acts/framework/acts/controllers/utils_lib/commands/
Droute.py18 from acts.controllers.utils_lib.ssh import connection
63 except connection.CommandError as e:
174 except connection.CommandError as e:
/tools/tradefederation/core/src/com/android/tradefed/testtype/suite/
DITestSuite.java38 import com.android.tradefed.device.connection.AbstractConnection;
39 import com.android.tradefed.device.connection.AdbTcpConnection;
809 AbstractConnection connection = mDevice.getConnection(); in run() local
810 if (connection instanceof AdbTcpConnection) { in run()
812 if (((AdbTcpConnection) connection).getSuiteSnapshots().containsKey(mDevice)) { in run()
815 ((AdbTcpConnection) connection) in run()
817 ((AdbTcpConnection) connection) in run()
823 ((AdbTcpConnection) connection).getSuiteSnapshots().get(mDevice); in run()
824 ((AdbTcpConnection) connection).recoverVirtualDevice(mDevice, snapshot, null); in run()
1040 AbstractConnection connection = device.getConnection(); in moduleIsolation() local
[all …]
/tools/tradefederation/core/clearcut_client/com/android/tradefed/clearcut/
DClearcutClient.java343 HttpURLConnection connection = helper.createConnection(new URL(mUrl), "POST", "text"); in sendToClearcut() local
344 outputStream = connection.getOutputStream(); in sendToClearcut()
351 inputStream = connection.getInputStream(); in sendToClearcut()
354 errorStream = connection.getErrorStream(); in sendToClearcut()
/tools/netsim/rust/daemon/src/http_server/
Dserver_response.rs43 fn put_ok_switch_protocol(&mut self, connection: &str, headers: StrHeaders); in put_ok_switch_protocol()
125 fn put_ok_switch_protocol(&mut self, connection: &str, headers: StrHeaders) { in put_ok_switch_protocol()
128 .header("Upgrade", HeaderValue::from_str(connection).unwrap()) in put_ok_switch_protocol()
/tools/apksig/
DAndroid.bp59 "awssdk-url-connection-client",
126 "awssdk-url-connection-client",
172 "awssdk-url-connection-client",
/tools/tradefederation/core/src/com/android/tradefed/device/cloud/
DRemoteAndroidVirtualDevice.java25 import com.android.tradefed.device.connection.AdbSshConnection;
26 import com.android.tradefed.device.connection.DefaultConnection;
DOxygenUtil.java441 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); in getTargetRegion() local
442 connection.setRequestProperty("Metadata-Flavor", "Google"); in getTargetRegion()
446 new BufferedReader(new InputStreamReader(connection.getInputStream()))) { in getTargetRegion()
/tools/test/connectivity/acts_tests/tests/google/wifi/
DSetupWifiNetworkTest.py43 connection, client_address = sock.accept()
49 connection.close()
DWifiPreTest.py26 from acts.controllers.utils_lib.ssh import connection
106 openwrt.ssh = connection.SshConnection(openwrt.ssh_settings)
/tools/test/connectivity/acts/framework/acts/controllers/
Dopenwrt_ap.py19 from acts.controllers.utils_lib.ssh import connection
118 self.ssh = connection.SshConnection(self.ssh_settings)
120 except connection.Error:
127 self.ssh = connection.SshConnection(self.ssh_settings)
Diperf_client.py29 from acts.controllers.utils_lib.ssh import connection
245 self._ssh_session = connection.SshConnection(self._ssh_settings)
Dpacket_capture.py24 from acts.controllers.utils_lib.ssh import connection
104 self.ssh = connection.SshConnection(self.ssh_settings)
/tools/test/connectivity/acts_tests/acts_contrib/test_utils/bt/protos/
Dbluetooth.proto28 // Session information that gets logged for every BT connection.
84 // Information that gets logged for every Bluetooth connection.
86 // Type of technology used in the connection.
/tools/tradefederation/core/javatests/com/android/tradefed/device/connection/
DAdbTcpConnectionTest.java16 package com.android.tradefed.device.connection;
28 import com.android.tradefed.device.connection.DefaultConnection.ConnectionBuilder;
/tools/test/openhst/
DREADME.md18 * ADB connection between the test server and android handset
19 * Internet connection on android handset
/tools/tradefederation/core/device_build_interfaces/com/android/tradefed/device/connection/
DAbstractConnection.java16 package com.android.tradefed.device.connection;

123