35 using std::chrono_literals::operator""ms;
42 void workDone(const std::shared_ptr<android::Codec2Client::Component> &component,
43               std::unique_ptr<C2Work> &work, std::list<uint64_t> &flushedIndices,
44               std::mutex &queueLock, std::condition_variable &queueCondition,
45               std::list<std::unique_ptr<C2Work>> &workQueue, bool &eos, bool &csd,
56     explicit LinearBuffer(const std::shared_ptr<C2LinearBlock> &block)  in LinearBuffer()
59     explicit LinearBuffer(const std::shared_ptr<C2LinearBlock> &block, size_t size)  in LinearBuffer()
70             const std::function<void(std::list<std::unique_ptr<C2Work>> &workItems)> fn = nullptr)  in CodecListener()
72     virtual void onWorkDone(const std::weak_ptr<android::Codec2Client::Component> &comp,  in onWorkDone()
73                             std::list<std::unique_ptr<C2Work>> &workItems) override {  in onWorkDone()
81             const std::weak_ptr<android::Codec2Client::Component> &comp,  in onTripped()
82             const std::vector<std::shared_ptr<C2SettingResult>> &settingResults) override {  in onTripped()
87     virtual void onError(const std::weak_ptr<android::Codec2Client::Component> &comp,  in onError()
93     virtual void onDeath(const std::weak_ptr<android::Codec2Client::Component> &comp) override {  in onDeath()
108     std::function<void(std::list<std::unique_ptr<C2Work>> &workItems)> callBack;
118         mListener.reset(new CodecListener([this](std::list<std::unique_ptr<C2Work>> &workItems) {  in SetUp()
131         std::shared_ptr<C2AllocatorStore> store = android::GetCodec2PlatformAllocatorStore();  in SetUp()
135         mLinearPool = std::make_shared<C2PooledBlockPool>(mLinearAllocator, ++mBlockPoolId);  in SetUp()
154     std::shared_ptr<android::Codec2Client> getClient() {  in getClient()
156         for (std::string instance : instances) {  in getClient()
157             std::shared_ptr<android::Codec2Client> client =  in getClient()
159             std::vector<C2Component::Traits> components = client->listComponents();  in getClient()
176     void checkBufferOK(std::unique_ptr<C2Work> &work) {  in checkBufferOK()
198         std::vector<std::unique_ptr<C2SettingResult>> failures;  in configPixelFormat()
201         std::vector<C2Param *> configParam{&pixelformat};  in configPixelFormat()
210     void handleWorkDone(std::list<std::unique_ptr<C2Work>> &workItems) {  in handleWorkDone()
211         for (std::unique_ptr<C2Work> &work : workItems) {  in handleWorkDone()
229     const std::string mComponentName = "c2.android.hevc.decoder";
235     std::list<uint64_t> mFlushedIndices;
238     std::shared_ptr<C2BlockPool> mLinearPool;
239     std::shared_ptr<C2Allocator> mLinearAllocator;
241     std::mutex mQueueLock;
242     std::condition_variable mQueueCondition;
243     std::list<std::unique_ptr<C2Work>> mWorkQueue;
245     std::shared_ptr<android::Codec2Client> mClient;
246     std::shared_ptr<android::Codec2Client::Listener> mListener;
247     std::shared_ptr<android::Codec2Client::Component> mComponent;
251 void workDone(const std::shared_ptr<android::Codec2Client::Component> &component,  in workDone()
252               std::unique_ptr<C2Work> &work, std::list<uint64_t> &flushedIndices,  in workDone()
253               std::mutex &queueLock, std::condition_variable &queueCondition,  in workDone()
254               std::list<std::unique_ptr<C2Work>> &workQueue, bool &eos, bool &csd,  in workDone()
258         std::vector<std::unique_ptr<C2Param>> updates =  in workDone()
259                 std::move(work->worklets.front()->output.configUpdate);  in workDone()
260         std::vector<C2Param *> configParam;  in workDone()
261         std::vector<std::unique_ptr<C2SettingResult>> failures;  in workDone()
282         auto frameIndexIt = std::find(flushedIndices.begin(), flushedIndices.end(),  in workDone()
287             typedef std::unique_lock<std::mutex> ULock;  in workDone()
289             workQueue.push_back(std::move(work));  in workDone()
298 bool decodeNFrames(const std::shared_ptr<android::Codec2Client::Component> &component,  in decodeNFrames()
299                    std::mutex &queueLock, std::condition_variable &queueCondition,  in decodeNFrames()
300                    std::list<std::unique_ptr<C2Work>> &workQueue,  in decodeNFrames()
301                    std::list<uint64_t> &flushedIndices, std::shared_ptr<C2BlockPool> &linearPool,  in decodeNFrames()
302                    std::ifstream &ifStream, android::Vector<FrameInfo> *Info) {  in decodeNFrames()
303     typedef std::unique_lock<std::mutex> ULock;  in decodeNFrames()
311         std::unique_ptr<C2Work> work;  in decodeNFrames()
356             std::shared_ptr<C2LinearBlock> block;  in decodeNFrames()
388         std::list<std::unique_ptr<C2Work>> items;  in decodeNFrames()
389         items.push_back(std::move(work));  in decodeNFrames()
402 void waitOnInputConsumption(std::mutex &queueLock, std::condition_variable &queueCondition,  in waitOnInputConsumption()
403                             std::list<std::unique_ptr<C2Work>> &workQueue,  in waitOnInputConsumption()
405     typedef std::unique_lock<std::mutex> ULock;  in waitOnInputConsumption()
425 int32_t populateInfoVector(std::string info, android::Vector<FrameInfo> *frameInfo) {  in populateInfoVector()
426     std::ifstream eleInfo;  in populateInfoVector()
463     std::string eleStreamInfo{argv[2]};  in main()
468     std::string eleStream{argv[1]};  in main()
469     std::ifstream ifStream;  in main()
470     ifStream.open(eleStream, std::ifstream::binary);  in main()