Home
last modified time | relevance | path

Searched refs:enqueue (Results 1 – 25 of 67) sorted by relevance

123

/packages/modules/Nfc/NfcNci/nci/jni/
DDataQueueTest.cpp33 ASSERT_TRUE(queue.enqueue(data, sizeof(data))); in TEST_F()
48 ASSERT_TRUE(queue.enqueue(data1, sizeof(data1))); in TEST_F()
49 ASSERT_TRUE(queue.enqueue(data2, sizeof(data2))); in TEST_F()
66 ASSERT_TRUE(queue.enqueue(data, sizeof(data))); in TEST_F()
89 ASSERT_FALSE(queue.enqueue(nullptr, 10)); in TEST_F()
90 ASSERT_FALSE(queue.enqueue(reinterpret_cast<uint8_t*>(0x1234), 0)); in TEST_F()
DDataQueue.h62 bool enqueue(uint8_t* data, uint16_t dataLen);
/packages/providers/MediaProvider/tests/src/com/android/providers/media/photopicker/sync/
DSearchResultsSyncWorkerTest.java146 workManager.enqueue(request).getResult().get(); in testInvalidSyncSource()
175 workManager.enqueue(request).getResult().get(); in testMissingSearchRequestId()
204 workManager.enqueue(request).getResult().get(); in testInvalidSearchRequestId()
240 workManager.enqueue(request).getResult().get(); in testMissingInputAuthority()
275 workManager.enqueue(request).getResult().get(); in testIncorrectInputAuthority()
313 workManager.enqueue(request).getResult().get(); in testInvalidAlbumSuggestionsSearchRequestId()
341 workManager.enqueue(request).getResult().get(); in testTextSearchSyncWithCloudProvider()
433 workManager.enqueue(request).getResult().get(); in testTextSearchSyncWithLocalProvider()
514 workManager.enqueue(request).getResult().get(); in testSuggestionSearchSyncWithCloudProvider()
613 workManager.enqueue(request).getResult().get(); in testSuggestionSearchSyncWithLocalProvider()
[all …]
DMediaSetsSyncWorkerTest.java124 workManager.enqueue(request).getResult().get(); in testMediaSetsSyncWithInvalidSyncSource()
145 workManager.enqueue(request).getResult().get(); in testMediaSetsSyncWithMissingSyncSource()
167 workManager.enqueue(request).getResult().get(); in testMediaSetsSyncWithInvalidCategoryId()
188 workManager.enqueue(request).getResult().get(); in testMediaSetsSyncWithMissingCategoryId()
209 workManager.enqueue(request).getResult().get(); in testMediaSetsSyncWithMissingCategoryAuthority()
230 workManager.enqueue(request).getResult().get(); in testMediaSetsSyncWithValidSyncSourceAndCategoryIdForCloudAuth()
278 workManager.enqueue(request).getResult().get(); in testMediaSetsSyncWithValidSyncSourceAndCategoryIdForLocalAuth()
324 workManager.enqueue(request).getResult().get(); in testMediaSetsSyncLoop()
DImmediateAlbumSyncWorkerTest.java97 workManager.enqueue(request).getResult().get(); in testLocalAlbumImmediateSync()
130 workManager.enqueue(request).getResult().get(); in testCloudAlbumImmediateSync()
164 workManager.enqueue(request).getResult().get(); in testInvalidSyncSourceImmediateAlbumSync()
198 workManager.enqueue(request).getResult().get(); in testLocalAndCloudImmediateSyncFailure()
232 workManager.enqueue(request).getResult().get(); in testInvalidAlbumIdImmediateSyncFailure()
DImmediateSyncWorkerTest.java95 workManager.enqueue(request).getResult().get(); in testLocalImmediateSync()
127 workManager.enqueue(request).getResult().get(); in testCloudImmediateSync()
160 workManager.enqueue(request).getResult().get(); in testLocalAndCloudImmediateSync()
194 workManager.enqueue(request).getResult().get(); in testLocalAndCloudImmediateSyncFailure()
DProactiveSyncWorkerTest.java95 workManager.enqueue(request).getResult().get(); in testLocalProactiveSync()
127 workManager.enqueue(request).getResult().get(); in testCloudProactiveSync()
159 workManager.enqueue(request).getResult().get(); in testLocalAndCloudProactiveSync()
191 workManager.enqueue(request).getResult().get(); in testProactiveSyncFailure()
DMediaInMediaSetsSyncWorkerTest.java137 workManager.enqueue(request).getResult().get(); in testMediaInMediaSetSyncWithInvalidSyncSource()
157 workManager.enqueue(request).getResult().get(); in testMediaInMediaSetSyncWithInvalidMediaSetPickerId()
177 workManager.enqueue(request).getResult().get(); in testMediaInMediaSetSyncWithInvalidMediaSetAuthority()
228 workManager.enqueue(request).getResult().get(); in testMediaInMediaSetSyncWithCloudProvider()
348 workManager.enqueue(request).getResult().get(); in testMediaInMediaSetsSyncLocalProvider()
457 workManager.enqueue(request).getResult().get(); in testMediaSetContentsSyncLoop()
548 workManager.enqueue(request).getResult().get(); in testMediaInMediaSetSyncComplete()
DMediaResetWorkerTest.java145 workManager.enqueue(request).getResult().get(); in testResetCloudAlbumMediaForAlbumId()
196 workManager.enqueue(request).getResult().get(); in testResetLocalAlbumMediaForAlbumId()
248 workManager.enqueue(request).getResult().get(); in testResetAllAlbumMedia()
296 workManager.enqueue(request).getResult().get(); in testPeriodicWorkerAlbumReset_WithCloudProvider()
346 workManager.enqueue(request).getResult().get(); in testPeriodicWorkerAlbumReset_WithLocalProvider()
DImmediateGrantsSyncWorkerTest.java99 workManager.enqueue(request).getResult().get(); in testGrantsImmediateSync()
126 workManager.enqueue(request).getResult().get(); in testLocalAndCloudImmediateSyncFailure()
/packages/modules/adb/docs/dev/
Dasocket.md20 - A asocket is uni-directional. It only allows data to be `enqueue`d.
51 ┌──┐ write(3) │ ┌─────┐ enqueue() │ │
57 peer.enqueue()
85 If `peer.enqueue` indicates that the peer cannot take more updates, the LS deletes
94 - enqueue -> A_WRTE
103 ┌──┐ write(3) │ ┌─────┐ enqueue() │ │ │
113 │ enqueue() │ │ │
143 Upon creation, a SS enqueue does not forward anything until the [smart protocol](services.md)
/packages/modules/AdServices/adservices/tests/unittest/service-core/protectedaudience/src/com/android/adservices/service/adselection/debug/
DDebugReportSenderStrategyHttpImplTest.java64 mDebugReportSender.enqueue(uri); in testSend_withSingleReport_allRequestsAreSuccessful()
103 mDebugReportSender.enqueue(uri1); in testSend_withFailedRequest_otherRequestsAreSuccessful()
104 mDebugReportSender.enqueue(uri2); in testSend_withFailedRequest_otherRequestsAreSuccessful()
DDebugReportSenderStrategyBatchImplTest.java79 mDebugReportSender.enqueue(uri); in testEnqueue()
84 Assert.assertThrows(NullPointerException.class, () -> mDebugReportSender.enqueue(null)); in testEnqueueNullUriThrowsException()
104 mDebugReportSender.enqueue(uri); in testSend_withSingleReport_allRequestsAreSuccessful()
/packages/modules/Connectivity/networksecurity/tests/unit/src/com/android/server/net/ct/
DDownloadHelperTest.java51 when(mDownloadManager.enqueue(any())).thenReturn(downloadId); in testDownloadHelper_scheduleDownload()
58 when(mDownloadManager.enqueue(any())).thenReturn(666L); in testDownloadHelper_wrongUri()
/packages/modules/adb/daemon/
Djdwp_service.cpp423 peer->enqueue(peer, std::move(data)); in jdwp_socket_ready()
440 s->enqueue = jdwp_socket_enqueue; in create_jdwp_service_socket()
477 t->peer->enqueue(t->peer, std::move(payload)); in process_list_updated()
515 s->peer->enqueue(s->peer, std::move(data)); in jdwp_tracker_ready()
542 t->enqueue = jdwp_tracker_enqueue; in create_process_tracker_service_socket()
/packages/apps/DocumentsUI/tests/functional/com/android/documentsui/
DIntegratedDownloadsUiTest.java48 dm.enqueue(new Request(Uri.parse("http://hammychamp.toodles"))); in testDownload_Queued()
59 dm.enqueue(new Request(Uri.parse("http://www.google.com/hamfancy"))); in testDownload_RetryUnsuccessful()
/packages/providers/CalendarProvider/src/com/android/providers/calendar/
DCalendarProviderBroadcastReceiver.java53 if (jobScheduler.enqueue(alarmJobBuilder.build(), jwi) == JobScheduler.RESULT_SUCCESS) { in onReceive()
59 if (jobScheduler.enqueue(alarmJobBuilder.build(), jwi) == JobScheduler.RESULT_SUCCESS) { in onReceive()
/packages/inputmethods/LatinIME/java/src/com/android/inputmethod/dictionarypack/
DDownloadManagerWrapper.java100 public long enqueue(final Request request) { in enqueue() method in DownloadManagerWrapper
103 return mDownloadManager.enqueue(request); in enqueue()
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/adselection/debug/
DDebugReportSenderStrategy.java29 void enqueue(Uri uri); in enqueue() method
DDebugReportSenderStrategyNoOp.java42 public void enqueue(Uri uri) { in enqueue() method in DebugReportSenderStrategyNoOp
/packages/providers/DownloadProvider/tests/public_api_access/src/com/android/providers/downloads/public_api_access_tests/
DPublicApiAccessTest.java173 mManager.enqueue(request); in testDownloadManagerRequest()
182 mManager.enqueue(request); in testDownloadManagerRequest()
/packages/services/Car/service/jni/evs/
DEvsCallbackThread.h54 void enqueue(const Task& task) EXCLUDES(mLock);
DEvsServiceContext.cpp435 mCallbackThread.enqueue([event, this](JNIEnv* env) { in onNewEvent()
484 mCallbackThread.enqueue([ahwb, bufferId = bufferDesc.bufferId, this](JNIEnv* env) { in onNewFrame()
515 mCallbackThread.enqueue([this](JNIEnv* env) { in onEvsServiceDiedImpl()
/packages/providers/MediaProvider/src/com/android/providers/media/photopicker/sync/
DEndlessWorker.java51 WorkManager.getInstance().enqueue(request); in doWork()
/packages/modules/Nfc/libnfc-nci/src/gki/common/
Dgki.h468 virtual void enqueue(BUFFER_Q* p_q, void* p_buf) = 0;
515 void enqueue(BUFFER_Q* p_q, void* p_buf) override { in enqueue() function

123