#include <exception>
#include <stdexcept>
#include <sstream>
+#include <cmath>
#include <glibmm/timer.h>
#include <glibmm/pattern.h>
gint AudioEngine::m_meter_exit;
AudioEngine* AudioEngine::_instance = 0;
+#ifdef SILENCE_AFTER
+#define SILENCE_AFTER_SECONDS 600
+#endif
+
AudioEngine::AudioEngine ()
: session_remove_pending (false)
, session_removal_countdown (-1)
, _hw_devicelist_update_thread(0)
, _hw_devicelist_update_count(0)
, _stop_hw_devicelist_processing(0)
+#ifdef SILENCE_AFTER_SECONDS
+ , _silence_countdown (0)
+ , _silence_hit_cnt (0)
+#endif
{
g_atomic_int_set (&m_meter_exit, 0);
- start_hw_event_processing();
+ reset_silence_countdown ();
+ start_hw_event_processing();
discover_backends ();
}
SampleRateChanged (nframes); /* EMIT SIGNAL */
+#ifdef SILENCE_AFTER_SECONDS
+ _silence_countdown = nframes * SILENCE_AFTER_SECONDS;
+#endif
+
return 0;
}
last_monitor_check = next_processed_frames;
}
+#ifdef SILENCE_AFTER_SECONDS
+
+ bool was_silent = (_silence_countdown == 0);
+
+ if (_silence_countdown >= nframes) {
+ _silence_countdown -= nframes;
+ } else {
+ _silence_countdown = 0;
+ }
+
+ if (!was_silent && _silence_countdown == 0) {
+ _silence_hit_cnt++;
+ BecameSilent (); /* EMIT SIGNAL */
+ }
+
+ if (_silence_countdown == 0 || _session->silent()) {
+ PortManager::silence (nframes);
+ }
+
+#else
if (_session->silent()) {
PortManager::silence (nframes);
}
-
+#endif
+
if (session_remove_pending && session_removal_countdown) {
PortManager::fade_out (session_removal_gain, session_removal_gain_step, nframes);
return 0;
}
+void
+AudioEngine::reset_silence_countdown ()
+{
+#ifdef SILENCE_AFTER_SECONDS
+ double sr = 48000; /* default in case there is no backend */
+
+ sr = sample_rate();
+
+ _silence_countdown = max (60 * sr, /* 60 seconds */
+ sr * (SILENCE_AFTER_SECONDS / pow (2, _silence_hit_cnt)));
+
+#endif
+}
+
+void
+AudioEngine::launch_device_control_app()
+{
+ if (_state_lock.trylock () ) {
+ _backend->launch_control_app ();
+ _state_lock.unlock ();
+ }
+}
+
void
AudioEngine::request_backend_reset()
_hw_reset_condition.signal ();
}
+int
+AudioEngine::backend_reset_requested()
+{
+ return g_atomic_int_get (&_hw_reset_request_count);
+}
void
AudioEngine::do_reset_backend()
{
- SessionEvent::create_per_thread_pool (X_("Backend reset processing thread"), 512);
+ SessionEvent::create_per_thread_pool (X_("Backend reset processing thread"), 512);
- Glib::Threads::Mutex::Lock guard (_reset_request_lock);
+ Glib::Threads::Mutex::Lock guard (_reset_request_lock);
- while (!_stop_hw_reset_processing) {
+ while (!_stop_hw_reset_processing) {
- if (_hw_reset_request_count && _backend) {
-
+ if (g_atomic_int_get (&_hw_reset_request_count) != 0 && _backend) {
+
_reset_request_lock.unlock();
-
+
Glib::Threads::RecMutex::Lock pl (_state_lock);
-
- g_atomic_int_dec_and_test (&_hw_reset_request_count);
-
- std::cout << "AudioEngine::RESET::Reset request processing" << std::endl;
-
- // backup the device name
- std::string name = _backend->device_name ();
-
+ g_atomic_int_dec_and_test (&_hw_reset_request_count);
+
+ std::cout << "AudioEngine::RESET::Reset request processing. Requests left: " << _hw_reset_request_count << std::endl;
+ DeviceResetStarted(); // notify about device reset to be started
+
+ // backup the device name
+ std::string name = _backend->device_name ();
+
std::cout << "AudioEngine::RESET::Stoping engine..." << std::endl;
stop();
-
+
std::cout << "AudioEngine::RESET::Reseting device..." << std::endl;
if ( 0 == _backend->reset_device () ) {
-
+
std::cout << "AudioEngine::RESET::Starting engine..." << std::endl;
start ();
-
+
// inform about possible changes
BufferSizeChanged (_backend->buffer_size() );
} else {
DeviceError();
}
-
+
std::cout << "AudioEngine::RESET::Done." << std::endl;
- _reset_request_lock.lock();
+ _reset_request_lock.lock();
- } else {
+ } else {
- _hw_reset_condition.wait (_reset_request_lock);
+ _hw_reset_condition.wait (_reset_request_lock);
- }
- }
+ }
+ }
}
-
-
void
AudioEngine::request_device_list_update()
{
if (!_backend) {
return -1;
}
+
return _backend->set_sample_rate (sr);
}