| /dports/www/firefox-esr/firefox-91.8.0/dom/media/platforms/ |
| H A D | PlatformEncoderModule.h | 230 mTaskQueue(aTaskQueue), in CreateEncoderParams()
234 MOZ_ASSERT(mTaskQueue); in CreateEncoderParams()
247 mTaskQueue(aTaskQueue), in CreateEncoderParams()
251 MOZ_ASSERT(mTaskQueue); in CreateEncoderParams()
271 const RefPtr<TaskQueue> mTaskQueue; member
|
| /dports/lang/spidermonkey78/firefox-78.9.0/dom/media/platforms/ |
| H A D | PlatformEncoderModule.h | 230 mTaskQueue(aTaskQueue), in CreateEncoderParams()
234 MOZ_ASSERT(mTaskQueue); in CreateEncoderParams()
247 mTaskQueue(aTaskQueue), in CreateEncoderParams()
251 MOZ_ASSERT(mTaskQueue); in CreateEncoderParams()
271 const RefPtr<TaskQueue> mTaskQueue; member
|
| /dports/mail/thunderbird/thunderbird-91.8.0/dom/media/platforms/ |
| H A D | PlatformEncoderModule.h | 230 mTaskQueue(aTaskQueue), in CreateEncoderParams()
234 MOZ_ASSERT(mTaskQueue); in CreateEncoderParams()
247 mTaskQueue(aTaskQueue), in CreateEncoderParams()
251 MOZ_ASSERT(mTaskQueue); in CreateEncoderParams()
271 const RefPtr<TaskQueue> mTaskQueue; member
|
| /dports/www/firefox/firefox-99.0/ipc/glue/ |
| H A D | BackgroundStarterChild.h | 21 : mOtherPid(aOtherPid), mTaskQueue(aTaskQueue) {} in NS_INLINE_DECL_THREADSAFE_REFCOUNTING()
26 const nsCOMPtr<nsISerialEventTarget> mTaskQueue; variable
|
| /dports/lang/spidermonkey78/firefox-78.9.0/dom/media/platforms/agnostic/ |
| H A D | OpusDecoder.cpp | 32 mTaskQueue(aParams.mTaskQueue), in OpusDataDecoder()
51 return InvokeAsync(mTaskQueue, __func__, [self]() { in Shutdown()
182 return InvokeAsync<MediaRawData*>(mTaskQueue, this, __func__, in Decode()
355 return InvokeAsync(mTaskQueue, __func__, [] { in Drain()
366 return InvokeAsync(mTaskQueue, __func__, [self, this]() { in Flush()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/dom/media/platforms/android/ |
| H A D | AndroidDataEncoder.h | 24 : mConfig(aConfig), mTaskQueue(aTaskQueue) {} in AndroidDataEncoder()
67 MOZ_ASSERT(mTaskQueue->IsCurrentThreadIn()); in AssertOnTaskQueue()
72 RefPtr<TaskQueue> mTaskQueue; variable
|
| /dports/www/firefox/firefox-99.0/dom/media/platforms/android/ |
| H A D | AndroidDataEncoder.cpp | 47 return InvokeAsync(mTaskQueue, this, __func__, in Init()
165 return InvokeAsync(mTaskQueue, __func__, [self, sample]() { in Encode()
273 if (!mTaskQueue->IsCurrentThreadIn()) { in ProcessOutput()
275 mTaskQueue->Dispatch(NewRunnableMethod<java::Sample::GlobalRef&&, in ProcessOutput()
400 return InvokeAsync(mTaskQueue, this, __func__, in Drain()
437 return InvokeAsync(mTaskQueue, this, __func__, in Shutdown()
464 return InvokeAsync(mTaskQueue, __func__, [self, aBitsPerSec]() { in SetBitrate()
474 if (!mTaskQueue->IsCurrentThreadIn()) { in Error()
475 nsresult rv = mTaskQueue->Dispatch(NewRunnableMethod<MediaResult>( in Error()
|
| /dports/lang/spidermonkey60/firefox-60.9.0/gfx/layers/apz/test/gtest/ |
| H A D | APZTestCommon.h | 114 while (mTaskQueue.Length() > 0 && mTaskQueue[0].second <= target) { in AdvanceBy()
123 int insIndex = mTaskQueue.Length(); in PostDelayedTask()
125 if (mTaskQueue[insIndex - 1].second <= runAtTime) { in PostDelayedTask()
130 mTaskQueue.InsertElementAt(insIndex, std::make_pair(task, runAtTime)); in PostDelayedTask()
140 runQueue.SwapElements(mTaskQueue); in RunThroughDelayedTasks()
155 std::pair<RefPtr<Runnable>, TimeStamp> next = mTaskQueue[0]; in RunNextDelayedTask()
156 mTaskQueue.RemoveElementAt(0); in RunNextDelayedTask()
166 nsTArray<std::pair<RefPtr<Runnable>, TimeStamp>> mTaskQueue; variable
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/android/feed/core/java/src/org/chromium/chrome/browser/feed/library/feedsessionmanager/ |
| H A D | FeedSessionManagerImpl.java | 139 private final TaskQueue mTaskQueue; field in FeedSessionManagerImpl
168 this.mTaskQueue = taskQueue; in FeedSessionManagerImpl()
207 mTaskQueue.initialize(this::initializationTask); in initialize()
229 mTaskQueue.reset(); in initializationTask()
262 mTaskQueue.execute(Task.GET_NEW_SESSION, TaskType.IMMEDIATE, in getNewSession()
396 mTaskQueue.execute( in modelErrorObserver()
468 mTaskQueue.execute(Task.DETACH_SESSION, TaskType.USER_FACING, in detachSession()
492 mTaskQueue.execute(Task.HANDLE_TOKEN, TaskType.BACKGROUND, () -> { in handleToken()
513 mTaskQueue.execute(Task.SESSION_MANAGER_TRIGGER_REFRESH, in triggerRefresh()
758 dumper.dump(mTaskQueue); in dump()
[all …]
|
| /dports/lang/spidermonkey78/firefox-78.9.0/xpcom/tests/gtest/ |
| H A D | TestMozPromise.cpp | 27 : mTaskQueue( in AutoTaskQueue()
30 ~AutoTaskQueue() { mTaskQueue->AwaitShutdownAndIdle(); } in ~AutoTaskQueue()
32 TaskQueue* Queue() { return mTaskQueue; } in Queue()
35 RefPtr<TaskQueue> mTaskQueue; member in AutoTaskQueue
44 mTaskQueue(aTaskQueue), in DelayedResolveOrReject()
50 MOZ_ASSERT(mTaskQueue->IsCurrentThreadIn()); in Run()
62 return mTaskQueue->Dispatch(r.forget()); in Run()
71 RefPtr<TaskQueue> mTaskQueue; member in DelayedResolveOrReject
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/angle/src/libANGLE/ |
| H A D | WorkerThread.cpp | 150 std::queue<std::pair<std::shared_ptr<AsyncWaitableEvent>, std::shared_ptr<Closure>>> mTaskQueue; member in angle::AsyncWorkerPool
161 mTaskQueue.push(std::make_pair(waitable, task)); in postWorkerTask()
184 while (mRunningThreads < mMaxThreads && !mTaskQueue.empty()) in checkToRunPendingTasks()
186 auto task = mTaskQueue.front(); in checkToRunPendingTasks()
187 mTaskQueue.pop(); in checkToRunPendingTasks()
|
| /dports/www/firefox-esr/firefox-91.8.0/gfx/angle/checkout/src/libANGLE/ |
| H A D | WorkerThread.cpp | 150 std::queue<std::pair<std::shared_ptr<AsyncWaitableEvent>, std::shared_ptr<Closure>>> mTaskQueue; member in angle::AsyncWorkerPool
161 mTaskQueue.push(std::make_pair(waitable, task)); in postWorkerTask()
184 while (mRunningThreads < mMaxThreads && !mTaskQueue.empty()) in checkToRunPendingTasks()
186 auto task = mTaskQueue.front(); in checkToRunPendingTasks()
187 mTaskQueue.pop(); in checkToRunPendingTasks()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/gfx/angle/checkout/src/libANGLE/ |
| H A D | WorkerThread.cpp | 150 std::queue<std::pair<std::shared_ptr<AsyncWaitableEvent>, std::shared_ptr<Closure>>> mTaskQueue; member in angle::AsyncWorkerPool
161 mTaskQueue.push(std::make_pair(waitable, task)); in postWorkerTask()
184 while (mRunningThreads < mMaxThreads && !mTaskQueue.empty()) in checkToRunPendingTasks()
186 auto task = mTaskQueue.front(); in checkToRunPendingTasks()
187 mTaskQueue.pop(); in checkToRunPendingTasks()
|
| /dports/www/firefox/firefox-99.0/gfx/angle/checkout/src/libANGLE/ |
| H A D | WorkerThread.cpp | 150 std::queue<std::pair<std::shared_ptr<AsyncWaitableEvent>, std::shared_ptr<Closure>>> mTaskQueue; member in angle::AsyncWorkerPool
161 mTaskQueue.push(std::make_pair(waitable, task)); in postWorkerTask()
184 while (mRunningThreads < mMaxThreads && !mTaskQueue.empty()) in checkToRunPendingTasks()
186 auto task = mTaskQueue.front(); in checkToRunPendingTasks()
187 mTaskQueue.pop(); in checkToRunPendingTasks()
|
| /dports/mail/thunderbird/thunderbird-91.8.0/gfx/angle/checkout/src/libANGLE/ |
| H A D | WorkerThread.cpp | 150 std::queue<std::pair<std::shared_ptr<AsyncWaitableEvent>, std::shared_ptr<Closure>>> mTaskQueue; member in angle::AsyncWorkerPool
161 mTaskQueue.push(std::make_pair(waitable, task)); in postWorkerTask()
184 while (mRunningThreads < mMaxThreads && !mTaskQueue.empty()) in checkToRunPendingTasks()
186 auto task = mTaskQueue.front(); in checkToRunPendingTasks()
187 mTaskQueue.pop(); in checkToRunPendingTasks()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/dom/media/platforms/omx/ |
| H A D | OmxDecoderModule.cpp | 38 aParams.mConfig, aParams.mTaskQueue, aParams.mImageContainer); in CreateVideoDecoder()
45 new OmxDataDecoder(aParams.mConfig, aParams.mTaskQueue, nullptr); in CreateAudioDecoder()
|
| /dports/www/firefox-legacy/firefox-52.8.0esr/dom/media/platforms/omx/ |
| H A D | GonkOmxPlatformLayer.cpp | 76 mTaskQueue->Dispatch(r.forget()); in onMessage()
89 mTaskQueue->Dispatch(r.forget()); in onMessage()
116 mTaskQueue->Dispatch(r.forget()); in onMessage()
128 MOZ_ASSERT(mTaskQueue->IsCurrentThreadIn()); in Shutdown()
134 : mTaskQueue(aTaskQueue) in GonkOmxObserver()
140 RefPtr<TaskQueue> mTaskQueue; member in mozilla::GonkOmxObserver
346 : mTaskQueue(aTaskQueue) in GonkOmxPlatformLayer()
350 mOmxObserver = new GonkOmxObserver(mTaskQueue, aPromiseLayer, aDataDecoder); in GonkOmxPlatformLayer()
|
| /dports/www/firefox-legacy/firefox-52.8.0esr/dom/media/platforms/agnostic/ |
| H A D | OpusDecoder.cpp | 30 , mTaskQueue(aParams.mTaskQueue) in OpusDataDecoder()
148 mTaskQueue->Dispatch(NewRunnableMethod<RefPtr<MediaRawData>>( in Input()
325 mTaskQueue->Dispatch(NewRunnableMethod(this, &OpusDataDecoder::ProcessDrain)); in Drain()
344 SyncRunnable::DispatchToThread(mTaskQueue, runnable); in Flush()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/dom/media/platforms/apple/ |
| H A D | AppleDecoderModule.cpp | 44 new AppleVTDecoder(aParams.VideoConfig(), aParams.mTaskQueue, in CreateVideoDecoder()
52 new AppleATDecoder(aParams.AudioConfig(), aParams.mTaskQueue); in CreateAudioDecoder()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/android/feed/core/javatests/src/org/chromium/chrome/browser/feed/library/feedstore/ |
| H A D | FeedStoreTest.java | 92 private FakeTaskQueue mTaskQueue; field in FeedStoreTest
99 mTaskQueue = new FakeTaskQueue(mFakeClock, mFakeThreadUtils); in setUp()
100 mTaskQueue.initialize(() -> {}); in setUp()
108 new InMemoryJournalStorage(), mFakeThreadUtils, mTaskQueue, mFakeClock, in getStore()
140 contentStorageSpy, journalStorageSpy, mFakeThreadUtils, mTaskQueue, mFakeClock, in testDumpEphemeralActions_notEphemeralMode()
153 contentStorageSpy, journalStorageSpy, mFakeThreadUtils, mTaskQueue, mFakeClock, in testDumpEphemeralActions_ephemeralMode()
|
| /dports/www/firefox-esr/firefox-91.8.0/dom/media/ |
| H A D | MediaFormatReader.cpp | 497 : mTaskQueue( in DemuxerProxy()
611 mTaskQueue(aTaskQueue), in Wrapper()
636 mTaskQueue, __func__, in Seek()
971 if (mAudio.mTaskQueue) { in TearDownDecoders()
974 mAudio.mTaskQueue = nullptr; in TearDownDecoders()
976 if (mVideo.mTaskQueue) { in TearDownDecoders()
979 mVideo.mTaskQueue = nullptr; in TearDownDecoders()
993 mAudio.mTaskQueue = in Init()
997 mVideo.mTaskQueue = in Init()
1870 mTaskQueue, __func__, in DecodeDemuxedSamples()
[all …]
|
| /dports/lang/spidermonkey78/firefox-78.9.0/dom/media/ |
| H A D | MediaFormatReader.cpp | 454 : mTaskQueue( in DemuxerProxy()
568 mTaskQueue(aTaskQueue), in Wrapper()
593 mTaskQueue, __func__, in Seek()
928 if (mAudio.mTaskQueue) { in TearDownDecoders()
931 mAudio.mTaskQueue = nullptr; in TearDownDecoders()
933 if (mVideo.mTaskQueue) { in TearDownDecoders()
936 mVideo.mTaskQueue = nullptr; in TearDownDecoders()
952 mAudio.mTaskQueue = in Init()
956 mVideo.mTaskQueue = in Init()
1816 mTaskQueue, __func__, in DecodeDemuxedSamples()
[all …]
|
| /dports/www/firefox/firefox-99.0/dom/media/ |
| H A D | MediaFormatReader.cpp | 504 : mTaskQueue( in DemuxerProxy()
618 mTaskQueue(aTaskQueue), in Wrapper()
643 mTaskQueue, __func__, in Seek()
978 if (mAudio.mTaskQueue) { in TearDownDecoders()
981 mAudio.mTaskQueue = nullptr; in TearDownDecoders()
983 if (mVideo.mTaskQueue) { in TearDownDecoders()
986 mVideo.mTaskQueue = nullptr; in TearDownDecoders()
1000 mAudio.mTaskQueue = in Init()
1004 mVideo.mTaskQueue = in Init()
1921 mTaskQueue, __func__, in DecodeDemuxedSamples()
[all …]
|
| /dports/mail/thunderbird/thunderbird-91.8.0/dom/media/ |
| H A D | MediaFormatReader.cpp | 497 : mTaskQueue( in DemuxerProxy()
611 mTaskQueue(aTaskQueue), in Wrapper()
636 mTaskQueue, __func__, in Seek()
971 if (mAudio.mTaskQueue) { in TearDownDecoders()
974 mAudio.mTaskQueue = nullptr; in TearDownDecoders()
976 if (mVideo.mTaskQueue) { in TearDownDecoders()
979 mVideo.mTaskQueue = nullptr; in TearDownDecoders()
993 mAudio.mTaskQueue = in Init()
997 mVideo.mTaskQueue = in Init()
1870 mTaskQueue, __func__, in DecodeDemuxedSamples()
[all …]
|
| /dports/lang/spidermonkey60/firefox-60.9.0/dom/media/ |
| H A D | MediaFormatReader.cpp | 910 mTaskQueue(aTaskQueue), in Wrapper()
932 mTaskQueue, __func__, in Seek()
992 mTaskQueue, __func__, in SkipToNextRandomAccessPoint()
1243 if (mAudio.mTaskQueue) { in TearDownDecoders()
1246 mAudio.mTaskQueue = nullptr; in TearDownDecoders()
1248 if (mVideo.mTaskQueue) { in TearDownDecoders()
1251 mVideo.mTaskQueue = nullptr; in TearDownDecoders()
1267 mAudio.mTaskQueue = in Init()
1271 mVideo.mTaskQueue = in Init()
2111 ->Then(mTaskQueue, __func__, in DecodeDemuxedSamples()
[all …]
|