Home
last modified time | relevance | path

Searched refs:INVALID_TASK_ID (Results 1 - 25 of 49) sorted by relevance

12

/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); member in OHOS::NativeRdb::TaskExecutor
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()
/foundation/resourceschedule/ffrt/src/queue/
H A Dqueue_monitor.cpp26 constexpr uint32_t INVALID_TASK_ID = 0; member
84 queuesRunningInfo_.emplace_back(std::make_pair(INVALID_TASK_ID, std::chrono::steady_clock::now())); in RegisterQueueId()
86 lastReportedTask_.emplace_back(INVALID_TASK_ID); in RegisterQueueId()
94 queuesRunningInfo_.emplace_back(std::make_pair(INVALID_TASK_ID, std::chrono::steady_clock::now())); in RegisterQueueId()
96 lastReportedTask_.emplace_back(INVALID_TASK_ID); in RegisterQueueId()
111 queuesRunningInfo_[queueId].first = INVALID_TASK_ID; in ResetQueueInfo()
112 lastReportedTask_[queueId] = INVALID_TASK_ID; in ResetQueueInfo()
139 FFRT_COND_DO_ERR((queuesRunningInfo_.size() <= queueId), return INVALID_TASK_ID, in QueryQueueStatus()
175 [](const auto& pair) { return pair.first != INVALID_TASK_ID; }); in CheckQueuesStatus()
213 if (taskId == INVALID_TASK_ID) { in CheckQueuesStatus()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/
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 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.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()
/foundation/multimedia/av_session/utils/include/
H A Davsession_trace.h37 INVALID_TASK_ID = -1,
90 if (taskId <= INVALID_TASK_ID) { in TraceBegin()
100 if (taskId <= INVALID_TASK_ID) { in TraceEnd()
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/
H A Dtask_executor.h24 static constexpr TaskId INVALID_TASK_ID = ExecutorPool::INVALID_TASK_ID; member in OHOS::NativeRdb::TaskExecutor
H A Ddelay_notify.h47 ExecutorPool::TaskId delaySyncTaskId_ = ExecutorPool::INVALID_TASK_ID;
/foundation/distributeddatamgr/udmf/framework/innerkitsimpl/client/
H A Dasync_obtain_data.h49 ExecutorPool::TaskId progressTaskId_ = ExecutorPool::INVALID_TASK_ID;
50 ExecutorPool::TaskId obtainDataTaskId_ = ExecutorPool::INVALID_TASK_ID;
/foundation/distributeddatamgr/kv_store/frameworks/common/
H A Dtask_scheduler.h38 inline static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l); member in OHOS::TaskScheduler
45 taskId_ = INVALID_TASK_ID; in TaskScheduler()
67 return INVALID_TASK_ID; in At()
90 return INVALID_TASK_ID; in Reset()
146 TaskId taskId = INVALID_TASK_ID;
190 if (taskId == INVALID_TASK_ID) { in GenTaskId()
/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()
/foundation/distributeddatamgr/kv_store/frameworks/common/test/
H A Dexecutor_pool_test.cpp90 ASSERT_NE(taskId, ExecutorPool::INVALID_TASK_ID); in HWTEST_F()
201 auto taskId = ExecutorPool::INVALID_TASK_ID; in HWTEST_F()
207 taskId = ExecutorPool::INVALID_TASK_ID; in HWTEST_F()
211 ASSERT_EQ(taskId, ExecutorPool::INVALID_TASK_ID); in HWTEST_F()
H A Dtask_scheduler_test.cpp128 ASSERT_EQ(resetTaskId, TaskScheduler::INVALID_TASK_ID); in HWTEST_F()
154 ASSERT_EQ(resetTaskId, TaskScheduler::INVALID_TASK_ID); in HWTEST_F()
181 ASSERT_EQ(resetId, TaskScheduler::INVALID_TASK_ID); in HWTEST_F()
204 ASSERT_EQ(resetId, TaskScheduler::INVALID_TASK_ID); in HWTEST_F()
H A Dpriority_queue_test.cpp37 static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l); member
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); in HWTEST_F()
246 EXPECT_EQ(retFind.taskId, INVALID_TASK_ID); in HWTEST_F()
270 EXPECT_EQ(retFind.taskId, INVALID_TASK_ID); in HWTEST_F()
/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;
/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Dexecutor.h35 static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l); member in OHOS::Executor
46 TaskId taskId = INVALID_TASK_ID;
51 return taskId != INVALID_TASK_ID; in Valid()
H A Dexecutor_pool.h41 static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l); member in OHOS::ExecutorPool
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()
/foundation/distributeddatamgr/preferences/frameworks/native/include/
H A Dexecutor.h38 static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l); member in OHOS::NativePreferences::Executor
49 TaskId taskId = INVALID_TASK_ID;
54 return taskId != INVALID_TASK_ID; in Valid()
H A Dexecutor_pool.h44 static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l); member in OHOS::NativePreferences::ExecutorPool
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()
/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()
/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()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/permission/
H A Duri_permission_manager.cpp70 if (taskId_ == ExecutorPool::INVALID_TASK_ID && executorPool_ != nullptr) { in GrantUriPermission()
111 taskId_ = ExecutorPool::INVALID_TASK_ID; in RevokeUriPermission()
H A Duri_permission_manager.h47 ExecutorPool::TaskId taskId_ = ExecutorPool::INVALID_TASK_ID;
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/
H A Dtask_executor.h25 static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l); member in OHOS::TaskExecutor

Completed in 9 milliseconds

12