Lines Matching defs:worker
55 FFRT_LOGW("Get process name failed, skip worker monitor.");
109 FFRT_LOGW("Set delayed worker failed.");
147 FFRT_LOGW("Set delayed worker failed.");
182 WorkerThread* worker = thread.first;
183 CPUEUTask* workerTask = worker->curTask;
185 workerStatus_.erase(worker);
189 RecordTimeoutFunctionInfo(coWorkerInfo, worker, workerTask, timeoutFunctions);
200 void WorkerMonitor::RecordTimeoutFunctionInfo(const CoWorkerInfo& coWorkerInfo, WorkerThread* worker,
203 auto workerIter = workerStatus_.find(worker);
205 workerStatus_[worker] = TaskTimeoutInfo(workerTask);
217 WorkerInfo workerInfo(worker->Id(), worker->curTaskGid_, worker->curTaskType_, worker->curTaskLabel_);
228 FFRT_LOGI("Tid[%d] function is executed, which occupies worker for [%d]s.",
229 worker->Id(), taskInfo.executionTime_);
254 ss << "occupies worker for more than [" << timeoutFunction.executionTime_ << "]s";