Home
last modified time | relevance | path

Searched refs:taskId_ (Results 1 - 25 of 43) sorted by relevance

12

/foundation/distributeddatamgr/pasteboard/framework/framework/ffrt/
H A Dffrt_utils.cpp84 taskId_.clear(); in Clear()
106 ++taskId_[timerId]; in SetTimer()
108 PASTEBOARD_MODULE_SERVICE, "Timer[%{public}s] Add Task[%{public}u]", timerId.c_str(), taskId_[timerId]); in SetTimer()
121 ++taskId_[timerId]; in SetTimer()
123 timerId.c_str(), taskId_[timerId], delayMs); in SetTimer()
131 uint32_t id = taskId_[timerId]; in GetTaskId()
142 taskId_[p.first]); in CancelAllTimerInner()
152 PASTEBOARD_MODULE_SERVICE, "Timer[%{public}s] Cancel Task[%{public}u]", timerId.c_str(), taskId_[timerId]); in CancelTimerInner()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/
H A Ddb_delegate.cpp23 ExecutorPool::TaskId DBDelegate::taskId_ = ExecutorPool::INVALID_TASK_ID; member in OHOS::DataShare::DBDelegate
78 if (executor_ == nullptr || taskId_ != Executor::INVALID_TASK_ID) { in StartTimer()
81 taskId_ = executor_->Schedule( in StartTimer()
85 if (executor_ == nullptr || taskId_ == Executor::INVALID_TASK_ID) { in StartTimer()
88 executor_->Remove(taskId_); in StartTimer()
89 ZLOGD("remove timer, taskId: %{public}" PRIu64, taskId_); in StartTimer()
90 taskId_ = Executor::INVALID_TASK_ID; in StartTimer()
94 ZLOGD("start timer, taskId: %{public}" PRIu64, taskId_); in StartTimer()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/store/
H A Dstore_cache.cpp65 if (taskId_ == ExecutorPool::INVALID_TASK_ID && executorPool_ != nullptr) { in GetStore()
66 taskId_ = executorPool_->Schedule(std::chrono::minutes(INTERVAL), std::bind(&StoreCache::GarbageCollect, this)); in GetStore()
84 taskId_ = executorPool_->Schedule(std::chrono::minutes(INTERVAL), std::bind(&StoreCache::GarbageCollect, this)); in GarbageCollect()
86 taskId_ = ExecutorPool::INVALID_TASK_ID; in GarbageCollect()
H A Dstore_cache.h47 ExecutorPool::TaskId taskId_ = ExecutorPool::INVALID_TASK_ID; member in OHOS::UDMF::StoreCache
/foundation/bundlemanager/app_domain_verify/frameworks/common/src/httpsession/
H A Di_http_task.cpp21 taskId_ = idGen_++; in IHttpTask()
25 return taskId_; in GetTaskId()
/foundation/ability/dmsfwk/services/dtbschedmgr/src/
H A Ddms_free_install_callback.cpp28 : taskId_(taskId), info_(info) in DmsFreeInstallCallback()
38 DistributedSchedService::GetInstance().NotifyCompleteFreeInstall(info_, taskId_, resultCode); in OnInstallFinished()
/foundation/multimedia/media_foundation/engine/foundation/utils/
H A Dhitrace_utils.cpp31 :title_(title), taskId_(taskId) in AsyncTracker()
38 FinishAsyncTrace(DEFAULT_HITRACE_TAG, title_, taskId_); in ~AsyncTracker()
/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()
71 taskId_ = executorPool_->Schedule( in GrantUriPermission()
108 taskId_ = executorPool_->Schedule( in RevokeUriPermission()
111 taskId_ = ExecutorPool::INVALID_TASK_ID; in RevokeUriPermission()
H A Duri_permission_manager.h47 ExecutorPool::TaskId taskId_ = ExecutorPool::INVALID_TASK_ID; member in OHOS::UDMF::UriPermissionManager
/foundation/distributedhardware/distributed_screen/services/screenservice/sourceservice/dscreenmgr/2.0/include/
H A Ddscreen.h54 taskId_(taskId), taskParam_(taskParam) {}; in Task()
56 taskId_(""), taskParam_(taskParam) {}; in Task()
65 return taskId_; in GetTaskId()
74 std::string taskId_; member in OHOS::DistributedHardware::V2_0::Task
/foundation/distributedhardware/distributed_screen/services/screenservice/sourceservice/dscreenmgr/1.0/include/
H A Ddscreen.h56 taskId_(taskId), taskParam_(taskParam) {}; in Task()
58 taskId_(""), taskParam_(taskParam) {}; in Task()
67 return taskId_; in GetTaskId()
76 std::string taskId_; member in OHOS::DistributedHardware::V1_0::Task
/foundation/filemanagement/dfs_service/services/cloudsyncservice/src/transport/
H A Dmessage_handler.cpp33 taskId_(info.taskId) in MessageHandler()
72 userData->taskId = htole64(taskId_); in PackData()
123 taskId_ = le64toh(userData->taskId); in UnPackData()
145 return taskId_; in GetTaskId()
/foundation/communication/netstack/frameworks/native/http/http_client/
H A Dhttp_client_task.cpp77 taskId_(nextTaskId_++), in HttpClientTask()
82 trace_(std::make_unique<RequestTracer::Trace>("HttpClientTask" + std::to_string(taskId_))) in HttpClientTask()
98 NETSTACK_LOGD("Destroy: taskId_=%{public}d", taskId_); in ~HttpClientTask()
418 NETSTACK_LOGD("task is running, taskId_=%{public}d", taskId_); in Start()
436 NETSTACK_LOGD("taskId_=%{public}d", taskId_); in Start()
473 return taskId_; in GetTaskId()
510 NETSTACK_LOGD("taskId=%{public}d size=%{public}zu memBytes=%{public}zu", task->taskId_, siz in DataReceiveCallback()
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/store/
H A Dauto_cache.cpp43 if (executor == nullptr || taskId_ != Executor::INVALID_TASK_ID) { in Bind()
57 executor_->Remove(taskId_, true); in ~AutoCache()
126 if (executor_ == nullptr || taskId_ != Executor::INVALID_TASK_ID) { in StartTimer()
129 taskId_ = executor_->Schedule( in StartTimer()
133 if (executor_ == nullptr || taskId_ == Executor::INVALID_TASK_ID) { in StartTimer()
136 executor_->Remove(taskId_); in StartTimer()
137 ZLOGD("remove timer,taskId: %{public}" PRIu64, taskId_); in StartTimer()
138 taskId_ = Executor::INVALID_TASK_ID; in StartTimer()
142 ZLOGD("start timer,taskId: %{public}" PRIu64, taskId_); in StartTimer()
/foundation/arkui/ace_engine/frameworks/base/log/
H A Dace_trace.cpp138 taskId_ = id_++; in AceAsyncScopedTrace()
141 name_ = AceAsyncTraceBeginWithArgv(taskId_, format, args); in AceAsyncScopedTrace()
148 AceAsyncTraceEnd(taskId_, name_.c_str()); in ~AceAsyncScopedTrace()
/foundation/ability/dmsfwk/services/dtbschedmgr/include/
H A Ddms_free_install_callback.h49 int64_t taskId_ = 0; member in OHOS::DistributedSchedule::DmsFreeInstallCallback
/foundation/resourceschedule/ffrt/src/util/
H A Devent_handler_adapter.h48 uintptr_t taskId_; member
50 : dfxName_(dfxName), delayTime_(delayTime), priority_(priority), taskId_(taskId) {} in TaskOptions()
/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Dexecutor_pool.h44 : pool_(max, min), delayTasks_(InnerTask(), NextTimer), taskId_(INVALID_TASK_ID) in ExecutorPool()
195 auto taskId = ++taskId_; in GenTaskId()
197 taskId = ++taskId_; in GenTaskId()
217 std::atomic<TaskId> taskId_; member in OHOS::ExecutorPool
/foundation/distributeddatamgr/kv_store/frameworks/common/
H A Dtask_scheduler.h45 taskId_ = INVALID_TASK_ID; in TaskScheduler()
189 auto taskId = ++taskId_; in GenTaskId()
191 return ++taskId_; in GenTaskId()
205 std::atomic<uint64_t> taskId_; member in OHOS::TaskScheduler
/foundation/distributeddatamgr/preferences/frameworks/native/include/
H A Dexecutor_pool.h47 : pool_(max, min), delayTasks_(InnerTask(), NextTimer), taskId_(INVALID_TASK_ID) in ExecutorPool()
199 auto taskId = ++taskId_; in GenTaskId()
201 taskId = ++taskId_; in GenTaskId()
221 std::atomic<TaskId> taskId_; member in OHOS::NativePreferences::ExecutorPool
/foundation/bundlemanager/app_domain_verify/frameworks/common/include/httpsession/
H A Di_http_task.h41 uint32_t taskId_; member in OHOS::AppDomainVerify::IHttpTask
/foundation/filemanagement/dfs_service/frameworks/native/cloudsync_kit_inner/include/
H A Ddownload_asset_callback_client.h42 std::atomic<TaskId> taskId_{0};
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/
H A Dsoftbus_adapter_standard.cpp186 if (taskId_ != ExecutorPool::INVALID_TASK_ID && expireTime < next_) { in GetExpireTime()
187 taskId_ = Context::GetInstance().GetThreadPool()->Reset(taskId_, expireTime - now); in GetExpireTime()
267 if (taskId_ == ExecutorPool::INVALID_TASK_ID) { in StartCloseSessionTask()
269 taskId_ = Context::GetInstance().GetThreadPool()->Schedule(expireTime - now, GetCloseSessionTask()); in StartCloseSessionTask()
317 taskId_ = ExecutorPool::INVALID_TASK_ID; in GetCloseSessionTask()
320 taskId_ = Context::GetInstance().GetThreadPool()->Schedule( in GetCloseSessionTask()
/foundation/multimedia/media_foundation/engine/include/foundation/utils/
H A Dhitrace_utils.h58 int32_t taskId_; member in OHOS::Media::AsyncTracker
/foundation/multimedia/media_foundation/interface/inner_api/osal/utils/
H A Dhitrace_utils.h58 int32_t taskId_; member in OHOS::Media::AsyncTracker

Completed in 10 milliseconds

12