Lines Matching refs:work
471 const std::unique_ptr<C2Work> &work, in drainRingBuffer() argument
499 const std::unique_ptr<C2Work> &work, c2_status_t err) { in drainRingBuffer() argument
500 work->result = err; in drainRingBuffer()
501 C2FrameData &output = work->worklets.front()->output; in drainRingBuffer()
502 output.flags = work->input.flags; in drainRingBuffer()
504 output.ordinal = work->input.ordinal; in drainRingBuffer()
506 work->workletsProcessed = 1u; in drainRingBuffer()
532 const std::unique_ptr<C2Work> &work) { in drainRingBuffer() argument
533 work->result = C2_OK; in drainRingBuffer()
534 C2FrameData &output = work->worklets.front()->output; in drainRingBuffer()
535 output.flags = work->input.flags; in drainRingBuffer()
538 output.ordinal = work->input.ordinal; in drainRingBuffer()
539 work->workletsProcessed = 1u; in drainRingBuffer()
543 if (work && work->input.ordinal.frameIndex == c2_cntr64_t(outInfo.frameIndex)) { in drainRingBuffer()
544 fillWork(work); in drainRingBuffer()
555 const std::unique_ptr<C2Work> &work, in process() argument
558 work->result = C2_OK; in process()
559 work->workletsProcessed = 1u; in process()
560 work->worklets.front()->output.configUpdate.clear(); in process()
561 work->worklets.front()->output.flags = work->input.flags; in process()
575 if (!work->input.buffers.empty()) { in process()
576 view = work->input.buffers[0]->data().linearBlocks().front().map().get(); in process()
580 bool eos = (work->input.flags & C2FrameData::FLAG_END_OF_STREAM) != 0; in process()
581 bool codecConfig = (work->input.flags & C2FrameData::FLAG_CODEC_CONFIG) != 0; in process()
603 work->result = C2_CORRUPTED; in process()
606 work->worklets.front()->output.flags = work->input.flags; in process()
607 work->worklets.front()->output.ordinal = work->input.ordinal; in process()
608 work->worklets.front()->output.buffers.clear(); in process()
613 inInfo.frameIndex = work->input.ordinal.frameIndex.peeku(); in process()
614 inInfo.timestamp = work->input.ordinal.timestamp.peeku(); in process()
664 work->result = C2_CORRUPTED; in process()
765 work->result = C2_CORRUPTED; in process()
776 work->result = C2_CORRUPTED; in process()
787 work->result = C2_CORRUPTED; in process()
840 C2FrameData &output = work->worklets.front()->output; in process()
846 work->result = C2_CORRUPTED; in process()
862 work->worklets.front()->output.configUpdate.push_back( in process()
876 work->worklets.front()->output.configUpdate.push_back( in process()
881 work->worklets.front()->output.configUpdate.push_back( in process()
889 work->worklets.front()->output.configUpdate.push_back( in process()
895 work->worklets.front()->output.configUpdate.push_back( in process()
900 work->worklets.front()->output.configUpdate.push_back( in process()
905 work->worklets.front()->output.configUpdate.push_back( in process()
910 work->worklets.front()->output.configUpdate.push_back( in process()
914 work->worklets.front()->output.configUpdate.push_back( in process()
934 work->worklets.front()->output.configUpdate.push_back( in process()
939 work->workletsProcessed = 1u; in process()
940 work->result = C2_CORRUPTED; in process()
946 work->workletsProcessed = 0u; in process()
960 drainInternal(DRAIN_COMPONENT_WITH_EOS, pool, work); in process()
962 drainRingBuffer(work, pool, false /* not EOS */); in process()
969 const std::unique_ptr<C2Work> &work) { in drainInternal() argument
982 drainRingBuffer(work, pool, eos); in drainInternal()
985 auto fillEmptyWork = [](const std::unique_ptr<C2Work> &work) { in drainInternal() argument
986 work->worklets.front()->output.flags = work->input.flags; in drainInternal()
987 work->worklets.front()->output.buffers.clear(); in drainInternal()
988 work->worklets.front()->output.ordinal = work->input.ordinal; in drainInternal()
989 work->workletsProcessed = 1u; in drainInternal()
995 if (work && work->workletsProcessed == 0u) { in drainInternal()
996 fillEmptyWork(work); in drainInternal()