Lines Matching refs:work

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()
270 std::unique_ptr<C2Work> work = queue->pop_front(); in flush_sm() local
271 if (work) { in flush_sm()
272 flushedWork->push_back(std::move(work)); in flush_sm()
383 std::list<std::unique_ptr<C2Work>> vec(std::unique_ptr<C2Work> &work) { in vec() argument
385 ret.push_back(std::move(work)); in vec()
393 std::unique_ptr<C2Work> work; in finish() local
400 work = std::move(queue->pending().at(frameIndex)); in finish()
403 if (work) { in finish()
404 fillWork(work); in finish()
406 listener->onWorkDone_nb(shared_from_this(), vec(work)); in finish()
415 std::unique_ptr<C2Work> work(new C2Work); in cloneAndSend() local
417 work->input.flags = currentWork->input.flags; in cloneAndSend()
418 work->input.ordinal = currentWork->input.ordinal; 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()
428 work->worklets.emplace_back(new C2Worklet); in cloneAndSend()
429 if (work) { in cloneAndSend()
430 fillWork(work); in cloneAndSend()
432 listener->onWorkDone_nb(shared_from_this(), vec(work)); in cloneAndSend()
438 std::unique_ptr<C2Work> work; in processQueue() local
452 work = queue->pop_front(); in processQueue()
511 if (!work) { in processQueue()
524 for (const std::unique_ptr<C2Param> &param: work->input.configUpdate) { in processQueue()
536 ALOGV("start processing frame #%" PRIu64, work->input.ordinal.frameIndex.peeku()); in processQueue()
540 if (!work->input.buffers.empty() && !work->input.buffers[0]) { in processQueue()
542 work->input.buffers.clear(); in processQueue()
544 process(work, mOutputBlockPool); in processQueue()
545 ALOGV("processed frame #%" PRIu64, work->input.ordinal.frameIndex.peeku()); in processQueue()
550 work->result = C2_NOT_FOUND; in processQueue()
556 listener->onWorkDone_nb(shared_from_this(), vec(work)); in processQueue()
559 if (work->workletsProcessed != 0u) { in processQueue()
565 listener->onWorkDone_nb(shared_from_this(), vec(work)); in processQueue()
568 work->input.buffers.clear(); in processQueue()
571 uint64_t frameIndex = work->input.ordinal.frameIndex.peeku(); in processQueue()
576 (void)queue->pending().insert({ frameIndex, std::move(work) }); in processQueue()