Lines Matching refs:t
73 auto t = g_cur_task; in SaveCurrent() local
74 if (t) { in SaveCurrent()
75 if (t->type == ffrt_normal_task || t->type == ffrt_queue_task) { in SaveCurrent()
77 g_cur_signame, g_cur_tid, t->gid, t->qos(), t->label.c_str()); in SaveCurrent()
103 CPUEUTask* t = reinterpret_cast<CPUEUTask*>(worker->localFifo.PopHead()); in SaveLocalFifoStatus() local
104 while (t != nullptr) { in SaveLocalFifoStatus()
105 if (t->type == ffrt_normal_task || t->type == ffrt_queue_task) { in SaveLocalFifoStatus()
107 qos, worker->Id(), t->gid, t->label.c_str()); in SaveLocalFifoStatus()
109 t = reinterpret_cast<CPUEUTask*>(worker->localFifo.PopHead()); in SaveLocalFifoStatus()
121 CPUEUTask* t = thread.first->curTask; in SaveWorkerStatus() local
122 if (t == nullptr) { in SaveWorkerStatus()
126 if (t->type == ffrt_normal_task || t->type == ffrt_queue_task) { in SaveWorkerStatus()
128 t->gid, t->label.c_str()); in SaveWorkerStatus()
144 CPUEUTask* t = FFRTFacade::GetSchedInstance()->GetScheduler(i).PickNextTask(); in SaveReadyQueueStatus() local
145 if (t == nullptr) { in SaveReadyQueueStatus()
149 if (t->type == ffrt_normal_task || t->type == ffrt_queue_task) { in SaveReadyQueueStatus()
151 i, j, nt, t->gid, t->label.c_str()); in SaveReadyQueueStatus()
174 auto t = reinterpret_cast<CPUEUTask*>(task); in SaveNormalTaskStatus() local
175 if (filter(t)) { in SaveNormalTaskStatus()
176 tmp.emplace_back(t); in SaveNormalTaskStatus()
184 for (auto t : tmp) { in SaveNormalTaskStatus() local
185 if (t->type == ffrt_normal_task) { in SaveNormalTaskStatus()
187 tmp.size(), t->gid, t->qos(), t->label.c_str()); in SaveNormalTaskStatus()
190 … if (t->coRoutine && (t->coRoutine->status.load() == static_cast<int>(CoStatus::CO_NOT_FINISH)) in SaveNormalTaskStatus()
191 && t != g_cur_task) { in SaveNormalTaskStatus()
192 CoStart(t, GetCoEnv()); in SaveNormalTaskStatus()
197 apply("blocked by synchronization primitive(mutex etc)", [](CPUEUTask* t) { in SaveNormalTaskStatus() argument
198 return (t->state == TaskState::RUNNING) && t->coRoutine && in SaveNormalTaskStatus()
199 … t->coRoutine->status.load() == static_cast<int>(CoStatus::CO_NOT_FINISH) && t != g_cur_task; in SaveNormalTaskStatus()
201 apply("blocked by task dependence", [](CPUEUTask* t) { in SaveNormalTaskStatus() argument
202 return t->state == TaskState::BLOCKED; in SaveNormalTaskStatus()
204 apply("pending task", [](CPUEUTask* t) { in SaveNormalTaskStatus() argument
205 return t->state == TaskState::PENDING; in SaveNormalTaskStatus()
217 auto t = reinterpret_cast<QueueTask*>(task); in SaveQueueTaskStatus() local
218 if (filter(t)) { in SaveQueueTaskStatus()
219 tmp.emplace_back(t); in SaveQueueTaskStatus()
227 for (auto t : tmp) { in SaveQueueTaskStatus() local
228 if (t->type == ffrt_queue_task) { in SaveQueueTaskStatus()
230 tmp.size(), t->gid, t->GetQos(), t->label.c_str()); in SaveQueueTaskStatus()
234 … if (t->coRoutine && (t->coRoutine->status.load() == static_cast<int>(CoStatus::CO_NOT_FINISH))) { in SaveQueueTaskStatus()
235 CoStart(reinterpret_cast<CPUEUTask*>(t), GetCoEnv()); in SaveQueueTaskStatus()
240 applyqueue("queue task blocked by synchronization primitive(mutex etc)", [](QueueTask* t) { in SaveQueueTaskStatus() argument
241 return (t->GetFinishStatus() == false) && t->coRoutine && in SaveQueueTaskStatus()
242 t->coRoutine->status.load() == static_cast<int>(CoStatus::CO_NOT_FINISH); in SaveQueueTaskStatus()
285 auto t = ExecuteCtx::Cur()->task; in RecordDebugInfo() local
288 if ((t != nullptr) && (t->type == ffrt_normal_task || t->type == ffrt_queue_task)) { in RecordDebugInfo()
289 …X_LOG("debug log: tid %d, task id %lu, qos %d, name %s", gettid(), t->gid, t->qos(), t->label.c_st… in RecordDebugInfo()
497 CPUEUTask* t = thread.first->curTask; in SaveWorkerStatusInfo() local
499 if (t == nullptr) { in SaveWorkerStatusInfo()
504 if (t->type == ffrt_normal_task || t->type == ffrt_queue_task) { in SaveWorkerStatusInfo()
506 << " is running, task id " << t->gid << " name " << t->label.c_str(); in SaveWorkerStatusInfo()
507 AppendTaskInfo(ss, t); in SaveWorkerStatusInfo()
515 std::for_each(tidArr.begin(), tidArr.end(), [&](const int &t) { in SaveWorkerStatusInfo() argument
516 if (&t == &tidArr.back()) { in SaveWorkerStatusInfo()
517 oss << t; in SaveWorkerStatusInfo()
519 oss << t << ", "; in SaveWorkerStatusInfo()
542 CPUEUTask* t = FFRTFacade::GetSchedInstance()->GetScheduler(i).PickNextTask(); in SaveReadyQueueStatusInfo() local
543 if (t == nullptr) { in SaveReadyQueueStatusInfo()
548 if (t->type == ffrt_normal_task || t->type == ffrt_queue_task) { in SaveReadyQueueStatusInfo()
550 << t->gid << " name " << t->label.c_str(); in SaveReadyQueueStatusInfo()
551 AppendTaskInfo(ss, t); in SaveReadyQueueStatusInfo()
555 FFRTFacade::GetSchedInstance()->GetScheduler(i).WakeupTask(t); in SaveReadyQueueStatusInfo()
570 auto t = reinterpret_cast<CPUEUTask*>(task); in SaveNormalTaskStatusInfo() local
571 if (filter(t)) { in SaveNormalTaskStatusInfo()
572 tmp.emplace_back(reinterpret_cast<CPUEUTask*>(t)); in SaveNormalTaskStatusInfo()
581 for (auto t : tmp) { in SaveNormalTaskStatusInfo() local
583 if (t->type == ffrt_normal_task) { in SaveNormalTaskStatusInfo()
584 … ss << " <" << idx++ << "/" << tmp.size() << ">" << "stack: task id " << t->gid << ",qos " in SaveNormalTaskStatusInfo()
585 << t->qos() << ",name " << t->label.c_str(); in SaveNormalTaskStatusInfo()
586 AppendTaskInfo(ss, t); in SaveNormalTaskStatusInfo()
590 … if (t->coRoutine && (t->coRoutine->status.load() == static_cast<int>(CoStatus::CO_NOT_FINISH))) { in SaveNormalTaskStatusInfo()
592 DumpTask(t, dumpInfo, 1); in SaveNormalTaskStatusInfo()
598 apply("blocked by synchronization primitive(mutex etc)", [](CPUEUTask* t) { in SaveNormalTaskStatusInfo() argument
599 return (t->state == TaskState::RUNNING) && t->coRoutine && in SaveNormalTaskStatusInfo()
600 t->coRoutine->status.load() == static_cast<int>(CoStatus::CO_NOT_FINISH); in SaveNormalTaskStatusInfo()
602 apply("blocked by task dependence", [](CPUEUTask* t) { in SaveNormalTaskStatusInfo() argument
603 return t->state == TaskState::BLOCKED; in SaveNormalTaskStatusInfo()
605 apply("pending task", [](CPUEUTask* t) { in SaveNormalTaskStatusInfo() argument
606 return t->state == TaskState::PENDING; in SaveNormalTaskStatusInfo()
622 auto t = reinterpret_cast<QueueTask*>(task); in SaveQueueTaskStatusInfo() local
623 if (filter(t)) { in SaveQueueTaskStatusInfo()
624 tmp.emplace_back(t); in SaveQueueTaskStatusInfo()
633 for (auto t : tmp) { in SaveQueueTaskStatusInfo() local
635 if (t->type == ffrt_queue_task) { in SaveQueueTaskStatusInfo()
636 ss << "<" << idx++ << "/" << tmp.size() << ">" << "id" << t->gid << "qos" in SaveQueueTaskStatusInfo()
637 << t->GetQos() << "name" << t->label.c_str(); in SaveQueueTaskStatusInfo()
638 AppendTaskInfo(ss, t); in SaveQueueTaskStatusInfo()
642 … if (t->coRoutine && (t->coRoutine->status.load() == static_cast<int>(CoStatus::CO_NOT_FINISH))) { in SaveQueueTaskStatusInfo()
644 DumpTask(reinterpret_cast<CPUEUTask*>(t), dumpInfo, 1); in SaveQueueTaskStatusInfo()
650 applyqueue("queue task blocked by synchronization primitive(mutex etc)", [](QueueTask* t) { in SaveQueueTaskStatusInfo() argument
651 return (t->GetFinishStatus() == false) && t->coRoutine && in SaveQueueTaskStatusInfo()
652 t->coRoutine->status.load() == static_cast<int>(CoStatus::CO_NOT_FINISH); in SaveQueueTaskStatusInfo()