From cf785e2ad6c8ce57cc3517f3fbc6a9e4812ea063 Mon Sep 17 00:00:00 2001 From: hoholee12 Date: Mon, 24 Jul 2023 00:27:36 +0900 Subject: [PATCH] oops --- Utilities/Thread.cpp | 23 +++++++++++++++++------ 1 file changed, 17 insertions(+), 6 deletions(-) diff --git a/Utilities/Thread.cpp b/Utilities/Thread.cpp index 3a06ae841799..20c2761e96df 100644 --- a/Utilities/Thread.cpp +++ b/Utilities/Thread.cpp @@ -3028,9 +3028,9 @@ void thread_ctrl::set_native_priority(int priority) { sig_log.error("SetThreadPriority() failed: %s", fmt::win_error{GetLastError(), nullptr}); } -#else +#elif defined(__linux__) // available niceness for nonroot: 0~19 - int linuxprio = 0; + int linuxprio = 9; id_t threadpid = gettid(); if (priority > 0) @@ -3045,10 +3045,21 @@ void thread_ctrl::set_native_priority(int priority) { sig_log.error("setpriority(%d, %d) failed: %d", threadpid, linuxprio, err); } - else - { - sig_log.success("setpriority(%d, %d) successful.", threadpid, linuxprio); - } + } +#else + int policy; + struct sched_param param; + + pthread_getschedparam(pthread_self(), &policy, ¶m); + + if (priority > 0) + param.sched_priority = sched_get_priority_max(policy); + if (priority < 0) + param.sched_priority = sched_get_priority_min(policy); + + if (int err = pthread_setschedparam(pthread_self(), policy, ¶m)) + { + sig_log.error("pthread_setschedparam() failed: %d", err); } #endif }