AlsaAudioBackend::AlsaAudioBackend (AudioEngine& e, AudioBackendInfo& info)
: AudioBackend (e, info)
, _pcmi (0)
- , _running (false)
+ , _run (false)
+ , _active (false)
, _freewheeling (false)
, _capture_device("")
, _playback_device("")
int
AlsaAudioBackend::_start (bool for_latency_measurement)
{
- if (_running) {
+ if (_active || _run) {
PBD::error << _("AlsaAudioBackend: already active.") << endmsg;
return -1;
}
engine.buffer_size_change (_samples_per_period);
engine.reconnect_ports ();
+ _run = true;
if (_realtime_pthread_create (SCHED_FIFO, -20,
&_main_thread, pthread_process, this))
{
PBD::error << _("AlsaAudioBackend: failed to create process thread.") << endmsg;
delete _pcmi; _pcmi = 0;
+ _run = false;
return -1;
} else {
PBD::warning << _("AlsaAudioBackend: cannot acquire realtime permissions.") << endmsg;
}
int timeout = 5000;
- while (!_running && --timeout > 0) { Glib::usleep (1000); }
+ while (!_active && --timeout > 0) { Glib::usleep (1000); }
- if (timeout == 0 || !_running) {
+ if (timeout == 0 || !_active) {
PBD::error << _("AlsaAudioBackend: failed to start process thread.") << endmsg;
delete _pcmi; _pcmi = 0;
+ _run = false;
return -1;
}
AlsaAudioBackend::stop ()
{
void *status;
- if (!_running) {
+ if (!_active) {
return 0;
}
- _running = false;
+ _run = false;
if (pthread_join (_main_thread, &status)) {
PBD::error << _("AlsaAudioBackend: failed to terminate.") << endmsg;
return -1;
unregister_system_ports();
delete _pcmi; _pcmi = 0;
- return 0;
+ return (_active == false) ? 0 : -1;
}
int
bool
AlsaAudioBackend::available () const
{
- return true;
+ return _run && _active;
}
uint32_t
AlsaAudioBackend::main_process_thread ()
{
AudioEngine::thread_init_callback (this);
- _running = true;
+ _active = true;
_processed_samples = 0;
uint64_t clock1, clock2;
_pcmi->pcm_start ();
int no_proc_errors = 0;
- while (_running) {
+ while (_run) {
long nr;
bool xrun = false;
if (!_freewheeling) {
}
_pcmi->pcm_stop ();
+ _active = false;
return 0;
}