Lines Matching defs:task
276 WatchdogTask task("ThreadSampler", sampleTask, 0, interval, true);
277 InsertWatchdogTaskLocked("ThreadSampler", std::move(task));
366 WatchdogTask task("TraceCollector", traceTask, 0, interval, true);
368 InsertWatchdogTaskLocked("TraceCollector", std::move(task));
475 void WatchdogInner::RunOneShotTask(const std::string& name, Task&& task, uint64_t delay)
477 if (name.empty() || task == nullptr) {
478 XCOLLIE_LOGE("Add task fail, invalid args!");
488 InsertWatchdogTaskLocked(limitedName, WatchdogTask(limitedName, std::move(task), delay, 0, true));
518 const WatchdogTask& task = checkerQueue_.top();
519 if (task.id != id || task.timeout == 0) {
520 tmpQueue.push(task);
531 void WatchdogInner::RunPeriodicalTask(const std::string& name, Task&& task, uint64_t interval, uint64_t delay)
533 if (name.empty() || task == nullptr) {
534 XCOLLIE_LOGE("Add task fail, invalid args!");
543 XCOLLIE_LOGD("Add periodical task %{public}s to watchdog.", name.c_str());
545 InsertWatchdogTaskLocked(limitedName, WatchdogTask(limitedName, std::move(task), delay, interval, false));
577 WatchdogTask task = checkerQueue_.top();
578 if (task.name == name) {
581 task.triggerTimes.push_back(now);
582 task.message = message;
584 task.triggerTimes.clear();
587 tmpQueue.push(task);
605 XCOLLIE_LOGE("Exceed max watchdog task!");
612 int64_t WatchdogInner::InsertWatchdogTaskLocked(const std::string& name, WatchdogTask&& task)
614 if (!task.isOneshotTask && IsTaskExistLocked(name)) {
620 XCOLLIE_LOGE("Exceed max watchdog task, failed to insert.");
623 int64_t id = task.id;
624 checkerQueue_.push(std::move(task));
625 if (!task.isOneshotTask) {
684 uint64_t WatchdogInner::FetchNextTask(uint64_t now, WatchdogTask& task)
734 currentScene_ = "thread DfxWatchdog: Current scenario is task name: " + queuedTask.name + "\n";
735 task = queuedTask;
740 void WatchdogInner::ReInsertTaskIfNeed(WatchdogTask& task)
742 if (task.checkInterval == 0) {
747 task.nextTickTime = task.nextTickTime + task.checkInterval;
748 checkerQueue_.push(task);
765 WatchdogTask task;
766 uint64_t leftTimeMill = FetchNextTask(now, task);
768 task.Run(now);
769 ReInsertTaskIfNeed(task);
854 std::string description = "FfrtCallback: task(";
940 std::string taskIdFrontStr = " is running, task id ";
1024 const WatchdogTask& task = checkerQueue_.top();
1025 if (task.name != name) {
1026 tmpQueue.push(task);
1029 if (nameSize != 0 && !task.isOneshotTask) {