Home
last modified time | relevance | path

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

12345

/aosp12/frameworks/av/media/libmediatranscoding/transcoder/tests/
H A DMediaSampleQueueTests.cpp53 sampleQueue.enqueue(newSample(i)); in TEST_F()
76 sampleQueue.enqueue(newSample(i)); in TEST_F()
98 sampleQueue.enqueue(newSample(1)); in TEST_F()
123 bool aborted = sampleQueue.enqueue( in TEST_F()
160 bool aborted = sampleQueue.enqueue( in TEST_F()
182 bool aborted = sampleQueue.enqueue(newSample(1)); in TEST_F()
192 aborted = sampleQueue.enqueue(sample); in TEST_F()
207 aborted = sampleQueue.enqueue(sample); in TEST_F()
/aosp12/frameworks/base/services/core/jni/BroadcastRadio/
H A DTunerCallback.cpp161 mCallbackThread.enqueue([this](JNIEnv *env) { in hardwareFailure()
201 mCallbackThread.enqueue([this, info](JNIEnv *env) { in tuneComplete()
216 mCallbackThread.enqueue([result, this](JNIEnv *env) { in tuneComplete_1_1()
238 mCallbackThread.enqueue([this, connected](JNIEnv *env) { in antennaStateChange()
248 mCallbackThread.enqueue([this, active](JNIEnv *env) { in trafficAnnouncement()
258 mCallbackThread.enqueue([this, active](JNIEnv *env) { in emergencyAnnouncement()
286 mCallbackThread.enqueue([this, info](JNIEnv *env) { in newMetadata()
298 mCallbackThread.enqueue([this, isAvailable](JNIEnv *env) { in backgroundScanAvailable()
309 mCallbackThread.enqueue([this, result](JNIEnv *env) { in backgroundScanComplete()
325 mCallbackThread.enqueue([this](JNIEnv *env) { in programListChanged()
[all …]
H A DNativeCallbackThread.h47 void enqueue(const Task &task);
/aosp12/frameworks/base/core/tests/coretests/src/android/app/
H A DDownloadManagerFunctionalTest.java81 long dlRequest = mDownloadManager.enqueue(request); in doErrorTest()
166 long dlRequest = mDownloadManager.enqueue(request); in testDownloadToExternal_fileExists()
204 long dlRequest = mDownloadManager.enqueue(request); in testDownloadToExternal()
236 mDownloadManager.enqueue(request); in testDownloadToProhibitedDirectory()
308 long dlRequest = mDownloadManager.enqueue(request); in testRelativeRedirect()
352 long dlRequest = mDownloadManager.enqueue(request); in testSetTitle()
381 long dlRequest = mDownloadManager.enqueue(request); in testDownloadNoWifi()
/aosp12/frameworks/base/core/tests/coretests/src/android/net/http/
H A DAbstractProxyTest.java63 server.enqueue(new MockResponse() in testConnectToHttps()
116 server.enqueue(mockResponse); in testConnectViaProxy()
152 server.enqueue(new MockResponse() in testConnectViaHttpProxyToHttps()
155 server.enqueue(new MockResponse() in testConnectViaHttpProxyToHttps()
191 server.enqueue(new MockResponse().setBody("Via request parameter proxy!")); in testParamPreferredOverSystemProperty()
207 server.enqueue(new MockResponse().setBody("Via the origin server!")); in testExplicitNoProxyCancelsSystemProperty()
224 server.enqueue(new MockResponse() in testRetryWithProxy()
H A DCookiesTest.java58 server.enqueue(new MockResponse() in testCookiesAreNotLogged()
88 server.enqueue(new MockResponse() in testCookiesWithNonMatchingCase()
93 server.enqueue(new MockResponse() in testCookiesWithNonMatchingCase()
H A DDefaultHttpClientTest.java74 server.enqueue(new MockResponse() in testServerClosesOutput()
77 server.enqueue(new MockResponse() in testServerClosesOutput()
/aosp12/frameworks/base/core/tests/hosttests/test-apps/DownloadManagerTestApp/src/com/android/frameworks/downloadmanagertests/
H A DDownloadManagerTestApp.java141 dlRequest = mDownloadManager.enqueue(request); in initiateDownload()
233 dlRequest = mDownloadManager.enqueue(request); in runLargeDownloadOverWiFi()
287 dlRequest = mDownloadManager.enqueue(request); in runDownloadMultipleSwitching()
363 dlRequest = mDownloadManager.enqueue(request); in runDownloadMultipleWiFiEnableDisable()
433 dlRequest = mDownloadManager.enqueue(request); in runDownloadMultipleAirplaneModeEnableDisable()
491 dlRequest = mDownloadManager.enqueue(request); in runDownloadMultipleSimultaneously()
/aosp12/frameworks/base/core/java/com/android/internal/infra/
H A DServiceConnector.java344 return enqueue(job); in run()
356 enqueue(task); in postForResult()
365 enqueue(task); in postAsync()
378 enqueue(mServiceConnectionFutureCache); in connect()
384 private void enqueue(@NonNull CompletionAwareJob<I, ?> task) { in enqueue() method in ServiceConnector.Impl
385 if (!enqueue((Job<I, ?>) task)) { in enqueue()
392 private boolean enqueue(@NonNull Job<I, ?> job) { in enqueue() method in ServiceConnector.Impl
/aosp12/frameworks/base/libs/hwui/thread/
H A DWorkQueue.h84 enqueue(WorkItem{time, std::function<void()>(std::forward<F>(func))}); in postAt()
89 enqueue(WorkItem{clock::now() + delay, std::function<void()>(std::forward<F>(func))}); in postDelayed()
121 void enqueue(WorkItem&& item) { in enqueue() function
H A DCommonPool.cpp76 instance().enqueue(std::move(task)); in post()
83 void CommonPool::enqueue(Task&& task) { in enqueue() function in android::uirenderer::CommonPool
/aosp12/frameworks/wilhelm/tests/sandbox/
H A Dintbufq.c191 goto enqueue; in main()
195 goto enqueue; in main()
199 goto enqueue; in main()
215 enqueue: in main()
/aosp12/frameworks/native/libs/renderengine/skia/debug/
H A DCommonPool.cpp59 instance().enqueue(std::move(task)); in post()
62 void CommonPool::enqueue(Task&& task) { in enqueue() function in android::renderengine::skia::CommonPool
H A DCommonPool.h58 void enqueue(Task&&);
/aosp12/packages/apps/DocumentsUI/tests/functional/com/android/documentsui/
H A 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()
/aosp12/packages/inputmethods/LatinIME/java/src/com/android/inputmethod/dictionarypack/
H A DDownloadManagerWrapper.java98 public long enqueue(final Request request) { in enqueue() method in DownloadManagerWrapper
101 return mDownloadManager.enqueue(request); in enqueue()
/aosp12/frameworks/base/apex/jobscheduler/framework/java/android/app/
H A DJobSchedulerImpl.java54 public int enqueue(JobInfo job, JobWorkItem work) { in enqueue() method in JobSchedulerImpl
56 return mBinder.enqueue(job, work); in enqueue()
/aosp12/packages/modules/adb/daemon/
H A Djdwp_service.cpp366 peer->enqueue(peer, std::move(data)); in jdwp_socket_ready()
383 s->enqueue = jdwp_socket_enqueue; in create_jdwp_service_socket()
414 t->peer->enqueue(t->peer, std::move(payload)); in process_list_updated()
452 s->peer->enqueue(s->peer, std::move(data)); in jdwp_tracker_ready()
475 t->enqueue = jdwp_tracker_enqueue; in create_process_tracker_service_socket()
/aosp12/frameworks/base/core/tests/bandwidthtests/src/com/android/bandwidthtest/util/
H A DConnectionUtil.java369 long enqueue = mDownloadManager.enqueue(request); in startDownloadAndWait() local
376 return downloadSuccessful(enqueue); in startDownloadAndWait()
385 if (!downloadSuccessful(enqueue)) { in startDownloadAndWait()
415 private boolean downloadSuccessful(long enqueue) { in downloadSuccessful() argument
417 query.setFilterById(enqueue); in downloadSuccessful()
/aosp12/hardware/ril/libril/
H A DrilSocketQueue.h72 void enqueue(T* request);
121 void Ril_queue<T>::enqueue(T* request) { in enqueue() function
/aosp12/packages/services/Car/service/jni/evs/
H A DEvsServiceContext.cpp228 mCallbackThread.enqueue([event, this](JNIEnv* env) { in onNewEvent()
240 mCallbackThread.enqueue([bufferDesc, this](JNIEnv* env) { in onNewFrame()
282 mCallbackThread.enqueue([who, this](JNIEnv* env) { in onServiceDied()
H A DEvsCallbackThread.h56 void enqueue(const Task& task) ACQUIRE(mLock);
/aosp12/hardware/qcom/camera/msm8998/QCamera2/util/
H A DQCameraBufferMaps.cpp114 enqueue(pType, pStreamId, pFrameIndex, pPlaneIndex, pCookie, pFd, pSize, buffer); in QCameraBufferMaps()
166 uint32_t QCameraBufferMaps::enqueue(cam_mapping_buf_type pType, in enqueue() function in qcamera::QCameraBufferMaps
/aosp12/packages/apps/Nfc/nci/jni/
H A DDataQueue.h62 bool enqueue(uint8_t* data, uint16_t dataLen);
/aosp12/frameworks/av/media/libmediatranscoding/transcoder/include/media/
H A DMediaSampleQueue.h42 bool enqueue(const std::shared_ptr<MediaSample>& sample);

12345