Home
last modified time | relevance | path

Searched refs:client (Results 1 – 25 of 55) sorted by relevance

123

/tools/test/connectivity/acts/framework/tests/controllers/sl4a_lib/
Drpc_client_test.py38 client = rpc_client.RpcClient(session.uid, session.adb.serial,
41 client._log = mock.Mock()
42 client._working_connections = [mock.Mock()]
44 client.terminate()
46 self.assertTrue(client._log.warning.called)
55 client = rpc_client.RpcClient(session.uid, session.adb.serial,
58 client._log = mock.Mock()
61 client._free_connections = free_connections
62 client._working_connections = working_connections
64 client.terminate()
[all …]
/tools/acloud/internal/lib/
Dandroid_build_client_test.py47 self.client = android_build_client.AndroidBuildClient(mock.MagicMock())
48 self.client._service = mock.MagicMock()
67 self.client._service.buildartifact = mock.MagicMock(
71 self.client.DownloadArtifact(self.BUILD_TARGET, self.BUILD_ID,
91 self.assertRaises(errors.DriverError, self.client.DownloadArtifact,
98 self.client._service.buildartifact = mock.MagicMock(
100 self.client.CopyTo(
109 attemptId=self.client.DEFAULT_ATTEMPT_ID,
120 self.client._service.buildartifact.return_value = mock_resource
125 self.client.CopyTo,
[all …]
Dgstorage_client_test.py29 self.client = gstorage_client.StorageClient(mock.MagicMock())
30 self.client._service = mock.MagicMock()
36 self.client._service.objects = mock.MagicMock(
39 self.client.Get(self.BUCKET, self.OBJECT)
52 self.client._service.objects = mock.MagicMock(
54 items = self.client.List(self.BUCKET, self.OBJECT)
55 self.client.ListWithMultiPages.assert_called_once_with(
75 self.client._service.objects = mock.MagicMock(
81 response = self.client.Upload(self.LOCAL_SRC, self.BUCKET, self.OBJECT,
95 self.assertRaises(errors.DriverError, self.client.Upload,
[all …]
Dbase_cloud_client_test.py97 client = self._SetupInitMocks()
107 results = client.BatchExecute(
119 client.RETRY_COUNT + 1)
121 client.RETRY_COUNT + 1)
134 client = self._SetupInitMocks()
135 items = client.ListWithMultiPages(
142 client = self._SetupInitMocks()
146 self.assertRaises(errors.HttpError, client.Execute, api_mock)
153 client.Execute,
156 self.assertEqual(api_mock.execute.call_count, client.RETRY_COUNT + 1)
/tools/test/connectivity/acts/framework/acts/test_utils/tel/
Dtel_data_utils.py65 for client in client_list:
66 client.droid.telephonyToggleDataConnection(True)
67 set_wifi_to_default(log, client)
135 for client in client_list:
136 log.info("Client: {}".format(client.serial))
137 wifi_toggle_state(log, client, False)
138 client.droid.telephonyToggleDataConnection(False)
140 for client in client_list:
142 log, client, expected_state=False):
143 client.log.error("Turn off Data on client fail")
[all …]
/tools/test/connectivity/acts/framework/acts/test_utils/net/
Dsocket_test_utils.py56 def listen_accept_android_socket(client, argument
73 client.droid.connectSocket(client_fd, server_ip, server_port)
78 def send_recv_data_android_sockets(client, argument
101 client.log.info("Sending message: %s" % msg)
102 client.droid.sendDataOverSocket(server_ip, server_port, msg, client_fd)
137 def send_recv_data_datagram_sockets(client, argument
160 client.log.info("Sending message: %s" % msg)
161 client.droid.sendDataOverDatagramSocket(client_sock,
179 def _client_socket(client, server_ip, server_port, client_ip, client_port, q): argument
181 sock = client.droid.openTcpSocket(server_ip,
[all …]
/tools/test/connectivity/acts/framework/acts/controllers/buds_lib/data_storage/bigquery/
Dtest_bigquery_utils.py327 client = utils.BigqueryLoggerClient('', '')
328 dataset = client.create_dataset('existing_dataset')
337 client = utils.BigqueryLoggerClient('', '')
338 dataset = client.create_dataset('new_dataset')
356 client = utils.BigqueryLoggerClient('', '')
357 table = client.create_table('existing_dataset', 'existing_table', schema)
375 client = utils.BigqueryLoggerClient('', '')
376 table = client.create_table('existing_dataset', 'new_table', schema)
397 client = utils.BigqueryLoggerClient('', '')
398 table, changed_fields = client.update_table_schema(
[all …]
Dbigquery_logger_utils.py316 self.client = bigquery.Client(project_id)
330 dataset_ref = self.client.dataset(dataset_id)
333 dataset = self.client.get_dataset(dataset_ref)
335 self.client.create_dataset(dataset)
353 table = self.client.get_table(table_ref)
355 self.client.create_table(table)
382 table = self.client.update_table(
395 dataset_ref = self.client.dataset(dataset_id)
401 self.client.delete_table(table)
403 self.client.delete_dataset(dataset)
[all …]
/tools/test/connectivity/acts/framework/tests/controllers/
Diperf_client_test.py87 client = IPerfClient()
89 client._get_full_file_path = lambda _: file_path
91 client.start('127.0.0.1', 'IPERF_ARGS', 'TAG')
106 client = IPerfClientOverSsh({'host': '', 'user': ''})
107 client._ssh_session = mock.Mock()
109 client._get_full_file_path = lambda _: file_path
111 client.start('127.0.0.1', 'IPERF_ARGS', 'TAG')
115 client._ssh_session.run().stdout
124 client = IPerfClientOverAdb(None)
127 client._get_full_file_path = lambda _: file_path
[all …]
/tools/test/connectivity/acts/framework/acts/controllers/
Dchameleon_controller.py19 import xmlrpc.client
108 self.client = xmlrpc.client.ServerProxy(
114 self.client.Reset()
133 self.client.StartCapturingAudio(port_id, has_file)
145 return self.client.StopCapturingAudio(port_id)
154 self.client.AudioBoardConnect(bus_number, endpoint)
163 self.client.AudioBoardDisconnect(bus_number, endpoint)
167 self.client.AudioBoardDisableBluetooth()
175 self.client.AudioBoardClearRoutes(bus_number)
Dnative.py57 self.client.write(request.encode("utf8") + b'\n')
58 self.client.flush()
59 response = self.client.readline()
/tools/tradefederation/core/tests/src/com/android/tradefed/util/keystore/
DJSONFileKeyStoreFactoryTest.java60 IKeyStoreClient client = mFactory.createKeyStoreClient(); in testLoadKeyStore_same() local
61 assertNotNull(client); in testLoadKeyStore_same()
63 assertSame(client, client2); in testLoadKeyStore_same()
71 IKeyStoreClient client = mFactory.createKeyStoreClient(); in testLoadKeyStore_modified() local
72 assertNotNull(client); in testLoadKeyStore_modified()
76 assertNotSame(client, client2); in testLoadKeyStore_modified()
87 IKeyStoreClient client = mFactory.createKeyStoreClient(); in testLoadKeyStore_null() local
88 assertNotNull(client); in testLoadKeyStore_null()
92 assertSame(client, client2); in testLoadKeyStore_null()
/tools/loganalysis/tests/src/com/android/loganalysis/item/
DLocationDumpsItemTest.java71 LocationInfoItem client = item.getLocationClients().iterator().next(); in testGetLocationDumps() local
72 assertNotNull(client); in testGetLocationDumps()
73 assertEquals(client.getPackage(), "com.google.android.gms"); in testGetLocationDumps()
74 assertEquals(client.getEffectiveInterval(), 500); in testGetLocationDumps()
75 assertEquals(client.getMinInterval(), 60); in testGetLocationDumps()
76 assertEquals(client.getMaxInterval(), 1000); in testGetLocationDumps()
77 assertEquals(client.getPriority(), "PRIORITY_ACCURACY"); in testGetLocationDumps()
78 assertEquals(client.getDuration(), 45); in testGetLocationDumps()
/tools/loganalysis/tests/src/com/android/loganalysis/parser/
DLocationServiceParserTest.java66 LocationInfoItem client = locationClients.getLocationClients().iterator().next(); in testLocationClientParser() local
67 assertEquals(client.getPackage(), "com.google.android.gms"); in testLocationClientParser()
68 assertEquals(client.getEffectiveInterval(), 1); in testLocationClientParser()
69 assertEquals(client.getMinInterval(), 0); in testLocationClientParser()
70 assertEquals(client.getMaxInterval(), 0); in testLocationClientParser()
71 assertEquals(client.getPriority(), "PRIORITY_NO_POWER"); in testLocationClientParser()
72 assertEquals(client.getDuration(), 140); in testLocationClientParser()
/tools/tradefederation/core/src/com/android/tradefed/util/
DGoogleApiClientUtil.java22 import com.google.api.client.googleapis.auth.oauth2.GoogleCredential;
23 import com.google.api.client.googleapis.javanet.GoogleNetHttpTransport;
24 import com.google.api.client.http.HttpBackOffUnsuccessfulResponseHandler;
25 import com.google.api.client.http.HttpRequest;
26 import com.google.api.client.http.HttpRequestInitializer;
27 import com.google.api.client.http.HttpResponse;
28 import com.google.api.client.http.HttpUnsuccessfulResponseHandler;
29 import com.google.api.client.json.jackson2.JacksonFactory;
30 import com.google.api.client.util.ExponentialBackOff;
DBluetoothUtils.java213 Sl4aClient client = new Sl4aClient(device, sl4aApkFile); in enableBtsnoopLogging() local
214 return toggleBtsnoopLogging(client, true); in enableBtsnoopLogging()
245 Sl4aClient client = new Sl4aClient(device, sl4aApkFile); in disableBtsnoopLogging() local
246 return toggleBtsnoopLogging(client, false); in disableBtsnoopLogging()
249 public static boolean toggleBtsnoopLogging(Sl4aClient client, boolean onOff) in toggleBtsnoopLogging() argument
252 client.startSl4A(); in toggleBtsnoopLogging()
253 client.rpcCall(BTSNOOP_API, onOff); in toggleBtsnoopLogging()
259 client.close(); in toggleBtsnoopLogging()
DGCSCommon.java20 import com.google.api.client.googleapis.auth.oauth2.GoogleCredential;
21 import com.google.api.client.googleapis.javanet.GoogleNetHttpTransport;
22 import com.google.api.client.json.jackson2.JacksonFactory;
/tools/test/connectivity/acts/tests/google/wifi/rtt/functional/
DRangeSoftApTest.py50 client = self.android_devices[1]
51 client.pretty_name = "Client"
64 client, self.SOFT_AP_SSID)
65 scans = client.droid.wifiGetScanResults()
89 events = rutils.run_ranging(client, [scanned_softap],
/tools/test/connectivity/acts/framework/acts/controllers/sl4a_lib/
Drpc_client.py201 client = self._free_connections.pop()
202 self._working_connections.append(client)
203 return client
212 client = self._create_connection_func(self.uid)
213 self._working_connections.append(client)
214 return client
Dsl4a_session.py161 client = rpc_connection.RpcConnection(
163 client.open()
165 self.uid = client.uid
166 return client
/tools/tradefederation/core/tests/src/com/android/tradefed/util/sl4a/
DFakeSocketServerHelper.java52 Socket client = null; in run() local
56 client = mSocket.accept(); in run()
58 new InputStreamReader(client.getInputStream())); in run()
59 out = new PrintWriter(client.getOutputStream(), true); in run()
/tools/tradefederation/core/src/com/android/tradefed/command/
DCommandRunner.java83 ClearcutClient client = new ClearcutClient(); in run() local
84 Runtime.getRuntime().addShutdownHook(new TerminateClearcutClient(client)); in run()
85 client.notifyTradefedStartEvent(); in run()
88 mScheduler.setClearcutClient(client); in run()
/tools/tradefederation/core/remote/
DAndroid.mk19 DEST_JAR := $(HOST_OUT)/tradefed/tf-remote-client.jar
20 BUILT_JAR := $(call intermediates-dir-for,JAVA_LIBRARIES,tf-remote-client,HOST)/javalib.jar
25 $(HOST_OUT_JAVA_LIBRARIES)/tf-remote-client.jar : $(DEST_JAR)
/tools/tradefederation/core/src/com/android/tradefed/result/proto/
DStreamProtoReceiver.java135 Socket client = null; in run() local
138 client = mSocket.accept(); in run()
140 while ((received = TestRecord.parseDelimitedFrom(client.getInputStream())) in run()
/tools/tradefederation/core/clearcut_client/com/android/tradefed/clearcut/
DTerminateClearcutClient.java23 public TerminateClearcutClient(ClearcutClient client) { in TerminateClearcutClient() argument
24 mClient = client; in TerminateClearcutClient()

123