Searched refs:task_p (Results 1 – 1 of 1) sorted by relevance
443 std::shared_ptr<Task> task_p = *(task_queue_.begin()); in ThreadRoutine() local444 if (task_p->time < std::chrono::steady_clock::now()) { in ThreadRoutine()446 callback = task_p->callback; in ThreadRoutine()447 task_queue_.erase(task_p); // need to remove and add again if in ThreadRoutine()449 if (task_p->isPeriodic()) { in ThreadRoutine()450 task_p->time += task_p->period; in ThreadRoutine()451 task_queue_.insert(task_p); in ThreadRoutine()453 tasks_by_user_id_[task_p->user_id].erase(task_p->task_id); in ThreadRoutine()454 tasks_by_id_.erase(task_p->task_id); in ThreadRoutine()