diff options
author | Andrej Rode <andrej.rode@ettus.com> | 2017-04-18 16:46:44 -0700 |
---|---|---|
committer | Martin Braun <martin.braun@ettus.com> | 2017-06-29 13:43:05 -0700 |
commit | c33928d2bbdd27688c3475e77fc461e7d16eba5a (patch) | |
tree | d5bffc49696e2bc03c9b8576864e387373b950fb /host/lib/utils/thread_priority.cpp | |
parent | 47cdd6319c74a7b823843aad5ff3fa370ed1e6ef (diff) | |
download | uhd-c33928d2bbdd27688c3475e77fc461e7d16eba5a.tar.gz uhd-c33928d2bbdd27688c3475e77fc461e7d16eba5a.tar.bz2 uhd-c33928d2bbdd27688c3475e77fc461e7d16eba5a.zip |
utils: add set_thread_name API call, move thread_priority to thread
Diffstat (limited to 'host/lib/utils/thread_priority.cpp')
-rw-r--r-- | host/lib/utils/thread_priority.cpp | 110 |
1 files changed, 0 insertions, 110 deletions
diff --git a/host/lib/utils/thread_priority.cpp b/host/lib/utils/thread_priority.cpp deleted file mode 100644 index 729edcf0a..000000000 --- a/host/lib/utils/thread_priority.cpp +++ /dev/null @@ -1,110 +0,0 @@ -// -// Copyright 2010-2011,2015 Ettus Research LLC -// -// This program is free software: you can redistribute it and/or modify -// it under the terms of the GNU General Public License as published by -// the Free Software Foundation, either version 3 of the License, or -// (at your option) any later version. -// -// This program is distributed in the hope that it will be useful, -// but WITHOUT ANY WARRANTY; without even the implied warranty of -// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the -// GNU General Public License for more details. -// -// You should have received a copy of the GNU General Public License -// along with this program. If not, see <http://www.gnu.org/licenses/>. -// - -#include <uhd/utils/thread_priority.hpp> -#include <uhd/utils/log.hpp> -#include <uhd/exception.hpp> -#include <boost/format.hpp> -#include <iostream> - -bool uhd::set_thread_priority_safe(float priority, bool realtime){ - try{ - set_thread_priority(priority, realtime); - return true; - }catch(const std::exception &e){ - UHD_LOGGER_WARNING("UHD") << boost::format( - "Unable to set the thread priority. Performance may be negatively affected.\n" - "Please see the general application notes in the manual for instructions.\n" - "%s" - ) % e.what(); - return false; - } -} - -static void check_priority_range(float priority){ - if (priority > +1.0 or priority < -1.0) - throw uhd::value_error("priority out of range [-1.0, +1.0]"); -} - -/*********************************************************************** - * Pthread API to set priority - **********************************************************************/ -#ifdef HAVE_PTHREAD_SETSCHEDPARAM - #include <pthread.h> - - void uhd::set_thread_priority(float priority, bool realtime){ - check_priority_range(priority); - - //when realtime is not enabled, use sched other - int policy = (realtime)? SCHED_RR : SCHED_OTHER; - - //we cannot have below normal priority, set to zero - if (priority < 0) priority = 0; - - //get the priority bounds for the selected policy - int min_pri = sched_get_priority_min(policy); - int max_pri = sched_get_priority_max(policy); - if (min_pri == -1 or max_pri == -1) throw uhd::os_error("error in sched_get_priority_min/max"); - - //set the new priority and policy - sched_param sp; - sp.sched_priority = int(priority*(max_pri - min_pri)) + min_pri; - int ret = pthread_setschedparam(pthread_self(), policy, &sp); - if (ret != 0) throw uhd::os_error("error in pthread_setschedparam"); - } -#endif /* HAVE_PTHREAD_SETSCHEDPARAM */ - -/*********************************************************************** - * Windows API to set priority - **********************************************************************/ -#ifdef HAVE_WIN_SETTHREADPRIORITY - #include <windows.h> - - void uhd::set_thread_priority(float priority, UHD_UNUSED(bool realtime)){ - check_priority_range(priority); - - /* - * Process wide priority is no longer set. - * This is the responsibility of the application. - //set the priority class on the process - int pri_class = (realtime)? REALTIME_PRIORITY_CLASS : NORMAL_PRIORITY_CLASS; - if (SetPriorityClass(GetCurrentProcess(), pri_class) == 0) - throw uhd::os_error("error in SetPriorityClass"); - */ - - //scale the priority value to the constants - int priorities[] = { - THREAD_PRIORITY_IDLE, THREAD_PRIORITY_LOWEST, THREAD_PRIORITY_BELOW_NORMAL, THREAD_PRIORITY_NORMAL, - THREAD_PRIORITY_ABOVE_NORMAL, THREAD_PRIORITY_HIGHEST, THREAD_PRIORITY_TIME_CRITICAL - }; - size_t pri_index = size_t((priority+1.0)*6/2.0); // -1 -> 0, +1 -> 6 - - //set the thread priority on the thread - if (SetThreadPriority(GetCurrentThread(), priorities[pri_index]) == 0) - throw uhd::os_error("error in SetThreadPriority"); - } -#endif /* HAVE_WIN_SETTHREADPRIORITY */ - -/*********************************************************************** - * Unimplemented API to set priority - **********************************************************************/ -#ifdef HAVE_THREAD_PRIO_DUMMY - void uhd::set_thread_priority(float, bool){ - throw uhd::not_implemented_error("set thread priority not implemented"); - } - -#endif /* HAVE_THREAD_PRIO_DUMMY */ |