diff options
| author | Michael Dickens <mlk@alum.mit.edu> | 2014-04-24 10:08:39 -0400 |
|---|---|---|
| committer | Tom Rondeau <tom@trondeau.com> | 2014-04-24 14:51:34 -0400 |
| commit | e4ce0b18808c65ea52602a28207fe9d5c0292ffe (patch) | |
| tree | f86b76d2583f10ad4970ec826edb01a234eb9dfc | |
| parent | b56927aa1269d91a105381d6798d4671ff220da1 (diff) | |
runtime: enable thread priority, same as with Linux; fix header comments to this effect
| -rw-r--r-- | gnuradio-runtime/include/gnuradio/thread/thread.h | 8 | ||||
| -rw-r--r-- | gnuradio-runtime/lib/thread/thread.cc | 16 |
2 files changed, 14 insertions, 10 deletions
diff --git a/gnuradio-runtime/include/gnuradio/thread/thread.h b/gnuradio-runtime/include/gnuradio/thread/thread.h index a0c9e4f09d..5149e21a24 100644 --- a/gnuradio-runtime/include/gnuradio/thread/thread.h +++ b/gnuradio-runtime/include/gnuradio/thread/thread.h @@ -1,6 +1,6 @@ /* -*- c++ -*- */ /* - * Copyright 2009-2013 Free Software Foundation, Inc. + * Copyright 2009-2014 Free Software Foundation, Inc. * * This file is part of GNU Radio * @@ -139,14 +139,10 @@ namespace gr { GR_RUNTIME_API void thread_unbind(gr_thread_t thread); /*! \brief get current thread priority for a given thread ID - * - * Note: this does not work on OSX */ GR_RUNTIME_API int thread_priority(gr_thread_t thread); - /*! \brief get current thread priority for a given thread ID - * - * Note: this does not work on OSX + /*! \brief set current thread priority for a given thread ID */ GR_RUNTIME_API int set_thread_priority(gr_thread_t thread, int priority); diff --git a/gnuradio-runtime/lib/thread/thread.cc b/gnuradio-runtime/lib/thread/thread.cc index 8d1ef767a7..1b3ebe57d3 100644 --- a/gnuradio-runtime/lib/thread/thread.cc +++ b/gnuradio-runtime/lib/thread/thread.cc @@ -167,15 +167,23 @@ namespace gr { int thread_priority(gr_thread_t thread) { - // Not implemented on OSX - return -1; + sched_param param; + int priority; + int policy; + int ret; + ret = pthread_getschedparam (thread, &policy, ¶m); + priority = param.sched_priority; + return (ret==0)?priority:ret; } int set_thread_priority(gr_thread_t thread, int priority) { - // Not implemented on OSX - return -1; + int policy; + struct sched_param param; + pthread_getschedparam (thread, &policy, ¶m); + param.sched_priority = priority; + return pthread_setschedparam(thread, policy, ¶m); } } /* namespace thread */ |