| /foundation/resourceschedule/ffrt/src/sched/ |
| H A D | scheduler.cpp | 105 int taskCount = fifoQue[static_cast<size_t>(level)]->RQSize(); in WakeupTask() local
110 if (taskCount >= TASK_OVERRUN_THRESHOLD && taskCount % TASK_OVERRUN_ALARM_FREQ == 0) { in WakeupTask()
112 level, label.c_str(), taskCount); in WakeupTask()
|
| H A D | task_manager.h | 35 return taskCount[static_cast<size_t>(state)]; in GetCount()
64 std::array<std::atomic_uint64_t, static_cast<size_t>(TaskState::MAX)> taskCount; member in ffrt::TaskManager
|
| H A D | task_manager.cpp | 28 DecreCount(taskCount[static_cast<size_t>(task->state.PreState())]); in TaskStateCount()
29 IncreCount(taskCount[static_cast<size_t>(task->state.CurState())]); in TaskStateCount()
|
| /foundation/resourceschedule/ffrt/src/eu/ |
| H A D | cpu_monitor.cpp | 258 size_t taskCount = static_cast<size_t>(ops.GetTaskCount(i)); in MonitorMain() local
259 if (taskCount > 0 && domainInfoMonitor.localinfo[i].nrRunning <= wakeupCond.local[i].low) { in MonitorMain()
260 Poke(i, taskCount, TaskNotifyType::TASK_ADDED); in MonitorMain()
453 void CPUMonitor::Poke(const QoS& qos, uint32_t taskCount, TaskNotifyType notifyType) in Poke() argument
475 (runningNum > TIGGER_SUPPRESS_EXECUTION_NUM) && (taskCount < runningNum); in Poke()
533 size_t taskCount = static_cast<size_t>(monitor->GetOps().GetTaskCount(qos)); in HandleTaskNotifyDefault() local
537 if (taskCount > 0) { in HandleTaskNotifyDefault()
538 monitor->Poke(qos, taskCount, notifyType); in HandleTaskNotifyDefault()
542 monitor->Poke(qos, taskCount, notifyType); in HandleTaskNotifyDefault()
|
| H A D | cpu_monitor.h | 85 void Poke(const QoS& qos, uint32_t taskCount, TaskNotifyType notifyType);
|
| H A D | scpuworker_manager.cpp | 79 int taskCount = GetTaskCount(QoS(qos)); in AddDelayedTask()
89 if (taskCount != 0) { in AddDelayedTask()
|
| /foundation/window/window_manager/wmserver/src/ |
| H A D | window_node_state_machine.cpp | 94 void WindowNodeStateMachine::ResetAnimationTaskCount(int32_t taskCount) in ResetAnimationTaskCount() argument
97 taskCount_ = taskCount; in ResetAnimationTaskCount()
|
| H A D | remote_animation.cpp | 873 int32_t taskCount = node->stateMachine_.GetAnimationCount(); in ProcessNodeStateTask() local
874 if (taskCount <= 0) { // no animation task but finishCallback come in ProcessNodeStateTask()
875 WLOGFE("ProcessNodeStateTask failed with windowId: %{public}u, name:%{public}s taskCount:%{public}d", in ProcessNodeStateTask()
876 node->GetWindowId(), node->GetWindowName().c_str(), taskCount); in ProcessNodeStateTask()
881 taskCount = node->stateMachine_.GetAnimationCount(); in ProcessNodeStateTask()
882 WLOGFI("ProcessNodeStateTask windowId: %{public}u, name:%{public}s state: %{public}u, taskCount:%{public}d", in ProcessNodeStateTask()
884 static_cast<uint32_t>(node->stateMachine_.GetCurrentState()), taskCount); in ProcessNodeStateTask()
885 if (taskCount > 0 || taskCount < 0) { in ProcessNodeStateTask()
887 node->GetWindowId(), taskCount); in ProcessNodeStateTask()
[all...] |
| /foundation/window/window_manager/wmserver/include/ |
| H A D | window_node_state_machine.h | 75 void ResetAnimationTaskCount(int32_t taskCount);
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
| H A D | sync_able_kvdb.cpp | 652 int32_t taskCount = 0; in GetTaskCount() local
655 taskCount += cloudSyncer->GetCloudSyncTaskCount(); in GetTaskCount()
659 return taskCount; in GetTaskCount()
661 taskCount += syncer_.GetTaskCount(); in GetTaskCount()
662 return taskCount; in GetTaskCount()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/mock/ |
| H A D | kv_store_nb_delegate_mock.cpp | 287 int32_t taskCount = taskCountMock_;
in GetTaskCount() local
288 return taskCount;
in GetTaskCount()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_sync_task_context.cpp | 637 int32_t taskCount = static_cast<int32_t>(responseTargetQueue_.size()); in GetResponseTaskCount() local
639 taskCount++; in GetResponseTaskCount()
641 return taskCount; in GetResponseTaskCount()
|
| /foundation/graphic/graphic_3d/lume/Lume_3D/api/3d/gltf/ |
| H A D | gltf.h | 237 virtual void OnImportProgressed(size_t taskIndex, size_t taskCount) = 0;
|
| /foundation/graphic/graphic_3d/lume/Lume_3D/api/3d/loaders/ |
| H A D | intf_scene_loader.h | 173 virtual void OnImportProgressed(size_t taskIndex, size_t taskCount) = 0;
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | sync_engine.cpp | 1279 int32_t taskCount = 0; in GetResponseTaskCount() local
1281 taskCount += iter->GetResponseTaskCount(); in GetResponseTaskCount()
1286 taskCount += static_cast<int32_t>(execTaskCount_); in GetResponseTaskCount()
1288 return taskCount; in GetResponseTaskCount()
|
| /foundation/graphic/graphic_3d/lume/Lume_3D/src/gltf/ |
| H A D | gltf2_importer.h | 222 void OnImportProgressed(size_t taskIndex, size_t taskCount) override;
|
| H A D | gltf2_importer.cpp | 3702 void Gltf2SceneImporter::OnImportProgressed(size_t taskIndex, size_t taskCount)
3705 listener_->OnImportProgressed(taskIndex, taskCount);
|
| /foundation/graphic/graphic_3d/lume/LumeEcsSerializer/EcsSerializer/src/ecs_serializer/ |
| H A D | ecs_asset_loader.cpp | 175 void OnImportProgressed(size_t taskIndex, size_t taskCount) override {}
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/ |
| H A D | object_manager.cpp | 737 int32_t taskCount = delegate_->GetTaskCount();
in Close() local
738 if (taskCount > 0 && syncCount_ == 1) {
in Close()
740 ZLOGW("Store is busy, close after a minute, task count: %{public}d", taskCount);
in Close()
|
| /foundation/graphic/graphic_3d/lume/scenewidgetplugin/plugin/src/ |
| H A D | asset_loader.cpp | 189 void OnImportProgressed(size_t taskIndex, size_t taskCount) override {}
|