| /packages/services/Car/tests/carservice_test/src/com/android/car/vms/ |
| D | VmsClientTest.java | 105 VmsClient client = connectVmsClient(mClientCallback1); in testRegister() local
108 assertThat(client.getAvailableLayers()).isEqualTo(DEFAULT_AVAILABLE_LAYERS); in testRegister()
109 assertThat(client.getSubscriptionState()).isEqualTo(DEFAULT_SUBSCRIPTION_STATE); in testRegister()
116 VmsClient client = connectVmsClient(mClientCallback1); in testRegister_ReceivesCurrentLayerAvailabilityAndSubscriptions() local
117 int providerId = client.registerProvider(PROVIDER_DESC1); in testRegister_ReceivesCurrentLayerAvailabilityAndSubscriptions()
118 client.setProviderOfferings(providerId, asSet( in testRegister_ReceivesCurrentLayerAvailabilityAndSubscriptions()
120 client.setSubscriptions(asSet( in testRegister_ReceivesCurrentLayerAvailabilityAndSubscriptions()
143 VmsClient client = connectVmsClient(mClientCallback1); in testRegisterProvider_SameIdForSameInfo() local
145 int providerId = client.registerProvider(PROVIDER_DESC1); in testRegisterProvider_SameIdForSameInfo()
146 int providerId2 = client.registerProvider(PROVIDER_DESC1); in testRegisterProvider_SameIdForSameInfo()
[all …]
|
| /packages/apps/Bluetooth/src/com/android/bluetooth/gatt/ |
| D | ScanManager.java | 222 for (ScanClient client : mBatchClients) { in getFullBatchScanQueue()
223 if (client.settings.getScanResultType() == ScanSettings.SCAN_RESULT_TYPE_FULL) { in getFullBatchScanQueue()
224 fullBatchClients.add(client); in getFullBatchScanQueue()
230 void startScan(ScanClient client) { in startScan() argument
231 sendMessage(MSG_START_BLE_SCAN, client); in startScan()
235 ScanClient client = mScanNative.getBatchScanClient(scannerId); in stopScan() local
236 if (client == null) { in stopScan()
237 client = mScanNative.getRegularScanClient(scannerId); in stopScan()
239 sendMessage(MSG_STOP_BLE_SCAN, client); in stopScan()
242 void flushBatchScanResults(ScanClient client) { in flushBatchScanResults() argument
[all …]
|
| /packages/modules/adb/pairing_auth/tests/ |
| D | pairing_auth_test.cpp | 52 PairingAuthUniquePtr client(nullptr, PairingAuthDeleter); in TEST_F() local
55 client = PairingAuthUniquePtr(pairing_auth_client_new(nullptr, 0), in TEST_F()
61 client = PairingAuthUniquePtr(pairing_auth_client_new(nullptr, 2), in TEST_F()
68 client = PairingAuthUniquePtr(pairing_auth_client_new(&p, 0), PairingAuthDeleter); in TEST_F()
76 auto client = makeClient(pswd); in TEST_F() local
79 ASSERT_NE(nullptr, client); in TEST_F()
84 size_t msg_size = pairing_auth_msg_size(client.get()); in TEST_F()
87 pairing_auth_get_spake2_msg(client.get(), buf.data()); in TEST_F()
143 auto client = makeClient({0x01, 0x02, 0x03}); in TEST_F() local
144 std::vector<uint8_t> client_msg(pairing_auth_msg_size(client.get())); in TEST_F()
[all …]
|
| /packages/services/Car/service/src/com/android/car/vms/ |
| D | VmsBrokerService.java | 123 .forEach(client -> client.dump(writer, " ")); in dump()
187 VmsClientInfo client = getClient(clientToken); in registerProvider() local
192 client.addProviderId(providerId); in registerProvider()
200 VmsClientInfo client = getClient(clientToken); in setProviderOfferings() local
201 if (!client.hasProviderId(providerId) && !client.isLegacyClient()) { in setProviderOfferings()
205 if (client.setProviderOfferings(providerId, offerings)) { in setProviderOfferings()
229 VmsClientInfo client = getClient(clientToken); in deliverToSubscribers() local
230 if (!client.hasOffering(providerId, layer) && !client.isLegacyClient()) { in deliverToSubscribers()
235 mStatsService.getVmsClientLogger(client.getUid()) in deliverToSubscribers()
268 VmsClientInfo client; in unregisterClient() local
[all …]
|
| /packages/apps/DocumentsUI/tests/functional/com/android/documentsui/ |
| D | ArchivesProviderTest.java | 83 try (ContentProviderClient client = resolver.acquireUnstableContentProviderClient( in testQueryRoots() argument
85 Cursor cursor = client.query(rootsUri, null, null, null, null, null); in testQueryRoots()
104 final ContentProviderClient client = resolver.acquireUnstableContentProviderClient( in testOpen_Success() local
106 ArchivesProvider.acquireArchive(client, archiveUri); in testOpen_Success()
139 ArchivesProvider.releaseArchive(client, archiveUri); in testOpen_Success()
140 client.release(); in testOpen_Success()
156 final ContentProviderClient client = resolver.acquireUnstableContentProviderClient( in testOpen_Failure() local
158 ArchivesProvider.acquireArchive(client, archiveUri); in testOpen_Failure()
192 ArchivesProvider.releaseArchive(client, archiveUri); in testOpen_Failure()
193 client.release(); in testOpen_Failure()
[all …]
|
| /packages/services/Telephony/testapps/TestRcsApp/aosp_test_rcsclient/javatests/com/android/libraries/rcs/simpleclient/provisioning/ |
| D | StaticConfigProvisioningControllerTest.java | 38 private StaticConfigProvisioningController client; field in StaticConfigProvisioningControllerTest
45 client = StaticConfigProvisioningController.createForSubscriptionId(/*subscriptionId=*/ 2); in setUp()
46 client.onConfigurationChange(cb); in setUp()
52 client.register(); in whenGetConfigCalled_returnsCorrectXmlData()
53 client.getProvisioningManager().getCallbackForTests().onConfigurationChanged(CONFIG_DATA); in whenGetConfigCalled_returnsCorrectXmlData()
55 assertThat(client.isRcsVolteSingleRegistrationCapable()).isTrue(); in whenGetConfigCalled_returnsCorrectXmlData()
56 assertThat(client.getLatestConfiguration()).isEqualTo(CONFIG_DATA); in whenGetConfigCalled_returnsCorrectXmlData()
58 client.unRegister(); in whenGetConfigCalled_returnsCorrectXmlData()
64 client.register(); in whenGetConfigCalled_throwsErrorWhenNoConfigPresent()
65 client.triggerReconfiguration(); in whenGetConfigCalled_throwsErrorWhenNoConfigPresent()
[all …]
|
| /packages/services/Car/cpp/evs/manager/1.1/ |
| D | HalCamera.cpp | 51 sp<VirtualCamera> client = new VirtualCamera(sourceCameras); in makeVirtualCamera() local
52 if (client == nullptr) { in makeVirtualCamera()
57 if (!ownVirtualCamera(client)) { in makeVirtualCamera()
59 client = nullptr; in makeVirtualCamera()
62 return client; in makeVirtualCamera()
118 for (auto&& client : mClients) { in changeFramesInFlight()
119 sp<VirtualCamera> virtCam = client.promote(); in changeFramesInFlight()
169 for (auto&& client : mClients) { in changeFramesInFlight()
170 sp<VirtualCamera> virtCam = client.promote(); in changeFramesInFlight()
211 void HalCamera::requestNewFrame(sp<VirtualCamera> client, in requestNewFrame() argument
[all …]
|
| /packages/apps/Bluetooth/src/com/android/bluetooth/avrcpcontroller/ |
| D | AvrcpCoverArtManager.java | 161 AvrcpBipClient client = new AvrcpBipClient(device, psm, new BipClientCallback(device)); in connect()
162 mClients.put(device, client); in connect()
175 AvrcpBipClient client = getClient(device); in refreshSession() local
176 if (client == null) { in refreshSession()
180 client.refreshSession(); in refreshSession()
192 AvrcpBipClient client = getClient(device); in disconnect() local
193 if (client == null) { in disconnect()
197 client.shutdown(); in disconnect()
223 AvrcpBipClient client = getClient(device); in getState() local
224 if (client == null) return BluetoothProfile.STATE_DISCONNECTED; in getState()
[all …]
|
| /packages/services/Car/service/src/com/android/car/watchdog/ |
| D | WatchdogProcessHandler.java | 131 public void registerClient(ICarWatchdogServiceCallback client, int timeout) { in registerClient() argument
138 IBinder binder = client.asBinder(); in registerClient()
141 if (binder == clientInfo.client.asBinder()) { in registerClient()
150 ClientInfo clientInfo = new ClientInfo(client, pid, userId, timeout); in registerClient()
166 public void unregisterClient(ICarWatchdogServiceCallback client) { in unregisterClient() argument
168 IBinder binder = client.asBinder(); in unregisterClient()
173 if (binder != clientInfo.client.asBinder()) { in unregisterClient()
192 public void tellClientAlive(ICarWatchdogServiceCallback client, int sessionId) { in tellClientAlive() argument
200 if (clientInfo != null && clientInfo.client.asBinder() == client.asBinder()) { in tellClientAlive()
243 private void onClientDeath(ICarWatchdogServiceCallback client, int timeout) { in onClientDeath() argument
[all …]
|
| /packages/apps/TvSettings/Settings/src/com/android/tv/settings/util/bluetooth/ |
| D | BluetoothScanner.java | 257 ClientRecord client = mClients.get(ptr); in stopListening() local
258 if (client.listener == listener) { in stopListening()
327 ClientRecord client = mClients.get(ptr); in removeDevice() local
328 for (int devPtr = client.devices.size() - 1; devPtr > -1; devPtr--) { in removeDevice()
329 Device d = client.devices.get(devPtr); in removeDevice()
331 client.devices.remove(devPtr); in removeDevice()
482 ClientRecord client = mClients.get(i); in sendScanningStopped() local
483 client.listener.onScanningStopped(client.devices); in sendScanningStopped()
491 ClientRecord client = mClients.get(ptr); in sendDeviceAdded() local
492 for (BluetoothDeviceCriteria matcher : client.matchers) { in sendDeviceAdded()
[all …]
|
| /packages/services/Car/cpp/watchdog/server/tests/ |
| D | WatchdogProcessServiceTest.cpp | 76 sp<MockCarWatchdogClient> client = new MockCarWatchdogClient(); in createMockCarWatchdogClient() local
77 sp<MockBinder> binder = client->getBinder(); in createMockCarWatchdogClient()
80 EXPECT_CALL(*client, onAsBinder()).WillRepeatedly(Return(binder.get())); in createMockCarWatchdogClient()
81 return client; in createMockCarWatchdogClient()
110 sp<MockCarWatchdogClient> client = expectNormalCarWatchdogClient(); in TEST_F() local
112 mWatchdogProcessService->registerClient(client, TimeoutLength::TIMEOUT_CRITICAL); in TEST_F()
114 status = mWatchdogProcessService->registerClient(client, TimeoutLength::TIMEOUT_CRITICAL); in TEST_F()
119 sp<MockCarWatchdogClient> client = expectNormalCarWatchdogClient(); in TEST_F() local
120 mWatchdogProcessService->registerClient(client, TimeoutLength::TIMEOUT_CRITICAL); in TEST_F()
121 Status status = mWatchdogProcessService->unregisterClient(client); in TEST_F()
[all …]
|
| /packages/modules/adb/client/pairing/tests/ |
| D | pairing_connection_test.cpp | 163 auto client = PairingClient::create({}, client_info_, {}, {}, ""); in TEST_F() local
164 EXPECT_EQ(nullptr, client); in TEST_F()
166 client = PairingClient::create({}, client_info_, {0x01}, {0x01}, "127.0.0.1"); in TEST_F()
167 EXPECT_EQ(nullptr, client); in TEST_F()
169 client = PairingClient::create({0x01}, {}, {0x01}, {0x01}, "127.0.0.1"); in TEST_F()
170 EXPECT_EQ(nullptr, client); in TEST_F()
172 client = PairingClient::create({0x01}, client_info_, {}, {0x01}, "127.0.0.1"); in TEST_F()
173 EXPECT_EQ(nullptr, client); in TEST_F()
175 client = PairingClient::create({0x01}, client_info_, {0x01}, {}, "127.0.0.1"); in TEST_F()
176 EXPECT_EQ(nullptr, client); in TEST_F()
[all …]
|
| /packages/modules/Connectivity/Tethering/src/com/android/networkstack/tethering/ |
| D | ConnectedClientsTracker.java | 91 for (TetheredClient client : server.getAllLeases()) { in updateConnectedClients()
92 if (client.getTetheringType() == TETHERING_WIFI in updateConnectedClients()
93 && !wifiClientMacs.contains(client.getMacAddress())) { in updateConnectedClients()
97 final TetheredClient prunedClient = pruneExpired(client, now); in updateConnectedClients()
107 for (MacAddress client : wifiClientMacs) { in updateConnectedClients()
108 if (clientsMap.containsKey(client)) continue; in updateConnectedClients()
109 clientsMap.put(client, new TetheredClient( in updateConnectedClients()
110 client, Collections.emptyList() /* addresses */, TETHERING_WIFI)); in updateConnectedClients()
157 private static TetheredClient pruneExpired(TetheredClient client, long now) { in pruneExpired() argument
158 final List<AddressInfo> addresses = client.getAddresses(); in pruneExpired()
[all …]
|
| /packages/services/Car/cpp/evs/manager/1.0/ |
| D | HalCamera.cpp | 38 sp<VirtualCamera> client = new VirtualCamera(this); in makeVirtualCamera() local
39 if (client == nullptr) { in makeVirtualCamera()
45 if (!changeFramesInFlight(client->getAllowedBuffers())) { in makeVirtualCamera()
48 client = nullptr; in makeVirtualCamera()
53 mClients.push_back(client); in makeVirtualCamera()
56 return client; in makeVirtualCamera()
88 for (auto&& client : mClients) { in changeFramesInFlight()
89 sp<VirtualCamera> virtCam = client.promote(); in changeFramesInFlight()
144 for (auto&& client : mClients) { in clientStreamEnding()
145 sp<VirtualCamera> virtCam = client.promote(); in clientStreamEnding()
[all …]
|
| /packages/modules/adb/ |
| D | Android.bp | 265 "client/openscreen/mdns_service_info.cpp",
266 "client/openscreen/mdns_service_watcher.cpp",
267 "client/openscreen/platform/logging.cpp",
268 "client/openscreen/platform/task_runner.cpp",
269 "client/openscreen/platform/udp_socket.cpp",
270 "client/auth.cpp",
271 "client/adb_wifi.cpp",
272 "client/usb_libusb.cpp",
273 "client/transport_local.cpp",
274 "client/mdnsresponder_client.cpp",
[all …]
|
| D | transport_benchmark.cpp | 61 auto client = MakeConnection<ConnectionType>(unique_fd(fds[0])); in BM_Connection_Unidirectional() local
66 client->SetReadCallback([](Connection*, std::unique_ptr<apacket>) -> bool { return true; }); in BM_Connection_Unidirectional()
72 client->SetErrorCallback( in BM_Connection_Unidirectional()
77 client->Start(); in BM_Connection_Unidirectional()
91 client->Write(std::move(packet)); in BM_Connection_Unidirectional()
98 client->Stop(); in BM_Connection_Unidirectional()
116 auto client = MakeConnection<ConnectionType>(unique_fd(fds[0])); in BM_Connection_Echo() local
124 … client->SetReadCallback([&received_bytes](Connection*, std::unique_ptr<apacket> packet) -> bool { in BM_Connection_Echo()
146 client->SetErrorCallback( in BM_Connection_Echo()
151 client->Start(); in BM_Connection_Echo()
[all …]
|
| /packages/services/Car/car-lib/src/android/car/vms/ |
| D | VmsClientManager.java | 57 void onClientConnected(@NonNull VmsClient client); in onClientConnected() argument
122 VmsClient client; in registerVmsClientCallback() local
129 client = new VmsClient(mBrokerService, executor, callback, legacyClient, in registerVmsClientCallback()
132 mClients.put(callback, client); in registerVmsClientCallback()
138 client.register(); in registerVmsClientCallback()
150 callback.onClientConnected(client); in registerVmsClientCallback()
152 callback.onLayerAvailabilityChanged(client.getAvailableLayers()); in registerVmsClientCallback()
153 callback.onSubscriptionStateChanged(client.getSubscriptionState()); in registerVmsClientCallback()
167 VmsClient client; in unregisterVmsClientCallback() local
169 client = mClients.remove(callback); in unregisterVmsClientCallback()
[all …]
|
| D | VmsClient.java | 303 private IVmsClientCallbackImpl(VmsClient client, boolean autoCloseMemory) { in IVmsClientCallbackImpl() argument
304 mClient = new WeakReference<>(client); in IVmsClientCallbackImpl()
311 executeCallback((client, callback) -> { in onLayerAvailabilityChanged() argument
312 synchronized (client.mLock) { in onLayerAvailabilityChanged()
313 client.mAvailableLayers = availableLayers; in onLayerAvailabilityChanged()
322 executeCallback((client, callback) -> { in onSubscriptionStateChanged() argument
323 synchronized (client.mLock) { in onSubscriptionStateChanged()
324 client.mSubscriptionState = subscriptionState; in onSubscriptionStateChanged()
336 executeCallback((client, callback) -> in onPacketReceived()
354 executeCallback((client, callback) -> in onLargePacketReceived()
[all …]
|
| /packages/services/Car/tests/BugReportApp/libs/ |
| D | Android.bp | 20 name: "car-br-google-api-java-client-jar",
21 jars: ["google-api-client-1.30.2.jar"],
26 name: "car-br-google-api-client-android-jar",
27 jars: ["google-api-client-android-1.30.2.jar"],
38 name: "car-br-google-oauth-client-jar",
39 jars: ["google-oauth-client-1.30.1.jar"],
44 name: "car-br-google-http-client-jar",
45 jars: ["google-http-client-1.30.1.jar"],
50 name: "car-br-google-http-client-android-jar",
51 jars: ["google-http-client-android-1.30.1.jar"],
[all …]
|
| /packages/services/Car/service/src/com/android/car/ |
| D | CarPropertyService.java | 234 Client client = mClientMap.get(listenerBinder); in registerListener() local
235 if (client == null) { in registerListener()
236 client = new Client(listener); in registerListener()
238 client.addProperty(propId, rate); in registerListener()
245 if (!clients.contains(client)) { in registerListener()
246 clients.add(client); in registerListener()
256 finalClient = client; in registerListener()
264 private void getAndDispatchPropertyInitValue(CarPropertyConfig config, Client client) { in getAndDispatchPropertyInitValue() argument
285 client.getListener().onEvent(events); in getAndDispatchPropertyInitValue()
311 Client client = mClientMap.get(listenerBinder); in unregisterListenerBinderLocked() local
[all …]
|
| D | CarProjectionService.java | 419 ProjectionReceiverClient client = getOrCreateProjectionReceiverClientLocked(token); in updateProjectionStatus() local
420 client.mProjectionStatus = status; in updateProjectionStatus()
457 ProjectionReceiverClient client; in getOrCreateProjectionReceiverClientLocked() local
458 client = mProjectionReceiverClients.get(token); in getOrCreateProjectionReceiverClientLocked()
459 if (client == null) { in getOrCreateProjectionReceiverClientLocked()
460 client = new ProjectionReceiverClient(() -> unregisterProjectionReceiverClient(token)); in getOrCreateProjectionReceiverClientLocked()
461 token.linkToDeath(client.mDeathRecipient, 0 /* flags */); in getOrCreateProjectionReceiverClientLocked()
462 mProjectionReceiverClients.put(token, client); in getOrCreateProjectionReceiverClientLocked()
464 return client; in getOrCreateProjectionReceiverClientLocked()
469 ProjectionReceiverClient client = mProjectionReceiverClients.remove(token); in unregisterProjectionReceiverClient() local
[all …]
|
| /packages/inputmethods/LatinIME/tests/src/com/android/inputmethod/latin/network/ |
| D | BlockingHttpClientTests.java | 65 final BlockingHttpClient client = new BlockingHttpClient(mMockHttpConnection); in testError_badGateway() local
69 client.execute(null /* empty request */, processor); in testError_badGateway()
81 final BlockingHttpClient client = new BlockingHttpClient(mMockHttpConnection); in testError_clientTimeout() local
85 client.execute(null /* empty request */, processor); in testError_clientTimeout()
98 final BlockingHttpClient client = new BlockingHttpClient(mMockHttpConnection); in testError_forbiddenWithRequest() local
102 client.execute(new byte[100], processor); in testError_forbiddenWithRequest()
117 final BlockingHttpClient client = new BlockingHttpClient(mMockHttpConnection); in testSuccess_emptyRequest() local
121 client.execute(null /* empty request */, processor); in testSuccess_emptyRequest()
134 final BlockingHttpClient client = new BlockingHttpClient(mMockHttpConnection); in testSuccess() local
138 client.execute(new byte[100], processor); in testSuccess()
|
| /packages/modules/Wifi/service/java/com/android/server/wifi/aware/ |
| D | WifiAwareStateManager.java | 602 WifiAwareClientState client = mClients.valueAt(i); in requestMacAddresses() local
603 if (client.getUid() != uid) { in requestMacAddresses()
607 SparseArray<WifiAwareDiscoverySessionState> sessions = client.getSessions(); in requestMacAddresses()
2410 WifiAwareClientState client = new WifiAwareClientState(mContext, clientId, uid, pid, in connectLocal() local
2413 client.enableVerboseLogging(mDbg); in connectLocal()
2414 client.onInterfaceAddressChange(mCurrentDiscoveryInterfaceMac); in connectLocal()
2415 mClients.append(clientId, client); in connectLocal()
2451 WifiAwareClientState client = mClients.get(clientId); in disconnectLocal() local
2452 if (client == null) { in disconnectLocal()
2457 mAwareMetrics.recordAttachSessionDuration(client.getCreationTime()); in disconnectLocal()
[all …]
|
| /packages/services/Car/car-lib/src/android/car/watchdog/ |
| D | CarWatchdogManager.java | 186 @NonNull CarWatchdogClientCallback client, @TimeoutLengthEnum int timeout) { in registerClient() argument
187 Objects.requireNonNull(client, "Client must be non-null"); in registerClient()
190 if (mRegisteredClient == client) { in registerClient()
197 mRegisteredClient = client; in registerClient()
222 public void unregisterClient(@NonNull CarWatchdogClientCallback client) { in unregisterClient() argument
223 Objects.requireNonNull(client, "Client must be non-null"); in unregisterClient()
225 if (mRegisteredClient != client) { in unregisterClient()
254 public void tellClientAlive(@NonNull CarWatchdogClientCallback client, int sessionId) { in tellClientAlive() argument
255 Objects.requireNonNull(client, "Client must be non-null"); in tellClientAlive()
258 if (mRegisteredClient != client) { in tellClientAlive()
[all …]
|
| /packages/apps/Gallery2/gallerycommon/src/com/android/gallery3d/common/ |
| D | HttpClientFactory.java | 25 import org.apache.http.client.HttpClient;
62 HttpClient client = (HttpClient) instance; in newHttpClient() local
65 HttpParams params = client.getParams(); in newHttpClient()
75 return client; in newHttpClient()
90 public static void close(HttpClient client) { in close() argument
94 Class<?> clazz = client.getClass(); in close()
96 method.invoke(client, (Object[]) null); in close()
|