Home
last modified time | relevance | path

Searched refs:jobQueue_ (Results 1 – 12 of 12) sorted by relevance

/ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/src/schedule/video_processor/video_job_repository/
H A Dvideo_job_repository.cpp24 …jobQueue_ = std::make_shared<VideoJobQueue>([] (DeferredVideoJobPtr a, DeferredVideoJobPtr b) {ret… 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_->Update(jobPtr)); in UpdateRunningCountUnLocked()
[all …]
/ohos5.0/foundation/multimedia/media_foundation/src/osal/task/pthread/
H A DtaskInner.cpp249 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()
311 nextJob = std::move(jobQueue_.begin()->second); in HandleJob()
312 jobQueue_.erase(jobQueue_.begin()); in HandleJob()
338 … while (jobQueue_.find(processTime) != jobQueue_.end()) { // To prevent dropping job unexpectedly in InsertJob()
342 jobQueue_[processTime] = std::move(job); in InsertJob()
/ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/src/schedule/photo_processor/photo_job_repository/
H A Dphoto_job_repository.cpp33 jobQueue_(), in PhotoJobRepository()
48 jobQueue_.clear(); in ~PhotoJobRepository()
362 auto it = std::find_if(jobQueue_.begin(), jobQueue_.end(), [](auto& jobPtr) { in GetHighPriorityJob()
365 return it != jobQueue_.end() ? *it : nullptr; in GetHighPriorityJob()
430 …auto it = std::find_if(jobQueue_.begin(), jobQueue_.end(), [jobPtr](const auto& ptr) { return ptr … in UpdateJobQueueUnLocked()
431 if (it != jobQueue_.end()) { in UpdateJobQueueUnLocked()
432 jobQueue_.erase(it); in UpdateJobQueueUnLocked()
436 jobQueue_.push_front(jobPtr); in UpdateJobQueueUnLocked()
438 …auto it = std::find_if(jobQueue_.begin(), jobQueue_.end(), [jobPtr](const auto& ptr) { return ptr … in UpdateJobQueueUnLocked()
439 if (it != jobQueue_.end()) { in UpdateJobQueueUnLocked()
[all …]
/ohos5.0/base/print/print_fwk/test/unittest/others/
H A Dprint_cups_client_vendor_helper_other_test.cpp288 EXPECT_EQ(client.jobQueue_.size(), 1); in TEST_F()
300 EXPECT_EQ(client.jobQueue_.size(), 0); in TEST_F()
309 client.jobQueue_.clear(); in TEST_F()
312 EXPECT_EQ(client.jobQueue_.size(), 1); in TEST_F()
324 EXPECT_EQ(client.jobQueue_.size(), 1); in TEST_F()
336 EXPECT_EQ(client.jobQueue_.size(), 0); in TEST_F()
349 EXPECT_EQ(client.jobQueue_.size(), 1); in TEST_F()
361 EXPECT_EQ(client.jobQueue_.size(), 0); in TEST_F()
373 EXPECT_EQ(client.jobQueue_.size(), 1); in TEST_F()
385 EXPECT_EQ(client.jobQueue_.size(), 0); in TEST_F()
[all …]
/ohos5.0/foundation/multimedia/media_foundation/interface/inner_api/osal/task/
H A DtaskInner.h98 std::shared_ptr<ffrt::queue> jobQueue_; variable
112 std::map<int64_t, std::function<void()>> jobQueue_; // msg will be sorted by timeUs variable
/ohos5.0/foundation/multimedia/camera_framework/frameworks/native/camera/test/unittest/src/v1_1/
H A Dcamera_deferred_video_unittest.cpp240 auto jobQueue = jobRepository_->jobQueue_;
249 jobQueue = jobRepository_->jobQueue_;
276 auto jobQueue = jobRepository_->jobQueue_;
285 jobQueue = jobRepository_->jobQueue_;
/ohos5.0/base/print/print_fwk/services/print_service/src/
H A Dprint_cups_client.cpp782 jobQueue_.push_back(jobParams); in AddCupsPrintJob()
788 if (jobQueue_.empty()) { in GetNextJob()
793 JobParameters *lastJob = jobQueue_.back(); in GetNextJob()
798 PRINT_HILOGE("a active job is running, job len: %{public}zd", jobQueue_.size()); in GetNextJob()
804 currentJob_ = jobQueue_.at(0); in GetNextJob()
805 jobQueue_.erase(jobQueue_.begin()); in GetNextJob()
1581 for (int index = 0; index < static_cast<int>(jobQueue_.size()); index++) { in CancelCupsJob()
1582 …PRINT_HILOGD("jobQueue_[index]->serviceJobId: %{public}s", jobQueue_[index]->serviceJobId.c_str()); in CancelCupsJob()
1583 if (jobQueue_[index]->serviceJobId == serviceJobId) { in CancelCupsJob()
1591 JobParameters* erasedJob = jobQueue_.at(jobIndex); in CancelCupsJob()
[all …]
/ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/include/schedule/video_processor/video_job_repository/
H A Dvideo_job_repository.h57 std::shared_ptr<VideoJobQueue> jobQueue_ {nullptr};
/ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/include/schedule/photo_processor/photo_job_repository/
H A Dphoto_job_repository.h70 std::deque<DeferredPhotoJobPtr> jobQueue_; variable
/ohos5.0/base/print/print_fwk/test/unittest/fwk_print_cups_client_test/
H A Dprint_cups_wrapper_test.cpp331 printCupsClient.jobQueue_.push_back(jobParams1);
332 printCupsClient.jobQueue_.push_back(jobParams2);
H A Dprint_cups_client_test.cpp330 printCupsClient->jobQueue_.push_back(jobParams);
347 printCupsClient->jobQueue_.push_back(jobParams);
1262 printCupsClient.jobQueue_.push_back(jobParams);
1263 …"CancelCupsJob(): printCupsClient.jobQueue_.size(): %{public}u", printCupsClient.jobQueue_.size());
1287 printCupsClient.jobQueue_.push_back(jobParams);
/ohos5.0/base/print/print_fwk/services/print_service/include/
H A Dprint_cups_client.h160 std::vector<JobParameters*> jobQueue_; variable