/foundation/resourceschedule/resource_schedule_service/ressched_executor/services/resschedexeservice/src/ |
H A D | res_sched_exe_service_stub.cpp | 58 bool GetExtResType(uint32_t& resType, const nlohmann::json& context) in GetExtResType() argument 60 if (resType != ResExeType::RES_TYPE_COMMON_SYNC && resType != ResExeType::RES_TYPE_COMMON_ASYNC) { in GetExtResType() 66 RSSEXE_LOGE("use extend resType, but not send resTypeExt with payload"); in GetExtResType() 69 resType = (uint32_t)type; in GetExtResType() 70 RSSEXE_LOGD("use extend resType = %{public}d.", resType); in GetExtResType() 97 uint32_t resType = 0; in ReportRequestInner() local 100 if (!ParseParcel(data, resType, value, context)) { in ReportRequestInner() 108 RSSEXE_LOGD("receive data from ipc resType in ReportRequestInner() 156 uint32_t resType = 0; ReportDebugInner() local 203 ParseParcel(MessageParcel& data, uint32_t& resType, int64_t& value, nlohmann::json& context) ParseParcel() argument [all...] |
H A D | res_sched_exe_service.cpp | 40 int32_t ResSchedExeService::SendRequestSync(uint32_t resType, int64_t value, in SendRequestSync() argument 43 return ResSchedExeMgr::GetInstance().SendRequestSync(resType, value, context, reply); in SendRequestSync() 46 void ResSchedExeService::SendRequestAsync(uint32_t resType, int64_t value, const nlohmann::json& context) in SendRequestAsync() argument 48 ResSchedExeMgr::GetInstance().SendRequestAsync(resType, value, context); in SendRequestAsync()
|
/foundation/resourceschedule/resource_schedule_service/ressched_executor/services/resschedexemgr/src/ |
H A D | res_sched_exe_mgr.cpp | 64 int32_t ResSchedExeMgr::SendRequestSync(uint32_t resType, int64_t value, in SendRequestSync() argument 67 RSSEXE_LOGD("receive resType = %{public}u, value = %{public}lld.", resType, (long long)value); in SendRequestSync() 68 std::string traceStr = BuildTraceStr(__func__, resType, value); in SendRequestSync() 70 switch (resType) { in SendRequestSync() 78 HandleRequestForCgroup(resType, payload, reply); in SendRequestSync() 81 auto resData = std::make_shared<ResData>(resType, value, payload, reply); in SendRequestSync() 91 void ResSchedExeMgr::SendRequestAsync(uint32_t resType, int64_t value, const nlohmann::json& payload) in SendRequestAsync() argument 93 RSSEXE_LOGD("receive resType = %{public}u, value = %{public}lld.", resType, (lon in SendRequestAsync() 142 BuildTraceStr(const std::string& func, uint32_t resType, int64_t value) BuildTraceStr() argument 150 HandleRequestForCgroup(uint32_t resType, const nlohmann::json& payload, nlohmann::json& reply) HandleRequestForCgroup() argument 202 GetCgroupFileContent(uint32_t resType, const nlohmann::json& payload, nlohmann::json& reply) GetCgroupFileContent() argument 224 CheckProcTaskForCgroup(uint32_t resType, const nlohmann::json& payload, nlohmann::json& reply) CheckProcTaskForCgroup() argument [all...] |
/foundation/resourceschedule/resource_schedule_service/ressched/plugins/cgroup_sched_plugin/framework/sched_controller/ |
H A D | sched_controller.cpp | 82 for (auto resType: resTypes) { in Init() 83 PluginMgr::GetInstance().SubscribeResource(LIB_NAME, resType); in Init() 156 auto iter = dispatchResFuncMap_.find(resData->resType); in DispatchResource() 158 DispatchOtherResource(resData->resType, resData->value, resData->payload); in DispatchResource() 162 func(handler, resData->resType, resData->value, resData->payload); in DispatchResource() 164 DispatchOtherResource(resData->resType, resData->value, resData->payload); in DispatchResource() 167 void SchedController::DispatchOtherResource(uint32_t resType, int64_t value, const nlohmann::json& payload) in DispatchOtherResource() argument 173 handler->PostTask([handler, resType, value, payload] { in DispatchOtherResource() 174 switch (resType) { in DispatchOtherResource() 179 handler->HandleReportHisysEvent(resType, valu in DispatchOtherResource() [all...] |
/foundation/resourceschedule/resource_schedule_service/ressched/plugins/cgroup_sched_plugin/framework/sched_controller/include/ |
H A D | cgroup_event_handler.h | 60 void HandleReportMMIProcess(uint32_t resType, int64_t value, const nlohmann::json& payload); 61 void HandleReportRenderThread(uint32_t resType, int64_t value, const nlohmann::json& payload); 62 void HandleReportKeyThread(uint32_t resType, int64_t value, const nlohmann::json& payload); 63 void HandleReportWindowState(uint32_t resType, int64_t value, const nlohmann::json& payload); 64 void HandleReportAudioState(uint32_t resType, int64_t value, const nlohmann::json& payload); 65 void HandleReportWebviewAudioState(uint32_t resType, int64_t value, const nlohmann::json& payload); 66 void HandleReportRunningLockEvent(uint32_t resType, int64_t value, const nlohmann::json& payload); 67 void HandleReportHisysEvent(uint32_t resType, int64_t value, const nlohmann::json& payload); 68 void HandleReportAvCodecEvent(uint32_t resType, int64_t value, const nlohmann::json& payload); 69 void HandleSceneBoardState(uint32_t resType, int64_ [all...] |
/foundation/resourceschedule/resource_schedule_service/ressched_executor/services/resschedexemgr/include/ |
H A D | res_sched_exe_mgr.h | 46 * @param resType Resource type. 51 int32_t SendRequestSync(uint32_t resType, int64_t value, 57 * @param resType Resource type. 61 void SendRequestAsync(uint32_t resType, int64_t value, const nlohmann::json& payload = nullptr); 70 std::string BuildTraceStr(const std::string& func, uint32_t resType, int64_t value); 72 void HandleRequestForCgroup(uint32_t resType, const nlohmann::json& payload, nlohmann::json& reply); 73 void GetCgroupFileContent(uint32_t resType, const nlohmann::json& payload, nlohmann::json& reply); 74 void CheckProcTaskForCgroup(uint32_t resType, const nlohmann::json& payload, nlohmann::json& reply);
|
/foundation/resourceschedule/resource_schedule_service/ressched_executor/interfaces/innerkits/ressched_executor_client/src/ |
H A D | res_sched_exe_client.cpp | 45 int32_t ResSchedExeClient::SendRequestSync(uint32_t resType, int64_t value, in SendRequestSync() argument 48 return SendRequestInner(true, resType, value, context, reply); in SendRequestSync() 51 void ResSchedExeClient::SendRequestAsync(uint32_t resType, int64_t value, in SendRequestAsync() argument 55 SendRequestInner(false, resType, value, context, reply); in SendRequestAsync() 73 int32_t ResSchedExeClient::SendRequestInner(bool isSync, uint32_t resType, int64_t value, in SendRequestInner() argument 79 RSSEXE_LOGD("receive resType = %{public}u, value = %{public}lld.", resType, (long long)value); in SendRequestInner() 89 return resSchedExe_->SendRequestSync(resType, value, context, reply); in SendRequestInner() 91 resSchedExe_->SendRequestAsync(resType, value, context); in SendRequestInner()
|
H A D | res_sched_exe_service_proxy.cpp | 28 int32_t ResSchedExeServiceProxy::SendRequestSync(uint32_t resType, int64_t value, in SendRequestSync() argument 33 if (resType == ResExeType::RES_TYPE_DEBUG) { in SendRequestSync() 38 MakeUpParcel(data, resType, value, context); in SendRequestSync() 53 void ResSchedExeServiceProxy::SendRequestAsync(uint32_t resType, int64_t value, const nlohmann::json& context) in SendRequestAsync() argument 57 if (resType == ResExeType::RES_TYPE_DEBUG) { in SendRequestAsync() 62 MakeUpParcel(data, resType, value, context); in SendRequestAsync() 91 uint32_t resType, int64_t value, const nlohmann::json& context) in MakeUpParcel() 95 WRITE_PARCEL(data, Uint32, resType, ResIpcErrCode::RSSEXE_DATA_ERROR, ResSchedExeServiceProxy); in MakeUpParcel() 90 MakeUpParcel(MessageParcel& data, uint32_t resType, int64_t value, const nlohmann::json& context) MakeUpParcel() argument
|
/foundation/ability/ability_runtime/services/common/src/ |
H A D | res_sched_util.cpp | 55 uint32_t resType = ResourceSchedule::ResType::RES_TYPE_APP_ABILITY_START; in ReportAbilityStartInfoToRSS() local 64 ResourceSchedule::ResSchedClient::GetInstance().ReportData(resType, isColdStart ? 1 : 0, eventParams); in ReportAbilityStartInfoToRSS() 72 uint32_t resType = ResourceSchedule::ResType::RES_TYPE_APP_ASSOCIATED_START; in ReportAbilityAssociatedStartInfoToRSS() local 82 ResourceSchedule::ResSchedClient::GetInstance().ReportData(resType, type, eventParams); in ReportAbilityAssociatedStartInfoToRSS() 107 uint32_t resType = ResourceSchedule::ResType::SYNC_RES_TYPE_THAW_ONE_APP; in ReportEventToRSS() local 116 ResourceSchedule::ResSchedClient::GetInstance().ReportSyncEvent(resType, 0, payload, reply); in ReportEventToRSS() 123 uint32_t resType = ResourceSchedule::ResType::SYNC_RES_TYPE_GET_ALL_SUSPEND_STATE; in GetAllFrozenPidsFromRSS() local 127 int32_t ret = ResourceSchedule::ResSchedClient::GetInstance().ReportSyncEvent(resType, 0, payload, reply); in GetAllFrozenPidsFromRSS() 160 uint32_t resType = ResourceSchedule::ResType::SYNC_RES_TYPE_SHOULD_FORCE_KILL_PROCESS; in CheckShouldForceKillProcess() local 164 ResourceSchedule::ResSchedClient::GetInstance().ReportSyncEvent(resType, in CheckShouldForceKillProcess() 177 uint32_t resType = ResourceSchedule::ResType::RES_TYPE_KEY_PERF_SCENE; ReportLoadingEventToRss() local [all...] |
/foundation/resourceschedule/resource_schedule_service/ressched/plugins/cgroup_sched_plugin/framework/utils/include/ |
H A D | ressched_utils.h | 27 using ReportDataFunc = void (*)(uint32_t resType, int64_t value, const nlohmann::json& payload); 29 using ReportSysEventFunc = void (*)(Application &app, ProcessRecord &pr, uint32_t resType, int32_t state); 30 using DispatchResourceExtFunc = void (*)(uint32_t resType, int64_t value, const nlohmann::json& payload); 36 void ReportDataInProcess(uint32_t resType, int64_t value, const nlohmann::json& payload); 38 void ReportSysEvent(Application &app, ProcessRecord &pr, uint32_t resType, int32_t state); 40 void DispatchResourceExt(uint32_t resType, int64_t value, const nlohmann::json& payload);
|
/foundation/resourceschedule/resource_schedule_service/ressched/plugins/device_standby_plugin/src/ |
H A D | device_standby_plugin.cpp | 50 for (auto resType : resTypes_) { in Init() 51 PluginMgr::GetInstance().SubscribeResource(LIB_NAME, resType); in Init() 58 for (auto resType : resTypes_) { in Disable() 59 PluginMgr::GetInstance().UnSubscribeResource(LIB_NAME, resType); in Disable() 74 data->resType, (long long)(data->value)); in DispatchResource() 77 std::make_shared<DevStandbyMgr::ResData>(data->resType, data->value, data->payload)); in DispatchResource()
|
/foundation/resourceschedule/resource_schedule_service/ressched/services/resschedmgr/resschedfwk/src/ |
H A D | res_sched_mgr.cpp | 163 void ResSchedMgr::ReportData(uint32_t resType, int64_t value, const nlohmann::json& payload)
in ReportData() argument 165 ReportDataInner(resType, value, payload);
in ReportData() 166 SceneRecognizerMgr::GetInstance().DispatchResource(resType, value, payload);
in ReportData() 169 void ResSchedMgr::ReportDataInner(uint32_t resType, int64_t value, const nlohmann::json& payload)
in ReportDataInner() argument 171 RESSCHED_LOGD("%{public}s, receive resType = %{public}u, value = %{public}lld.", __func__,
in ReportDataInner() 172 resType, (long long)value);
in ReportDataInner() 174 trace_str.append(",resType[").append(std::to_string(resType)).append("]");
in ReportDataInner() 177 PluginMgr::GetInstance().DispatchResource(std::make_shared<ResData>(resType, value, payload));
in ReportDataInner() 203 extern "C" void ReportDataInProcess(uint32_t resType, int64_ argument [all...] |
/foundation/resourceschedule/resource_schedule_service/ressched/scene_recognize/src/ |
H A D | background_sensitive_task_overlapping_scene_recognizer.cpp | 51 void BackgroundSensitiveTaskOverlappingSceneRecognizer::OnDispatchResource(uint32_t resType, int64_t value, in OnDispatchResource() argument 58 switch (resType) { in OnDispatchResource() 60 HandleForeground(resType, value, payload); in OnDispatchResource() 63 HandleContinuousTask(resType, value, payload); in OnDispatchResource() 73 void BackgroundSensitiveTaskOverlappingSceneRecognizer::HandleContinuousTask(uint32_t resType, int64_t value, in HandleContinuousTask() argument 94 RESSCHED_LOGI("%{public}s, resType:%{public}d, value:%{public}lld, typeIds:{%{public}s}", in HandleContinuousTask() 95 __func__, resType, (long long)value, typeIdsStr.str().c_str()); in HandleContinuousTask() 190 void BackgroundSensitiveTaskOverlappingSceneRecognizer::HandleForeground(uint32_t resType, int64_t value, in HandleForeground() argument
|
H A D | scene_recognizer_mgr.cpp | 49 void SceneRecognizerMgr::DispatchResource(uint32_t resType, int64_t value, const nlohmann::json& payload) in DispatchResource() argument 56 ffrtQueue_->submit([resType, value, payload, recognizer]() { in DispatchResource() 57 recognizer->OnDispatchResource(resType, value, payload); in DispatchResource()
|
/foundation/resourceschedule/resource_schedule_service/ressched/services/resschedmgr/pluginbase/include/ |
H A D | res_data.h | 28 ResData(uint32_t type, int64_t value, const nlohmann::json& payload) : resType(type),
in ResData() 31 ResData(uint32_t type, int64_t value, const nlohmann::json& payload, nlohmann::json& reply) : resType(type),
in ResData() 34 uint32_t resType = 0;
member
|
/foundation/resourceschedule/resource_schedule_service/ressched/plugins/frame_aware_plugin/test/unittest/ |
H A D | frame_aware_plugin_test.cpp | 68 data->resType = RES_TYPE_APP_STATE_CHANGE; in HWTEST_F() 70 data1->resType = RES_TYPE_APP_STATE_CHANGE; in HWTEST_F() 108 data->resType = RES_TYPE_PROCESS_STATE_CHANGE; in HWTEST_F() 110 data1->resType = RES_TYPE_PROCESS_STATE_CHANGE; in HWTEST_F() 148 data->resType = RES_TYPE_CGROUP_ADJUSTER; in HWTEST_F() 150 data1->resType = RES_TYPE_CGROUP_ADJUSTER; in HWTEST_F() 198 data->resType = RES_TYPE_WINDOW_FOCUS; in HWTEST_F() 200 data1->resType = RES_TYPE_WINDOW_FOCUS; in HWTEST_F() 232 data->resType = RES_TYPE_CONTINUOUS_TASK; in HWTEST_F() 234 data1->resType in HWTEST_F() [all...] |
/foundation/resourceschedule/resource_schedule_service/ressched/scene_recognize/include/ |
H A D | background_sensitive_task_overlapping_scene_recognizer.h | 27 void OnDispatchResource(uint32_t resType, int64_t value, const nlohmann::json& payload) override; 34 void HandleContinuousTask(uint32_t resType, int64_t value, const nlohmann::json& payload); 38 void HandleForeground(uint32_t resType, int64_t value, const nlohmann::json& payload);
|
/foundation/resourceschedule/resource_schedule_service/ressched_executor/interfaces/innerkits/ressched_executor_client/include/ |
H A D | res_sched_exe_service_proxy.h | 37 * @param resType Indicates the resource type, all of the type have listed in res_exe_type.h. 43 int32_t SendRequestSync(uint32_t resType, int64_t value, 49 * @param resType Indicates the resource type, all of the type have listed in res_exe_type.h. 53 void SendRequestAsync(uint32_t resType, int64_t value, const nlohmann::json& context) override; 76 int32_t MakeUpParcel(MessageParcel& data, uint32_t resType, int64_t value, const nlohmann::json& context);
|
H A D | res_sched_exe_client.h | 44 * @param resType Indicates the resource type, all of the type have listed in res_exe_type.h. 50 int32_t SendRequestSync(uint32_t resType, int64_t value, const nlohmann::json& context, nlohmann::json& reply); 55 * @param resType Indicates the resource type, all of the type have listed in res_exe_type.h. 59 void SendRequestAsync(uint32_t resType, int64_t value, const nlohmann::json& context); 98 int32_t SendRequestInner(bool isSync, uint32_t resType, int64_t value,
|
H A D | ires_sched_exe_service.h | 31 * @param resType Indicates the resource type, all of the type have listed in res_exe_type.h. 37 virtual int32_t SendRequestSync(uint32_t resType, int64_t value, 43 * @param resType Indicates the resource type, all of the type have listed in res_exe_type.h. 47 virtual void SendRequestAsync(uint32_t resType, int64_t value, const nlohmann::json& payload) = 0;
|
/foundation/resourceschedule/resource_schedule_service/ressched_executor/plugins/socperf_executor_plugin/framework/src/ |
H A D | socperf_executor_plugin.cpp | 46 for (auto resType : resType_) { in Init() 47 PluginMgr::GetInstance().SubscribeResource(LIB_NAME, resType); in Init() 56 for (auto resType : resType_) { in Disable() 57 PluginMgr::GetInstance().UnSubscribeResource(LIB_NAME, resType); in Disable() 68 auto funcIter = functionMap_.find(data->resType); in DispatchResource()
|
/foundation/resourceschedule/device_standby/utils/common/include/ |
H A D | standby_res_data.h | 28 ResData(uint32_t type, int64_t value, const nlohmann::json& payload) : resType(type), in ResData() 31 uint32_t resType = 0; member
|
/foundation/distributedhardware/distributed_camera/interfaces/inner_kits/native_cpp/test/sinkfuzztest/callbacksinkonremoterequest_fuzzer/ |
H A D | callbacksinkonremoterequest_fuzzer.cpp | 44 int32_t resType = static_cast<int32_t>(resourceEventType[data[0] % DC_RESOURCE_SIZE]); in CallbackSinkOnRemoteRequestFuzzTest() local 49 pdata.WriteInt32(resType); in CallbackSinkOnRemoteRequestFuzzTest() 70 int32_t resType = static_cast<int32_t>(resourceEventType[data[0] % DC_RESOURCE_SIZE]); in CallbackSinkOnNotifyResourceInfoInnerFuzzTest() local 75 pdata.WriteInt32(resType); in CallbackSinkOnNotifyResourceInfoInnerFuzzTest()
|
/foundation/resourceschedule/resource_schedule_service/ressched/plugins/cgroup_sched_plugin/framework/utils/ |
H A D | ressched_utils.cpp | 128 void ResSchedUtils::ReportDataInProcess(uint32_t resType, int64_t value, const nlohmann::json& payload) in ReportDataInProcess() argument 134 reportFunc_(resType, value, payload); in ReportDataInProcess() 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() 178 void ResSchedUtils::DispatchResourceExt(uint32_t resType, int64_t value, const nlohmann::json& payload) in DispatchResourceExt() argument 184 dispatchResourceExtFunc_(resType, value, payload); in DispatchResourceExt()
|
/foundation/resourceschedule/resource_schedule_service/ressched/interfaces/innerkits/ressched_client/include/ |
H A D | res_sched_service_proxy.h | 34 * @param resType Indicates the resource type, all of the type have listed in res_type.h. 38 void ReportData(uint32_t resType, int64_t value, const nlohmann::json& payload) override; 43 * @param resType Indicates the resource type, all of the type have listed in res_type.h. 48 int32_t ReportSyncEvent(const uint32_t resType, const int64_t value, const nlohmann::json& payload, 112 int32_t WriteParcelForReportData(const uint32_t resType, const int64_t value, const nlohmann::json& payload,
|