Home
last modified time | relevance | path

Searched refs:INVALID_TASK_ID (Results 1 – 25 of 48) sorted by relevance

12

/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/include/
H A Dtask_executor.h27 static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l); variable
40 return INVALID_TASK_ID; in Execute()
45 return INVALID_TASK_ID; in Schedule()
50 return INVALID_TASK_ID; in Schedule()
55 return INVALID_TASK_ID; in Schedule()
60 return INVALID_TASK_ID; in Schedule()
70 return INVALID_TASK_ID; in Reset()
/ohos5.0/foundation/resourceschedule/ffrt/src/queue/
H A Dqueue_monitor.cpp26 constexpr uint32_t INVALID_TASK_ID = 0; variable
72 …queuesRunningInfo_.emplace_back(std::make_pair(INVALID_TASK_ID, std::chrono::steady_clock::now())); in RegisterQueueId()
74 lastReportedTask_.emplace_back(INVALID_TASK_ID); in RegisterQueueId()
82 …queuesRunningInfo_.emplace_back(std::make_pair(INVALID_TASK_ID, std::chrono::steady_clock::now())); in RegisterQueueId()
84 lastReportedTask_.emplace_back(INVALID_TASK_ID); in RegisterQueueId()
99 queuesRunningInfo_[queueId].first = INVALID_TASK_ID; in ResetQueueInfo()
100 lastReportedTask_[queueId] = INVALID_TASK_ID; in ResetQueueInfo()
126 FFRT_COND_DO_ERR((queuesRunningInfo_.size() <= queueId), return INVALID_TASK_ID, in QueryQueueStatus()
158 [](const auto& pair) { return pair.first != INVALID_TASK_ID; }); in CheckQueuesStatus()
181 if (taskId == INVALID_TASK_ID) { in CheckQueuesStatus()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/common/
H A Dtask_scheduler.h38 inline static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l); variable
45 taskId_ = INVALID_TASK_ID; in TaskScheduler()
67 return INVALID_TASK_ID;
90 return INVALID_TASK_ID; in Reset()
146 TaskId taskId = INVALID_TASK_ID;
190 if (taskId == INVALID_TASK_ID) { in GenTaskId()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/
H A Dtask_executor.cpp36 return INVALID_TASK_ID; in Execute()
47 return INVALID_TASK_ID; in Schedule()
63 return INVALID_TASK_ID; in Reset()
H A Dauto_sync_timer_mock.cpp31 if (forceSyncTaskId_ == TaskExecutor::INVALID_TASK_ID) { in StartTimer()
35 if (delaySyncTaskId_ == TaskExecutor::INVALID_TASK_ID) { in StartTimer()
129 forceSyncTaskId_ = TaskExecutor::INVALID_TASK_ID; in StopTimer()
130 delaySyncTaskId_ = TaskExecutor::INVALID_TASK_ID; in StopTimer()
H A Dauto_sync_timer.cpp33 if (forceSyncTaskId_ == TaskExecutor::INVALID_TASK_ID) { in StartTimer()
37 if (delaySyncTaskId_ == TaskExecutor::INVALID_TASK_ID) { in StartTimer()
147 forceSyncTaskId_ = TaskExecutor::INVALID_TASK_ID; in StopTimer()
148 delaySyncTaskId_ = TaskExecutor::INVALID_TASK_ID; in StopTimer()
/ohos5.0/foundation/multimedia/av_session/utils/include/
H A Davsession_trace.h37 INVALID_TASK_ID = -1, enumerator
91 if (taskId <= INVALID_TASK_ID) { in TraceBegin()
101 if (taskId <= INVALID_TASK_ID) { in TraceEnd()
/ohos5.0/foundation/distributeddatamgr/preferences/frameworks/native/include/
H A Dexecutor_pool.h44 static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l); variable
47 : pool_(max, min), delayTasks_(InnerTask(), NextTimer), taskId_(INVALID_TASK_ID) in ExecutorPool()
81 return INVALID_TASK_ID; in Execute()
139 return updated ? taskId : INVALID_TASK_ID; in Reset()
200 if (taskId == INVALID_TASK_ID) { in GenTaskId()
H A Dexecutor.h38 static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l); variable
49 TaskId taskId = INVALID_TASK_ID;
54 return taskId != INVALID_TASK_ID; in Valid()
/ohos5.0/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Dexecutor_pool.h41 static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l); variable
44 : pool_(max, min), delayTasks_(InnerTask(), NextTimer), taskId_(INVALID_TASK_ID) in ExecutorPool()
77 return INVALID_TASK_ID; in Execute()
135 return updated ? taskId : INVALID_TASK_ID; in Reset()
196 if (taskId == INVALID_TASK_ID) { in GenTaskId()
H A Dexecutor.h35 static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l); variable
46 TaskId taskId = INVALID_TASK_ID;
51 return taskId != INVALID_TASK_ID; in Valid()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/
H A Ddb_delegate.cpp23 ExecutorPool::TaskId DBDelegate::taskId_ = ExecutorPool::INVALID_TASK_ID;
78 if (executor_ == nullptr || taskId_ != Executor::INVALID_TASK_ID) { in StartTimer()
85 if (executor_ == nullptr || taskId_ == Executor::INVALID_TASK_ID) { in StartTimer()
90 taskId_ = Executor::INVALID_TASK_ID; in StartTimer()
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/
H A Dtask_executor.h24 static constexpr TaskId INVALID_TASK_ID = ExecutorPool::INVALID_TASK_ID; variable
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/common/test/
H A Dexecutor_pool_test.cpp90 ASSERT_NE(taskId, ExecutorPool::INVALID_TASK_ID);
201 auto taskId = ExecutorPool::INVALID_TASK_ID;
207 taskId = ExecutorPool::INVALID_TASK_ID; in __anon319724040902()
211 ASSERT_EQ(taskId, ExecutorPool::INVALID_TASK_ID);
H A Dpriority_queue_test.cpp37 static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0); variable
45 TaskId taskId = INVALID_TASK_ID;
50 return taskId != INVALID_TASK_ID; in Valid()
65 PriorityQueue<TestTask, Time, TaskId>::PQMatrix(TestTask(), INVALID_TASK_ID);
115 EXPECT_EQ(retPop.taskId, INVALID_TASK_ID);
246 EXPECT_EQ(retFind.taskId, INVALID_TASK_ID);
270 EXPECT_EQ(retFind.taskId, INVALID_TASK_ID);
H A Dtask_scheduler_test.cpp128 ASSERT_EQ(resetTaskId, TaskScheduler::INVALID_TASK_ID);
154 ASSERT_EQ(resetTaskId, TaskScheduler::INVALID_TASK_ID);
181 ASSERT_EQ(resetId, TaskScheduler::INVALID_TASK_ID);
204 ASSERT_EQ(resetId, TaskScheduler::INVALID_TASK_ID);
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Ddelay_notify.cpp29 if (delaySyncTaskId_ != Executor::INVALID_TASK_ID) { in ~DelayNotify()
88 if (delaySyncTaskId_ == Executor::INVALID_TASK_ID) { in StartTimer()
127 delaySyncTaskId_ = Executor::INVALID_TASK_ID; in StopTimer()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/store/
H A Dstore_cache.cpp65 if (taskId_ == ExecutorPool::INVALID_TASK_ID && executorPool_ != nullptr) { in GetStore()
86 taskId_ = ExecutorPool::INVALID_TASK_ID; in GarbageCollect()
H A Dstore_cache.h47 ExecutorPool::TaskId taskId_ = ExecutorPool::INVALID_TASK_ID;
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/lifecycle/
H A Dlifecycle_manager.cpp49 if (taskId == ExecutorPool::INVALID_TASK_ID) { in OnGot()
83 if (taskId == ExecutorPool::INVALID_TASK_ID) { in StartLifeCycleTimer()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/permission/
H A Duri_permission_manager.cpp69 if (taskId_ == ExecutorPool::INVALID_TASK_ID && executorPool_ != nullptr) { in GrantUriPermission()
110 taskId_ = ExecutorPool::INVALID_TASK_ID; in RevokeUriPermission()
H A Duri_permission_manager.h46 ExecutorPool::TaskId taskId_ = ExecutorPool::INVALID_TASK_ID;
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/store/
H A Dauto_cache.cpp43 if (executor == nullptr || taskId_ != Executor::INVALID_TASK_ID) { in Bind()
126 if (executor_ == nullptr || taskId_ != Executor::INVALID_TASK_ID) { in StartTimer()
133 if (executor_ == nullptr || taskId_ == Executor::INVALID_TASK_ID) { in StartTimer()
138 taskId_ = Executor::INVALID_TASK_ID; in StartTimer()
/ohos5.0/foundation/multimedia/av_session/frameworks/js/napi/session/src/
H A Dnapi_async_work.cpp104 if (!ctxt->taskName.empty() && ctxt->taskId > INVALID_TASK_ID) { in Enqueue()
120 if (!ctxt->taskName.empty() && ctxt->taskId > INVALID_TASK_ID) { in Enqueue()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/
H A Dkvstore_meta_manager.cpp72 if (delaySyncTaskId_ != ExecutorPool::INVALID_TASK_ID) { in ~KvStoreMetaManager()
74 delaySyncTaskId_ = ExecutorPool::INVALID_TASK_ID; in ~KvStoreMetaManager()
338 if (delaySyncTaskId_ == Executor::INVALID_TASK_ID) { in SetCloudSyncer()
352 delaySyncTaskId_ = ExecutorPool::INVALID_TASK_ID; in CloudSyncTask()

12