Home
last modified time | relevance | path

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

123456

/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/tradefederation/core/javatests/com/android/tradefed/util/keystore/
DJSONFileKeyStoreFactoryTest.java75 IKeyStoreClient client = mFactory.createKeyStoreClient(); in testLoadKeyStore_same() local
76 assertNotNull(client); in testLoadKeyStore_same()
78 assertSame(client, client2); in testLoadKeyStore_same()
86 IKeyStoreClient client = mFactory.createKeyStoreClient(); in testLoadKeyStore_modified() local
87 assertNotNull(client); in testLoadKeyStore_modified()
91 assertNotSame(client, client2); in testLoadKeyStore_modified()
102 IKeyStoreClient client = mFactory.createKeyStoreClient(); in testLoadKeyStore_null() local
103 assertNotNull(client); in testLoadKeyStore_null()
107 assertSame(client, client2); in testLoadKeyStore_null()
119 IKeyStoreClient client = mFactory.createKeyStoreClient(); in testLoadKeyStore_primaryFileModified() local
[all …]
/tools/acloud/internal/lib/
Dandroid_build_client_test.py50 self.client = android_build_client.AndroidBuildClient(mock.MagicMock())
51 self.client._service = mock.MagicMock()
70 self.client._service.buildartifact = mock.MagicMock(
74 self.client.DownloadArtifact(self.BUILD_TARGET, self.BUILD_ID,
94 self.assertRaises(errors.DriverError, self.client.DownloadArtifact,
101 self.client._service.buildartifact = mock.MagicMock(
103 self.client.CopyTo(
112 attemptId=self.client.DEFAULT_ATTEMPT_ID,
123 self.client._service.buildartifact.return_value = mock_resource
128 self.client.CopyTo,
[all …]
Dgstorage_client_test.py30 self.client = gstorage_client.StorageClient(mock.MagicMock())
31 self.client._service = mock.MagicMock()
37 self.client._service.objects = mock.MagicMock(
40 self.client.Get(self.BUCKET, self.OBJECT)
53 self.client._service.objects = mock.MagicMock(
55 items = self.client.List(self.BUCKET, self.OBJECT)
56 self.client.ListWithMultiPages.assert_called_once_with(
76 self.client._service.objects = mock.MagicMock(
82 response = self.client.Upload(self.LOCAL_SRC, self.BUCKET, self.OBJECT,
96 self.assertRaises(errors.DriverError, self.client.Upload,
[all …]
Dbase_cloud_client_test.py63 client): argument
90 self.Patch(client.service, "new_batch_http_request",
96 client = self._SetupInitMocks()
105 self._SetupBatchHttpRequestMock(responses, exceptions, client)
106 results = client.BatchExecute(
118 client.RETRY_COUNT + 1)
120 client.RETRY_COUNT + 1)
133 client = self._SetupInitMocks()
134 items = client.ListWithMultiPages(
141 client = self._SetupInitMocks()
[all …]
Dremote_host_client_test.py33 client = remote_host_client.RemoteHostClient(self._IP_ADDRESS)
34 ip_addr = client.GetInstanceIP("name")
40 client = remote_host_client.RemoteHostClient(self._IP_ADDRESS)
41 self.assertFalse(client.execution_time)
45 self.assertEqual(1.0, client.RecordTime("TIME", 0.25))
46 self.assertDictEqual({"TIME": 0.75}, client.execution_time)
/tools/netsim/testing/mobly/
Dble_utils.py327 client: android_device.AndroidDevice, server: android_device.AndroidDevice
358 client.client_callback = client.mbs.bleConnectGatt(client.connect_to_address)
359 start_client_result = client.client_callback.waitAndGet(
362 extra_events = client.client_callback.getAll('onConnectionStateChange')
370 client.log.info('BLE client connected')
386 client: android_device.AndroidDevice, server: android_device.AndroidDevice
401 client.mbs.bleDisconnect()
402 stop_client_result = client.client_callback.waitAndGet(
407 client.log.info('BLE client disconnected')
412 def DiscoverServices(client: android_device.AndroidDevice) -> None:
[all …]
/tools/test/connectivity/acts/framework/tests/controllers/bits_lib/
Dbits_client_test.py61 client = bits_client.BitsClient('bits.par', mock_service,
64 client.run_cmd('-i', '-am', '-not', '-a', '-teapot', timeout=12345)
80 client = bits_client.BitsClient('bits.par', self.mock_service,
83 client.start_collection('collection')
95 client = bits_client.BitsClient('bits.par', self.mock_service,
98 client.start_collection('collection', default_sampling_rate=12345)
110 client = bits_client.BitsClient('bits.par', self.mock_service,
113 client.start_collection('collection')
126 client = bits_client.BitsClient('bits.par', self.mock_service,
129 client.stop_collection('collection')
[all …]
/tools/treble/fetcher/
Dfetcher_lib.py144 def fetch_artifact(client, build_id, target, resource_id, dest): argument
158 dl_req = client.buildartifact().get_media(
176 def get_build_list(client, **kwargs): argument
186 build_request = client.build().list(**kwargs)
191 def list_artifacts(client, regex, **kwargs): argument
204 req = client.buildartifact().list(nameRegexp=regex, **kwargs)
210 req = client.buildartifact().list_next(req, result)
214 def fetch_artifacts(client, out_dir, target, pattern, build_id): argument
230 client=client,
237 client=client,
[all …]
Dfetcher.py41 client = fetcher_lib.create_client_from_json_keyfile(
45 client=client, branch=args.branch,
50 client=client,
58 client=client,
/tools/tradefederation/core/src/com/android/tradefed/util/
DRestApiHelper.java18 import com.google.api.client.auth.oauth2.Credential;
19 import com.google.api.client.googleapis.javanet.GoogleNetHttpTransport;
20 import com.google.api.client.http.ByteArrayContent;
21 import com.google.api.client.http.GenericUrl;
22 import com.google.api.client.http.HttpBackOffIOExceptionHandler;
23 import com.google.api.client.http.HttpContent;
24 import com.google.api.client.http.HttpRequest;
25 import com.google.api.client.http.HttpRequestFactory;
26 import com.google.api.client.http.HttpRequestInitializer;
27 import com.google.api.client.http.HttpResponse;
[all …]
DSl4aBluetoothUtil.java233 void setSl4a(ITestDevice device, Sl4aClient client) { in setSl4a() argument
234 mSl4aClients.put(device.getSerialNumber(), client); in setSl4a() local
276 Sl4aClient client = getSl4aClient(device); in getAddress() local
279 address = (String) client.rpcCall(Commands.BLUETOOTH_GET_LOCAL_ADDRESS); in getAddress()
298 Sl4aClient client = getSl4aClient(device); in getBondedDevices() local
300 Object response = client.rpcCall(Commands.BLUETOOTH_GET_BONDED_DEVICES); in getBondedDevices()
372 Sl4aClient client = getSl4aClient(device); in unpairAll() local
375 Boolean res = (Boolean) client.rpcCall(Commands.BLUETOOTH_UNBOND, address); in unpairAll()
579 Sl4aClient client = getSl4aClient(device); in toggleState() local
581 boolean currentState = (Boolean) client.rpcCall(Commands.BLUETOOTH_CHECK_STATE); in toggleState()
[all …]
/tools/test/connectivity/acts_tests/acts_contrib/test_utils/net/
Dsocket_test_utils.py58 def listen_accept_android_socket(client, server, client_fd, server_fd, argument
71 client.droid.connectSocket(client_fd, server_ip, server_port)
77 def send_recv_data_android_sockets(client, server, client_fd, server_fd, argument
96 client.log.info("Sending message: %s" % msg)
97 client.droid.sendDataOverSocket(server_ip, server_port, msg, client_fd)
137 def send_recv_data_datagram_sockets(client, server, client_sock, server_sock, argument
156 client.log.info("Sending message: %s" % msg)
157 client.droid.sendDataOverDatagramSocket(client_sock, msg, server_ip,
177 def _client_socket(client, server_ip, server_port, client_ip, client_port, q): argument
179 sock = client.droid.openTcpSocket(server_ip, server_port, client_ip,
[all …]
/tools/apksig/src/test/java/com/android/apksig/kms/gcp/
DGcpTestData.java40 try (KeyRingClient client = new KeyRingClient(KEY_RING_NAME)) { in getCryptoKeyVersionName() argument
41 return client.findCryptoKeyVersion(cryptoKeyId) in getCryptoKeyVersionName()
49 try (KeyRingClient client = new KeyRingClient(KEY_RING_NAME)) { in main() argument
50 client.createKeyRing(); in main()
51 importRsa2048Sha256(client, FIRST_RSA_2048_SIGNER_RESOURCE_NAME); in main()
52 importRsa2048Sha256(client, SECOND_RSA_2048_SIGNER_RESOURCE_NAME); in main()
53 importRsa2048Sha256(client, THIRD_RSA_2048_SIGNER_RESOURCE_NAME); in main()
57 private static void importRsa2048Sha256(KeyRingClient client, String privateKeyNameInResources) in importRsa2048Sha256() argument
60 client.createCryptoKeyForImport( in importRsa2048Sha256()
64 ImportJob importJob = client.createImportJob(cryptoKey.getName()); in importRsa2048Sha256()
[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.py18 import xmlrpc.client
107 self.client = xmlrpc.client.ServerProxy(self.address,
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)
/tools/test/connectivity/acts_tests/acts_contrib/test_utils/abstract_devices/
Dwmm_transceiver.py231 (client, server_ip,
239 client,
267 (client, server_ip,
273 'client': client,
296 client = pending_stream_config['client']
305 uuid, client, server_ip,
389 client, argument
425 if type(client) == iperf_client.IPerfClientOverSsh:
427 client.start_ssh()
454 path = client.start(server_ip, iperf_flags, '%s' % uuid)
[all …]
/tools/asuite/atest/logstorage/
Dlogstorage_utils.py29 from oauth2client import client as oauth2_client
124 self.client = build(
134 return self.client.branch().list(maxResults=10000).execute()
138 return self.client.target().list(branch=branch, maxResults=10000).execute()
148 query_branch = self.client.branch().get(resourceId=branch).execute()
172 return self.client.build().insert(buildType='local', body=body).execute()
185 self.client.buildattempt()
228 return self.client.invocation().insert(body=invocation).execute()
245 self.client.invocation()
264 self.client.invocation()
[all …]
/tools/test/connectivity/acts_tests/tests/google/fuchsia/wlan/functional/
DSoftApTest.py194 for client in self.clients:
195 client.disconnect()
196 client.reset_wifi()
197 client.wifi_toggle_state(True)
204 for client in self.clients:
205 client.disconnect()
498 client, argument
520 client, INTERFACE_ROLE_CLIENT)
525 client_ipv4 = self.wait_for_ipv4_address(client,
536 if not self.device_can_ping_addr(client, ap_ipv4):
[all …]
/tools/test/mobly_extensions/tools/results_uploader/src/
Dresults_uploader.py273 client = resultstore_client.ResultstoreClient(service, creds, project_id)
274 client.create_invocation()
275 client.create_default_configuration()
276 client.create_target(target_id)
277 client.create_configured_target()
278 client.create_action(f'gs://{gcs_bucket}/{gcs_dir}', file_paths)
279 client.set_status(status)
280 client.merge_configured_target()
281 client.finalize_configured_target()
282 client.merge_target()
[all …]
/tools/netsim/rust/proto/src/
Dfrontend_grpc.rs118 pub client: ::grpcio::Client, field
123 FrontendServiceClient { client: ::grpcio::Client::new(channel) } in new()
131 self.client.unary_call(&METHOD_FRONTEND_SERVICE_GET_VERSION, req, opt) in get_version_opt()
146 self.client.unary_call_async(&METHOD_FRONTEND_SERVICE_GET_VERSION, req, opt) in get_version_async_opt()
161 self.client.unary_call(&METHOD_FRONTEND_SERVICE_CREATE_DEVICE, req, opt) in create_device_opt()
177 self.client.unary_call_async(&METHOD_FRONTEND_SERVICE_CREATE_DEVICE, req, opt) in create_device_async_opt()
193 self.client.unary_call(&METHOD_FRONTEND_SERVICE_DELETE_CHIP, req, opt) in delete_chip_opt()
208 self.client.unary_call_async(&METHOD_FRONTEND_SERVICE_DELETE_CHIP, req, opt) in delete_chip_async_opt()
223 self.client.unary_call(&METHOD_FRONTEND_SERVICE_PATCH_DEVICE, req, opt) in patch_device_opt()
238 self.client.unary_call_async(&METHOD_FRONTEND_SERVICE_PATCH_DEVICE, req, opt) in patch_device_async_opt()
[all …]
/tools/netsim/rust/cli/src/
Dlib.rs45 client: &cxx::UniquePtr<FrontendClient>, in perform_streaming_request()
57 client.get_capture( in perform_streaming_request()
73 client: cxx::UniquePtr<FrontendClient>, in perform_command()
80 command.get_requests(&client) in perform_command()
93 continuous_perform_command(command, &client, grpc_method, req, verbose)? in perform_command()
96 continuous_perform_command(command, &client, grpc_method, req, verbose)? in perform_command()
100 perform_streaming_request(&client, cmd, req, &cmd.filenames[i].to_owned()) in perform_command()
103 let devices = client.send_grpc(&GrpcMethod::ListDevice, req); in perform_command()
109 client.send_grpc(&grpc_method, req) in perform_command()
112 _ => client.send_grpc(&grpc_method, req), in perform_command()
[all …]
/tools/loganalysis/javatests/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/javatests/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/treble/gki/
Drepack_gki_lib.py10 def fetch_bootimg(client, out_dir, build_id, kernel_version, target): argument
13 client=client,
21 def fetch_kernel(client, out_dir, build_id, kernel_target, kernel_debug_target): argument
29 client=client,
35 client=client,

123456