| /packages/modules/OnDevicePersonalization/framework/java/android/adservices/ondevicepersonalization/ |
| D | RemoteDataImpl.java | 54 BlockingQueue<Bundle> asyncResult = new ArrayBlockingQueue<>(1); in get() local
64 asyncResult.add(result); in get()
66 asyncResult.add(Bundle.EMPTY); in get()
72 asyncResult.add(Bundle.EMPTY); in get()
75 Bundle result = asyncResult.take(); in get()
100 BlockingQueue<Bundle> asyncResult = new ArrayBlockingQueue<>(1); in keySet() local
108 asyncResult.add(result); in keySet()
110 asyncResult.add(Bundle.EMPTY); in keySet()
116 asyncResult.add(Bundle.EMPTY); in keySet()
119 Bundle result = asyncResult.take(); in keySet()
|
| D | LogReader.java | 136 BlockingQueue<Bundle> asyncResult = new ArrayBlockingQueue<>(1); in handleAsyncRequest() local
144 asyncResult.add(result); in handleAsyncRequest()
146 asyncResult.add(Bundle.EMPTY); in handleAsyncRequest()
152 asyncResult.add(Bundle.EMPTY); in handleAsyncRequest()
155 return asyncResult.take(); in handleAsyncRequest()
|
| D | LocalDataImpl.java | 143 BlockingQueue<Bundle> asyncResult = new ArrayBlockingQueue<>(1); in handleAsyncRequest() local
151 asyncResult.add(result); in handleAsyncRequest()
153 asyncResult.add(Bundle.EMPTY); in handleAsyncRequest()
159 asyncResult.add(Bundle.EMPTY); in handleAsyncRequest()
162 return asyncResult.take(); in handleAsyncRequest()
|
| D | EventUrlProvider.java | 108 BlockingQueue<CallbackResult> asyncResult = new ArrayBlockingQueue<>(1); in getUrl() local
116 asyncResult.add(new CallbackResult(result, 0)); in getUrl()
120 asyncResult.add(new CallbackResult(null, errorCode)); in getUrl()
123 CallbackResult callbackResult = asyncResult.take(); in getUrl()
|
| /packages/modules/OnDevicePersonalization/federatedcompute/src/com/android/federatedcompute/services/training/ |
| D | ResultCallbackHelper.java | 92 BlockingQueue<Integer> asyncResult = new ArrayBlockingQueue<>(1); in callHandleResult() local
98 asyncResult.add(STATUS_SUCCESS); in callHandleResult()
103 asyncResult.add(errorCode); in callHandleResult()
107 asyncResult.poll( in callHandleResult()
|
| /packages/modules/OnDevicePersonalization/federatedcompute/src/com/android/federatedcompute/services/examplestore/ |
| D | ExampleStoreServiceProvider.java | 89 BlockingQueue<CallbackResult> asyncResult = new ArrayBlockingQueue<>(1); in getExampleIterator() local
96 asyncResult.add(new CallbackResult(iterator, 0)); in getExampleIterator()
103 asyncResult.add(new CallbackResult(null, errorCode)); in getExampleIterator()
108 asyncResult.poll( in getExampleIterator()
|
| /packages/modules/OnDevicePersonalization/src/com/android/ondevicepersonalization/services/inference/ |
| D | IsolatedModelServiceImpl.java | 170 BlockingQueue<Bundle> asyncResult = new ArrayBlockingQueue<>(1); in fetchModel() local
180 asyncResult.add(result); in fetchModel()
182 asyncResult.add(Bundle.EMPTY); in fetchModel()
188 asyncResult.add(Bundle.EMPTY); in fetchModel()
191 Bundle result = asyncResult.take(); in fetchModel()
|
| /packages/services/Telephony/src/com/android/services/telephony/ |
| D | PstnIncomingCallNotifier.java | 155 private void handleNewRingingConnection(AsyncResult asyncResult) { in handleNewRingingConnection() argument
157 Connection connection = (Connection) asyncResult.result; in handleNewRingingConnection()
185 private void handleCdmaCallWaiting(AsyncResult asyncResult) { in handleCdmaCallWaiting() argument
187 CdmaCallWaitingNotification ccwi = (CdmaCallWaitingNotification) asyncResult.result; in handleCdmaCallWaiting()
216 private void handleNewUnknownConnection(AsyncResult asyncResult) { in handleNewUnknownConnection() argument
218 if (!(asyncResult.result instanceof Connection)) { in handleNewUnknownConnection()
222 Connection connection = (Connection) asyncResult.result; in handleNewUnknownConnection()
|
| D | TelephonyConnection.java | 265 AsyncResult asyncResult = (AsyncResult) msg.obj;
268 asyncResult.result;
|
| /packages/services/Car/tests/carservice_unit_test/src/com/android/car/hal/fakevhal/ |
| D | FakeVehicleStubUnitTest.java | 645 GetVehicleStubAsyncResult asyncResult = getAsyncResult.get(0); in testGetAsyncMethodForSingleValue() local
646 HalPropValue propValue = asyncResult.getHalPropValue(); in testGetAsyncMethodForSingleValue()
647 expect.that(asyncResult.getServiceRequestId()).isEqualTo(0); in testGetAsyncMethodForSingleValue()
670 GetVehicleStubAsyncResult asyncResult = getAsyncResult.get(0); in testGetAsyncMethodForSingleValueNoReadPermissionError() local
671 HalPropValue propValue = asyncResult.getHalPropValue(); in testGetAsyncMethodForSingleValueNoReadPermissionError()
673 expect.that(asyncResult.getServiceRequestId()).isEqualTo(0); in testGetAsyncMethodForSingleValueNoReadPermissionError()
674 expect.that(asyncResult.getErrorCode()) in testGetAsyncMethodForSingleValueNoReadPermissionError()
692 GetVehicleStubAsyncResult asyncResult = getAsyncResult.get(0); in testGetAsyncForPropNotAvailable() local
693 expect.that(asyncResult.getHalPropValue()).isNull(); in testGetAsyncForPropNotAvailable()
694 expect.that(asyncResult.getServiceRequestId()).isEqualTo(0); in testGetAsyncForPropNotAvailable()
[all …]
|
| /packages/modules/Telephony/services/QualifiedNetworksService/tests/src/com/android/telephony/qns/ |
| D | RestrictManagerTest.java | 2395 QnsAsyncResult asyncResult = in testHandlerEventOnDataConnectionChangedEvent() local
2404 Message.obtain(mRestrictManager.mHandler, 3001, asyncResult)); in testHandlerEventOnDataConnectionChangedEvent()
2407 asyncResult = in testHandlerEventOnDataConnectionChangedEvent()
2416 Message.obtain(mRestrictManager.mHandler, 3001, asyncResult)); in testHandlerEventOnDataConnectionChangedEvent()
|