34     std::unique_ptr<C2Work> work = std::move(mQueue.front().work);  in pop_front()  local
36     return work;  in pop_front()
39 void SimpleC2Component::WorkQueue::push_back(std::unique_ptr<C2Work> work) {  in push_back()  argument
40     mQueue.push_back({ std::move(work), NO_DRAIN });  in push_back()
220             std::unique_ptr<C2Work> work = queue->pop_front();  in flush_sm()  local
221             if (work) {  in flush_sm()
222                 flushedWork->push_back(std::move(work));  in flush_sm()
342 std::list<std::unique_ptr<C2Work>> vec(std::unique_ptr<C2Work> &work) {  in vec()  argument
344     ret.push_back(std::move(work));  in vec()
352     std::unique_ptr<C2Work> work;  in finish()  local
359         work = std::move(pending->at(frameIndex));  in finish()
362     if (work) {  in finish()
363         fillWork(work);  in finish()
365         listener->onWorkDone_nb(shared_from_this(), vec(work));  in finish()
374     std::unique_ptr<C2Work> work(new C2Work);  in cloneAndSend()  local
376         work->input.flags = currentWork->input.flags;  in cloneAndSend()
377         work->input.ordinal = currentWork->input.ordinal;  in cloneAndSend()
384         work->input.flags = pending->at(frameIndex)->input.flags;  in cloneAndSend()
385         work->input.ordinal = pending->at(frameIndex)->input.ordinal;  in cloneAndSend()
387     work->worklets.emplace_back(new C2Worklet);  in cloneAndSend()
388     if (work) {  in cloneAndSend()
389         fillWork(work);  in cloneAndSend()
391         listener->onWorkDone_nb(shared_from_this(), vec(work));  in cloneAndSend()
397     std::unique_ptr<C2Work> work;  in processQueue()  local
411         work = queue->pop_front();  in processQueue()
466     if (!work) {  in processQueue()
479         for (const std::unique_ptr<C2Param> &param: work->input.configUpdate) {  in processQueue()
491     ALOGV("start processing frame #%" PRIu64, work->input.ordinal.frameIndex.peeku());  in processQueue()
495     if (!work->input.buffers.empty() && !work->input.buffers[0]) {  in processQueue()
497         work->input.buffers.clear();  in processQueue()
499     process(work, mOutputBlockPool);  in processQueue()
500     ALOGV("processed frame #%" PRIu64, work->input.ordinal.frameIndex.peeku());  in processQueue()
506             work->result = C2_NOT_FOUND;  in processQueue()
512                 listener->onWorkDone_nb(shared_from_this(), vec(work));  in processQueue()
518     if (work->workletsProcessed != 0u) {  in processQueue()
523         listener->onWorkDone_nb(shared_from_this(), vec(work));  in processQueue()
526         work->input.buffers.clear();  in processQueue()
530             uint64_t frameIndex = work->input.ordinal.frameIndex.peeku();  in processQueue()
535             (void)pending->insert({ frameIndex, std::move(work) });  in processQueue()