#include <cerrno>
#include <cstring>
+#include <pthread.h>
+#include <sched.h>
+
#include "pbd/base_ui.h"
#include "pbd/debug.h"
#include "pbd/pthread_utils.h"
#include "pbd/compose.h"
#include "pbd/failed_constructor.h"
-#include "i18n.h"
+#include "pbd/i18n.h"
#include "pbd/debug.h"
return rt;
}
+int
+BaseUI::set_thread_priority (const int policy, int priority) const
+{
+ struct sched_param param;
+ memset (¶m, 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, ¶m);
+}
+
void
BaseUI::main_thread ()
{
/* handle requests */
- DEBUG_TRACE (DEBUG::EventLoop, "BaseUI::request_handler\n");
+ DEBUG_TRACE (DEBUG::EventLoop, string_compose ("%1: request handler\n", event_loop_name()));
handle_ui_requests ();
}
void
BaseUI::signal_new_request ()
{
- DEBUG_TRACE (DEBUG::EventLoop, "BaseUI::signal_new_request\n");
+ DEBUG_TRACE (DEBUG::EventLoop, string_compose ("%1: signal_new_request\n", event_loop_name()));
request_channel.wakeup ();
}
void
BaseUI::attach_request_source ()
{
- DEBUG_TRACE (DEBUG::EventLoop, "BaseUI::attach_request_source\n");
+ DEBUG_TRACE (DEBUG::EventLoop, string_compose ("%1: attach request source\n", event_loop_name()));
request_channel.attach (m_context);
}