| /ohos5.0/foundation/resourceschedule/ffrt/src/sched/ |
| H A D | execute_ctx.cpp | 26 auto ctx = static_cast<ExecuteCtx*>(args); in ExecuteCtxTlsDestructor()
38 ExecuteCtx::ExecuteCtx() in ExecuteCtx() function in ffrt::ExecuteCtx
45 ExecuteCtx::~ExecuteCtx() in ~ExecuteCtx()
49 ExecuteCtx* ExecuteCtx::Cur() in Cur()
51 ExecuteCtx* ctx = nullptr; in Cur()
56 ctx = reinterpret_cast<ExecuteCtx *>(curTls); in Cur()
58 ctx = new (std::nothrow) ExecuteCtx(); in Cur()
|
| H A D | execute_ctx.h | 84 struct ExecuteCtx { struct
85 ExecuteCtx();
86 virtual ~ExecuteCtx();
109 static ExecuteCtx* Cur(); argument
|
| /ohos5.0/foundation/resourceschedule/ffrt/src/core/ |
| H A D | task_io.cpp | 96 return reinterpret_cast<void*>(ffrt::ExecuteCtx::Cur()->exec_task);
116 bool selfWakeup = (ffrt::ExecuteCtx::Cur()->exec_task == task);
118 if (ffrt::ExecuteCtx::Cur()->PushTaskToPriorityStack(wakedTask)) {
123 if (ffrt::ExecuteCtx::Cur()->localFifo != nullptr &&
124 ffrt::ExecuteCtx::Cur()->localFifo->PushTail(task) == 0) {
|
| H A D | task.cpp | 57 CPUEUTask* curTask = ffrt::ExecuteCtx::Cur()->task;
66 CPUEUTask* curTask = ffrt::ExecuteCtx::Cur()->task;
477 auto curTask = ffrt::ExecuteCtx::Cur()->task;
498 if (ffrt::ExecuteCtx::Cur()->task == nullptr) {
502 return ffrt::ExecuteCtx::Cur()->qos();
508 auto curTask = ffrt::ExecuteCtx::Cur()->task;
525 auto curTask = ffrt::ExecuteCtx::Cur()->task;
594 return ffrt::ExecuteCtx::Cur()->task;
607 auto curTask = ffrt::ExecuteCtx::Cur()->task;
656 return ffrt::ExecuteCtx::Cur()->lastGid_;
|
| /ohos5.0/foundation/resourceschedule/ffrt/src/sync/ |
| H A D | mutex.cpp | 40 …uint64_t task = ExecuteCtx::Cur()->task ? reinterpret_cast<uint64_t>(ExecuteCtx::Cur()->task) : Ge… in try_lock()
53 task = ExecuteCtx::Cur()->task ? reinterpret_cast<uint64_t>(ExecuteCtx::Cur()->task) : GetTid(); in lock()
81 auto ctx = ExecuteCtx::Cur(); in try_lock()
132 auto ctx = ExecuteCtx::Cur(); in lock()
166 auto ctx = ExecuteCtx::Cur(); in unlock()
218 auto ctx = ExecuteCtx::Cur(); in wait()
|
| H A D | wait_queue.cpp | 27 auto ctx = ExecuteCtx::Cur(); in TaskWithNode()
82 ExecuteCtx* ctx = ExecuteCtx::Cur(); in SuspendAndWait()
128 ExecuteCtx* ctx = ExecuteCtx::Cur(); in SuspendAndWaitUntil()
|
| H A D | timer_api.cpp | 30 mappedQos = ffrt::ExecuteCtx::Cur()->qos(); in QosConvert()
|
| H A D | sleep.cpp | 37 auto ctx = ExecuteCtx::Cur(); in ExecuteCtxTask()
|
| H A D | poller_api.cpp | 29 mappedQos = ffrt::ExecuteCtx::Cur()->qos(); in QosConvert()
|
| H A D | poller.cpp | 54 auto wakeData = std::make_unique<WakeDataWithCb>(fd, data, cb, ExecuteCtx::Cur()->task); in AddFdEvent()
164 auto task = ExecuteCtx::Cur()->task; in WaitFdEvent()
521 TimerDataWithCb timerMapValue(data, cb, ExecuteCtx::Cur()->task, repeat, timeout); in RegisterTimer()
|
| H A D | io_poller.cpp | 107 auto ctx = ExecuteCtx::Cur(); in WaitFdEvent()
|
| H A D | shared_mutex.cpp | 99 auto ctx = ExecuteCtx::Cur(); in Wait()
|
| /ohos5.0/foundation/resourceschedule/ffrt/src/eu/ |
| H A D | cpu_worker.cpp | 111 ExecuteCtx* ctx = ExecuteCtx::Cur(); in RunTask()
116 void CPUWorker::RunTask(ffrt_executor_task_t* curtask, CPUWorker* worker, ExecuteCtx* ctx, CoRoutin… in RunTask()
223 auto ctx = ExecuteCtx::Cur(); in Dispatch()
|
| H A D | cpu_worker.h | 60 …static void RunTask(ffrt_executor_task_t* curtask, CPUWorker* worker, ExecuteCtx* ctx, CoRoutineEn…
|
| /ohos5.0/foundation/resourceschedule/ffrt/test/ut/testcase/ |
| H A D | ut_ffrt_io.cpp | 58 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos; in TearDown()
201 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
214 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
242 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
266 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
300 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
330 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
359 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
389 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
|
| H A D | ut_deadline.cpp | 128 CPUEUTask *ctx = ExecuteCtx::Cur()->task;
|
| /ohos5.0/foundation/resourceschedule/ffrt/src/ipc/ |
| H A D | ipc.cpp | 29 auto task = ffrt::ExecuteCtx::Cur()->task;
|
| /ohos5.0/foundation/resourceschedule/ffrt/src/dfx/trace_record/ |
| H A D | ffrt_trace_record.h | 90 *fromTid = ExecuteCtx::Cur()->tid; in TaskSubmit()
102 *fromTid = ExecuteCtx::Cur()->tid; in TaskSubmit()
|
| /ohos5.0/foundation/resourceschedule/ffrt/src/dm/ |
| H A D | sdependence_manager.cpp | 87 auto ctx = ExecuteCtx::Cur(); in onSubmit()
170 auto ctx = ExecuteCtx::Cur(); in onWait()
205 auto ctx = ExecuteCtx::Cur(); in onWait()
|
| /ohos5.0/foundation/resourceschedule/ffrt/src/dfx/dump/ |
| H A D | dump.cpp | 51 if (ExecuteCtx::Cur()->task == task || task == nullptr) { in DumpTask()
|
| /ohos5.0/foundation/resourceschedule/ffrt/src/dfx/bbox/ |
| H A D | bbox.cpp | 285 auto t = ExecuteCtx::Cur()->task; in RecordDebugInfo()
375 g_cur_task = ExecuteCtx::Cur()->task; in SignalHandler()
|
| /ohos5.0/foundation/resourceschedule/ffrt/src/queue/ |
| H A D | queue_api.cpp | 277 CPUEUTask* curTask = ffrt::ExecuteCtx::Cur()->task;
|
| H A D | queue_handler.cpp | 134 task->fromTid = ExecuteCtx::Cur()->tid; in Submit()
|