/foundation/resourceschedule/resource_schedule_service/ressched/plugins/cgroup_sched_plugin/framework/sched_controller/ |
H A D | cgroup_adjuster.cpp | 61 void CgroupAdjuster::AdjustForkProcessGroup(Application &app, ProcessRecord &pr) in AdjustForkProcessGroup() argument 63 std::string filePath = ResSchedUtils::GetInstance().GetProcessFilePath(app.GetUid(), app.GetName(), pr.GetPid()); in AdjustForkProcessGroup() 86 if (forkPid != pr.GetPid()) { in AdjustForkProcessGroup() 87 int ret = CgroupSetting::SetThreadGroupSchedPolicy(forkPid, pr.curSchedGroup_); in AdjustForkProcessGroup() 90 __func__, forkPid, (int)pr.curSchedGroup_, ret); in AdjustForkProcessGroup() 100 void CgroupAdjuster::AdjustProcessGroup(Application &app, ProcessRecord &pr, AdjustSource source) in AdjustProcessGroup() argument 102 CGS_LOGI("%{public}s for %{public}d, source : %{public}d", __func__, pr.GetPid(), source); in AdjustProcessGroup() 103 ComputeProcessGroup(app, pr, source); in AdjustProcessGroup() 104 ResSchedUtils::GetInstance().ReportArbitrationResult(app, pr, source); in AdjustProcessGroup() 105 ApplyProcessGroup(app, pr); in AdjustProcessGroup() 159 ComputeProcessGroup(Application &app, ProcessRecord &pr, AdjustSource source) ComputeProcessGroup() argument 199 ApplyProcessGroup(Application &app, ProcessRecord &pr) ApplyProcessGroup() argument [all...] |
H A D | supervisor.cpp | 110 std::shared_ptr<ProcessRecord> Application::AddProcessRecord(std::shared_ptr<ProcessRecord> pr) 112 if (pr) { 113 pidsMap_[pr->GetPid()] = pr; 115 return pr; 147 auto pr = std::make_shared<ProcessRecord>(this->GetUid(), pid); 148 pidsMap_[pid] = pr; 149 return pr; 155 auto pr = iter->second; 156 if (pr [all...] |
H A D | sched_controller.cpp | 114 std::shared_ptr<ProcessRecord> pr = supervisor_->FindProcessRecord(pid); in GetProcessGroup() local 115 return pr ? (int32_t)(pr->curSchedGroup_) : (int32_t)(SP_DEFAULT); in GetProcessGroup()
|
H A D | cgroup_event_handler.cpp | 986 bool CgroupEventHandler::CheckVisibilityForRenderProcess(ProcessRecord &pr, ProcessRecord &mainProc) in CheckVisibilityForRenderProcess() argument 988 return (pr.processType_ == ProcRecordType::RENDER) && pr.isActive_ && in CheckVisibilityForRenderProcess() 989 !mainProc.GetWindowInfoNonNull(pr.linkedWindowId_)->isVisible_; in CheckVisibilityForRenderProcess()
|
/foundation/graphic/graphic_2d/rosen/modules/2d_engine/rosen_text/skia_txt/impl/ |
H A D | drawing_painter_impl.cpp | 96 const PaintRecord &pr) in DrawSymbolSkiaTxt() 104 if (pr.pen.has_value() && pr.brush.has_value()) { in DrawSymbolSkiaTxt() 105 canvas_->AttachBrush(pr.brush.value()); in DrawSymbolSkiaTxt() 106 canvas_->AttachPen(pr.pen.value()); in DrawSymbolSkiaTxt() 107 hmSymbolRun.DrawSymbol(canvas_, blob, offset, pr.symbol); in DrawSymbolSkiaTxt() 110 } else if (pr.pen.has_value() && !pr.brush.has_value()) { in DrawSymbolSkiaTxt() 111 canvas_->AttachPen(pr.pen.value()); in DrawSymbolSkiaTxt() 112 hmSymbolRun.DrawSymbol(canvas_, blob, offset, pr in DrawSymbolSkiaTxt() 95 DrawSymbolSkiaTxt(RSTextBlob* blob, const RSPoint& offset, const PaintRecord &pr) DrawSymbolSkiaTxt() argument 131 const PaintRecord& pr = paints_[std::get<PaintID>(paint)]; drawTextBlob() local 170 SymbolAnimation(const PaintRecord &pr) SymbolAnimation() argument 201 const PaintRecord& pr = paints_[std::get<PaintID>(paint)]; drawRect() local [all...] |
H A D | drawing_painter_impl.h | 44 void SymbolAnimation(const PaintRecord &pr); 45 void DrawSymbolSkiaTxt(RSTextBlob* blob, const RSPoint& offset, const PaintRecord &pr);
|
/foundation/graphic/graphic_3d/lume/metaobject/src/ |
H A D | register_anys.cpp | 89 static void RegisterTypes(IPropertyRegister& pr, TypeList<List...>) in RegisterTypes() argument 91 (pr.RegisterAny(CreateShared<DefaultAnyBuilder<Any<List>>>()), ...); in RegisterTypes() 92 (pr.RegisterAny(CreateShared<DefaultAnyBuilder<ArrayAny<List>>>()), ...); in RegisterTypes() 96 static void UnregisterTypes(IPropertyRegister& pr, TypeList<List...>) in UnregisterTypes() argument 98 (pr.UnregisterAny(ArrayAny<List>::StaticGetClassId()), ...); in UnregisterTypes() 99 (pr.UnregisterAny(Any<List>::StaticGetClassId()), ...); in UnregisterTypes() 104 auto& pr = registry.GetPropertyRegister(); in RegisterAnys() local 105 RegisterTypes(pr, BasicTypes {}); in RegisterAnys() 106 RegisterTypes(pr, ObjectTypes {}); in RegisterAnys() 111 auto& pr in UnRegisterAnys() local [all...] |
H A D | register_engine_access.cpp | 93 auto& pr = registry.GetEngineData(); in RegisterEngineTypes() local 94 RegisterBasicEngineTypes<true>(pr, SingleAndArrayTypes {}); in RegisterEngineTypes() 95 RegisterBasicEngineTypes<false>(pr, VectorTypes {}); in RegisterEngineTypes() 100 auto& pr = registry.GetEngineData(); in UnRegisterEngineTypes() local 101 UnRegisterBasicEngineTypes<false>(pr, VectorTypes {}); in UnRegisterEngineTypes() 102 UnRegisterBasicEngineTypes<true>(pr, SingleAndArrayTypes {}); in UnRegisterEngineTypes()
|
/foundation/window/window_manager/utils/test/unittest/ |
H A D | perform_reporter_test.cpp | 36 void SimuReportProcess(PerformReporter& pr, const std::vector<uint32_t>& durations); 37 bool PerformDataCmp(const PerformReporter& pr, const uint32_t totalCount, const std::vector<uint32_t>& splitCount); 56 void PerformReporterTest::SimuReportProcess(PerformReporter& pr, const std::vector<uint32_t>& durations) in SimuReportProcess() argument 59 pr.start(); in SimuReportProcess() 61 pr.end(); in SimuReportProcess() 65 bool PerformReporterTest::PerformDataCmp(const PerformReporter& pr, in PerformDataCmp() argument 68 if (pr.totalCount_ != totalCount) { in PerformDataCmp() 69 WLOGFE("pr.totalCount_=%{public}u, expect=%{public}u", pr.totalCount_.load(), totalCount); in PerformDataCmp() 74 for (auto& iter: pr in PerformDataCmp() 95 PerformReporter pr = PerformReporter("TestTag", {100, 200, 300}, 10); HWTEST_F() local 107 PerformReporter pr = PerformReporter("TestTag", {100, 200, 300}, 3); HWTEST_F() local 119 PerformReporter pr = PerformReporter("TestTag", {100, 200, 300}, 4); HWTEST_F() local 131 PerformReporter pr = PerformReporter("TestTag", {100, 200, 300}, 10); HWTEST_F() local [all...] |
/foundation/resourceschedule/resource_schedule_service/ressched/plugins/cgroup_sched_plugin/framework/sched_controller/include/ |
H A D | cgroup_adjuster.h | 60 void AdjustForkProcessGroup(Application &app, ProcessRecord &pr); 61 void AdjustProcessGroup(Application &app, ProcessRecord &pr, AdjustSource source); 63 void ApplyProcessGroup(Application &app, ProcessRecord &pr); 74 void ComputeProcessGroup(Application &app, ProcessRecord &pr, AdjustSource source);
|
H A D | supervisor.h | 156 std::shared_ptr<ProcessRecord> AddProcessRecord(std::shared_ptr<ProcessRecord> pr);
|
H A D | cgroup_event_handler.h | 80 bool CheckVisibilityForRenderProcess(ProcessRecord &pr, ProcessRecord &mainProc);
|
/foundation/resourceschedule/resource_schedule_service/ressched/plugins/cgroup_sched_plugin/framework/utils/include/ |
H A D | ressched_utils.h | 28 using ReportArbitrationResultFunc = void (*)(Application &app, ProcessRecord &pr, AdjustSource source); 29 using ReportSysEventFunc = void (*)(Application &app, ProcessRecord &pr, uint32_t resType, int32_t state); 37 void ReportArbitrationResult(Application &app, ProcessRecord &pr, AdjustSource source); 38 void ReportSysEvent(Application &app, ProcessRecord &pr, uint32_t resType, int32_t state);
|
/foundation/filemanagement/app_file_service/interfaces/kits/js/backup/ |
H A D | incremental_backup_data.h | 81 LibN::NVal pr = data.GetProp(BConstants::PRIORITY); in BackupPriority() local 82 if (pr.val_ != nullptr) { in BackupPriority() 83 auto [succ, tmp] = pr.ToInt32(); in BackupPriority()
|
/foundation/arkui/ace_engine/test/unittest/core/pattern/tabs/ |
H A D | tab_bar_pattern_test_ng.cpp | 375 auto pr = tabBarPattern_->tabBarType_.emplace(std::make_pair(1, true)); in HWTEST_F() local 376 ASSERT_TRUE(pr.second); in HWTEST_F() 448 auto pr = tabBarPattern_->tabBarType_.emplace(std::make_pair(1, true)); in HWTEST_F() local 449 ASSERT_TRUE(pr.second); in HWTEST_F() 519 auto pr = tabBarPattern_->tabBarType_.emplace(std::make_pair(1, true)); in HWTEST_F() local 520 ASSERT_TRUE(pr.second); in HWTEST_F() 590 auto pr = tabBarPattern_->tabBarType_.emplace(std::make_pair(1, true)); in HWTEST_F() local 591 ASSERT_TRUE(pr.second); in HWTEST_F() 659 auto pr = tabBarPattern_->tabBarType_.emplace(std::make_pair(1, true)); in HWTEST_F() local 660 ASSERT_TRUE(pr in HWTEST_F() 695 auto pr = tabBarPattern_->tabBarType_.emplace(std::make_pair(1, true)); HWTEST_F() local 730 auto pr = tabBarPattern_->tabBarType_.emplace(std::make_pair(1, true)); HWTEST_F() local 765 auto pr = tabBarPattern_->tabBarType_.emplace(std::make_pair(1, true)); HWTEST_F() local 923 auto pr = tabBarPattern_->tabBarType_.emplace(std::make_pair(1, true)); HWTEST_F() local 959 auto pr = tabBarPattern_->tabBarType_.emplace(std::make_pair(1, true)); HWTEST_F() local 994 auto pr = tabBarPattern_->tabBarType_.emplace(std::make_pair(1, true)); HWTEST_F() local 1029 auto pr = tabBarPattern_->tabBarType_.emplace(std::make_pair(1, true)); HWTEST_F() local 1063 auto pr = tabBarPattern_->tabBarType_.emplace(std::make_pair(1, true)); HWTEST_F() local 1098 auto pr = tabBarPattern_->tabBarType_.emplace(std::make_pair(1, true)); HWTEST_F() local 1132 auto pr = tabBarPattern_->tabBarType_.emplace(std::make_pair(1, true)); HWTEST_F() local 1166 auto pr = tabBarPattern_->tabBarType_.emplace(std::make_pair(1, true)); HWTEST_F() local [all...] |
H A D | tab_bar_test_ng.cpp | 616 auto pr = tabBarPattern_->tabBarType_.emplace(std::make_pair(1, true)); in HWTEST_F() local 617 ASSERT_TRUE(pr.second); in HWTEST_F()
|
/foundation/resourceschedule/resource_schedule_service/ressched/plugins/cgroup_sched_plugin/framework/utils/ |
H A D | ressched_utils.cpp | 137 void ResSchedUtils::ReportArbitrationResult(Application &app, ProcessRecord &pr, AdjustSource source) in ReportArbitrationResult() argument 143 reportArbitrationResultFunc_(app, pr, source); in ReportArbitrationResult() 146 void ResSchedUtils::ReportSysEvent(Application &app, ProcessRecord &pr, uint32_t resType, int32_t state) in ReportSysEvent() argument 152 reportSysEventFunc_(app, pr, resType, state); in ReportSysEvent()
|
/foundation/resourceschedule/resource_schedule_service/ressched/plugins/cgroup_sched_plugin/test/unittest/ |
H A D | process_group_sub_test.cpp | 195 auto pr = new ProcessRecord(20150011, 9050); in HWTEST_F() local 196 CgroupAdjuster::GetInstance().AdjustForkProcessGroup(*application, *pr); in HWTEST_F()
|
/foundation/arkui/ace_engine/test/component_test/tools/middle_ground/util/ |
H A D | index.js | 39 function promiseRun(list, pr) { 44 let workerProcess = spawn('node', [hostPath, pr, path], { encoding: 'utf-8', stdio: 'pipe' });
|
/foundation/resourceschedule/resource_schedule_service/ressched/plugins/cgroup_sched_plugin/test/fuzztest/cgroupsched_fuzzer/ |
H A D | cgroupsched_fuzzer.cpp | 732 ProcessRecord pr(uid, pid); in CheckVisibilityForRenderProcessFuzzTest() 733 pr.processType_ = ProcRecordType::RENDER; in CheckVisibilityForRenderProcessFuzzTest() 734 pr.isActive_ = true; in CheckVisibilityForRenderProcessFuzzTest() 739 cgroupEventHandler->CheckVisibilityForRenderProcess(pr, mainProc); in CheckVisibilityForRenderProcessFuzzTest() 741 cgroupEventHandler->CheckVisibilityForRenderProcess(pr, mainProc); in CheckVisibilityForRenderProcessFuzzTest() 1162 ProcessRecord pr(uid, pid); in AdjustForkProcessGroupFuzzTest() 1165 CgroupAdjuster::GetInstance().AdjustForkProcessGroup(app, pr); in AdjustForkProcessGroupFuzzTest() 1184 ProcessRecord pr(uid, pid); in AdjustProcessGroupFuzzTest() 1187 CgroupAdjuster::GetInstance().AdjustProcessGroup(app, pr, AdjustSource::ADJS_FG_APP_CHANGE); in AdjustProcessGroupFuzzTest() 1226 ProcessRecord pr(ui in ComputeProcessGroupFuzzTest() [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
H A D | rdb_result_set_impl_test.cpp | 81 std::find_if(Names.begin(), Names.end(), [&columnType, &name](auto &pr) { in getColumnType() 82 if (pr.first == name) { in getColumnType() 83 columnType = pr.second; in getColumnType()
|
/foundation/arkui/ace_engine/test/component_test/tools/middle_ground/public/ |
H A D | index.js | 67 function run(list, pr) { 68 let data = JSON.stringify({list, pr});
|
/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_common/ |
H A D | wifi_internal_event_dispatcher.cpp | 1023 pr = g_CallbackEventPermissionMap.equal_range(callbackEventId); in VerifyRegisterCallbackPermission() local 1025 for (auto itr = pr.first; itr != pr.second; ++itr) { in VerifyRegisterCallbackPermission()
|