smokephil/ardour
1
0
Fork 0
mirror of https://github.com/Ardour/ardour.git synced 2025-12-09 16:24:57 +01:00
Code Issues Projects Releases Wiki Activity

Add a PBD API to set pthread priority

Browse source
This commit is contained in:
Robin Gareus 2017-08-29 17:14:34 +02:00
parent f72c819035
commit 229c9584bf
3 changed files with 68 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

25
libs/pbd/base_ui.cc
View file

@ -82,30 +82,7 @@ BaseUI::new_request_type ()
int int
BaseUI::set_thread_priority (const int policy, int priority) const BaseUI::set_thread_priority (const int policy, int priority) const
{ {
struct sched_param param; return pbd_set_thread_priority (pthread_self(), policy, priority);
memset (&param, 0, sizeof (param));
/* POSIX requires a spread of at least 32 steps between min..max */
const int p_min = sched_get_priority_min (policy); // Linux: 1
const int p_max = sched_get_priority_max (policy); // Linux: 99
if (priority == 0) {
/* use default. XXX this should be relative to audio (JACK) thread,
* internal backends use -20 (Audio), -21 (MIDI), -22 (compuation)
*/
priority = 7;
}
if (priority > 0) {
priority += p_min;
} else {
priority += p_max;
}
if (priority > p_max) priority = p_max;
if (priority < p_min) priority = p_min;
param.sched_priority = priority;
return pthread_setschedparam (pthread_self(), SCHED_FIFO, &param);
} }
void void

8
libs/pbd/pbd/pthread_utils.h
View file

@ -54,6 +54,14 @@ LIBPBD_API void pthread_kill_all (int signum);
LIBPBD_API const char* pthread_name (); LIBPBD_API const char* pthread_name ();
LIBPBD_API void pthread_set_name (const char* name); LIBPBD_API void pthread_set_name (const char* name);
LIBPBD_API int pbd_realtime_pthread_create (
const int policy, int priority, const size_t stacksize,
pthread_t *thread,
void *(*start_routine) (void *),
void *arg);
LIBPBD_API int pbd_set_thread_priority (pthread_t, const int policy, int priority);
namespace PBD { namespace PBD {
LIBPBD_API extern void notify_event_loops_about_thread_creation (pthread_t, const std::string&, int requests = 256); LIBPBD_API extern void notify_event_loops_about_thread_creation (pthread_t, const std::string&, int requests = 256);
LIBPBD_API extern PBD::Signal3<void,pthread_t,std::string,uint32_t> ThreadCreatedWithRequestSize; LIBPBD_API extern PBD::Signal3<void,pthread_t,std::string,uint32_t> ThreadCreatedWithRequestSize;

59
libs/pbd/pthread_utils.cc
View file

@ -207,3 +207,62 @@ pthread_cancel_one (pthread_t thread)
pthread_cancel (thread); pthread_cancel (thread);
pthread_mutex_unlock (&thread_map_lock); pthread_mutex_unlock (&thread_map_lock);
} }
int
pbd_realtime_pthread_create (
const int policy, int priority, const size_t stacksize,
pthread_t *thread,
void *(*start_routine) (void *),
void *arg)
{
int rv;
pthread_attr_t attr;
struct sched_param parm;
const int p_min = sched_get_priority_min (policy);
const int p_max = sched_get_priority_max (policy);
priority += p_max;
if (priority > p_max) priority = p_max;
if (priority < p_min) priority = p_min;
parm.sched_priority = priority;
pthread_attr_init (&attr);
pthread_attr_setschedpolicy (&attr, policy);
pthread_attr_setschedparam (&attr, &parm);
pthread_attr_setscope (&attr, PTHREAD_SCOPE_SYSTEM);
pthread_attr_setinheritsched (&attr, PTHREAD_EXPLICIT_SCHED);
pthread_attr_setstacksize (&attr, stacksize);
rv = pthread_create (thread, &attr, start_routine, arg);
pthread_attr_destroy (&attr);
return rv;
}
int
pbd_set_thread_priority (pthread_t thread, const int policy, int priority)
{
struct sched_param param;
memset (&param, 0, sizeof (param));
/* POSIX requires a spread of at least 32 steps between min..max */
const int p_min = sched_get_priority_min (policy); // Linux: 1
const int p_max = sched_get_priority_max (policy); // Linux: 99
if (priority == 0) {
/* use default. XXX this should be relative to audio (JACK) thread,
* internal backends use -20 (Audio), -21 (MIDI), -22 (compuation)
*/
priority = 7; // BaseUI backwards compat.
}
if (priority > 0) {
priority += p_min;
} else {
priority += p_max;
}
if (priority > p_max) priority = p_max;
if (priority < p_min) priority = p_min;
param.sched_priority = priority;
return pthread_setschedparam (thread, SCHED_FIFO, &param);
}