Home
last modified time | relevance | path

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

12

/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.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.py62 client): argument
89 self.Patch(client.service, "new_batch_http_request",
95 client = self._SetupInitMocks()
104 self._SetupBatchHttpRequestMock(responses, exceptions, client)
105 results = client.BatchExecute(
117 client.RETRY_COUNT + 1)
119 client.RETRY_COUNT + 1)
132 client = self._SetupInitMocks()
133 items = client.ListWithMultiPages(
140 client = self._SetupInitMocks()
[all …]
Dbase_cloud_client.py31 from oauth2client import client
62 RETRIABLE_AUTH_ERRORS = (client.AccessTokenRefreshError, )
/tools/test/connectivity/acts/framework/tests/controllers/bits_lib/
Dbits_client_test.py51 client = bits_client.BitsClient('bits.par', self.mock_service,
54 client.start_collection()
72 client = bits_client.BitsClient('bits.par', self.mock_service,
74 client._active_collection = self.mock_active_collection
76 client.stop_collection()
90 client = bits_client.BitsClient('bits.par', self.mock_service,
92 client._active_collection = self.mock_active_collection
94 client.stop_collection()
108 client = bits_client.BitsClient('bits.par', self.mock_service,
110 client._active_collection = self.mock_active_collection
[all …]
/tools/treble/fetcher/
Dfetcher_lib.py143 def fetch_artifact(client, build_id, target, resource_id, dest): argument
157 dl_req = client.buildartifact().get_media(
175 def get_build_list(client, **kwargs): argument
185 build_request = client.build().list(**kwargs)
190 def list_artifacts(client, regex, **kwargs): argument
204 req = client.buildartifact().list(**kwargs)
211 req = client.buildartifact().list_next(req, result)
215 def fetch_artifacts(client, out_dir, target, pattern, build_id): argument
231 client=client,
238 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/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_tests/acts_contrib/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/
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/asuite/atest/logstorage/
Dlogstorage_utils.py63 self.client = build(
71 return self.client.branch().list(maxResults=10000).execute()
75 return self.client.target().list(branch=branch,
98 return self.client.build().insert(buildType="local",
114 return self.client.buildattempt().insert(
135 return self.client.invocation().insert(body=invocation).execute()
145 return self.client.invocation().update(
160 return self.client.workunit().insert(body=workunit).execute()
/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/test/connectivity/acts_tests/tests/google/wifi/rtt/functional/
DRangeSoftApTest.py47 client = self.android_devices[1]
48 client.pretty_name = "Client"
61 client, self.SOFT_AP_SSID)
62 scans = client.droid.wifiGetScanResults()
86 events = rutils.run_ranging(client, [scanned_softap],
/tools/test/connectivity/acts_tests/acts_contrib/test_utils/tel/
Dtel_data_utils.py121 for client in client_list:
122 client.droid.telephonyToggleDataConnection(True)
123 set_wifi_to_default(log, client)
192 for client in client_list:
193 log.info("Client: {}".format(client.serial))
194 wifi_toggle_state(log, client, False)
195 client.droid.telephonyToggleDataConnection(False)
197 for client in client_list:
199 log, client, expected_state=False):
200 client.log.error("Turn off Data on client fail")
[all …]
Dtwilio_client.py46 self.client = Client(self.__account_sid, self.__auth_token)
47 self.call_handle = self.client.api.account.calls
/tools/test/connectivity/acts/framework/acts/controllers/fuchsia_lib/
Dhardware_power_statecontrol_lib.py69 http.client.RemoteDisconnected, base_lib.DeviceOffline):
89 http.client.RemoteDisconnected, base_lib.DeviceOffline):
109 http.client.RemoteDisconnected, base_lib.DeviceOffline):
129 http.client.RemoteDisconnected, base_lib.DeviceOffline):
/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.py165 client = rpc_connection.RpcConnection(self.adb,
170 client.open()
172 self.uid = client.uid
173 return client
/tools/test/connectivity/acts_tests/tests/google/coex/config/
Dsample_config.json10 // Iperf client controller, this specifies where you want to run the iperf client
/tools/asuite/atest/test_runners/
Datest_tf_test_runner.py213 client = logstorage_utils.BuildClient(creds)
214 branch = self._get_branch(client)
215 target = self._get_target(branch, client)
216 build_record = client.insert_local_build(external_id,
219 client.insert_build_attempts(build_record)
220 invocation = client.insert_invocation(build_record)
221 workunit = client.insert_work_unit(invocation)
/tools/carrier_settings/proto/
Dcarrier_settings.proto192 // The configs of one vendor client.
194 // Name of the client for which the configuration items need to
199 // of the configuration depends on the specific client.
214 repeated VendorConfigClient client = 2; field
/tools/metalava/src/test/java/com/android/tools/metalava/apilevels/
DApiGeneratorTest.kt101 val client = object : LintCliClient() { in Extract API levels() constant
114 val apiLookup = ApiLookup.get(client) in Extract API levels()
/tools/treble/hacksaw/client/
Dclient_test.go15 package client package

12