Use ARDOUR::DSPLoadCalculator in DummyBackend
[ardour.git] / libs / backends / dummy / dummy_audiobackend.cc
index 7b5f41bc890246f9accc30711fd2778690b2a03d..f43d51251368292917d21a0ef2bb9e73ed1eec91 100644 (file)
 
 #include <glibmm.h>
 
+#ifdef PLATFORM_WINDOWS
+#include <windows.h>
+#include <pbd/windows_timer_utils.h>
+#endif
+
 #include "dummy_audiobackend.h"
 #include "dummy_midi_seq.h"
 
@@ -37,20 +42,11 @@ size_t DummyAudioBackend::_max_buffer_size = 8192;
 std::vector<std::string> DummyAudioBackend::_midi_options;
 std::vector<AudioBackend::DeviceStatus> DummyAudioBackend::_device_status;
 
-#ifdef PLATFORM_WINDOWS
-static double _win_pc_rate = 0; // usec per tick
-#endif
+std::vector<DummyAudioBackend::DriverSpeed> DummyAudioBackend::_driver_speed;
 
 static int64_t _x_get_monotonic_usec() {
 #ifdef PLATFORM_WINDOWS
-       if (_win_pc_rate > 0) {
-               LARGE_INTEGER Count;
-               // not very reliable, but the only realistic way for sub milli-seconds
-               if (QueryPerformanceCounter (&Count)) {
-                       return (int64_t) (Count.QuadPart * _win_pc_rate);
-               }
-               return -1;
-       }
+       return PBD::get_microseconds();
 #endif
        return g_get_monotonic_time();
 }
@@ -60,6 +56,7 @@ DummyAudioBackend::DummyAudioBackend (AudioEngine& e, AudioBackendInfo& info)
        , _running (false)
        , _freewheel (false)
        , _freewheeling (false)
+       , _speedup (1.0)
        , _device ("")
        , _samplerate (48000)
        , _samples_per_period (1024)
@@ -77,6 +74,18 @@ DummyAudioBackend::DummyAudioBackend (AudioEngine& e, AudioBackendInfo& info)
        _instance_name = s_instance_name;
        _device = _("Silence");
        pthread_mutex_init (&_port_callback_mutex, 0);
+
+       if (_driver_speed.empty()) {
+               _driver_speed.push_back (DriverSpeed (_("Half Speed"),   2.0f));
+               _driver_speed.push_back (DriverSpeed (_("Normal Speed"), 1.0f));
+               _driver_speed.push_back (DriverSpeed (_("Double Speed"), 0.5f));
+               _driver_speed.push_back (DriverSpeed (_("5x Speed"),     0.2f));
+               _driver_speed.push_back (DriverSpeed (_("10x Speed"),    0.1f));
+               _driver_speed.push_back (DriverSpeed (_("15x Speed"),    0.06666f));
+               _driver_speed.push_back (DriverSpeed (_("20x Speed"),    0.05f));
+               _driver_speed.push_back (DriverSpeed (_("50x Speed"),    0.02f));
+       }
+
 }
 
 DummyAudioBackend::~DummyAudioBackend ()
@@ -89,7 +98,7 @@ DummyAudioBackend::~DummyAudioBackend ()
 std::string
 DummyAudioBackend::name () const
 {
-       return X_("Dummy");
+       return X_("Dummy"); // internal name
 }
 
 bool
@@ -178,6 +187,41 @@ DummyAudioBackend::can_change_buffer_size_when_running () const
        return true;
 }
 
+std::vector<std::string>
+DummyAudioBackend::enumerate_drivers () const
+{
+       std::vector<std::string> speed_drivers;
+       for (std::vector<DriverSpeed>::const_iterator it = _driver_speed.begin () ; it != _driver_speed.end (); ++it) {
+               speed_drivers.push_back (it->name);
+       }
+       return speed_drivers;
+}
+
+std::string
+DummyAudioBackend::driver_name () const
+{
+       for (std::vector<DriverSpeed>::const_iterator it = _driver_speed.begin () ; it != _driver_speed.end (); ++it) {
+               if (rintf (1e6f * _speedup) == rintf (1e6f * it->speedup)) {
+                       return it->name;
+               }
+       }
+       assert (0);
+       return _("Normal Speed");
+}
+
+int
+DummyAudioBackend::set_driver (const std::string& d)
+{
+       for (std::vector<DriverSpeed>::const_iterator it = _driver_speed.begin () ; it != _driver_speed.end (); ++it) {
+               if (d == it->name) {
+                       _speedup = it->speedup;
+                       return 0;
+               }
+       }
+       assert (0);
+       return -1;
+}
+
 int
 DummyAudioBackend::set_device_name (const std::string& d)
 {
@@ -197,7 +241,7 @@ DummyAudioBackend::set_sample_rate (float sr)
 int
 DummyAudioBackend::set_buffer_size (uint32_t bs)
 {
-       if (bs <= 0 || bs >= _max_buffer_size) {
+       if (bs <= 0 || bs > _max_buffer_size) {
                return -1;
        }
        _samples_per_period = bs;
@@ -403,6 +447,8 @@ DummyAudioBackend::_start (bool /*for_latency_measurement*/)
        engine.sample_rate_change (_samplerate);
        engine.buffer_size_change (_samples_per_period);
 
+       _dsp_load_calc.set_max_time (_samplerate, _samples_per_period);
+
        if (engine.reestablish_ports ()) {
                PBD::error << _("DummyAudioBackend: Could not re-establish ports.") << endmsg;
                stop ();
@@ -636,7 +682,7 @@ DummyAudioBackend::get_ports (
        }
        for (size_t i = 0; i < _ports.size (); ++i) {
                DummyPort* port = _ports[i];
-               if ((port->type () == type) && (port->flags () & flags)) {
+               if ((port->type () == type) && flags == (port->flags () & flags)) {
                        if (!use_regexp || !regexec (&port_regex, port->name ().c_str (), 0, NULL, 0)) {
                                port_names.push_back (port->name ());
                                ++rv;
@@ -815,17 +861,17 @@ DummyAudioBackend::register_system_ports()
 void
 DummyAudioBackend::unregister_ports (bool system_only)
 {
-       size_t i = 0;
        _system_inputs.clear();
        _system_outputs.clear();
        _system_midi_in.clear();
        _system_midi_out.clear();
-       while (i <  _ports.size ()) {
-               DummyPort* port = _ports[i];
+
+       for (std::vector<DummyPort*>::iterator i = _ports.begin (); i != _ports.end ();) {
+               DummyPort* port = *i;
                if (! system_only || (port->is_physical () && port->is_terminal ())) {
                        port->disconnect_all ();
                        delete port;
-                       _ports.erase (_ports.begin() + i);
+                       i = _ports.erase (i);
                } else {
                        ++i;
                }
@@ -981,8 +1027,8 @@ DummyAudioBackend::midi_event_put (
        assert (buffer && port_buffer);
        DummyMidiBuffer& dst = * static_cast<DummyMidiBuffer*>(port_buffer);
        if (dst.size () && (pframes_t)dst.back ()->timestamp () > timestamp) {
+               // nevermind, ::get_buffer() sorts events, but always print warning
                fprintf (stderr, "DummyMidiBuffer: it's too late for this event.\n");
-               return -1;
        }
        dst.push_back (boost::shared_ptr<DummyMidiEvent>(new DummyMidiEvent (timestamp, buffer, size)));
        return 0;
@@ -1169,8 +1215,8 @@ DummyAudioBackend::main_process_thread ()
        manager.registration_callback();
        manager.graph_order_callback();
 
-       int64_t clock1, clock2;
-       clock1 = _x_get_monotonic_usec();
+       int64_t clock1;
+       clock1 = -1;
        while (_running) {
 
                if (_freewheeling != _freewheel) {
@@ -1220,31 +1266,15 @@ DummyAudioBackend::main_process_thread ()
                }
 
                if (!_freewheel) {
-                       const int64_t nomial_time = 1e6 * _samples_per_period / _samplerate;
-                       clock2 = _x_get_monotonic_usec();
-#ifdef PLATFORM_WINDOWS
-                       bool win_timers_ok = true;
-                       /* querying the performance counter can fail occasionally (-1).
-                        * Also on some multi-core systems, timers are CPU specific and not
-                        * synchronized. We assume they differ more than a few milliseconds
-                        * (4 * nominal cycle time) and simply ignore cases where the
-                        * execution switches cores.
-                        */
-                       if (clock1 < 0 || clock2 < 0 || (clock1 > clock2) || (clock2 - clock1) > 4 * nomial_time) {
-                               clock2 = clock1 = 0;
-                               win_timers_ok = false;
-                       }
-#endif
-                       const int64_t elapsed_time = clock2 - clock1;
-#ifdef PLATFORM_WINDOWS
-                       if (win_timers_ok)
-#endif
-                       { // low pass filter
-                               _dsp_load = _dsp_load + .05 * ((elapsed_time / (float) nomial_time) - _dsp_load) + 1e-12;
-                       }
-
-                       if (elapsed_time < nomial_time) {
-                               Glib::usleep (nomial_time - elapsed_time);
+                       _dsp_load_calc.set_start_timestamp_us (clock1);
+                       _dsp_load_calc.set_stop_timestamp_us (_x_get_monotonic_usec());
+                       _dsp_load = _dsp_load_calc.get_dsp_load ();
+
+                       const int64_t elapsed_time = _dsp_load_calc.elapsed_time_us ();
+                       const int64_t nominal_time = _dsp_load_calc.get_max_time_us ();
+                       if (elapsed_time < nominal_time) {
+                               const int64_t sleepy = _speedup * (nominal_time - elapsed_time);
+                               Glib::usleep (std::max ((int64_t) 100, sleepy));
                        } else {
                                Glib::usleep (100); // don't hog cpu
                        }
@@ -1253,7 +1283,7 @@ DummyAudioBackend::main_process_thread ()
                        Glib::usleep (100); // don't hog cpu
                }
 
-               /* beginning of netx cycle */
+               /* beginning of next cycle */
                clock1 = _x_get_monotonic_usec();
 
                bool connections_changed = false;
@@ -1302,7 +1332,7 @@ static bool already_configured ();
 static bool available ();
 
 static ARDOUR::AudioBackendInfo _descriptor = {
-       "Dummy",
+       _("None (Dummy)"),
        instantiate,
        deinstantiate,
        backend_factory,
@@ -1323,14 +1353,6 @@ static int
 instantiate (const std::string& arg1, const std::string& /* arg2 */)
 {
        s_instance_name = arg1;
-#ifdef PLATFORM_WINDOWS
-       LARGE_INTEGER Frequency;
-       if (!QueryPerformanceFrequency(&Frequency) || Frequency.QuadPart < 1) {
-               _win_pc_rate = 0;
-       } else {
-               _win_pc_rate = 1000000.0 / Frequency.QuadPart;
-       }
-#endif
        return 0;
 }
 
@@ -1344,8 +1366,9 @@ deinstantiate ()
 static bool
 already_configured ()
 {
-       if (_instance) {
-               return _instance->is_running();
+       // special-case: unit-tests require backend to be pre-configured.
+       if (s_instance_name == "Unit-Test") {
+               return true;
        }
        return false;
 }
@@ -1600,8 +1623,9 @@ void DummyAudioPort::setup_generator (GeneratorType const g, float const sampler
                                const double b = log (f_max / f_min) / g_p2;
                                const double a = f_min / (b * samplerate);
 #endif
+                               const uint32_t g_p2i = rint(g_p2);
                                _wavetable = (Sample*) malloc (_gen_period * sizeof(Sample));
-                               for (uint32_t i = 0 ; i < g_p2; ++i) {
+                               for (uint32_t i = 0 ; i < g_p2i; ++i) {
 #ifdef LINEAR_SWEEP
                                        const double phase = i * (a + b * i);
 #else
@@ -1609,14 +1633,14 @@ void DummyAudioPort::setup_generator (GeneratorType const g, float const sampler
 #endif
                                        _wavetable[i] = (float)sin (2. * M_PI * (phase - floor (phase)));
                                }
-                               for (uint32_t i = g_p2; i < _gen_period; ++i) {
+                               for (uint32_t i = g_p2i; i < _gen_period; ++i) {
                                        const uint32_t j = _gen_period - i;
 #ifdef LINEAR_SWEEP
                                        const double phase = j * (a + b * j);
 #else
                                        const double phase = a * exp (b * j) - a;
 #endif
-                                       _wavetable[i] = (float)sin (2. * M_PI * (phase - floor (phase)));
+                                       _wavetable[i] = -(float)sin (2. * M_PI * (phase - floor (phase)));
                                }
                                if (_gen_type == SquareSweep) {
                                        for (uint32_t i = 0 ; i < _gen_period; ++i) {
@@ -1726,7 +1750,7 @@ void DummyAudioPort::generate (const pframes_t n_samples)
                        {
                                const float vols = 2.f / (float)_gen_perio2;
                                for (pframes_t i = 0; i < n_samples; ++i) {
-                                       const float g = fabsf (_gen_count2 * vols - 1.0);
+                                       const float g = fabsf (_gen_count2 * vols - 1.f);
                                        _buffer[i] = g * _wavetable[_gen_offset];
                                        _gen_offset = (_gen_offset + 1) % _gen_period;
                                        _gen_count2 = (_gen_count2 + 1) % _gen_perio2;