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

CoreAudio: Set MachThread RT Priority

Browse source
This commit is contained in:
Robin Gareus 2017-08-04 03:12:29 +02:00
parent 4ec72b5c76
commit 38c5e9de6d
2 changed files with 44 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

48
libs/backends/coreaudio/coreaudio_backend.cc
View file

@ -21,6 +21,9 @@
#include <sys/mman.h> #include <sys/mman.h>
#include <sys/time.h> #include <sys/time.h>
#include <mach/thread_policy.h>
#include <mach/thread_act.h>
#include <glibmm.h> #include <glibmm.h>
#include "coreaudio_backend.h" #include "coreaudio_backend.h"
@ -327,6 +330,12 @@ CoreAudioBackend::set_buffer_size (uint32_t bs)
} }
_samples_per_period = bs; _samples_per_period = bs;
_pcmio->set_samples_per_period(bs); _pcmio->set_samples_per_period(bs);
if (_run) {
coreaudio_set_realtime_policy (_main_thread);
}
for (std::vector<pthread_t>::const_iterator i = _threads.begin (); i != _threads.end (); ++i) {
coreaudio_set_realtime_policy (*i);
}
engine.buffer_size_change (bs); engine.buffer_size_change (bs);
return 0; return 0;
} }
@ -603,11 +612,6 @@ CoreAudioBackend::_start (bool for_latency_measurement)
PBD::info << _("CoreAudioBackend: adjusted input channel count to match device.") << endmsg; PBD::info << _("CoreAudioBackend: adjusted input channel count to match device.") << endmsg;
} }
if (_pcmio->samples_per_period() != _samples_per_period) {
_samples_per_period = _pcmio->samples_per_period();
PBD::warning << _("CoreAudioBackend: samples per period does not match.") << endmsg;
}
if (_pcmio->sample_rate() != _samplerate) { if (_pcmio->sample_rate() != _samplerate) {
_samplerate = _pcmio->sample_rate(); _samplerate = _pcmio->sample_rate();
engine.sample_rate_change (_samplerate); engine.sample_rate_change (_samplerate);
@ -816,6 +820,34 @@ CoreAudioBackend::coreaudio_process_thread (void *arg)
return 0; return 0;
} }
bool
CoreAudioBackend::coreaudio_set_realtime_policy (pthread_t thread_id) const
{
thread_time_constraint_policy_data_t policy;
#ifndef NDEBUG
mach_msg_type_number_t msgt = 4;
boolean_t dflt = false;
kern_return_t rv = thread_policy_get (pthread_mach_thread_np (_main_thread),
THREAD_TIME_CONSTRAINT_POLICY, (thread_policy_t) &policy,
&msgt, &dflt);
printf ("Coreaudio Main Thread(%p) %d %d %d %d DFLT %d OK: %d\n", _main_thread, policy.period, policy.computation, policy.constraint, policy.preemptible, dflt, rv == KERN_SUCCESS);
#endif
double period_ns = 1e9 * _samples_per_period / _samplerate;
policy.period = AudioConvertNanosToHostTime (period_ns);
policy.computation = AudioConvertNanosToHostTime (period_ns * .9);
policy.constraint = AudioConvertNanosToHostTime (period_ns * .95);
policy.preemptible = true;
kern_return_t res = thread_policy_set (pthread_mach_thread_np (thread_id),
THREAD_TIME_CONSTRAINT_POLICY, (thread_policy_t) &policy,
THREAD_TIME_CONSTRAINT_POLICY_COUNT);
#ifndef NDEBUG
printf ("Coreaudio Proc Thread(%p) %d %d %d %d OK: %d\n", thread_id, policy.period, policy.computation, policy.constraint, policy.preemptible, res == KERN_SUCCESS);
#endif
return res != KERN_SUCCESS;
}
int int
CoreAudioBackend::create_process_thread (boost::function<void()> func) CoreAudioBackend::create_process_thread (boost::function<void()> func)
{ {
@ -838,6 +870,10 @@ CoreAudioBackend::create_process_thread (boost::function<void()> func)
pthread_attr_destroy (&attr); pthread_attr_destroy (&attr);
} }
if (coreaudio_set_realtime_policy (thread_id)) {
PBD::warning << _("AudioEngine: process thread failed to set mach realtime policy.") << endmsg;
}
_threads.push_back (thread_id); _threads.push_back (thread_id);
return 0; return 0;
} }
@ -1673,6 +1709,7 @@ CoreAudioBackend::freewheel_thread ()
AudioEngine::thread_init_callback (this); AudioEngine::thread_init_callback (this);
_midiio->set_enabled(false); _midiio->set_enabled(false);
reset_midi_parsers (); reset_midi_parsers ();
coreaudio_set_realtime_policy (_main_thread);
} }
// process port updates first in every cycle. // process port updates first in every cycle.
@ -1738,6 +1775,7 @@ CoreAudioBackend::process_callback (const uint32_t n_samples, const uint64_t hos
_reinit_thread_callback = false; _reinit_thread_callback = false;
_main_thread = pthread_self(); _main_thread = pthread_self();
AudioEngine::thread_init_callback (this); AudioEngine::thread_init_callback (this);
coreaudio_set_realtime_policy (_main_thread);
} }
if (pthread_mutex_trylock (&_process_callback_mutex)) { if (pthread_mutex_trylock (&_process_callback_mutex)) {

1
libs/backends/coreaudio/coreaudio_backend.h
View file

@ -447,6 +447,7 @@ class CoreAudioBackend : public AudioBackend {
/* process threads */ /* process threads */
static void* coreaudio_process_thread (void *); static void* coreaudio_process_thread (void *);
bool coreaudio_set_realtime_policy (pthread_t) const;
std::vector<pthread_t> _threads; std::vector<pthread_t> _threads;
struct ThreadData { struct ThreadData {