test.cpp - OpenGrok cross reference for /commonlibrary/ets_utils/js_concurrent

Lines Matching refs:taskManager
188     TaskManager& taskManager = TaskManager::GetInstance();

189     taskManager.isHandleInited_ = false;

190     taskManager.TryTriggerExpand();

191     taskManager.isHandleInited_ = true;

192     taskManager.needChecking_ = false;

199     TaskManager& taskManager = TaskManager::GetInstance();

200     taskManager.workers_.clear();

201     taskManager.workers_.insert(worker);

202     taskManager.GetThreadInfos(env);

208     taskManager.CheckForBlockedWorkers();

214     taskManager.CheckForBlockedWorkers();

220     taskManager.idleWorkers_.insert(worker);

221     taskManager.CheckForBlockedWorkers();

222     taskManager.timeoutWorkers_.clear();

233     TaskManager& taskManager = TaskManager::GetInstance();

234     taskManager.idleWorkers_.clear();

237     taskManager.idleWorkers_.insert(worker);

239     taskManager.freeList_.emplace_back(worker);

241     taskManager.TriggerShrink(step);

243     taskManager.idleWorkers_.clear();

244     taskManager.idleWorkers_.insert(worker);

245     taskManager.freeList_.emplace_back(worker);

249     taskManager.TriggerShrink(step);

251     taskManager.idleWorkers_.clear();

252     taskManager.idleWorkers_.insert(worker);

253     taskManager.freeList_.emplace_back(worker);

259     taskManager.TriggerShrink(step);

260     taskManager.idleWorkers_.clear();

261     taskManager.globalEnableFfrtFlag_ = false;

267     TaskManager& taskManager = TaskManager::GetInstance();

268     taskManager.workers_.clear();

269     taskManager.timeoutWorkers_.clear();

279     taskManager.workers_.insert(worker1);

280     taskManager.workers_.insert(worker2);

281     taskManager.timeoutWorkers_.insert(worker1);

282     taskManager.timeoutWorkers_.insert(worker2);

283     taskManager.NotifyShrink(step);

285     taskManager.workers_.clear();

286     taskManager.timeoutWorkers_.clear();

287     taskManager.workers_.insert(worker1);

288     taskManager.idleWorkers_.insert(nullptr);

289     taskManager.NotifyShrink(step);

291     taskManager.idleWorkers_.clear();

292     taskManager.idleWorkers_.insert(worker2);

294     taskManager.NotifyShrink(step);

298     taskManager.NotifyShrink(step);

301     taskManager.workers_.clear();

302     taskManager.NotifyShrink(step);

307     TaskManager& taskManager = TaskManager::GetInstance();

308     taskManager.workers_.clear();

309     taskManager.timeoutWorkers_.clear();

310     taskManager.idleWorkers_.clear();

315     taskManager.idleWorkers_.insert(worker);

316     taskManager.TryExpand();

317     taskManager.nonIdleTaskNum_ = 1;

318     taskManager.TryExpand();

319     taskManager.nonIdleTaskNum_ = 0;

320     taskManager.TryExpand();

321     taskManager.idleWorkers_.clear();

322     taskManager.suspend_ = true;

323     taskManager.TryExpand();

328     TaskManager& taskManager = TaskManager::GetInstance();

335     taskManager.StoreTask(task->taskId_, task);

337     taskManager.CancelTask(env, task->taskId_);

344     taskManager.CancelTask(env, task->taskId_);

348     taskManager.CancelTask(env, task->taskId_);

351     taskManager.CancelTask(env, task->taskId_);

356     taskManager.CancelTask(env, task->taskId_);

357     taskManager.tasks_.clear();

363     TaskManager& taskManager = TaskManager::GetInstance();

366     taskManager.taskQueues_[Priority::DEFAULT]->EnqueueTaskId(task->taskId_);

372     taskManager.NotifyWorkerIdle(worker);

374     taskManager.NotifyWorkerIdle(worker);

380     TaskManager& taskManager = TaskManager::GetInstance();

383     taskManager.StoreTask(task->taskId_, task);

387     taskManager.EnqueueTaskId(task->taskId_);

389     taskManager.workers_.clear();

392     taskManager.workers_.insert(worker);

393     taskManager.IsChooseIdle();

394     taskManager.workers_.clear();

401     TaskManager& taskManager = TaskManager::GetInstance();

404     taskManager.StoreTask(task->taskId_, task);

405     auto& mediumTaskQueue = taskManager.taskQueues_[Priority::DEFAULT];

410     taskManager.EnqueueTaskId(task->taskId_);

412     taskManager.dependTaskInfos_.emplace(task->taskId_, std::move(set));

413     taskManager.GetTaskByPriority(mediumTaskQueue, Priority::DEFAULT);

414     taskManager.dependTaskInfos_.clear();

415     taskManager.tasks_.clear();

421     TaskManager& taskManager = TaskManager::GetInstance();

423     taskManager.suspend_ = false;

425     taskManager.RestoreWorker(worker);

429     taskManager.EnqueueTaskId(task->taskId_);

434     taskManager.RestoreWorker(worker);

439     TaskManager& taskManager = TaskManager::GetInstance();

441     taskManager.dependTaskInfos_.emplace(taskId, std::move(set));

446     TaskManager& taskManager = TaskManager::GetInstance();

448     taskManager.dependentTaskInfos_.emplace(taskId, std::move(set));

453     TaskManager& taskManager = TaskManager::GetInstance();

456     taskManager.taskDurationInfos_.emplace(taskId, std::move(durationData));

465     TaskManager& taskManager = TaskManager::GetInstance();

466     taskManager.globalEnableFfrtFlag_ = true;

467     taskManager.InitTaskManager(taskEnv);

468     taskManager.DecreaseRefCount(env, 0);

475     TaskManager& taskManager = TaskManager::GetInstance();

484     taskManager.dependentTaskInfos_.emplace(task->taskId_, std::move(set));

485     taskManager.NotifyDependencyTaskInfo(task->taskId_);

487     taskManager.dependentTaskInfos_.emplace(task->taskId_, std::move(set1));

488     taskManager.EnqueuePendingTaskInfo(0, Priority::DEFAULT);

489     taskManager.EnqueuePendingTaskInfo(id, Priority::DEFAULT);

490     taskManager.EnqueuePendingTaskInfo(task->taskId_, Priority::DEFAULT);

491     taskManager.NotifyDependencyTaskInfo(task->taskId_);

493     taskManager.dependentTaskInfos_.emplace(task->taskId_, std::move(set2));

494     taskManager.IsDependentByTaskId(task->taskId_);

499     TaskManager& taskManager = TaskManager::GetInstance();

509     taskManager.dependTaskInfos_.clear();

517     taskManager.dependTaskInfos_.emplace(id1, std::move(set));

519     taskManager.StoreTaskDependency(id3, taskId);

520     taskManager.StoreTaskDependency(id5, taskId);

522     taskManager.dependTaskInfos_.emplace(id3, std::move(set1));

523     taskManager.StoreTaskDependency(id1, taskId);

526     taskManager.dependTaskInfos_.emplace(id5, std::move(set3));

527     taskManager.StoreTaskDependency(id1, taskId);

528     taskManager.dependTaskInfos_.emplace(id5, std::move(set2));

529     taskManager.StoreTaskDependency(id1, taskId);

530     taskManager.dependTaskInfos_.clear();

537     TaskManager& taskManager = TaskManager::GetInstance();

544     taskManager.dependTaskInfos_.clear();

546     taskManager.dependTaskInfos_.emplace(task->taskId_, std::move(set));

547     taskManager.RemoveTaskDependency(task->taskId_, task1->taskId_);

548     taskManager.RemoveTaskDependency(task->taskId_, id);

550     taskManager.dependentTaskInfos_.emplace(task->taskId_, std::move(set2));

552     taskManager.StoreDependentTaskInfo(dependentTaskIdSet, task1->taskId_);

553     taskManager.RemoveDependentTaskInfo(task->taskId_, id2);

554     taskManager.RemoveDependentTaskInfo(task->taskId_, id);

555     taskManager.GetTaskDependInfoToString(task1->taskId_);

556     taskManager.taskDurationInfos_.emplace(task->taskId_, std::make_pair(UINT64_ZERO_, task1->taskId_));

557     taskManager.StoreTaskDuration(task->taskId_, UINT64_ZERO_, UINT64_ZERO_);

558     taskManager.GetTaskDuration(task->taskId_, "");

559     taskManager.RemoveTaskDuration(task->taskId_);

564     TaskManager& taskManager = TaskManager::GetInstance();

569     taskManager.StoreTask(task->taskId_, task);

570     taskManager.ReleaseTaskData(env, task);

572     taskManager.StoreTask(task->taskId_, task);

573     taskManager.ReleaseTaskData(env, task);

575     taskManager.dependTaskInfos_.emplace(task->taskId_, std::move(set));

577     taskManager.StoreTask(task->taskId_, task);

578     taskManager.ReleaseTaskData(env, task);

585     taskManager.ReleaseCallBackInfo(task1);

589     taskManager.ReleaseCallBackInfo(task2);

591     taskManager.ReleaseCallBackInfo(task2);

594     taskManager.ReleaseCallBackInfo(task2);

599     TaskManager& taskManager = TaskManager::GetInstance();

604     taskManager.StoreTask(task->taskId_, task);

605     taskManager.CheckTask(task1->taskId_);

650     TaskManager& taskManager = TaskManager::GetInstance();

654     taskManager.StoreTask(task->taskId_, task);

795     TaskManager& taskManager = TaskManager::GetInstance();

809     taskManager.StoreTask(task->taskId_, task);

811     auto& mediumTaskQueue = taskManager.taskQueues_[priority];

863     TaskManager& taskManager = TaskManager::GetInstance();

864     taskManager.globalEnableFfrtFlag_ = true;

867     taskManager.globalEnableFfrtFlag_ = false;