238         Mutexed<WorkQueue>::Locked queue(mWorkQueue);  in queue_nb()  local
239         queueWasEmpty = queue->empty();  in queue_nb()
241             queue->push_back(std::move(items->front()));  in queue_nb()
266         Mutexed<WorkQueue>::Locked queue(mWorkQueue);  in flush_sm()  local
267         queue->incGeneration();  in flush_sm()
269         while (!queue->empty()) {  in flush_sm()
270             std::unique_ptr<C2Work> work = queue->pop_front();  in flush_sm()
275         while (!queue->pending().empty()) {  in flush_sm()
276             flushedWork->push_back(std::move(queue->pending().begin()->second));  in flush_sm()
277             queue->pending().erase(queue->pending().begin());  in flush_sm()
296         Mutexed<WorkQueue>::Locked queue(mWorkQueue);  in drain_nb()  local
297         queueWasEmpty = queue->empty();  in drain_nb()
298         queue->markDrain(drainMode);  in drain_nb()
340         Mutexed<WorkQueue>::Locked queue(mWorkQueue);  in stop()  local
341         queue->clear();  in stop()
342         queue->pending().clear();  in stop()
361         Mutexed<WorkQueue>::Locked queue(mWorkQueue);  in reset()  local
362         queue->clear();  in reset()
363         queue->pending().clear();  in reset()
395         Mutexed<WorkQueue>::Locked queue(mWorkQueue);  in finish()  local
396         if (queue->pending().count(frameIndex) == 0) {  in finish()
400         work = std::move(queue->pending().at(frameIndex));  in finish()
401         queue->pending().erase(frameIndex);  in finish()
420         Mutexed<WorkQueue>::Locked queue(mWorkQueue);  in cloneAndSend()  local
421         if (queue->pending().count(frameIndex) == 0) {  in cloneAndSend()
425         work->input.flags = queue->pending().at(frameIndex)->input.flags;  in cloneAndSend()
426         work->input.ordinal = queue->pending().at(frameIndex)->input.ordinal;  in cloneAndSend()
444         Mutexed<WorkQueue>::Locked queue(mWorkQueue);  in processQueue()  local
445         if (queue->empty()) {  in processQueue()
449         generation = queue->generation();  in processQueue()
450         drainMode = queue->drainMode();  in processQueue()
451         isFlushPending = queue->popPendingFlush();  in processQueue()
452         work = queue->pop_front();  in processQueue()
453         hasQueuedWork = !queue->empty();  in processQueue()
546     Mutexed<WorkQueue>::Locked queue(mWorkQueue);  in processQueue()  local
547     if (queue->generation() != generation) {  in processQueue()
549                 queue->generation(), generation);  in processQueue()
551         queue.unlock();  in processQueue()
560         queue.unlock();  in processQueue()
572         if (queue->pending().count(frameIndex) != 0) {  in processQueue()
573             unexpected = std::move(queue->pending().at(frameIndex));  in processQueue()
574             queue->pending().erase(frameIndex);  in processQueue()
576         (void)queue->pending().insert({ frameIndex, std::move(work) });  in processQueue()
578         queue.unlock();  in processQueue()