Lines Matching refs:work
767 void fillEmptyWork(const std::unique_ptr<C2Work> &work) { in fillEmptyWork() argument
769 if (work->input.flags & C2FrameData::FLAG_END_OF_STREAM) { in fillEmptyWork()
773 work->worklets.front()->output.flags = (C2FrameData::flags_t)flags; in fillEmptyWork()
774 work->worklets.front()->output.buffers.clear(); in fillEmptyWork()
775 work->worklets.front()->output.ordinal = work->input.ordinal; in fillEmptyWork()
776 work->workletsProcessed = 1u; in fillEmptyWork()
779 void C2SoftMpeg2Dec::finishWork(uint64_t index, const std::unique_ptr<C2Work> &work) { in finishWork() argument
795 void operator()(const std::unique_ptr<C2Work>& work) { in finishWork() argument
796 work->worklets.front()->output.flags = (C2FrameData::flags_t)mFlags; in finishWork()
797 work->worklets.front()->output.buffers.clear(); in finishWork()
798 work->worklets.front()->output.ordinal = mOrdinal; in finishWork()
799 work->workletsProcessed = 1u; in finishWork()
800 work->result = C2_OK; in finishWork()
802 work->worklets.front()->output.buffers.push_back(mBuffer); in finishWork()
815 auto fillWork = [buffer](const std::unique_ptr<C2Work> &work) { in finishWork() argument
816 work->worklets.front()->output.flags = (C2FrameData::flags_t)0; in finishWork()
817 work->worklets.front()->output.buffers.clear(); in finishWork()
818 work->worklets.front()->output.buffers.push_back(buffer); in finishWork()
819 work->worklets.front()->output.ordinal = work->input.ordinal; in finishWork()
820 work->workletsProcessed = 1u; in finishWork()
822 if (work && c2_cntr64_t(index) == work->input.ordinal.frameIndex) { in finishWork()
823 bool eos = ((work->input.flags & C2FrameData::FLAG_END_OF_STREAM) != 0); in finishWork()
828 C2WorkOrdinalStruct outOrdinal = work->input.ordinal; in finishWork()
830 mOutIndex, work, in finishWork()
835 fillWork(work); in finishWork()
874 const std::unique_ptr<C2Work> &work, in process() argument
877 work->result = C2_OK; in process()
878 work->workletsProcessed = 0u; in process()
879 work->worklets.front()->output.configUpdate.clear(); in process()
880 work->worklets.front()->output.flags = work->input.flags; in process()
883 work->result = C2_BAD_VALUE; in process()
889 uint32_t workIndex = work->input.ordinal.frameIndex.peeku() & 0xFFFFFFFF; in process()
891 if (!work->input.buffers.empty()) { in process()
892 rView = work->input.buffers[0]->data().linearBlocks().front().map().get(); in process()
896 work->result = C2_CORRUPTED; in process()
900 bool eos = ((work->input.flags & C2FrameData::FLAG_END_OF_STREAM) != 0); in process()
904 inSize, (int)work->input.ordinal.timestamp.peeku(), in process()
905 (int)work->input.ordinal.frameIndex.peeku(), work->input.flags); in process()
910 work->workletsProcessed = 1u; in process()
911 work->result = C2_CORRUPTED; in process()
917 work->result = C2_CORRUPTED; in process()
926 work->workletsProcessed = 1u; in process()
927 work->result = C2_CORRUPTED; in process()
943 drainInternal(DRAIN_COMPONENT_NO_EOS, pool, work); in process()
945 work->workletsProcessed = 0u; in process()
956 work->worklets.front()->output.configUpdate.push_back( in process()
961 work->workletsProcessed = 1u; in process()
962 work->result = C2_CORRUPTED; in process()
969 work->workletsProcessed = 1u; in process()
970 work->result = C2_CORRUPTED; in process()
976 drainInternal(DRAIN_COMPONENT_NO_EOS, pool, work); in process()
979 work->workletsProcessed = 0u; in process()
995 work->worklets.front()->output.configUpdate.push_back( in process()
1000 work->workletsProcessed = 1u; in process()
1001 work->result = C2_CORRUPTED; in process()
1010 finishWork(s_decode_op.u4_ts, work); in process()
1022 drainInternal(DRAIN_COMPONENT_WITH_EOS, pool, work); in process()
1025 fillEmptyWork(work); in process()
1032 const std::unique_ptr<C2Work> &work) { in drainInternal() argument
1046 work->workletsProcessed = 1u; in drainInternal()
1047 work->result = C2_CORRUPTED; in drainInternal()
1059 work->workletsProcessed = 1u; in drainInternal()
1064 finishWork(s_decode_op.u4_ts, work); in drainInternal()
1066 fillEmptyWork(work); in drainInternal()