mirror of
https://github.com/openharmony/linux_frame_aware_sched.git
synced 2026-07-01 22:24:08 -04:00
update interfaces/innerkits/frameintf/rtg_interface.cpp.
Signed-off-by: mengyiping <1091773127@qq.com>
This commit is contained in:
@@ -108,7 +108,7 @@ int EnableRtg(bool flag)
|
||||
return 0;
|
||||
};
|
||||
|
||||
int AddThreadToRtg(int tid, int grpId, int prioType, bool isSelfRender)
|
||||
int AddThreadToRtg(int tid, int grpId, int prioType, [[maybe_unused]] bool isRender)
|
||||
{
|
||||
if (g_fd < 0) {
|
||||
return g_fd;
|
||||
@@ -119,14 +119,8 @@ int AddThreadToRtg(int tid, int grpId, int prioType, bool isSelfRender)
|
||||
grp_data.tid_num = 1;
|
||||
grp_data.tids[0] = tid;
|
||||
grp_data.grp_id = grpId;
|
||||
|
||||
grp_data.rtg_cmd = CMD_ADD_RTG_THREAD;
|
||||
grp_data.prio_type = prioType;
|
||||
if (isSelfRender) {
|
||||
grp_data.rtg_cmd = CMD_ADD_SELF_RENDER_RTG_THREAD;
|
||||
} else {
|
||||
grp_data.rtg_cmd = CMD_ADD_RTG_THREAD;
|
||||
}
|
||||
ret = ioctl(g_fd, CMD_ID_SET_RTG, &grp_data);
|
||||
if (ret != 0) {
|
||||
RME_LOGE("add thread to rtg failed, grpId = %{public}d, ret = %{public}d, errno = %{public}d (%{public}s)",
|
||||
grpId,
|
||||
@@ -139,7 +133,7 @@ int AddThreadToRtg(int tid, int grpId, int prioType, bool isSelfRender)
|
||||
return ret;
|
||||
}
|
||||
|
||||
int AddThreadsToRtg(vector<int> tids, int grpId, int prioType, bool isSelfRender)
|
||||
int AddThreadsToRtg(vector<int> tids, int grpId, int prioType, bool isRender)
|
||||
{
|
||||
struct rtg_grp_data grp_data;
|
||||
int ret;
|
||||
@@ -153,13 +147,8 @@ int AddThreadsToRtg(vector<int> tids, int grpId, int prioType, bool isSelfRender
|
||||
}
|
||||
grp_data.tid_num = num;
|
||||
grp_data.grp_id = grpId;
|
||||
|
||||
grp_data.rtg_cmd = CMD_ADD_RTG_THREAD;
|
||||
grp_data.prio_type = prioType;
|
||||
if (isSelfRender) {
|
||||
grp_data.rtg_cmd = CMD_ADD_SELF_RENDER_RTG_THREAD;
|
||||
} else {
|
||||
grp_data.rtg_cmd = CMD_ADD_RTG_THREAD;
|
||||
}
|
||||
for (int i = 0; i < num; i++) {
|
||||
if (tids[i] < 0) {
|
||||
return -1;
|
||||
@@ -179,7 +168,7 @@ int AddThreadsToRtg(vector<int> tids, int grpId, int prioType, bool isSelfRender
|
||||
return ret;
|
||||
};
|
||||
|
||||
int RemoveRtgThread(int tid, bool isSelfRender)
|
||||
int RemoveRtgThread(int tid, [[maybe_unused]] bool isRender)
|
||||
{
|
||||
if (g_fd < 0) {
|
||||
return g_fd;
|
||||
@@ -189,11 +178,7 @@ int RemoveRtgThread(int tid, bool isSelfRender)
|
||||
(void)memset_s(&grp_data, sizeof(struct rtg_grp_data), 0, sizeof(struct rtg_grp_data));
|
||||
grp_data.tid_num = 1;
|
||||
grp_data.tids[0] = tid;
|
||||
if (isSelfRender) {
|
||||
grp_data.rtg_cmd = CMD_REMOVE_SELF_RENDER_RTG_THREAD;
|
||||
} else {
|
||||
grp_data.rtg_cmd = CMD_REMOVE_RTG_THREAD;
|
||||
}
|
||||
grp_data.rtg_cmd = CMD_REMOVE_RTG_THREAD;
|
||||
ret = ioctl(g_fd, CMD_ID_SET_RTG, &grp_data);
|
||||
if (ret != 0) {
|
||||
RME_LOGE("remove grp failed, ret = %{public}d, errno = %{public}d (%{public}s)", ret, errno, strerror(errno));
|
||||
@@ -203,7 +188,7 @@ int RemoveRtgThread(int tid, bool isSelfRender)
|
||||
return ret;
|
||||
};
|
||||
|
||||
int RemoveRtgThreads(vector<int> tids, bool isSelfRender)
|
||||
int RemoveRtgThreads(vector<int> tids, [[maybe_unused]] bool isSelfRender)
|
||||
{
|
||||
struct rtg_grp_data grp_data;
|
||||
int ret;
|
||||
@@ -216,11 +201,7 @@ int RemoveRtgThreads(vector<int> tids, bool isSelfRender)
|
||||
return -1;
|
||||
}
|
||||
grp_data.tid_num = num;
|
||||
if (isSelfRender) {
|
||||
grp_data.rtg_cmd = CMD_REMOVE_SELF_RENDER_RTG_THREAD;
|
||||
} else {
|
||||
grp_data.rtg_cmd = CMD_REMOVE_RTG_THREAD;
|
||||
}
|
||||
grp_data.rtg_cmd = CMD_REMOVE_RTG_THREAD;
|
||||
for (int i = 0; i < num; i++) {
|
||||
if (tids[i] < 0) {
|
||||
return -1;
|
||||
|
||||
Reference in New Issue
Block a user