Android Framework 常见解决方案（25-1）定制CPUSET解决方案-framework部分修改

1 原理说明

这个方案有如下基本需求：

  • 构建自定义CPUSET，/dev/cpuset中包含一个全新的cpuset分组。且可以通过set_cpuset_policy和set_sched_policy接口可以设置自定义CPUSET。
  • 开机启动后可以通过zygote判定来对特定的应用进程设置CPUSET，并一直保持，且保证自定义CPUSET不受其他CPUSET影响，持续独立。

原理上因为修改代码涉及部分较多，因此共分3个部分：

  1. framework修改：添加SCHED GROUP和THREAD GROUP（THREAD_GROUP_对应SP_）的支持，且支持开机启动后直接设置。applyOomAdjLSP的判定保持不变。
  2. system修改：添加SP_CUSTOM的支持及set_cpuset_policy和set_sched_policy接口等支持，同时修改task_profiles.json，添加SP_CUSTOM CPUSET的支持。
  3. init.rc修改及编译部分调整：对自定义cpuset节点进行操作，vndk部分编译需要重新调整方案以及不修改VNDK如何保证编译通过。

由于修改中涉及代码量过大，这里拆分成两节进行展示。本章节主要针对第1部分修改进行说明。下一篇文章 👇

Android Framework 常见解决方案（25-2）定制CPUSET解决方案-system修改及编译部分调整

主要对第2和第3部分修改进行说明。

2 修改方案-framework部分（Android S）

这里需要添加THREAD_GROUP_CUSTOM，与system中修改的SP_CUSTOM同步，数值需一致，需要在$AOSP/frameworks/base/core/java/android/os/Process.java文件中修改：

public class Process {private static final String LOG_TAG = "Process";/*** An invalid UID value.*/public static final int INVALID_UID = -1;//.../*** Thread group for RT app.* @hide**/public static final int THREAD_GROUP_RT_APP = 6;/*** Thread group for bound foreground services that should* have additional CPU restrictions during screen off* @hide**/public static final int THREAD_GROUP_RESTRICTED = 7;/*** Thread Group for CUSTOM* @hide**/public static final int THREAD_GROUP_CUSTOM = 8;//...
}

接下来需要添加SCHED_GROUP_CUSTOM相关配置。在$AOSP/frameworks/base/services/core/java/com/android/server/am/ProcessList.java文件中修改：

public final class ProcessList {//...// Activity manager's version of Process.THREAD_GROUP_BACKGROUNDstatic final int SCHED_GROUP_BACKGROUND = 0;// Activity manager's version of Process.THREAD_GROUP_RESTRICTEDstatic final int SCHED_GROUP_RESTRICTED = 1;// Activity manager's version of Process.THREAD_GROUP_DEFAULTstatic final int SCHED_GROUP_DEFAULT = 2;// Activity manager's version of Process.THREAD_GROUP_TOP_APPpublic static final int SCHED_GROUP_TOP_APP = 3;// Activity manager's version of Process.THREAD_GROUP_TOP_APP// Disambiguate between actual top app and processes bound to the top appstatic final int SCHED_GROUP_TOP_APP_BOUND = 4;
+    //add custom schedule group
+    static final int SCHED_GROUP_CUSTOM = 10;//...private static boolean writeProcessOomListToProto(ProtoOutputStream proto, long fieldId,ActivityManagerService service, List<ProcessRecord> origList,boolean inclDetails, String dumpPackage) {//...switch (state.getSetSchedGroup()) {case SCHED_GROUP_BACKGROUND:schedGroup = ProcessOomProto.SCHED_GROUP_BACKGROUND;break;case SCHED_GROUP_DEFAULT:schedGroup = ProcessOomProto.SCHED_GROUP_DEFAULT;break;case SCHED_GROUP_TOP_APP:schedGroup = ProcessOomProto.SCHED_GROUP_TOP_APP;break;case SCHED_GROUP_TOP_APP_BOUND:schedGroup = ProcessOomProto.SCHED_GROUP_TOP_APP_BOUND;
+                case SCHED_GROUP_CUSTOM:
+                    schedGroup = ProcessOomProto.SCHED_GROUP_CUSTOM;
+                    break;}//...}//...private static boolean dumpProcessOomList(PrintWriter pw,ActivityManagerService service, List<ProcessRecord> origList,String prefix, String normalLabel, String persistentLabel,boolean inclDetails, String dumpPackage) {//...    for (int i = list.size() - 1; i >= 0; i--) {//...switch (state.getSetSchedGroup()) {case SCHED_GROUP_BACKGROUND:schedGroup = 'b';break;case SCHED_GROUP_DEFAULT:schedGroup = 'F';break;case SCHED_GROUP_TOP_APP:schedGroup = 'T';break;case SCHED_GROUP_RESTRICTED:schedGroup = 'R';break;case SCHED_GROUP_TOP_APP_BOUND:schedGroup = 'B';break;
+                case SCHED_GROUP_CUSTOM:
+                    schedGroup = 'C';
+                    break;default:schedGroup = '?';break;}}

添加SCHED_GROUP_CUSTOM，与ProcessList.java中同步。在$AOSP/frameworks/base/core/proto/android/server/activitymanagerservice.proto文件中修改：

//...
message ProcessOomProto {//...enum SchedGroup {SCHED_GROUP_UNKNOWN = -1;SCHED_GROUP_BACKGROUND = 0;SCHED_GROUP_DEFAULT = 1;SCHED_GROUP_TOP_APP = 2;SCHED_GROUP_TOP_APP_BOUND = 3;
+        SCHED_GROUP_CUSTOM = 10;}

 为适配之前的适配SP_CUSTOM，同时契合之前1中修改的task_profile.json文件中的配置，在AOSP/frameworks/base/core/jni/android_util_Process.cpp文件中修改：

//修改android_os_Process_setProcessGroup，适配SP_CUSTOM
void android_os_Process_setProcessGroup(JNIEnv* env, jobject clazz, int pid, jint grp)
{ALOGV("%s pid=%d grp=%" PRId32, __func__, pid, grp);//...while ((de = readdir(d))) {//...// grp != SP_BACKGROUND. Only change the cpuset cgroup for low priority thread, so it could// preserve it sched policy profile setting.if (t_pri >= ANDROID_PRIORITY_BACKGROUND) {switch (grp) {case SP_SYSTEM:taskprofile = "ServiceCapacityLow";break;case SP_RESTRICTED:taskprofile = "ServiceCapacityRestricted";break;case SP_FOREGROUND:case SP_AUDIO_APP:case SP_AUDIO_SYS:taskprofile = "ProcessCapacityHigh";break;case SP_TOP_APP:taskprofile = "ProcessCapacityMax";break;
+                case SP_CUSTOM:
+                    taskprofile = "CustomPerformance";
+                    break;default:taskprofile = "ProcessCapacityNormal";break;}if (!SetTaskProfiles(t_pid, {taskprofile}, true)) {signalExceptionForGroupError(env, errno ? errno : EPERM, t_pid);break;}// Change the cpuset policy profile for non-low priority thread according to the grp} else {if (!SetTaskProfiles(t_pid, {get_cpuset_policy_profile_name((SchedPolicy)grp)}, true)) {signalExceptionForGroupError(env, errno ? errno : EPERM, t_pid);break;}}}closedir(d);
}//修改get_cpuset_cores_for_policy，适配SP_CUSTOM
static void get_cpuset_cores_for_policy(SchedPolicy policy, cpu_set_t *cpu_set)
{FILE *file;std::string filename;CPU_ZERO(cpu_set);switch (policy) {case SP_BACKGROUND:if (!CgroupGetAttributePath("LowCapacityCPUs", &filename)) {return;}break;case SP_FOREGROUND:if (!CgroupGetAttributePath("HighCapacityCPUs", &filename)) {return;}break;case SP_AUDIO_APP:case SP_AUDIO_SYS:if (!CgroupGetAttributePath("AudioAppCapacityCPUs", &filename)) {return;}if (access(filename.c_str(), F_OK) != 0) {if (!CgroupGetAttributePath("HighCapacityCPUs", &filename)) {return;}}break;case SP_RT_APP:if (!CgroupGetAttributePath("HighCapacityCPUs", &filename)) {return;}break;case SP_TOP_APP:if (!CgroupGetAttributePath("MaxCapacityCPUs", &filename)) {return;}break;
+        case SP_CUSTOM:
+            if (!CgroupGetAttributePath("CustomCPUs", &filename)) {
+                return;
+            }
+            break;default:return;}file = fopen(filename.c_str(), "re");if (file != NULL) {// Parse cpus stringchar *line = NULL;size_t len = 0;ssize_t num_read = getline(&line, &len, file);fclose (file);if (num_read > 0) {parse_cpuset_cpus(line, cpu_set);} else {ALOGE("Failed to read %s", filename.c_str());}free(line);}return;
}

在这里使用com.ags.test应用demo进行测试后验证。根据自己需要调整即可。主要保证该应用始终在SCHED_GROUP_CUSTOM中，不切换到其它schedule group中，同时建立SCHED_GROUP_CUSTOM和THREAD_GROUP_CUSTOM之间的联系。在$AOSP/frameworks/base/services/core/java/com/android/server/am/OomAdjuster.java文件中修改：

//...
+import static android.os.Process.THREAD_GROUP_CUSTOM;
//...
public class OomAdjuster {//...private boolean applyOomAdjLSP(ProcessRecord app, boolean doingAll, long now,long nowElapsed) {boolean success = true;final ProcessStateRecord state = app.mState;if (state.getCurRawAdj() != state.getSetRawAdj()) {state.setSetRawAdj(state.getCurRawAdj());}//...int processGroup;switch (curSchedGroup) {case ProcessList.SCHED_GROUP_BACKGROUND:processGroup = THREAD_GROUP_BACKGROUND;break;case ProcessList.SCHED_GROUP_TOP_APP:case ProcessList.SCHED_GROUP_TOP_APP_BOUND:processGroup = THREAD_GROUP_TOP_APP;break;case ProcessList.SCHED_GROUP_RESTRICTED:processGroup = THREAD_GROUP_RESTRICTED;break;
+                    case ProcessList.SCHED_GROUP_CUSTOM:
+                        processGroup = THREAD_GROUP_CUSTOM;
+                        break;default:processGroup = THREAD_GROUP_DEFAULT;break;}//...}//...private boolean computeOomAdjLSP(ProcessRecord app, int cachedAdj,ProcessRecord topApp, boolean doingAll, long now, boolean cycleReEval,boolean computeClients) {//...
+        if(app.processName.equals("com.ags.test")){
+            schedGroup = ProcessList.SCHED_GROUP_CUSTOM;
+        }// Do final modification to adj.  Everything we do between here and applying// the final setAdj must be done in this function, because we will also use// it when computing the final cached adj later.  Note that we don't need to// worry about this for max adj above, since max adj will always be used to// keep it out of the cached vaues.state.setCurAdj(psr.modifyRawOomAdj(adj));state.setCurCapability(capability);state.setCurrentSchedulingGroup(schedGroup);state.setCurProcState(procState);state.setCurRawProcState(procState);state.updateLastInvisibleTime(hasVisibleActivities);state.setHasForegroundActivities(foregroundActivities);state.setCompletedAdjSeq(mAdjSeq);// if curAdj or curProcState improved, then this process was promotedreturn state.getCurAdj() < prevAppAdj || state.getCurProcState() < prevProcState|| state.getCurCapability() != prevCapability;}//... 
}

修改SpecializeCommon，主要是在创建进程时直接设置cpuset，在$AOSP/frameworks/base/core/jni/com_android_internal_os_Zygote.cpp文件中修改：

static void SpecializeCommon(JNIEnv* env, uid_t uid, gid_t gid, jintArray gids, jint runtime_flags,jobjectArray rlimits, jlong permitted_capabilities,jlong effective_capabilities, jint mount_external,jstring managed_se_info, jstring managed_nice_name,bool is_system_server, bool is_child_zygote,jstring managed_instruction_set, jstring managed_app_data_dir,bool is_top_app, jobjectArray pkg_data_info_list,jobjectArray allowlisted_data_info_list, bool mount_data_dirs,bool mount_storage_dirs) {const char* process_name = is_system_server ? "system_server" : "zygote";auto fail_fn = std::bind(ZygoteFailure, env, process_name, managed_nice_name, _1);auto extract_fn = std::bind(ExtractJString, env, process_name, managed_nice_name, _1);//...if (setresgid(gid, gid, gid) == -1) {fail_fn(CREATE_ERROR("setresgid(%d) failed: %s", gid, strerror(errno)));}// Must be called when the new process still has CAP_SYS_ADMIN, in this case,// before changing uid from 0, which clears capabilities.  The other// alternative is to call prctl(PR_SET_NO_NEW_PRIVS, 1) afterward, but that// breaks SELinux domain transition (see b/71859146).  As the result,// privileged syscalls used below still need to be accessible in app process.SetUpSeccompFilter(uid, is_child_zygote);// Must be called before losing the permission to set scheduler policy.SetSchedulerPolicy(fail_fn, is_top_app);+    if (nice_name.has_value()) {
+        if(strncmp(nice_name.value().c_str(),"com.ags.test",sizeof("com.ags.test"))==0){
+            //set_sched_policy兼容方案
+            int ret = set_sched_policy(0, SP_CUSTOM);
+            if (ret != 0) {
+                ALOGE("set_sched_policy call default failure,ret:%d,(%s)", ret,nice_name.value().c_str());
+            }else{
+                ALOGD("set_sched_policy call default success,ret==0,(%s)", nice_name.value().c_str());
+            }
+        }
+    }//...}

至此，framework层相关修改就结束了。主要添加SCHED_GROUP_CUSTOM、THREAD_GROUP_CUSTOM（THREAD_GROUP_对应SP_）即以和对应SP_CUSTOM之间的联系建立，且支持开机启动后直接过滤包，进行CPUSET的设置。同时applyOomAdjLSP的判定保持不变，不受其他CPUSET的影响。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/618529.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

序章 搭建环境篇—准备战士的剑和盾

序章 搭建环境篇—准备战士的剑和盾

第一步&#xff1a;安装node.js Node.js 内置了npm&#xff0c;只要安装了node.js&#xff0c;就可以直接使用 npm&#xff0c;官网地址&#xff1a; Download | Node.js 在这里不建议安装最新版本的node.js&#xff0c;可以选跟我一样的版本&#xff0c;node版本v16.13.2 链…
阅读更多...
C++内存管理机制（侯捷）笔记3

C++内存管理机制（侯捷）笔记3

C内存管理机制&#xff08;侯捷&#xff09; 本文是学习笔记&#xff0c;仅供个人学习使用。如有侵权&#xff0c;请联系删除。 参考链接 Youtube: 侯捷-C内存管理机制 Github课程视频、PPT和源代码: https://github.com/ZachL1/Bilibili-plus 第三讲&#xff1a;malloc和…
阅读更多...
POI：对Excel的基本写操作 整理1

POI：对Excel的基本写操作 整理1

首先导入相关依赖 <!-- https://mvnrepository.com/artifact/org.apache.poi/poi --><!--xls(03)--><dependency><groupId>org.apache.poi</groupId><artifactId>poi</artifactId><version>5.2.2</version></depend…
阅读更多...
算法训练营第四十六天|139.单词拆分 多重背包

算法训练营第四十六天|139.单词拆分 多重背包

目录 Leetcode139.单词拆分多重背包 Leetcode139.单词拆分 文章链接&#xff1a;代码随想录 题目链接&#xff1a;139.单词拆分 思路&#xff1a;完全背包&#xff0c;重点在于状态转移方程的条件。 class Solution { public:bool wordBreak(string s, vector<string>&a…
阅读更多...
【华为鸿蒙】HarmonyOS开发学习：下载与安装软件看这一篇就够了！

【华为鸿蒙】HarmonyOS开发学习：下载与安装软件看这一篇就够了！

下载与安装软件 DevEco Studio 支持 Windows 和 macOS 系统&#xff0c;下面将针对两种操作系统的软件安装方式进行介绍 Windows 环境 运行环境要求 为保证 DevEco Studio 正常运行&#xff0c;建议您的电脑配置满足如下要求&#xff1a;  操作系统&#xff1a;Windows10 …
阅读更多...
leetcode 动态规划(爬楼梯、零钱兑换、完全平方数)

leetcode 动态规划(爬楼梯、零钱兑换、完全平方数)

70. 爬楼梯&#xff08;进阶版&#xff09; 卡码网&#xff1a;57. 爬楼梯(opens new window) 假设你正在爬楼梯。需要 n 阶你才能到达楼顶。 每次你可以爬至多m (1 < m < n)个台阶。你有多少种不同的方法可以爬到楼顶呢&#xff1f; 注意&#xff1a;给定 n 是一个正…
阅读更多...
【前后端的那些事】快速上手富文本+富文本图片上传

【前后端的那些事】快速上手富文本+富文本图片上传

文章目录 fullText富文本1. 后端接口1.1 定义常量1.2 定义返回实体类1.3 上传图片接口1.4 下载图片接口 2. 前端代码编写2.1 安装2.2 快速使用 3. 配置富文本图片上传地址3.1 配置图片上传配置 4. 全部代码展示 前言&#xff1a;最近写项目&#xff0c;发现了一些很有意思的功能…
阅读更多...
RTMP 视频数据封装

RTMP 视频数据封装

RTMP 协议 与HTTP(超文本传输协议)同样是一个基于TCP的Real Time Messaging Protocol(实时消息传输协议)。由Adobe Systems公司为Flash播放器和服务器之间音频、视频和数据传输开发的一种开放协议 。在国内被广泛的应用于直 播领域。HTTP默认端口为80&#xff0c;RTMP则为1935…
阅读更多...
上海AI实验室等开源，音频、音乐统一开发工具包Amphion

上海AI实验室等开源，音频、音乐统一开发工具包Amphion

上海AI实验室、香港中文大学数据科学院、深圳大数据研究院联合开源了一个名为Amphion的音频、音乐和语音生成工具包。 Amphion可帮助开发人员研究文本生成音频、音乐等与音频相关的领域&#xff0c;可以在一个框架内完成&#xff0c;以解决生成模型黑箱、代码库分散、缺少评估…
阅读更多...
蓝桥杯AcWing学习笔记 8-1数论的学习（上）

蓝桥杯AcWing学习笔记 8-1数论的学习（上）

蓝桥杯 我的AcWing 题目及图片来自蓝桥杯C AB组辅导课 数论&#xff08;上&#xff09; 蓝桥杯省赛中考的数论不是很多&#xff0c;这里讲几个蓝桥杯常考的知识点。 欧几里得算法——辗转相除法 欧几里得算法代码&#xff1a; import java.util.Scanner ;public class Main…
阅读更多...
现代火箭发展的一个重要方向是无人火箭技术

现代火箭发展的一个重要方向是无人火箭技术

现代火箭发展的一个重要方向是无人火箭技术。无人火箭指的是不需要人员操控的火箭系统&#xff0c;可以自主进行发射、飞行、返回和着陆等任务。 在无人火箭发展方面&#xff0c;有以下重要形态和应用&#xff1a; 空间探测&#xff1a;无人火箭可以被用于太空探测任务&#x…
阅读更多...
无人驾驶技术在交通领域逐渐成熟

无人驾驶技术在交通领域逐渐成熟

随着技术的不断发展&#xff0c;无人驾驶技术在交通领域逐渐成熟&#xff0c;对于无人站台、无人公交车和无人公交车综合系统的发展也变得越来越重要。以下是这些系统的重要发展形势&#xff1a; 无人站台&#xff1a;无人站台可以提供自动售票、乘客导航和安全监控等功能&…
阅读更多...
Gradle的安装及换源详解

Gradle的安装及换源详解

Gradle是一种自动化构建工具&#xff0c;基于Apache Ant和Apache Maven的概念。以下是Gradle的安装步骤和换源方法&#xff1a; 下载安装包&#xff1a;可以从官网下载Gradle的安装包。为了避免官网下载速度慢&#xff0c;也可以通过腾讯的镜像地址进行下载。例如&#xff0c;…
阅读更多...
解决Android Studio Unexpected tokens (use ； to separate expressions on the same line)

解决Android Studio Unexpected tokens (use ； to separate expressions on the same line)

[TOC](Unexpected tokens (use ; to separate expressions on the same line)) 问题描述&#xff1a;Unexpected tokens (use ; to separate expressions on the same line) 原因&#xff1a;Android Studio 更新到最新的版本之后&#xff0c;gradle工程目录结构发生改变 问…
阅读更多...
【华为鸿蒙】HarmonyOS概述：技术特性

【华为鸿蒙】HarmonyOS概述：技术特性

来源&#xff1a;HarmnyOS 官网 https://developer.harmonyos.com/cn/docs/documentation/doc-guides/harmonyos-features-0000000000011907 技术特性 硬件互助&#xff0c;资源共享 多种设备之间能够实现硬件互助、资源共享&#xff0c;依赖的关键技术包括分布式软总线、分布…
阅读更多...
Vant-ui图片懒加载

Vant-ui图片懒加载

核心代码 在你的全局顶部引入和初始化 Vue.use(vant.Lazyload, {loading: /StaticFile/img/jiazai.jpg,error: /StaticFile/img/jiazai.jpg,lazyComponent: false, });//图片懒加载 <img v-lazy"https://img-blog.csdnimg.cn/direct/3d2c8a7e2c0040488a8128c3e381d58…
阅读更多...
CenOS系统软件依赖包安装常见命令

CenOS系统软件依赖包安装常见命令

sudo yum --excludekernel* --excludecentos-release* -y update 这个命令的含义是使用sudo权限运行yum命令&#xff0c;通过更新软件包来升级系统。 具体选项的解释如下&#xff1a; --excludekernel*&#xff1a;排除以"kernel"开头的所有软件包&#xff0c;即不…
阅读更多...
8.云原生存储之Ceph集群

8.云原生存储之Ceph集群

1. 私有云实战之基础环境搭建 2. 云原生实战之kubesphere搭建 3.云原生之kubesphere运维 4. 云原生之kubesphere基础服务搭建 5.云原生安全之kubesphere应用网关配置域名TLS证书 6.云原生之DevOps和CICD 7.云原生之jenkins集成SonarQube 8.云原生存储之Ceph集群 文章目录 为什么…
阅读更多...
DynastyPersist：一款功能强大的Linux持久化安全审计与测试工具

DynastyPersist：一款功能强大的Linux持久化安全审计与测试工具

关于DynastyPersist DynastyPersist是一款专为红队研究人员和CTF玩家设计的Linux安全测试工具&#xff0c;该工具可以适用于各种安全评估任务和安全测试场景。 DynastyPersist本质上是一个Linux持久化脚本&#xff0c;并提供了大量的安全测试功能&#xff0c;可以为我们展示在…
阅读更多...
Java多线程并发篇----第十一篇

Java多线程并发篇----第十一篇

系列文章目录 文章目录 系列文章目录前言一、什么是悲观锁二、什么是自旋锁三、Synchronized 同步锁前言 前些天发现了一个巨牛的人工智能学习网站，通俗易懂，风趣幽默，忍不住分享一下给大家。点击跳转到网站，这篇文章男女通用，看懂了就去分享给你的码吧。 一、什么是悲观…
阅读更多...
最新文章

Copyright @ 2022~2023