| /packages/modules/Bluetooth/android/app/src/com/android/bluetooth/gatt/ |
| D | ScanManager.java | 265 for (ScanClient client : mBatchClients) { in getFullBatchScanQueue()
266 if (client.settings.getScanResultType() == ScanSettings.SCAN_RESULT_TYPE_FULL) { in getFullBatchScanQueue()
267 fullBatchClients.add(client); in getFullBatchScanQueue()
273 void startScan(ScanClient client) { in startScan() argument
275 Log.d(TAG, "startScan() " + client); in startScan()
277 sendMessage(MSG_START_BLE_SCAN, client); in startScan()
281 ScanClient client = mScanNative.getBatchScanClient(scannerId); in stopScan() local
282 if (client == null) { in stopScan()
283 client = mScanNative.getRegularScanClient(scannerId); in stopScan()
285 if (client == null) { in stopScan()
[all …]
|
| /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/modules/Bluetooth/android/app/tests/unit/src/com/android/bluetooth/gatt/ |
| D | ScanManagerTest.java | 161 ScanClient client = new ScanClient(id, scanSettings, scanFilterList); in createScanClient() local
162 client.stats = new AppScanStats("Test", null, null, mService); in createScanClient()
163 client.stats.recordScanStart(scanSettings, scanFilterList, isFiltered, false, id); in createScanClient()
164 return client; in createScanClient()
237 ScanClient client = createScanClient(i, isFiltered, ScanMode); in testScreenOffStartUnfilteredScan() local
239 sendMessageWaitForProcessed(createStartStopScanMessage(true, client)); in testScreenOffStartUnfilteredScan()
240 assertThat(mScanManager.getRegularScanQueue().contains(client)).isFalse(); in testScreenOffStartUnfilteredScan()
241 assertThat(mScanManager.getSuspendedScanQueue().contains(client)).isTrue(); in testScreenOffStartUnfilteredScan()
242 assertThat(client.settings.getScanMode()).isEqualTo(expectedScanMode); in testScreenOffStartUnfilteredScan()
266 ScanClient client = createScanClient(i, isFiltered, ScanMode); in testScreenOffStartFilteredScan() local
[all …]
|
| /packages/modules/Bluetooth/system/gd/rust/linux/stack/src/ |
| D | bluetooth_gatt.rs | 51 self.clients.iter().find(|client| client.uuid == *uuid) in get_by_uuid()
55 self.clients.iter().find(|client| client.id.is_some() && client.id.unwrap() == client_id) in get_by_client_id()
61 .find(|client| client.id.is_some() && client.id.unwrap() == client_id) in get_by_client_id_mut()
102 self.clients.retain(|client| !(client.id.is_some() && client.id.unwrap() == id)); in remove()
106 let client = self.clients.iter_mut().find(|client| client.uuid == *uuid); in set_client_id() localVariable
107 if client.is_none() { in set_client_id()
111 client.unwrap().id = Some(id); in set_client_id()
583 self.gatt.as_ref().unwrap().client.register_client(&uuid, eatt_support); in register_client()
588 self.gatt.as_ref().unwrap().client.unregister_client(client_id); in unregister_client()
605 self.gatt.as_ref().unwrap().client.connect( in client_connect()
[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 | 126 .forEach(client -> client.dump(writer, " ")); in dump()
190 VmsClientInfo client = getClient(clientToken); in registerProvider() local
195 client.addProviderId(providerId); in registerProvider()
203 VmsClientInfo client = getClient(clientToken); in setProviderOfferings() local
204 if (!client.hasProviderId(providerId) && !client.isLegacyClient()) { in setProviderOfferings()
208 if (client.setProviderOfferings(providerId, offerings)) { in setProviderOfferings()
232 VmsClientInfo client = getClient(clientToken); in deliverToSubscribers() local
233 if (!client.hasOffering(providerId, layer) && !client.isLegacyClient()) { in deliverToSubscribers()
238 mStatsService.getVmsClientLogger(client.getUid()) in deliverToSubscribers()
270 VmsClientInfo client; in unregisterClient() local
[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/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/Car/cpp/evs/manager/1.1/ |
| D | HalCamera.cpp | 49 sp<VirtualCamera> client = new VirtualCamera(sourceCameras); in makeVirtualCamera() local
50 if (client == nullptr) { in makeVirtualCamera()
55 if (!ownVirtualCamera(client)) { in makeVirtualCamera()
57 client = nullptr; in makeVirtualCamera()
60 return client; in makeVirtualCamera()
119 [&clientToDisown](wp<VirtualCamera>& client) { return client == clientToDisown; }); in disownVirtualCamera() argument
137 for (auto&& client : mClients) { in changeFramesInFlight()
138 sp<VirtualCamera> virtCam = client.promote(); in changeFramesInFlight()
186 for (auto&& client : mClients) { in changeFramesInFlight()
187 sp<VirtualCamera> virtCam = client.promote(); in changeFramesInFlight()
[all …]
|
| /packages/modules/Bluetooth/android/app/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/cpp/evs/manager/aidl/src/ |
| D | HalCamera.cpp | 52 std::shared_ptr<VirtualCamera> client = in makeVirtualCamera() local
54 if (!client || !ownVirtualCamera(client)) { in makeVirtualCamera()
59 return std::move(client); in makeVirtualCamera()
93 mClients.remove_if([clientToDisown](std::weak_ptr<VirtualCamera>& client) { in disownVirtualCamera() argument
94 auto current = client.lock(); in disownVirtualCamera()
115 for (auto&& client : mClients) { in changeFramesInFlight()
116 std::shared_ptr<VirtualCamera> virtCam = client.lock(); in changeFramesInFlight()
162 for (auto&& client : mClients) { in changeFramesInFlight()
163 std::shared_ptr<VirtualCamera> virtCam = client.lock(); in changeFramesInFlight()
197 void HalCamera::requestNewFrame(std::shared_ptr<VirtualCamera> client, int64_t lastTimestamp) { in requestNewFrame() argument
[all …]
|
| /packages/modules/Bluetooth/system/service/ipc/binder/ |
| D | bluetooth_low_energy_binder_server.cc | 73 auto client = GetLEClient(client_id); in Connect() local
74 if (!client) { in Connect()
81 client->Connect(std::string(String8(address).string()), is_direct); in Connect()
91 auto client = GetLEClient(client_id); in Disconnect() local
92 if (!client) { in Disconnect()
98 *_aidl_return = client->Disconnect(std::string(String8(address).string())); in Disconnect()
109 auto client = GetLEClient(client_id); in SetMtu() local
110 if (!client) { in SetMtu()
116 *_aidl_return = client->SetMtu(std::string(String8(address).string()), mtu); in SetMtu()
121 bluetooth::LowEnergyClient* client, int status, const char* address, in OnConnectionState() argument
[all …]
|
| /packages/services/Car/service/src/com/android/car/watchdog/ |
| D | WatchdogProcessHandler.java | 156 public void registerClient(ICarWatchdogServiceCallback client, int timeout) { in registerClient() argument
163 IBinder binder = client.asBinder(); in registerClient()
166 if (binder == clientInfo.client.asBinder()) { in registerClient()
175 ClientInfo clientInfo = new ClientInfo(client, pid, userId, timeout); in registerClient()
191 public void unregisterClient(ICarWatchdogServiceCallback client) { in unregisterClient() argument
194 IBinder binder = client.asBinder(); in unregisterClient()
207 if (binder == notRespondingClientInfo.client.asBinder()) { in unregisterClient()
224 if (binder != clientInfo.client.asBinder()) { in removeFromClientMapsLocked()
240 public void tellClientAlive(ICarWatchdogServiceCallback client, int sessionId) { in tellClientAlive() argument
248 if (clientInfo != null && clientInfo.client.asBinder() == client.asBinder()) { in tellClientAlive()
[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/service/src/com/android/car/ |
| D | CarPropertyService.java | 280 Client client = mClientMap.get(listenerBinder); in registerListener() local
281 if (client == null) { in registerListener()
282 client = new Client(listener); in registerListener()
283 if (client.isDead()) { in registerListener()
287 mClientMap.put(listenerBinder, client); in registerListener()
289 client.addProperty(propId, rate); in registerListener()
296 if (!clients.contains(client)) { in registerListener()
297 clients.add(client); in registerListener()
303 finalClient = client; in registerListener()
311 private void getAndDispatchPropertyInitValue(CarPropertyConfig config, Client client) { in getAndDispatchPropertyInitValue() argument
[all …]
|
| /packages/modules/DnsResolver/tests/doh/src/ |
| D | dns_https_frontend.rs | 19 use crate::client::{ClientMap, ConnectionID, DNS_HEADER_SIZE, MAX_UDP_PAYLOAD_SIZE};
296 for (_, client) in clients.iter_mut() { in worker_thread()
298 client.on_timeout(); in worker_thread()
300 let connection_id = client.connection_id().clone(); in worker_thread()
319 let client = match clients.get_or_create(&hdr, &src) { in worker_thread() localVariable
326 debug!("Got client: {:?}", client); in worker_thread()
328 match client.handle_frontend_message(pkt_buf) { in worker_thread()
347 let connection_id = client.connection_id().clone(); in worker_thread()
359 for (_, client) in clients.iter_mut() { in worker_thread()
360 if client.is_waiting_for_query(&query_id) { in worker_thread()
[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/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/services/Car/car-lib/src/android/car/vms/ |
| D | VmsClientManager.java | 59 void onClientConnected(@NonNull VmsClient client); in onClientConnected() argument
129 VmsClient client; in registerVmsClientCallback() local
136 client = new VmsClient(mBrokerService, executor, callback, legacyClient, in registerVmsClientCallback()
139 mClients.put(callback, client); in registerVmsClientCallback()
145 client.register(); in registerVmsClientCallback()
157 callback.onClientConnected(client); in registerVmsClientCallback()
159 callback.onLayerAvailabilityChanged(client.getAvailableLayers()); in registerVmsClientCallback()
160 callback.onSubscriptionStateChanged(client.getSubscriptionState()); in registerVmsClientCallback()
175 VmsClient client; in unregisterVmsClientCallback() local
177 client = mClients.remove(callback); in unregisterVmsClientCallback()
[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/modules/adb/ |
| D | Android.bp | 264 "client/openscreen/mdns_service_info.cpp",
265 "client/openscreen/mdns_service_watcher.cpp",
266 "client/openscreen/platform/logging.cpp",
267 "client/openscreen/platform/task_runner.cpp",
268 "client/openscreen/platform/udp_socket.cpp",
269 "client/auth.cpp",
270 "client/adb_wifi.cpp",
271 "client/usb_libusb.cpp",
272 "client/transport_local.cpp",
273 "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/cpp/watchdog/server/tests/ |
| D | WatchdogProcessServiceTest.cpp | 128 sp<MockCarWatchdogClient> client = sp<MockCarWatchdogClient>::make(); in createMockCarWatchdogClient() local
129 sp<MockBinder> binder = client->getBinder(); in createMockCarWatchdogClient()
132 EXPECT_CALL(*client, onAsBinder()).WillRepeatedly(Return(binder.get())); in createMockCarWatchdogClient()
133 return client; in createMockCarWatchdogClient()
173 sp<MockCarWatchdogClient> client = expectNormalCarWatchdogClient(); in TEST_F() local
175 mWatchdogProcessService->registerClient(client, TimeoutLength::TIMEOUT_CRITICAL); in TEST_F()
177 status = mWatchdogProcessService->registerClient(client, TimeoutLength::TIMEOUT_CRITICAL); in TEST_F()
182 sp<MockCarWatchdogClient> client = expectNormalCarWatchdogClient(); in TEST_F() local
183 mWatchdogProcessService->registerClient(client, TimeoutLength::TIMEOUT_CRITICAL); in TEST_F()
184 Status status = mWatchdogProcessService->unregisterClient(client); in TEST_F()
[all …]
|
| /packages/modules/Bluetooth/system/service/test/ |
| D | low_energy_client_unittest.cc | 65 void OnConnectionState(LowEnergyClient* client, int status, in OnConnectionState() argument
67 ASSERT_TRUE(client); in OnConnectionState()
71 void OnMtuChanged(LowEnergyClient* client, int status, const char* address, in OnMtuChanged() argument
73 ASSERT_TRUE(client); in OnMtuChanged()
129 auto callback = [&](std::unique_ptr<LowEnergyClient> client) { in SetUp() argument
130 le_client_ = std::move(client); in SetUp()
144 const std::function<void(std::unique_ptr<LowEnergyClient> client)> in RegisterTestClient()
185 std::unique_ptr<LowEnergyClient> client; in TEST_F() local
192 client = std::unique_ptr<LowEnergyClient>( in TEST_F()
231 ASSERT_TRUE(client.get() != nullptr); // Assert to terminate in case of error in TEST_F()
[all …]
|