| /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 | 214 for (ScanClient client : mBatchClients) { in getFullBatchScanQueue()
215 if (client.settings.getScanResultType() == ScanSettings.SCAN_RESULT_TYPE_FULL) { in getFullBatchScanQueue()
216 fullBatchClients.add(client); in getFullBatchScanQueue()
222 void startScan(ScanClient client) { in startScan() argument
223 sendMessage(MSG_START_BLE_SCAN, client); in startScan()
227 ScanClient client = mScanNative.getBatchScanClient(scannerId); in stopScan() local
228 if (client == null) { in stopScan()
229 client = mScanNative.getRegularScanClient(scannerId); in stopScan()
231 sendMessage(MSG_STOP_BLE_SCAN, client); in stopScan()
234 void flushBatchScanResults(ScanClient client) { in flushBatchScanResults() argument
[all …]
|
| /packages/apps/Nfc/tests/src/com/android/nfc/snep/ |
| D | SnepValidationClientTests.java | 53 SnepClient client = getSnepClient(); in testNonFragmented() local
56 client.connect(); in testNonFragmented()
58 client.put(msg); in testNonFragmented()
61 byte[] responseBytes = client.get(msg).getNdefMessage().toByteArray(); in testNonFragmented()
69 client.close(); in testNonFragmented()
78 SnepClient client = getSnepClient(); in testFragmented() local
81 client.connect(); in testFragmented()
83 client.put(msg); in testFragmented()
86 byte[] responseBytes = client.get(msg).getNdefMessage().toByteArray(); in testFragmented()
93 client.close(); in testFragmented()
[all …]
|
| D | SnepDefaultClientTests.java | 47 SnepClient client = new SnepClient(); in testPutSmallToDefaultServer() local
48 client.connect(); in testPutSmallToDefaultServer()
49 client.put(getSmallNdef()); in testPutSmallToDefaultServer()
50 client.close(); in testPutSmallToDefaultServer()
54 SnepClient client = new SnepClient(); in testPutLargeToDefaultServer() local
55 client.connect(); in testPutLargeToDefaultServer()
56 client.put(getLargeNdef()); in testPutLargeToDefaultServer()
57 client.close(); in testPutLargeToDefaultServer()
61 SnepClient client = new SnepClient(); in testPutTwiceToDefaultServer() local
62 client.connect(); in testPutTwiceToDefaultServer()
[all …]
|
| D | SnepCustomClientTests.java | 47 SnepClient client = getSnepClient(); in testPutSmall() local
48 client.connect(); in testPutSmall()
49 client.put(getSmallNdef()); in testPutSmall()
50 client.close(); in testPutSmall()
54 SnepClient client = getSnepClient(); in testPutLarge() local
55 client.connect(); in testPutLarge()
56 client.put(getLargeNdef()); in testPutLarge()
57 client.close(); in testPutLarge()
61 SnepClient client = getSnepClient(); in testPutTwice() local
62 client.connect(); in testPutTwice()
[all …]
|
| D | SnepBasicTests.java | 41 final SnepMessenger client = new SnepMessenger(true, clientSocket, MIU); in testGetSmallNdef() local
57 client.sendMessage(SnepMessage.getGetRequest(ACCEPTABLE_LENGTH, getSmallNdef())); in testGetSmallNdef()
58 response = client.getMessage(); in testGetSmallNdef()
72 final SnepMessenger client = new SnepMessenger(true, clientSocket, MIU); in testGetLargeNdef() local
88 client.sendMessage(SnepMessage.getGetRequest(ACCEPTABLE_LENGTH, getNdef(900))); in testGetLargeNdef()
89 response = client.getMessage(); in testGetLargeNdef()
103 final SnepMessenger client = new SnepMessenger(true, clientSocket, MIU); in testGetExcessiveNdef() local
119 client.sendMessage(SnepMessage.getGetRequest(10, getSmallNdef())); in testGetExcessiveNdef()
120 response = client.getMessage(); in testGetExcessiveNdef()
134 final SnepMessenger client = new SnepMessenger(true, clientSocket, MIU); in testPutSmallNdef() local
[all …]
|
| /packages/services/Car/service/src/com/android/car/vms/ |
| D | VmsBrokerService.java | 122 .forEach(client -> client.dump(writer, " ")); in dump()
186 VmsClientInfo client = getClient(clientToken); in registerProvider() local
191 client.addProviderId(providerId); in registerProvider()
199 VmsClientInfo client = getClient(clientToken); in setProviderOfferings() local
200 if (!client.hasProviderId(providerId) && !client.isLegacyClient()) { in setProviderOfferings()
204 if (client.setProviderOfferings(providerId, offerings)) { in setProviderOfferings()
228 VmsClientInfo client = getClient(clientToken); in deliverToSubscribers() local
229 if (!client.hasOffering(providerId, layer) && !client.isLegacyClient()) { in deliverToSubscribers()
234 mStatsService.getVmsClientLogger(client.getUid()) in deliverToSubscribers()
267 VmsClientInfo client; in unregisterClient() local
[all …]
|
| /packages/services/Car/service/src/com/android/car/trust/ |
| D | CarTrustAgentEnrollmentService.java | 193 for (EnrollmentStateClient client : mEnrollmentStateClients) { in release()
194 client.mListenerBinder.unlinkToDeath(client, 0); in release()
196 for (BleStateChangeClient client : mBleStateChangeClients) { in release()
197 client.mListenerBinder.unlinkToDeath(client, 0); in release()
427 EnrollmentStateClient client = findEnrollmentStateClientLocked(listener); in registerEnrollmentCallback() local
428 if (client == null) { in registerEnrollmentCallback()
429 client = new EnrollmentStateClient(listener); in registerEnrollmentCallback()
431 listener.asBinder().linkToDeath(client, 0); in registerEnrollmentCallback()
436 mEnrollmentStateClients.add(client); in registerEnrollmentCallback()
460 for (EnrollmentStateClient client : mEnrollmentStateClients) { in onEscrowTokenAdded()
[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/apps/Bluetooth/src/com/android/bluetooth/avrcpcontroller/ |
| D | AvrcpCoverArtManager.java | 143 AvrcpBipClient client = new AvrcpBipClient(device, psm, new BipClientCallback(device)); in connect()
144 mClients.put(device, client); in connect()
157 AvrcpBipClient client = getClient(device); in refreshSession() local
158 if (client == null) { in refreshSession()
162 client.refreshSession(); in refreshSession()
174 AvrcpBipClient client = getClient(device); in disconnect() local
175 if (client == null) { in disconnect()
179 client.shutdown(); in disconnect()
205 AvrcpBipClient client = getClient(device); in getState() local
206 if (client == null) return BluetoothProfile.STATE_DISCONNECTED; in getState()
[all …]
|
| /packages/services/Car/tests/carservice_unit_test/src/android/car/watchdoglib/ |
| D | CarWatchdogDaemonHelperTest.java | 97 ICarWatchdogClient client = new ICarWatchdogClient.Default(); in testIndirectCall_RegisterUnregisterClient() local
98 mCarWatchdogDaemonHelper.registerClient(client, 0); in testIndirectCall_RegisterUnregisterClient()
99 verify(mFakeCarWatchdog).registerClient(client, 0); in testIndirectCall_RegisterUnregisterClient()
100 mCarWatchdogDaemonHelper.unregisterClient(client); in testIndirectCall_RegisterUnregisterClient()
101 verify(mFakeCarWatchdog).unregisterClient(client); in testIndirectCall_RegisterUnregisterClient()
124 ICarWatchdogClient client = new ICarWatchdogClient.Default(); in testIndirectCall_TellClientAlive() local
125 mCarWatchdogDaemonHelper.tellClientAlive(client, 123456); in testIndirectCall_TellClientAlive()
126 verify(mFakeCarWatchdog).tellClientAlive(client, 123456); in testIndirectCall_TellClientAlive()
158 ICarWatchdogClient client = new ICarWatchdogClientImpl(); in testMultipleRegistration() local
159 mCarWatchdogDaemonHelper.registerMediator(client); in testMultipleRegistration()
[all …]
|
| /packages/services/Car/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()
117 for (auto&& client : mClients) { in changeFramesInFlight()
118 sp<VirtualCamera> virtCam = client.promote(); in changeFramesInFlight()
168 for (auto&& client : mClients) { in changeFramesInFlight()
169 sp<VirtualCamera> virtCam = client.promote(); in changeFramesInFlight()
210 void HalCamera::requestNewFrame(sp<VirtualCamera> client, in requestNewFrame() 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/watchdog/server/tests/ |
| D | WatchdogProcessServiceTest.cpp | 79 sp<MockCarWatchdogClient> client = new MockCarWatchdogClient; in createMockCarWatchdogClient() local
80 sp<MockBinder> binder = client->getBinder(); in createMockCarWatchdogClient()
83 EXPECT_CALL(*client, onAsBinder()).WillRepeatedly(Return(binder.get())); in createMockCarWatchdogClient()
84 return client; in createMockCarWatchdogClient()
113 sp<MockCarWatchdogClient> client = expectNormalCarWatchdogClient(); in TEST_F() local
115 mWatchdogProcessService->registerClient(client, TimeoutLength::TIMEOUT_CRITICAL); in TEST_F()
117 status = mWatchdogProcessService->registerClient(client, TimeoutLength::TIMEOUT_CRITICAL); in TEST_F()
122 sp<MockCarWatchdogClient> client = expectNormalCarWatchdogClient(); in TEST_F() local
123 mWatchdogProcessService->registerClient(client, TimeoutLength::TIMEOUT_CRITICAL); in TEST_F()
124 Status status = mWatchdogProcessService->unregisterClient(client); in TEST_F()
[all …]
|
| /packages/services/Car/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/services/Car/watchdog/server/src/ |
| D | WatchdogProcessService.cpp | 91 Status WatchdogProcessService::registerClient(const sp<ICarWatchdogClient>& client, in registerClient() argument
94 return registerClientLocked(client, timeout, ClientType::Regular); in registerClient()
97 Status WatchdogProcessService::unregisterClient(const sp<ICarWatchdogClient>& client) { in unregisterClient() argument
99 sp<IBinder> binder = BnCarWatchdog::asBinder(client); in unregisterClient()
152 Status WatchdogProcessService::tellClientAlive(const sp<ICarWatchdogClient>& client, in tellClientAlive() argument
155 return tellClientAliveLocked(client, sessionId); in tellClientAlive()
317 Status status = clientInfo.client->checkIfAlive(clientInfo.sessionId, timeout); in doHealthCheck()
340 sp<IBinder> binder = BnCarWatchdog::asBinder((*it).client); in terminate()
365 bool WatchdogProcessService::isRegisteredLocked(const sp<ICarWatchdogClient>& client) { in isRegisteredLocked() argument
366 sp<IBinder> binder = BnCarWatchdog::asBinder(client); in isRegisteredLocked()
[all …]
|
| /packages/services/Car/service/src/com/android/car/watchdog/ |
| D | CarWatchdogService.java | 180 public void registerClient(ICarWatchdogServiceCallback client, int timeout) { in registerClient() argument
187 IBinder binder = client.asBinder(); in registerClient()
190 if (binder == clientInfo.client.asBinder()) { in registerClient()
199 ClientInfo clientInfo = new ClientInfo(client, pid, userId, timeout); in registerClient()
218 public void unregisterClient(ICarWatchdogServiceCallback client) { in unregisterClient() argument
220 IBinder binder = client.asBinder(); in unregisterClient()
225 if (binder != clientInfo.client.asBinder()) { in unregisterClient()
245 public void tellClientAlive(ICarWatchdogServiceCallback client, int sessionId) { in tellClientAlive() argument
253 if (clientInfo != null && clientInfo.client.asBinder() == client.asBinder()) { in tellClientAlive()
309 private void onClientDeath(ICarWatchdogServiceCallback client, int timeout) { in onClientDeath() argument
[all …]
|
| /packages/services/Car/service/src/com/android/car/ |
| D | CarPropertyService.java | 223 Client client = mClientMap.get(listenerBinder); in registerListener() local
224 if (client == null) { in registerListener()
225 client = new Client(listener); in registerListener()
227 client.addProperty(propId, rate); in registerListener()
234 if (!clients.contains(client)) { in registerListener()
235 clients.add(client); in registerListener()
245 finalClient = client; in registerListener()
253 private void getAndDispatchPropertyInitValue(CarPropertyConfig config, Client client) { in getAndDispatchPropertyInitValue() argument
274 client.getListener().onEvent(events); in getAndDispatchPropertyInitValue()
300 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/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 | 32 name: "car-br-google-api-java-client-jar",
33 jars: ["google-api-client-1.30.2.jar"],
38 name: "car-br-google-api-client-android-jar",
39 jars: ["google-api-client-android-1.30.2.jar"],
50 name: "car-br-google-oauth-client-jar",
51 jars: ["google-oauth-client-1.30.1.jar"],
56 name: "car-br-google-http-client-jar",
57 jars: ["google-http-client-1.30.1.jar"],
62 name: "car-br-google-http-client-android-jar",
63 jars: ["google-http-client-android-1.30.1.jar"],
[all …]
|
| /packages/services/Car/car-lib/src/android/car/watchdog/ |
| D | CarWatchdogManager.java | 150 @NonNull CarWatchdogClientCallback client, @TimeoutLengthEnum int timeout) { in registerClient() argument
152 if (mRegisteredClient == client) { in registerClient()
159 mRegisteredClient = client; in registerClient()
181 public void unregisterClient(@NonNull CarWatchdogClientCallback client) { in unregisterClient() argument
183 if (mRegisteredClient != client) { in unregisterClient()
209 public void tellClientAlive(@NonNull CarWatchdogClientCallback client, int sessionId) { in tellClientAlive() argument
212 if (mRegisteredClient != client) { in tellClientAlive()
239 CarWatchdogClientCallback client; in checkClientStatus() local
248 client = mRegisteredClient; in checkClientStatus()
259 boolean checkDone = client.onCheckHealthStatus(sessionId, timeout); in checkClientStatus()
[all …]
|
| /packages/services/Car/tests/carservice_unit_test/src/com/android/car/watchdog/ |
| D | CarWatchdogManagerUnitTest.java | 72 TestClient client = new TestClient(); in testRegisterClient() local
73 ICarWatchdogServiceCallback clientImpl = registerClient(client); in testRegisterClient()
74 mCarWatchdogManager.unregisterClient(client); in testRegisterClient()
83 TestClient client = new TestClient(); in testUnregisterUnregisteredClient() local
84 mCarWatchdogManager.registerClient(mExecutor, client, TIMEOUT_CRITICAL); in testUnregisterUnregisteredClient()
85 mCarWatchdogManager.unregisterClient(client); in testUnregisterUnregisteredClient()
87 mCarWatchdogManager.unregisterClient(client); in testUnregisterUnregisteredClient()
115 CarWatchdogManager.CarWatchdogClientCallback client) { in registerClient() argument
116 mCarWatchdogManager.registerClient(mExecutor, client, TIMEOUT_CRITICAL); in registerClient()
124 private void testClientResponse(CarWatchdogManager.CarWatchdogClientCallback client) in testClientResponse() argument
[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()
|