Loading media/codec2/sfplugin/C2OMXNode.cpp +3 −1 Original line number Original line Diff line number Diff line Loading @@ -76,10 +76,11 @@ protected: Mutexed<Jobs>::Locked jobs(mJobs); Mutexed<Jobs>::Locked jobs(mJobs); nsecs_t nowNs = systemTime(); nsecs_t nowNs = systemTime(); bool queued = false; bool queued = false; for (auto it = jobs->queues.begin(); it != jobs->queues.end(); ++it) { for (auto it = jobs->queues.begin(); it != jobs->queues.end(); ) { Queue &queue = it->second; Queue &queue = it->second; if (queue.workList.empty() if (queue.workList.empty() || nowNs - queue.lastQueuedTimestampNs < kIntervalNs) { || nowNs - queue.lastQueuedTimestampNs < kIntervalNs) { ++it; continue; continue; } } std::shared_ptr<Codec2Client::Component> comp = queue.component.lock(); std::shared_ptr<Codec2Client::Component> comp = queue.component.lock(); Loading Loading @@ -109,6 +110,7 @@ protected: } } jobs.lock(); jobs.lock(); it = jobs->queues.upper_bound(comp); queued = true; queued = true; } } if (queued) { if (queued) { Loading Loading
media/codec2/sfplugin/C2OMXNode.cpp +3 −1 Original line number Original line Diff line number Diff line Loading @@ -76,10 +76,11 @@ protected: Mutexed<Jobs>::Locked jobs(mJobs); Mutexed<Jobs>::Locked jobs(mJobs); nsecs_t nowNs = systemTime(); nsecs_t nowNs = systemTime(); bool queued = false; bool queued = false; for (auto it = jobs->queues.begin(); it != jobs->queues.end(); ++it) { for (auto it = jobs->queues.begin(); it != jobs->queues.end(); ) { Queue &queue = it->second; Queue &queue = it->second; if (queue.workList.empty() if (queue.workList.empty() || nowNs - queue.lastQueuedTimestampNs < kIntervalNs) { || nowNs - queue.lastQueuedTimestampNs < kIntervalNs) { ++it; continue; continue; } } std::shared_ptr<Codec2Client::Component> comp = queue.component.lock(); std::shared_ptr<Codec2Client::Component> comp = queue.component.lock(); Loading Loading @@ -109,6 +110,7 @@ protected: } } jobs.lock(); jobs.lock(); it = jobs->queues.upper_bound(comp); queued = true; queued = true; } } if (queued) { if (queued) { Loading