Searched refs:jobQueue_ (Results 1 - 7 of 7) sorted by relevance
| /foundation/multimedia/camera_framework/services/deferred_processing_service/src/schedule/video_processor/video_job_repository/ |
| H A D | video_job_repository.cpp | 24 jobQueue_ = std::make_shared<VideoJobQueue>([] (DeferredVideoJobPtr a, DeferredVideoJobPtr b) {return *a > *b;}); in VideoJobRepository()
43 jobQueue_->Push(jobPtr); in AddVideoJob()
45 static_cast<int>(jobQueue_->GetSize()), videoId.c_str(), srcFd->GetFd()); in AddVideoJob()
60 static_cast<int>(jobQueue_->GetSize()), videoId.c_str()); in RemoveVideoJob()
62 jobQueue_->Remove(jobPtrFind); in RemoveVideoJob()
77 DP_CHECK_EXECUTE(statusChanged, jobQueue_->Update(jobPtrFind)); in RestoreVideoJob()
152 jobQueue_->GetSize(), static_cast<int32_t>(runningSet_.size())); in GetJob()
154 auto jobPtr = jobQueue_->Peek(); in GetJob()
160 jobQueue_->Update(jobPtr); in GetJob()
211 DP_CHECK_EXECUTE(statusChanged, jobQueue_ in UpdateRunningCountUnLocked()
[all...] |
| /foundation/multimedia/camera_framework/services/deferred_processing_service/src/schedule/photo_processor/photo_job_repository/ |
| H A D | photo_job_repository.cpp | 33 jobQueue_(), in PhotoJobRepository()
48 jobQueue_.clear(); in ~PhotoJobRepository()
312 static_cast<int>(jobQueue_.size()), static_cast<int>(offlineJobList_.size()), in GetLowPriorityJob()
333 static_cast<int>(jobQueue_.size()), static_cast<int>(offlineJobList_.size()), in GetNormalPriorityJob()
361 static_cast<int>(jobQueue_.size()), static_cast<int>(offlineJobList_.size()), in GetHighPriorityJob()
364 auto it = std::find_if(jobQueue_.begin(), jobQueue_.end(), [](auto& jobPtr) { in GetHighPriorityJob()
367 return it != jobQueue_.end() ? *it : nullptr; in GetHighPriorityJob()
432 auto it = std::find_if(jobQueue_.begin(), jobQueue_ in UpdateJobQueueUnLocked()
[all...] |
| /foundation/multimedia/media_foundation/src/osal/task/pthread/ |
| H A D | taskInner.cpp | 250 replyCond_.Wait(lock, [this, time] { return jobQueue_.find(time) == jobQueue_.end(); }); in SubmitJob()
256 if (msgQueue_.empty() && ((runningState_.load() != RunningState::STARTED) || jobQueue_.empty())) { in UpdateTop()
261 topProcessUs_ = jobQueue_.begin()->first; in UpdateTop()
263 } else if ((runningState_.load() != RunningState::STARTED) || jobQueue_.empty()) { in UpdateTop()
268 int64_t jobProcessTime = jobQueue_.begin()->first; in UpdateTop()
310 nextJob = std::move(jobQueue_.begin()->second); in HandleJob()
311 jobQueue_.erase(jobQueue_.begin()); in HandleJob()
336 while (jobQueue_ in InsertJob()
[all...] |
| /foundation/multimedia/media_foundation/interface/inner_api/osal/task/ |
| H A D | taskInner.h | 98 std::shared_ptr<ffrt::queue> jobQueue_; member in OHOS::Media::TaskInner
112 std::map<int64_t, std::function<void()>> jobQueue_; // msg will be sorted by timeUs member in OHOS::Media::TaskInner
|
| /foundation/multimedia/camera_framework/frameworks/native/camera/test/unittest/src/v1_1/ |
| H A D | camera_deferred_video_unittest.cpp | 240 auto jobQueue = jobRepository_->jobQueue_; in HWTEST_F()
249 jobQueue = jobRepository_->jobQueue_; in HWTEST_F()
276 auto jobQueue = jobRepository_->jobQueue_; in HWTEST_F()
285 jobQueue = jobRepository_->jobQueue_; in HWTEST_F()
|
| /foundation/multimedia/camera_framework/services/deferred_processing_service/include/schedule/photo_processor/photo_job_repository/ |
| H A D | photo_job_repository.h | 70 std::deque<DeferredPhotoJobPtr> jobQueue_; member in OHOS::CameraStandard::DeferredProcessing::PhotoJobRepository
|
| /foundation/multimedia/camera_framework/services/deferred_processing_service/include/schedule/video_processor/video_job_repository/ |
| H A D | video_job_repository.h | 57 std::shared_ptr<VideoJobQueue> jobQueue_ {nullptr};
|
Completed in 4 milliseconds