diff options
Diffstat (limited to 'src/libs')
91 files changed, 478 insertions, 535 deletions
diff --git a/src/libs/engine/AlsaMidiDriver.cpp b/src/libs/engine/AlsaMidiDriver.cpp index fbf928bf..bc10de18 100644 --- a/src/libs/engine/AlsaMidiDriver.cpp +++ b/src/libs/engine/AlsaMidiDriver.cpp @@ -268,7 +268,7 @@ AlsaMidiDriver::activate() } #ifdef HAVE_LASH - lash_driver->set_alsa_client_id(snd_seq_client_id(m_seq_handle)); + om->lash_driver()->set_alsa_client_id(snd_seq_client_id(m_seq_handle)); #endif m_is_activated = true; diff --git a/src/libs/engine/DSSINode.cpp b/src/libs/engine/DSSINode.cpp index d9cad41d..0cd8ac22 100644 --- a/src/libs/engine/DSSINode.cpp +++ b/src/libs/engine/DSSINode.cpp @@ -63,7 +63,7 @@ DSSINode::instantiate() if (has_midi_input()) { _ports = new Array<Port*>(_descriptor->PortCount + 1); - _midi_in_port = new InputPort<MidiMessage>(this, "MIDI In", _ports->size()-1, 1, DataType::MIDI, _buffer_size); + _midi_in_port = new InputPort<MidiMessage>(this, "MIDI_In", _ports->size()-1, 1, DataType::MIDI, _buffer_size); _ports->at(_ports->size()-1) = _midi_in_port; } diff --git a/src/libs/engine/Event.cpp b/src/libs/engine/Event.cpp deleted file mode 100644 index fca60bdc..00000000 --- a/src/libs/engine/Event.cpp +++ /dev/null @@ -1,48 +0,0 @@ -/* This file is part of Ingen. Copyright (C) 2006 Dave Robillard. - * - * Om is free software; you can redistribute it and/or modify it under the - * terms of the GNU General Public License as published by the Free Software - * Foundation; either version 2 of the License, or (at your option) any later - * version. - * - * Om is distributed in the hope that it will be useful, but WITHOUT ANY - * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS - * FOR A PARTICULAR PURPOSE. See the GNU General Public License for details. - * - * You should have received a copy of the GNU General Public License along - * with this program; if not, write to the Free Software Foundation, Inc., - * 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA - */ - -#include "Event.h" -#include "Responder.h" -#include "Om.h" -#include "OmApp.h" -#include "AudioDriver.h" - -namespace Om { - -// It'd be nice if this was inlined.. -Event::Event(CountedPtr<Responder> responder) -: m_responder(responder), - m_executed(false) -{ - m_time_stamp = om->audio_driver()->time_stamp(); -} - - -/** Construct an event with no responder. - * - * For internal events only, attempting to access the responder will - * cause a NULL pointer dereference. - */ -Event::Event() -: m_responder(NULL), - m_executed(false) -{ - m_time_stamp = om->audio_driver()->time_stamp(); -} - - -} // namespace Om - diff --git a/src/libs/engine/Event.h b/src/libs/engine/Event.h index 355525cf..604d1e19 100644 --- a/src/libs/engine/Event.h +++ b/src/libs/engine/Event.h @@ -43,26 +43,29 @@ class Event : public MaidObject public: virtual ~Event() {} - /** Execute event, MUST be realtime safe */ - virtual void execute(samplecount offset) { assert(!m_executed); m_executed = true; } + /** Execute this event in the audio thread (MUST be realtime safe). */ + virtual void execute(samplecount offset) { assert(!_executed); _executed = true; } - /** Perform any actions after execution (ie send OSC response to client). - * No realtime requirement. */ + /** Perform any actions after execution (ie send replies to commands) + * (no realtime requirements). */ virtual void post_process() {} - inline samplecount time_stamp() { return m_time_stamp; } + inline samplecount time_stamp() { return _time_stamp; } protected: - Event(CountedPtr<Responder> responder); - Event(); - // Prevent copies Event(const Event&); Event& operator=(const Event&); + + Event(CountedPtr<Responder> responder, samplecount timestamp) + : _responder(responder) + , _time_stamp(timestamp) + , _executed(false) + {} - CountedPtr<Responder> m_responder; - samplecount m_time_stamp; - bool m_executed; + CountedPtr<Responder> _responder; + samplecount _time_stamp; + bool _executed; }; diff --git a/src/libs/engine/EventSource.h b/src/libs/engine/EventSource.h index 273100b7..6c52eb11 100644 --- a/src/libs/engine/EventSource.h +++ b/src/libs/engine/EventSource.h @@ -28,6 +28,12 @@ class QueuedEvent; * The AudioDriver gets events from an EventSource in the process callback * (realtime audio thread) and executes them, then they are sent to the * PostProcessor and finalised (post-processing thread). + * + * There are two distinct classes of events - "queued" and "stamped". Queued + * events are events that require non-realtime pre-processing before being + * executed in the process thread. Stamped events are timestamped realtime + * events that require no pre-processing and can be executed immediately + * (with sample accuracy). */ class EventSource { @@ -35,11 +41,9 @@ public: virtual ~EventSource() {} - virtual Event* pop_earliest_before(const samplecount time) = 0; - - virtual void start() = 0; + virtual Event* pop_earliest_queued_before(const samplecount time) = 0; - virtual void stop() = 0; + virtual Event* pop_earliest_stamped_before(const samplecount time) = 0; protected: EventSource() {} diff --git a/src/libs/engine/JackAudioDriver.cpp b/src/libs/engine/JackAudioDriver.cpp index 92794796..dd01941e 100644 --- a/src/libs/engine/JackAudioDriver.cpp +++ b/src/libs/engine/JackAudioDriver.cpp @@ -25,6 +25,7 @@ #include "Event.h" #include "QueuedEvent.h" #include "EventSource.h" +#include "OSCReceiver.h" #include "PostProcessor.h" #include "util/Queue.h" #include "Node.h" @@ -124,9 +125,7 @@ JackAudioDriver::JackAudioDriver() m_sample_rate(0), m_is_activated(false), m_local_client(true), - m_root_patch(NULL), - m_start_of_current_cycle(0), - m_start_of_last_cycle(0) + m_root_patch(NULL) { m_client = jack_client_new("Om"); if (m_client == NULL) { @@ -148,9 +147,7 @@ JackAudioDriver::JackAudioDriver(jack_client_t* jack_client) m_buffer_size(jack_get_buffer_size(jack_client)), m_sample_rate(jack_get_sample_rate(jack_client)), m_is_activated(false), - m_local_client(false), - m_start_of_current_cycle(0), - m_start_of_last_cycle(0) + m_local_client(false) { jack_on_shutdown(m_client, shutdown_cb, this); @@ -186,7 +183,7 @@ JackAudioDriver::activate() } else { cout << "[JackAudioDriver] Activated Jack client." << endl; #ifdef HAVE_LASH - lash_driver->set_jack_client_name("Om"); // FIXME: unique name + om->lash_driver()->set_jack_client_name("Om"); // FIXME: unique name #endif } } @@ -196,8 +193,7 @@ void JackAudioDriver::deactivate() { if (m_is_activated) { - // FIXME - reinterpret_cast<EventSource*>(om->osc_receiver())->stop(); + om->osc_receiver()->deactivate(); jack_deactivate(m_client); m_is_activated = false; @@ -268,38 +264,40 @@ JackAudioDriver::process_events(jack_nframes_t block_start, jack_nframes_t block Event* ev = NULL; /* Limit the maximum number of queued events to process per cycle. This - * makes the process callback truly realtime-safe by preventing being + * makes the process callback (more) realtime-safe by preventing being * choked by events coming in faster than they can be processed. * FIXME: run the math on this and figure out a good value */ - const int MAX_SLOW_EVENTS = m_buffer_size / 100; + const unsigned int MAX_QUEUED_EVENTS = m_buffer_size / 100; - int num_events_processed = 0; - int offset = 0; + unsigned int num_events_processed = 0; + unsigned int offset = 0; // Process the "slow" events first, because it's possible some of the // RT events depend on them + /* FIXME: Merge these next two loops into one */ + // FIXME - while ((ev = reinterpret_cast<EventSource*>(om->osc_receiver()) - ->pop_earliest_before(block_end)) != NULL) { + while ((ev = om->osc_receiver()->pop_earliest_queued_before(block_end))) { ev->execute(0); // QueuedEvents are not sample accurate om->post_processor()->push(ev); - if (++num_events_processed > MAX_SLOW_EVENTS) + if (++num_events_processed > MAX_QUEUED_EVENTS) break; } - while (!om->event_queue()->is_empty() - && om->event_queue()->front()->time_stamp() < block_end) { - ev = om->event_queue()->pop(); - offset = ev->time_stamp() - block_start; - if (offset < 0) offset = 0; // this can happen if we miss a cycle + while ((ev = om->osc_receiver()->pop_earliest_stamped_before(block_end))) { + if (ev->time_stamp() >= block_start) + offset = ev->time_stamp() - block_start; + else + offset = 0; + ev->execute(offset); om->post_processor()->push(ev); ++num_events_processed; } if (num_events_processed > 0) - om->post_processor()->signal(); + om->post_processor()->whip(); } @@ -315,20 +313,24 @@ JackAudioDriver::process_events(jack_nframes_t block_start, jack_nframes_t block int JackAudioDriver::m_process_cb(jack_nframes_t nframes) { + static jack_nframes_t start_of_current_cycle = 0; + static jack_nframes_t start_of_last_cycle = 0; + // FIXME: support nframes != buffer_size, even though that never damn well happens assert(nframes == m_buffer_size); - // Note that jack can elect to not call this function for a cycle, if things aren't - // keeping up - m_start_of_current_cycle = jack_last_frame_time(m_client); - m_start_of_last_cycle = m_start_of_current_cycle - nframes; + // Jack can elect to not call this function for a cycle, if overloaded + // FIXME: this doesn't make sense, and the start time isn't used anyway + start_of_current_cycle = jack_last_frame_time(m_client); + start_of_last_cycle = start_of_current_cycle - nframes; - assert(m_start_of_current_cycle - m_start_of_last_cycle == nframes); + // FIXME: ditto + assert(start_of_current_cycle - start_of_last_cycle == nframes); m_transport_state = jack_transport_query(m_client, &m_position); - process_events(m_start_of_last_cycle, m_start_of_current_cycle); - om->midi_driver()->prepare_block(m_start_of_last_cycle, m_start_of_current_cycle); + process_events(start_of_last_cycle, start_of_current_cycle); + om->midi_driver()->prepare_block(start_of_last_cycle, start_of_current_cycle); // Set buffers of patch ports to Jack port buffers (zero-copy processing) for (List<JackAudioPort*>::iterator i = m_ports.begin(); i != m_ports.end(); ++i) diff --git a/src/libs/engine/JackAudioDriver.h b/src/libs/engine/JackAudioDriver.h index f491ce11..7141d5d4 100644 --- a/src/libs/engine/JackAudioDriver.h +++ b/src/libs/engine/JackAudioDriver.h @@ -140,9 +140,6 @@ private: List<JackAudioPort*> m_ports; Patch* m_root_patch; - - jack_nframes_t m_start_of_current_cycle; - jack_nframes_t m_start_of_last_cycle; }; diff --git a/src/libs/engine/Makefile.am b/src/libs/engine/Makefile.am index e814b3b8..e356e488 100644 --- a/src/libs/engine/Makefile.am +++ b/src/libs/engine/Makefile.am @@ -56,7 +56,6 @@ libingen_la_SOURCES = \ MidiControlNode.h \ MidiControlNode.cpp \ Event.h \ - Event.cpp \ QueuedEvent.h \ EventSource.h \ QueuedEventSource.h \ diff --git a/src/libs/engine/MidiControlNode.cpp b/src/libs/engine/MidiControlNode.cpp index 5eba4a92..f7fe2984 100644 --- a/src/libs/engine/MidiControlNode.cpp +++ b/src/libs/engine/MidiControlNode.cpp @@ -36,10 +36,10 @@ MidiControlNode::MidiControlNode(const string& path, size_t poly, Patch* parent, { _ports = new Array<Port*>(7); - _midi_in_port = new InputPort<MidiMessage>(this, "MIDI In", 0, 1, DataType::MIDI, _buffer_size); + _midi_in_port = new InputPort<MidiMessage>(this, "MIDI_In", 0, 1, DataType::MIDI, _buffer_size); _ports->at(0) = _midi_in_port; - _param_port = new InputPort<sample>(this, "Controller Number", 1, 1, DataType::FLOAT, 1); + _param_port = new InputPort<sample>(this, "Controller_Number", 1, 1, DataType::FLOAT, 1); _ports->at(1) = _param_port; _log_port = new InputPort<sample>(this, "Logarithmic", 2, 1, DataType::FLOAT, 1); @@ -51,10 +51,10 @@ MidiControlNode::MidiControlNode(const string& path, size_t poly, Patch* parent, _max_port = new InputPort<sample>(this, "Max", 4, 1, DataType::FLOAT, 1); _ports->at(4) = _max_port; - _audio_port = new OutputPort<sample>(this, "Out (AR)", 5, 1, DataType::FLOAT, _buffer_size); + _audio_port = new OutputPort<sample>(this, "Out_(AR)", 5, 1, DataType::FLOAT, _buffer_size); _ports->at(5) = _audio_port; - _control_port = new OutputPort<sample>(this, "Out (CR)", 6, 1, DataType::FLOAT, 1); + _control_port = new OutputPort<sample>(this, "Out_(CR)", 6, 1, DataType::FLOAT, 1); _ports->at(6) = _control_port; _plugin.plug_label("midi_control_in"); @@ -94,7 +94,7 @@ MidiControlNode::control(uchar control_num, uchar val, samplecount offset) _learn_event->set_value(control_num); _learn_event->execute(offset); om->post_processor()->push(_learn_event); - om->post_processor()->signal(); + om->post_processor()->whip(); _learning = false; _learn_event = NULL; } diff --git a/src/libs/engine/MidiNoteNode.cpp b/src/libs/engine/MidiNoteNode.cpp index 3c66e283..47c2d5ac 100644 --- a/src/libs/engine/MidiNoteNode.cpp +++ b/src/libs/engine/MidiNoteNode.cpp @@ -41,7 +41,7 @@ MidiNoteNode::MidiNoteNode(const string& path, size_t poly, Patch* parent, sampl { _ports = new Array<Port*>(5); - _midi_in_port = new InputPort<MidiMessage>(this, "DataType::MIDI In", 0, 1, DataType::MIDI, _buffer_size); + _midi_in_port = new InputPort<MidiMessage>(this, "MIDI_In", 0, 1, DataType::MIDI, _buffer_size); _ports->at(0) = _midi_in_port; _freq_port = new OutputPort<sample>(this, "Frequency", 1, poly, DataType::FLOAT, _buffer_size); diff --git a/src/libs/engine/MidiTriggerNode.cpp b/src/libs/engine/MidiTriggerNode.cpp index 2f2d4362..4026da8e 100644 --- a/src/libs/engine/MidiTriggerNode.cpp +++ b/src/libs/engine/MidiTriggerNode.cpp @@ -30,10 +30,10 @@ MidiTriggerNode::MidiTriggerNode(const string& path, size_t poly, Patch* parent, { _ports = new Array<Port*>(5); - _midi_in_port = new InputPort<MidiMessage>(this, "DataType::MIDI In", 0, 1, DataType::MIDI, _buffer_size); + _midi_in_port = new InputPort<MidiMessage>(this, "MIDI_In", 0, 1, DataType::MIDI, _buffer_size); _ports->at(0) = _midi_in_port; - _note_port = new InputPort<sample>(this, "Note Number", 1, 1, DataType::FLOAT, 1); + _note_port = new InputPort<sample>(this, "Note_Number", 1, 1, DataType::FLOAT, 1); // new PortInfo("Note Number", CONTROL, INPUT, INTEGER, 60, 0, 127), 1); _ports->at(1) = _note_port; diff --git a/src/libs/engine/OSCReceiver.cpp b/src/libs/engine/OSCReceiver.cpp index 30bda10b..0e2cfd06 100644 --- a/src/libs/engine/OSCReceiver.cpp +++ b/src/libs/engine/OSCReceiver.cpp @@ -50,7 +50,7 @@ using Shared::ClientKey; OSCReceiver::OSCReceiver(size_t queue_size, const char* const port) -: QueuedEngineInterface(queue_size), +: QueuedEngineInterface(queue_size, queue_size), // FIXME _port(port), _server(NULL), _osc_responder(NULL) @@ -136,19 +136,19 @@ OSCReceiver::~OSCReceiver() void -OSCReceiver::start() +OSCReceiver::activate() { set_name("OSCReceiver"); - QueuedEventSource::start(); + QueuedEventSource::activate(); set_scheduling(SCHED_FIFO, 10); } void -OSCReceiver::stop() +OSCReceiver::deactivate() { cout << "[OSCReceiver] Stopped OSC listening thread" << endl; - QueuedEventSource::stop(); + QueuedEventSource::deactivate(); } @@ -158,9 +158,8 @@ OSCReceiver::stop() void OSCReceiver::_run() { - /* FIXME: Make Event() take a timestamp as a parameter, get a timestamp - * here and stamp all the events with the same time so they all get - * executed in the same cycle */ + /* get a timestamp here and stamp all the events with the same time so + * they all get executed in the same cycle */ while (true) { assert( ! unprepared_events()); @@ -174,7 +173,7 @@ OSCReceiver::_run() // Process them all while (unprepared_events()) - _signalled(); + _whipped(); // Whip our slave self // No more unprepared events } @@ -266,7 +265,6 @@ int OSCReceiver::m_ping_cb(const char* path, const char* types, lo_arg** argv, int argc, lo_message msg) { _responder->respond_ok(); - return 0; } @@ -284,7 +282,6 @@ int OSCReceiver::m_ping_slow_cb(const char* path, const char* types, lo_arg** argv, int argc, lo_message msg) { ping(); - return 0; } @@ -302,7 +299,6 @@ OSCReceiver::m_quit_cb(const char* path, const char* types, lo_arg** argv, int a { quit(); - return 0; } @@ -366,7 +362,7 @@ OSCReceiver::m_load_plugins_cb(const char* path, const char* types, lo_arg** arg int OSCReceiver::m_engine_activate_cb(const char* path, const char* types, lo_arg** argv, int argc, lo_message msg) { - activate(); + QueuedEngineInterface::activate(); return 0; } @@ -378,7 +374,7 @@ OSCReceiver::m_engine_activate_cb(const char* path, const char* types, lo_arg** int OSCReceiver::m_engine_deactivate_cb(const char* path, const char* types, lo_arg** argv, int argc, lo_message msg) { - deactivate(); + QueuedEngineInterface::deactivate(); return 0; } @@ -396,7 +392,6 @@ OSCReceiver::m_create_patch_cb(const char* path, const char* types, lo_arg** arg const int poly = argv[2]->i; create_patch(patch_path, poly); - return 0; } @@ -414,7 +409,6 @@ OSCReceiver::m_rename_cb(const char* path, const char* types, lo_arg** argv, int const char* name = &argv[2]->s; rename(object_path, name); - return 0; } @@ -430,7 +424,6 @@ OSCReceiver::m_enable_patch_cb(const char* path, const char* types, lo_arg** arg const char* patch_path = &argv[1]->s; enable_patch(patch_path); - return 0; } @@ -446,7 +439,6 @@ OSCReceiver::m_disable_patch_cb(const char* path, const char* types, lo_arg** ar const char* patch_path = &argv[1]->s; disable_patch(patch_path); - return 0; } @@ -462,7 +454,6 @@ OSCReceiver::m_clear_patch_cb(const char* path, const char* types, lo_arg** argv const char* patch_path = &argv[1]->s; clear_patch(patch_path); - return 0; } @@ -482,7 +473,6 @@ OSCReceiver::m_create_port_cb(const char* path, const char* types, lo_arg** argv const int direction = argv[3]->i; create_port(port_path, data_type, (direction == 1)); - return 0; } @@ -505,7 +495,6 @@ OSCReceiver::m_create_node_by_uri_cb(const char* path, const char* types, lo_arg // FIXME: make sure poly is valid create_node(node_path, type, plug_uri, (poly == 1)); - return 0; } @@ -533,7 +522,6 @@ OSCReceiver::m_create_node_cb(const char* path, const char* types, lo_arg** argv const int poly = argv[5]->i; create_node(node_path, type, lib_name, plug_label, (poly == 1)); - return 0; } @@ -549,7 +537,6 @@ OSCReceiver::m_destroy_cb(const char* path, const char* types, lo_arg** argv, in const char* node_path = &argv[1]->s; destroy(node_path); - return 0; } @@ -567,7 +554,6 @@ OSCReceiver::m_connect_cb(const char* path, const char* types, lo_arg** argv, in const char* dst_port_path = &argv[2]->s; connect(src_port_path, dst_port_path); - return 0; } @@ -585,7 +571,6 @@ OSCReceiver::m_disconnect_cb(const char* path, const char* types, lo_arg** argv, const char* dst_port_path = &argv[2]->s; disconnect(src_port_path, dst_port_path); - return 0; } @@ -601,7 +586,6 @@ OSCReceiver::m_disconnect_all_cb(const char* path, const char* types, lo_arg** a const char* node_path = &argv[1]->s; disconnect_all(node_path); - return 0; } @@ -619,7 +603,6 @@ OSCReceiver::m_set_port_value_cb(const char* path, const char* types, lo_arg** a const float value = argv[2]->f; set_port_value(port_path, value); - return 0; } @@ -639,7 +622,6 @@ OSCReceiver::m_set_port_value_voice_cb(const char* path, const char* types, lo_a const float value = argv[3]->f; set_port_value(port_path, voice, value); - return 0; } @@ -661,7 +643,6 @@ OSCReceiver::m_set_port_value_slow_cb(const char* path, const char* types, lo_ar const float value = argv[2]->f; set_port_value_queued(port_path, value); - return 0; } @@ -755,8 +736,7 @@ OSCReceiver::m_midi_learn_cb(const char* path, const char* types, lo_arg** argv, int OSCReceiver::m_lash_restore_done_cb(const char* path, const char* types, lo_arg** argv, int argc, lo_message msg) { - lash_retore_done(); - + lash_restore_done(); return 0; } #endif // HAVE_LASH @@ -818,11 +798,7 @@ OSCReceiver::m_metadata_get_cb(const char* path, const char* types, lo_arg** arg int OSCReceiver::m_request_plugins_cb(const char* path, const char* types, lo_arg** argv, int argc, lo_message msg) { - cerr << "REQUEST PLUGINS\n"; - - // FIXME request_plugins(); - return 0; } @@ -837,7 +813,6 @@ int OSCReceiver::m_request_all_objects_cb(const char* path, const char* types, lo_arg** argv, int argc, lo_message msg) { request_all_objects(); - return 0; } @@ -852,10 +827,9 @@ OSCReceiver::m_request_all_objects_cb(const char* path, const char* types, lo_ar int OSCReceiver::m_request_port_value_cb(const char* path, const char* types, lo_arg** argv, int argc, lo_message msg) { - const char* port_path = &argv[1]->s; + const char* port_path = &argv[1]->s; request_port_value(port_path); - return 0; } diff --git a/src/libs/engine/OSCReceiver.h b/src/libs/engine/OSCReceiver.h index c966632f..67cc8ee2 100644 --- a/src/libs/engine/OSCReceiver.h +++ b/src/libs/engine/OSCReceiver.h @@ -50,19 +50,20 @@ inline static int name##_cb(LO_HANDLER_ARGS, void* osc_receiver)\ * * This inherits from QueuedEngineInterface and calls it's own functions * via OSC. It's not actually a directly callable EngineInterface (it's - * callable via OSC...) so it is-implemented-as-a (privately inherits) - * QueuedEngineInterface. + * callable via OSC...) so it should be implemented-as-a (privately inherit) + * QueuedEngineInterface, but it needs to be public so it's an EventSource + * the Driver can use. This probably should be fixed somehow.. * * \ingroup engine */ -class OSCReceiver : private QueuedEngineInterface +class OSCReceiver : public QueuedEngineInterface { public: OSCReceiver(size_t queue_size, const char* const port); ~OSCReceiver(); - void start(); - void stop(); + void activate(); + void deactivate(); private: // Prevent copies (undefined) diff --git a/src/libs/engine/Om.cpp b/src/libs/engine/Om.cpp index f1e32a31..f991e08e 100644 --- a/src/libs/engine/Om.cpp +++ b/src/libs/engine/Om.cpp @@ -30,7 +30,4 @@ namespace Om { OmApp* om = 0; -#ifdef HAVE_LASH - LashDriver* lash_driver = 0; -#endif } diff --git a/src/libs/engine/Om.h b/src/libs/engine/Om.h index fe9689aa..002b3bc1 100644 --- a/src/libs/engine/Om.h +++ b/src/libs/engine/Om.h @@ -30,10 +30,6 @@ */ namespace Om { -#ifdef HAVE_LASH - class LashDriver; - extern LashDriver* lash_driver; -#endif class OmApp; extern OmApp* om; } diff --git a/src/libs/engine/OmApp.cpp b/src/libs/engine/OmApp.cpp index 5a001633..f6ef9f54 100644 --- a/src/libs/engine/OmApp.cpp +++ b/src/libs/engine/OmApp.cpp @@ -50,43 +50,9 @@ using std::cout; using std::cerr; using std::endl; namespace Om { -OmApp::OmApp(const char* port) -: m_maid(new Maid(maid_queue_size)), - m_audio_driver(new JackAudioDriver()), -#ifdef HAVE_JACK_MIDI - m_midi_driver(new JackMidiDriver(((JackAudioDriver*)m_audio_driver)->jack_client())), -#elif HAVE_ALSA_MIDI - m_midi_driver(new AlsaMidiDriver()), -#else - m_midi_driver(new DummyMidiDriver()), -#endif - m_osc_receiver(new OSCReceiver(pre_processor_queue_size, port)), - m_client_broadcaster(new ClientBroadcaster()), - m_object_store(new ObjectStore()), - m_node_factory(new NodeFactory()), - m_event_queue(new Queue<Event*>(event_queue_size)), -// m_pre_processor(new QueuedEventSource(pre_processor_queue_size)), - m_post_processor(new PostProcessor(post_processor_queue_size)), - m_quit_flag(false), - m_activated(false) -{ - mlock(m_audio_driver, sizeof(JackAudioDriver)); - mlock(m_object_store, sizeof(ObjectStore)); - mlock(m_osc_receiver, sizeof(OSCReceiver)); -#ifdef HAVE_ALSA_MIDI - mlock(m_midi_driver, sizeof(AlsaMidiDriver)); -#else - mlock(m_midi_driver, sizeof(DummyMidiDriver)); -#endif - - m_osc_receiver->start(); - m_post_processor->start(); -} - - OmApp::OmApp(const char* port, AudioDriver* audio_driver) -: m_maid(new Maid(maid_queue_size)), - m_audio_driver(audio_driver), +: m_audio_driver( (audio_driver) ? audio_driver : new JackAudioDriver() ), + m_osc_receiver(new OSCReceiver(pre_processor_queue_size, port)), #ifdef HAVE_JACK_MIDI m_midi_driver(new JackMidiDriver(((JackAudioDriver*)m_audio_driver)->jack_client())), #elif HAVE_ALSA_MIDI @@ -94,27 +60,20 @@ OmApp::OmApp(const char* port, AudioDriver* audio_driver) #else m_midi_driver(new DummyMidiDriver()), #endif - m_osc_receiver(new OSCReceiver(pre_processor_queue_size, port)), + m_post_processor(new PostProcessor(post_processor_queue_size)), + m_maid(new Maid(maid_queue_size)), m_client_broadcaster(new ClientBroadcaster()), m_object_store(new ObjectStore()), m_node_factory(new NodeFactory()), - m_event_queue(new Queue<Event*>(event_queue_size)), - //m_pre_processor(new QueuedEventSource(pre_processor_queue_size)), - m_post_processor(new PostProcessor(post_processor_queue_size)), +#ifdef HAVE_LASH + m_lash_driver(new LashDriver()), +#else + m_lash_driver(NULL), +#endif m_quit_flag(false), m_activated(false) { - mlock(m_audio_driver, sizeof(JackAudioDriver)); - mlock(m_object_store, sizeof(ObjectStore)); - mlock(m_osc_receiver, sizeof(OSCReceiver)); -#ifdef HAVE_ALSA_MIDI - mlock(m_midi_driver, sizeof(AlsaMidiDriver)); -#else - mlock(m_midi_driver, sizeof(DummyMidiDriver)); -#endif - - m_osc_receiver->start(); - m_post_processor->start(); + m_osc_receiver->activate(); } @@ -186,11 +145,11 @@ OmApp::activate() return; // Create root patch - CreatePatchEvent create_ev(CountedPtr<Responder>(new Responder()), "/", 1); + CreatePatchEvent create_ev(CountedPtr<Responder>(new Responder()), 0, "/", 1); create_ev.pre_process(); create_ev.execute(0); create_ev.post_process(); - EnablePatchEvent enable_ev(CountedPtr<Responder>(new Responder()), "/"); + EnablePatchEvent enable_ev(CountedPtr<Responder>(new Responder()), 0, "/"); enable_ev.pre_process(); enable_ev.execute(0); enable_ev.post_process(); @@ -201,6 +160,9 @@ OmApp::activate() #ifdef HAVE_ALSA_MIDI m_midi_driver->activate(); #endif + + m_post_processor->start(); + m_activated = true; } @@ -222,9 +184,13 @@ OmApp::deactivate() if (m_midi_driver != NULL) m_midi_driver->deactivate(); - m_osc_receiver->stop(); + m_osc_receiver->deactivate(); m_audio_driver->deactivate(); + // Finalize any lingering events (unlikely) + m_post_processor->whip(); + m_post_processor->stop(); + m_activated = false; } diff --git a/src/libs/engine/OmApp.h b/src/libs/engine/OmApp.h index 8f14d0c2..b7305a2d 100644 --- a/src/libs/engine/OmApp.h +++ b/src/libs/engine/OmApp.h @@ -33,6 +33,7 @@ class EventSource; class PostProcessor; class Event; class QueuedEvent; +class LashDriver; template <typename T> class Driver; @@ -45,8 +46,7 @@ template <typename T> class Driver; class OmApp { public: - OmApp(const char* const port); - OmApp(const char* const port, AudioDriver* audio_driver); + OmApp(const char* const port, AudioDriver* audio_driver = 0); ~OmApp(); int main(); @@ -58,16 +58,17 @@ public: void activate(); void deactivate(); - Maid* maid() const { return m_maid; } + AudioDriver* audio_driver() const { return m_audio_driver; } - MidiDriver* midi_driver() const { return m_midi_driver; } OSCReceiver* osc_receiver() const { return m_osc_receiver; } + MidiDriver* midi_driver() const { return m_midi_driver; } + PostProcessor* post_processor() const { return m_post_processor; } + Maid* maid() const { return m_maid; } ClientBroadcaster* client_broadcaster() const { return m_client_broadcaster; } ObjectStore* object_store() const { return m_object_store; } NodeFactory* node_factory() const { return m_node_factory; } - Queue<Event*>* event_queue() const { return m_event_queue; } - //EventSource* pre_processor() const { return m_pre_processor; } - PostProcessor* post_processor() const { return m_post_processor; } + LashDriver* lash_driver() const { return m_lash_driver; } + /** Return the active driver for the given (template parameter) type. * This is a hook for BridgeNode. See OmApp.cpp for specializations. */ @@ -78,16 +79,16 @@ private: OmApp(const OmApp&); OmApp& operator=(const OmApp&); - Maid* m_maid; + AudioDriver* m_audio_driver; - MidiDriver* m_midi_driver; OSCReceiver* m_osc_receiver; + MidiDriver* m_midi_driver; + PostProcessor* m_post_processor; + Maid* m_maid; ClientBroadcaster* m_client_broadcaster; ObjectStore* m_object_store; NodeFactory* m_node_factory; - Queue<Event*>* m_event_queue; - //EventSource* m_pre_processor; - PostProcessor* m_post_processor; + LashDriver* m_lash_driver; bool m_quit_flag; bool m_activated; diff --git a/src/libs/engine/PostProcessor.cpp b/src/libs/engine/PostProcessor.cpp index 8b68159e..9477317d 100644 --- a/src/libs/engine/PostProcessor.cpp +++ b/src/libs/engine/PostProcessor.cpp @@ -37,13 +37,12 @@ PostProcessor::PostProcessor(size_t queue_size) } -/** Post processing thread. +/** Post-Process every pending event. * - * Infinite loop that waits on the semaphore and processes every enqueued - * event (to be signalled at the end of every process cycle). + * The PostProcessor should be whipped by the audio thread once every cycle */ void -PostProcessor::_signalled() +PostProcessor::_whipped() { while ( ! _events.is_empty()) { Event* const ev = _events.pop(); diff --git a/src/libs/engine/PostProcessor.h b/src/libs/engine/PostProcessor.h index e0c384eb..a243d824 100644 --- a/src/libs/engine/PostProcessor.h +++ b/src/libs/engine/PostProcessor.h @@ -50,7 +50,7 @@ private: PostProcessor& operator=(const PostProcessor&); Queue<Event*> _events; - virtual void _signalled(); + virtual void _whipped(); }; diff --git a/src/libs/engine/QueuedEngineInterface.cpp b/src/libs/engine/QueuedEngineInterface.cpp index 0546b8a2..26632380 100644 --- a/src/libs/engine/QueuedEngineInterface.cpp +++ b/src/libs/engine/QueuedEngineInterface.cpp @@ -20,11 +20,12 @@ #include "Om.h" #include "util/Queue.h" #include "OmApp.h" +#include "AudioDriver.h" namespace Om { -QueuedEngineInterface::QueuedEngineInterface(size_t queue_size) -: QueuedEventSource(queue_size) +QueuedEngineInterface::QueuedEngineInterface(size_t queued_size, size_t stamped_size) +: QueuedEventSource(queued_size, stamped_size) , _responder(CountedPtr<Responder>(new Responder())) // NULL responder { } @@ -38,7 +39,6 @@ QueuedEngineInterface::QueuedEngineInterface(size_t queue_size) void QueuedEngineInterface::set_responder(CountedPtr<Responder> responder) { - //cerr << "SET\n"; _responder = responder; } @@ -58,16 +58,16 @@ QueuedEngineInterface::disable_responses() void QueuedEngineInterface::register_client(ClientKey key, CountedPtr<ClientInterface> client) { - RegisterClientEvent* ev = new RegisterClientEvent(_responder, key, client); - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new RegisterClientEvent(_responder, timestamp, key, client)); } void QueuedEngineInterface::unregister_client(ClientKey key) { - UnregisterClientEvent* ev = new UnregisterClientEvent(_responder, key); - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new UnregisterClientEvent(_responder, timestamp, key)); } @@ -76,8 +76,8 @@ QueuedEngineInterface::unregister_client(ClientKey key) void QueuedEngineInterface::load_plugins() { - LoadPluginsEvent* ev = new LoadPluginsEvent(_responder); - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new LoadPluginsEvent(_responder, timestamp)); } @@ -85,16 +85,16 @@ QueuedEngineInterface::load_plugins() void QueuedEngineInterface::activate() { - ActivateEvent* ev = new ActivateEvent(_responder); - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new ActivateEvent(_responder, timestamp)); } void QueuedEngineInterface::deactivate() { - DeactivateEvent* ev = new DeactivateEvent(_responder); - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new DeactivateEvent(_responder, timestamp)); } @@ -113,8 +113,8 @@ void QueuedEngineInterface::create_patch(const string& path, uint32_t poly) { - CreatePatchEvent* ev = new CreatePatchEvent(_responder, path, poly); - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new CreatePatchEvent(_responder, timestamp, path, poly)); } @@ -123,8 +123,8 @@ void QueuedEngineInterface::create_port(const string& path, const string& data_type, bool direction) { - AddPortEvent* ev = new AddPortEvent(_responder, path, data_type, direction); - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new AddPortEvent(_responder, timestamp, path, data_type, direction)); } @@ -134,14 +134,14 @@ QueuedEngineInterface::create_node(const string& path, const string& plugin_uri, bool polyphonic) { + const samplecount timestamp = om->audio_driver()->time_stamp(); // FIXME: ew Plugin* plugin = new Plugin(); plugin->set_type(plugin_type); plugin->uri(plugin_uri); - AddNodeEvent* ev = new AddNodeEvent(_responder, path, plugin, polyphonic); - push(ev); + push_queued(new AddNodeEvent(_responder, timestamp, path, plugin, polyphonic)); } @@ -152,6 +152,7 @@ QueuedEngineInterface::create_node(const string& path, const string& plugin_label, bool polyphonic) { + const samplecount timestamp = om->audio_driver()->time_stamp(); // FIXME: ew Plugin* plugin = new Plugin(); @@ -159,46 +160,47 @@ QueuedEngineInterface::create_node(const string& path, plugin->lib_name(plugin_lib); plugin->plug_label(plugin_label); - AddNodeEvent* ev = new AddNodeEvent(_responder, path, plugin, polyphonic); - push(ev); + push_queued(new AddNodeEvent(_responder, timestamp, path, plugin, polyphonic)); } void QueuedEngineInterface::rename(const string& old_path, const string& new_name) { - RenameEvent* ev = new RenameEvent(_responder, old_path, new_name); - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new RenameEvent(_responder, timestamp, old_path, new_name)); } void QueuedEngineInterface::destroy(const string& path) { - DestroyEvent* ev = new DestroyEvent(_responder, this, path); - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new DestroyEvent(_responder, timestamp, this, path)); } void QueuedEngineInterface::clear_patch(const string& patch_path) { + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new ClearPatchEvent(_responder, timestamp, patch_path)); } void QueuedEngineInterface::enable_patch(const string& patch_path) { - EnablePatchEvent* ev = new EnablePatchEvent(_responder, patch_path); - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new EnablePatchEvent(_responder, timestamp, patch_path)); } void QueuedEngineInterface::disable_patch(const string& patch_path) { - DisablePatchEvent* ev = new DisablePatchEvent(_responder, patch_path); - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new DisablePatchEvent(_responder, timestamp, patch_path)); } @@ -206,8 +208,8 @@ void QueuedEngineInterface::connect(const string& src_port_path, const string& dst_port_path) { - ConnectionEvent* ev = new ConnectionEvent(_responder, src_port_path, dst_port_path); - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new ConnectionEvent(_responder, timestamp, src_port_path, dst_port_path)); } @@ -216,16 +218,16 @@ void QueuedEngineInterface::disconnect(const string& src_port_path, const string& dst_port_path) { - DisconnectionEvent* ev = new DisconnectionEvent(_responder, src_port_path, dst_port_path); - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new DisconnectionEvent(_responder, timestamp, src_port_path, dst_port_path)); } void QueuedEngineInterface::disconnect_all(const string& node_path) { - DisconnectNodeEvent* ev = new DisconnectNodeEvent(_responder, node_path); - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new DisconnectNodeEvent(_responder, timestamp, node_path)); } @@ -233,8 +235,8 @@ void QueuedEngineInterface::set_port_value(const string& port_path, float value) { - SetPortValueEvent* ev = new SetPortValueEvent(_responder, port_path, value); - om->event_queue()->push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_stamped(new SetPortValueEvent(_responder, timestamp, port_path, value)); } @@ -243,8 +245,8 @@ QueuedEngineInterface::set_port_value(const string& port_path, uint32_t voice, float value) { - SetPortValueEvent* ev = new SetPortValueEvent(_responder, voice, port_path, value); - om->event_queue()->push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_stamped(new SetPortValueEvent(_responder, timestamp, voice, port_path, value)); } @@ -252,8 +254,8 @@ void QueuedEngineInterface::set_port_value_queued(const string& port_path, float value) { - SetPortValueQueuedEvent* ev = new SetPortValueQueuedEvent(_responder, port_path, value); - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new SetPortValueQueuedEvent(_responder, timestamp, port_path, value)); } @@ -262,15 +264,16 @@ QueuedEngineInterface::set_program(const string& node_path, uint32_t bank, uint32_t program) { - push(new DSSIProgramEvent(_responder, node_path, bank, program)); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new DSSIProgramEvent(_responder, timestamp, node_path, bank, program)); } void QueuedEngineInterface::midi_learn(const string& node_path) { - MidiLearnEvent* ev = new MidiLearnEvent(_responder, node_path); - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new MidiLearnEvent(_responder, timestamp, node_path)); } @@ -279,10 +282,8 @@ QueuedEngineInterface::set_metadata(const string& path, const string& predicate, const string& value) { - SetMetadataEvent* ev = new SetMetadataEvent(_responder, - path, predicate, value); - - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new SetMetadataEvent(_responder, timestamp, path, predicate, value)); } @@ -291,32 +292,32 @@ QueuedEngineInterface::set_metadata(const string& path, void QueuedEngineInterface::ping() { - PingQueuedEvent* ev = new PingQueuedEvent(_responder); - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new PingQueuedEvent(_responder, timestamp)); } void QueuedEngineInterface::request_port_value(const string& port_path) { - RequestPortValueEvent* ev = new RequestPortValueEvent(_responder, port_path); - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new RequestPortValueEvent(_responder, timestamp, port_path)); } void QueuedEngineInterface::request_plugins() { - RequestPluginsEvent* ev = new RequestPluginsEvent(_responder); - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new RequestPluginsEvent(_responder, timestamp)); } void QueuedEngineInterface::request_all_objects() { - RequestAllObjectsEvent* ev = new RequestAllObjectsEvent(_responder); - push(ev); + const samplecount timestamp = om->audio_driver()->time_stamp(); + push_queued(new RequestAllObjectsEvent(_responder, timestamp)); } diff --git a/src/libs/engine/QueuedEngineInterface.h b/src/libs/engine/QueuedEngineInterface.h index 12afcb65..1292623b 100644 --- a/src/libs/engine/QueuedEngineInterface.h +++ b/src/libs/engine/QueuedEngineInterface.h @@ -21,6 +21,7 @@ #include <string> #include <memory> #include "util/CountedPtr.h" +#include "interface/EngineInterface.h" #include "interface/ClientInterface.h" #include "interface/ClientKey.h" #include "QueuedEventSource.h" @@ -31,6 +32,7 @@ namespace Om { using Shared::ClientKey; using Shared::ClientInterface; +using Shared::EngineInterface; /** A queued (preprocessed) event source / interface. @@ -53,10 +55,10 @@ using Shared::ClientInterface; * events and get pushed directly into the realtime event queue. Should that * be separated into a different interface/client? */ -class QueuedEngineInterface : public Om::QueuedEventSource +class QueuedEngineInterface : public Om::QueuedEventSource, public EngineInterface { public: - QueuedEngineInterface(size_t queue_size); + QueuedEngineInterface(size_t queued_size, size_t stamped_size); virtual ~QueuedEngineInterface() {} virtual void set_responder(CountedPtr<Responder> responder); diff --git a/src/libs/engine/QueuedEvent.h b/src/libs/engine/QueuedEvent.h index d5cd9701..a46e0376 100644 --- a/src/libs/engine/QueuedEvent.h +++ b/src/libs/engine/QueuedEvent.h @@ -45,39 +45,44 @@ public: /** Process this event into a realtime-suitable event. */ virtual void pre_process() { - assert(m_pre_processed == false); - m_pre_processed = true; + assert(_pre_processed == false); + _pre_processed = true; } virtual void execute(samplecount offset) { - assert(m_pre_processed); + assert(_pre_processed); Event::execute(offset); } virtual void post_process() {} /** If this event blocks the prepare phase of other slow events */ - bool is_blocking() { return m_blocking; } + bool is_blocking() { return _blocking; } - bool is_prepared() { return m_pre_processed; } + bool is_prepared() { return _pre_processed; } protected: // Prevent copies QueuedEvent(const QueuedEvent& copy); QueuedEvent& operator=(const QueuedEvent&); - QueuedEvent(CountedPtr<Responder> responder, bool blocking = false, QueuedEventSource* source=NULL) - : Event(responder), m_pre_processed(false), m_blocking(blocking), m_source(source) + QueuedEvent(CountedPtr<Responder> responder, + samplecount timestamp, + bool blocking = false, + QueuedEventSource* source = NULL) + : Event(responder, timestamp) + , _pre_processed(false), _blocking(blocking), _source(source) {} // NULL event base (for internal events only!) QueuedEvent() - : Event(), m_pre_processed(false), m_blocking(false), m_source(NULL) + : Event(NULL, 0) + , _pre_processed(false), _blocking(false), _source(NULL) {} - bool m_pre_processed; - bool m_blocking; - QueuedEventSource* m_source; + bool _pre_processed; + bool _blocking; + QueuedEventSource* _source; }; diff --git a/src/libs/engine/QueuedEventSource.cpp b/src/libs/engine/QueuedEventSource.cpp index 8254f3c8..ba05a0c1 100644 --- a/src/libs/engine/QueuedEventSource.cpp +++ b/src/libs/engine/QueuedEventSource.cpp @@ -24,12 +24,13 @@ using std::cout; using std::cerr; using std::endl; namespace Om { -QueuedEventSource::QueuedEventSource(size_t size) +QueuedEventSource::QueuedEventSource(size_t queued_size, size_t stamped_size) : _front(0), _back(0), _prepared_back(0), - _size(size+1), - _blocking_semaphore(0) + _size(queued_size+1), + _blocking_semaphore(0), + _stamped_queue(stamped_size) { _events = (QueuedEvent**)calloc(_size, sizeof(QueuedEvent*)); @@ -39,7 +40,7 @@ QueuedEventSource::QueuedEventSource(size_t size) QueuedEventSource::~QueuedEventSource() { - stop(); + Thread::stop(); free(_events); } @@ -48,7 +49,7 @@ QueuedEventSource::~QueuedEventSource() /** Push an unprepared event onto the queue. */ void -QueuedEventSource::push(QueuedEvent* const ev) +QueuedEventSource::push_queued(QueuedEvent* const ev) { assert(!ev->is_prepared()); @@ -58,21 +59,30 @@ QueuedEventSource::push(QueuedEvent* const ev) } else { _events[_back] = ev; _back = (_back + 1) % _size; - signal(); + whip(); } } -/** Pops the prepared event at the front of the queue, if it exists. +void +QueuedEventSource::push_stamped(Event* const ev) +{ + _stamped_queue.push(ev); +} + +/** Pops the prepared event at the front of the prepare queue, if it exists. * * This method will only pop events that have been prepared, and are * stamped before the time passed. In other words, it may return NULL * even if there are events pending in the queue. The events returned are * actually QueuedEvents, but after this they are "normal" events and the - * engine deals with them just like a realtime in-band event. + * engine deals with them just like a realtime in-band event. The engine will + * not use the timestamps of the returned events in any way, since it is free + * to execute these non-time-stamped events whenever it wants (at whatever rate + * it wants). */ Event* -QueuedEventSource::pop_earliest_before(const samplecount time) +QueuedEventSource::pop_earliest_queued_before(const samplecount time) { QueuedEvent* const front_event = _events[_front]; @@ -102,18 +112,19 @@ QueuedEventSource::unblock() } +/** Pre-process a single event */ void -QueuedEventSource::_signalled() +QueuedEventSource::_whipped() { QueuedEvent* const ev = _events[_prepared_back]; - assert(ev != NULL); - + + assert(ev); if (ev == NULL) { cerr << "[QueuedEventSource] ERROR: Signalled, but event is NULL." << endl; return; } - assert(ev != NULL); + assert(ev); assert(!ev->is_prepared()); ev->pre_process(); diff --git a/src/libs/engine/QueuedEventSource.h b/src/libs/engine/QueuedEventSource.h index c3e6904a..9d450a27 100644 --- a/src/libs/engine/QueuedEventSource.h +++ b/src/libs/engine/QueuedEventSource.h @@ -21,12 +21,13 @@ #include <pthread.h> #include "types.h" #include "util/Semaphore.h" +#include "util/Queue.h" #include "Slave.h" +#include "Event.h" #include "EventSource.h" namespace Om { -class Event; class QueuedEvent; @@ -35,28 +36,32 @@ class QueuedEvent; * Implemented as a deque (ringbuffer) in a circular array. Pushing and * popping are threadsafe, as long as a single thread pushes and a single * thread pops (ie this data structure is threadsafe, but the push and pop - * methods themselves are not). + * methods themselves are not). Creating an instance of this class spawns + * a pre-processing thread to prepare queued events. * * This class is it's own slave. :) */ class QueuedEventSource : public EventSource, protected Slave { public: - QueuedEventSource(size_t size); + QueuedEventSource(size_t queued_size, size_t stamped_size); ~QueuedEventSource(); - void start() { Thread::start(); } - void stop() { Thread::stop(); } + void activate() { Slave::start(); } + void deactivate() { Slave::stop(); } - Event* pop_earliest_before(const samplecount time); + Event* pop_earliest_queued_before(const samplecount time); + inline Event* pop_earliest_stamped_before(const samplecount time); void unblock(); protected: - void push(QueuedEvent* const ev); + void push_queued(QueuedEvent* const ev); + void push_stamped(Event* const ev); + bool unprepared_events() { return (_prepared_back != _back); } - virtual void _signalled(); ///< Prepare 1 event + virtual void _whipped(); ///< Prepare 1 event private: // Prevent copies (undefined) @@ -66,15 +71,35 @@ private: // Note that it's crucially important which functions access which of these // variables, to maintain threadsafeness. + //(FIXME: make this a separate class?) + // 2-part queue for events that require pre-processing: size_t _front; ///< Front of queue size_t _back; ///< Back of entire queue (1 past index of back element) size_t _prepared_back; ///< Back of prepared section (1 past index of back prepared element) const size_t _size; QueuedEvent** _events; Semaphore _blocking_semaphore; + + /** Queue for timestamped events (no pre-processing). */ + Queue<Event*> _stamped_queue; }; +/** Pops the realtime (timestamped, not preprocessed) event off the realtime queue. + * + * Engine will use the sample timestamps of returned events directly and execute the + * event with sample accuracy. Timestamps in the past will be bumped forward to + * the beginning of the cycle (offset 0), when eg. skipped cycles occur. + */ +inline Event* +QueuedEventSource::pop_earliest_stamped_before(const samplecount time) +{ + if (!_stamped_queue.is_empty() && _stamped_queue.front()->time_stamp() < time) + return _stamped_queue.pop(); + return NULL; +} + + } // namespace Om #endif // QUEUEDEVENTSOURCE_H diff --git a/src/libs/engine/Slave.h b/src/libs/engine/Slave.h index e6cc8ed5..9b2b01bd 100644 --- a/src/libs/engine/Slave.h +++ b/src/libs/engine/Slave.h @@ -31,25 +31,26 @@ namespace Om { class Slave : public Thread { public: - Slave() : _semaphore(0) {} + Slave() : _whip(0) {} - inline void signal() { _semaphore.post(); } + /** Tell the slave to do whatever work it does. Realtime safe. */ + inline void whip() { _whip.post(); } protected: - virtual void _signalled() = 0; + virtual void _whipped() = 0; - Semaphore _semaphore; + Semaphore _whip; private: // Prevent copies Slave(const Slave&); Slave& operator=(const Slave&); - void _run() + inline void _run() { while (true) { - _semaphore.wait(); - _signalled(); + _whip.wait(); + _whipped(); } } }; diff --git a/src/libs/engine/events/ActivateEvent.cpp b/src/libs/engine/events/ActivateEvent.cpp index 716a0326..06dabddd 100644 --- a/src/libs/engine/events/ActivateEvent.cpp +++ b/src/libs/engine/events/ActivateEvent.cpp @@ -22,8 +22,8 @@ namespace Om { -ActivateEvent::ActivateEvent(CountedPtr<Responder> responder) -: QueuedEvent(responder) +ActivateEvent::ActivateEvent(CountedPtr<Responder> responder, samplecount timestamp) +: QueuedEvent(responder, timestamp) { } @@ -42,9 +42,9 @@ void ActivateEvent::post_process() { if (om != NULL) - m_responder->respond_ok(); + _responder->respond_ok(); else - m_responder->respond_error("Not ready to activate yet."); + _responder->respond_error("Not ready to activate yet."); } diff --git a/src/libs/engine/events/ActivateEvent.h b/src/libs/engine/events/ActivateEvent.h index 65831f05..a144fb88 100644 --- a/src/libs/engine/events/ActivateEvent.h +++ b/src/libs/engine/events/ActivateEvent.h @@ -29,7 +29,7 @@ namespace Om { class ActivateEvent : public QueuedEvent { public: - ActivateEvent(CountedPtr<Responder> responder); + ActivateEvent(CountedPtr<Responder> responder, samplecount timestamp); void pre_process(); void post_process(); diff --git a/src/libs/engine/events/AddNodeEvent.cpp b/src/libs/engine/events/AddNodeEvent.cpp index 1ad693dc..08011223 100644 --- a/src/libs/engine/events/AddNodeEvent.cpp +++ b/src/libs/engine/events/AddNodeEvent.cpp @@ -34,8 +34,8 @@ namespace Om { -AddNodeEvent::AddNodeEvent(CountedPtr<Responder> responder, const string& path, Plugin* plugin, bool poly) -: QueuedEvent(responder), +AddNodeEvent::AddNodeEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& path, Plugin* plugin, bool poly) +: QueuedEvent(responder, timestamp), m_path(path), m_plugin(plugin), m_poly(poly), @@ -107,17 +107,17 @@ AddNodeEvent::post_process() string msg; if (m_node_already_exists) { msg = string("Could not create node - ").append(m_path);// + " already exists."; - m_responder->respond_error(msg); + _responder->respond_error(msg); } else if (m_patch == NULL) { msg = "Could not find patch '" + m_path.parent() +"' for add_node."; - m_responder->respond_error(msg); + _responder->respond_error(msg); } else if (m_node == NULL) { msg = "Unable to load node "; msg.append(m_path).append(" (you're missing the plugin \"").append( m_plugin->lib_name()).append(":").append(m_plugin->plug_label()).append("\")");; - m_responder->respond_error(msg); + _responder->respond_error(msg); } else { - m_responder->respond_ok(); + _responder->respond_ok(); //om->client_broadcaster()->send_node_creation_messages(m_node); om->client_broadcaster()->send_node(m_node); } diff --git a/src/libs/engine/events/AddNodeEvent.h b/src/libs/engine/events/AddNodeEvent.h index eb02ddd5..cc5cc294 100644 --- a/src/libs/engine/events/AddNodeEvent.h +++ b/src/libs/engine/events/AddNodeEvent.h @@ -39,7 +39,7 @@ class Plugin; class AddNodeEvent : public QueuedEvent { public: - AddNodeEvent(CountedPtr<Responder> responder, const string& path, Plugin* plugin, bool poly); + AddNodeEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& path, Plugin* plugin, bool poly); ~AddNodeEvent(); void pre_process(); diff --git a/src/libs/engine/events/AddPortEvent.cpp b/src/libs/engine/events/AddPortEvent.cpp index 4c530227..ba7b28f8 100644 --- a/src/libs/engine/events/AddPortEvent.cpp +++ b/src/libs/engine/events/AddPortEvent.cpp @@ -37,8 +37,8 @@ namespace Om { -AddPortEvent::AddPortEvent(CountedPtr<Responder> responder, const string& path, const string& type, bool is_output) -: QueuedEvent(responder), +AddPortEvent::AddPortEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& path, const string& type, bool is_output) +: QueuedEvent(responder, timestamp), _path(path), _type(type), _is_output(is_output), @@ -124,9 +124,9 @@ AddPortEvent::post_process() { if (!_patch_port) { const string msg = string("Could not create port - ").append(_path); - m_responder->respond_error(msg); + _responder->respond_error(msg); } else { - m_responder->respond_ok(); + _responder->respond_ok(); om->client_broadcaster()->send_port(_patch_port); } } diff --git a/src/libs/engine/events/AddPortEvent.h b/src/libs/engine/events/AddPortEvent.h index 2ccf2f78..afc02a51 100644 --- a/src/libs/engine/events/AddPortEvent.h +++ b/src/libs/engine/events/AddPortEvent.h @@ -41,7 +41,7 @@ class DriverPort; class AddPortEvent : public QueuedEvent { public: - AddPortEvent(CountedPtr<Responder> responder, const string& path, const string& type, bool is_output); + AddPortEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& path, const string& type, bool is_output); void pre_process(); void execute(samplecount offset); diff --git a/src/libs/engine/events/AllNotesOffEvent.cpp b/src/libs/engine/events/AllNotesOffEvent.cpp index ae411ab9..4fe6a1d2 100644 --- a/src/libs/engine/events/AllNotesOffEvent.cpp +++ b/src/libs/engine/events/AllNotesOffEvent.cpp @@ -25,8 +25,8 @@ namespace Om { /** Note off with patch explicitly passed - triggered by MIDI. */ -AllNotesOffEvent::AllNotesOffEvent(CountedPtr<Responder> responder, Patch* patch) -: Event(responder), +AllNotesOffEvent::AllNotesOffEvent(CountedPtr<Responder> responder, samplecount timestamp, Patch* patch) +: Event(responder, timestamp), m_patch(patch) { } @@ -34,8 +34,8 @@ AllNotesOffEvent::AllNotesOffEvent(CountedPtr<Responder> responder, Patch* patch /** Note off event with lookup - triggered by OSC. */ -AllNotesOffEvent::AllNotesOffEvent(CountedPtr<Responder> responder, const string& patch_path) -: Event(responder), +AllNotesOffEvent::AllNotesOffEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& patch_path) +: Event(responder, timestamp), m_patch(NULL), m_patch_path(patch_path) { @@ -58,7 +58,7 @@ void AllNotesOffEvent::post_process() { if (m_patch != NULL) - m_responder->respond_ok(); + _responder->respond_ok(); } diff --git a/src/libs/engine/events/AllNotesOffEvent.h b/src/libs/engine/events/AllNotesOffEvent.h index 51d33b26..dc6aeb90 100644 --- a/src/libs/engine/events/AllNotesOffEvent.h +++ b/src/libs/engine/events/AllNotesOffEvent.h @@ -33,8 +33,8 @@ class Patch; class AllNotesOffEvent : public Event { public: - AllNotesOffEvent(CountedPtr<Responder> responder, Patch* patch); - AllNotesOffEvent(CountedPtr<Responder> responder, const string& patch_path); + AllNotesOffEvent(CountedPtr<Responder> responder, samplecount timestamp, Patch* patch); + AllNotesOffEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& patch_path); void execute(samplecount offset); void post_process(); diff --git a/src/libs/engine/events/ClearPatchEvent.cpp b/src/libs/engine/events/ClearPatchEvent.cpp index 1f60a5a7..e72e554a 100644 --- a/src/libs/engine/events/ClearPatchEvent.cpp +++ b/src/libs/engine/events/ClearPatchEvent.cpp @@ -31,7 +31,7 @@ namespace Om { -ClearPatchEvent::ClearPatchEvent(CountedPtr<Responder> responder, const string& patch_path) +ClearPatchEvent::ClearPatchEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& patch_path) : QueuedEvent(responder, true), m_patch_path(patch_path), m_patch(NULL), @@ -100,13 +100,13 @@ ClearPatchEvent::post_process() assert(m_patch->connections().size() == 0); // Reply - m_responder->respond_ok(); + _responder->respond_ok(); om->client_broadcaster()->send_patch_cleared(m_patch_path); } else { - m_responder->respond_error(string("Patch ") + m_patch_path + " not found"); + _responder->respond_error(string("Patch ") + m_patch_path + " not found"); } - m_source->unblock(); + _source->unblock(); } diff --git a/src/libs/engine/events/ClearPatchEvent.h b/src/libs/engine/events/ClearPatchEvent.h index d0b17fe0..88effdce 100644 --- a/src/libs/engine/events/ClearPatchEvent.h +++ b/src/libs/engine/events/ClearPatchEvent.h @@ -35,7 +35,7 @@ class Patch; class ClearPatchEvent : public QueuedEvent { public: - ClearPatchEvent(CountedPtr<Responder> responder, const string& patch_path); + ClearPatchEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& patch_path); void pre_process(); void execute(samplecount offset); diff --git a/src/libs/engine/events/ConnectionEvent.cpp b/src/libs/engine/events/ConnectionEvent.cpp index 0faff865..17e43147 100644 --- a/src/libs/engine/events/ConnectionEvent.cpp +++ b/src/libs/engine/events/ConnectionEvent.cpp @@ -17,6 +17,7 @@ #include "ConnectionEvent.h" #include <string> #include "Responder.h" +#include "types.h" #include "Om.h" #include "OmApp.h" #include "TypedConnection.h" @@ -36,8 +37,8 @@ namespace Om { //// ConnectionEvent //// -ConnectionEvent::ConnectionEvent(CountedPtr<Responder> responder, const string& src_port_path, const string& dst_port_path) -: QueuedEvent(responder), +ConnectionEvent::ConnectionEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& src_port_path, const string& dst_port_path) +: QueuedEvent(responder, timestamp), m_src_port_path(src_port_path), m_dst_port_path(dst_port_path), m_patch(NULL), @@ -104,10 +105,10 @@ ConnectionEvent::pre_process() // Create the typed event to actually do the work const DataType type = m_src_port->type(); if (type == DataType::FLOAT) { - m_typed_event = new TypedConnectionEvent<sample>(m_responder, + m_typed_event = new TypedConnectionEvent<sample>(_responder, _time_stamp, dynamic_cast<OutputPort<sample>*>(m_src_port), dynamic_cast<InputPort<sample>*>(m_dst_port)); } else if (type == DataType::MIDI) { - m_typed_event = new TypedConnectionEvent<MidiMessage>(m_responder, + m_typed_event = new TypedConnectionEvent<MidiMessage>(_responder, _time_stamp, dynamic_cast<OutputPort<MidiMessage>*>(m_src_port), dynamic_cast<InputPort<MidiMessage>*>(m_dst_port)); } else { m_error = TYPE_MISMATCH; @@ -140,7 +141,7 @@ ConnectionEvent::post_process() // FIXME: better error messages string msg = "Unable to make connection "; msg.append(m_src_port_path + " -> " + m_dst_port_path); - m_responder->respond_error(msg); + _responder->respond_error(msg); } } @@ -150,8 +151,8 @@ ConnectionEvent::post_process() template <typename T> -TypedConnectionEvent<T>::TypedConnectionEvent(CountedPtr<Responder> responder, OutputPort<T>* src_port, InputPort<T>* dst_port) -: QueuedEvent(responder), +TypedConnectionEvent<T>::TypedConnectionEvent(CountedPtr<Responder> responder, samplecount timestamp, OutputPort<T>* src_port, InputPort<T>* dst_port) +: QueuedEvent(responder, timestamp), m_src_port(src_port), m_dst_port(dst_port), m_patch(NULL), @@ -248,11 +249,11 @@ TypedConnectionEvent<T>::post_process() if (m_succeeded) { assert(m_connection != NULL); - m_responder->respond_ok(); + _responder->respond_ok(); om->client_broadcaster()->send_connection(m_connection); } else { - m_responder->respond_error("Unable to make connection."); + _responder->respond_error("Unable to make connection."); } } diff --git a/src/libs/engine/events/ConnectionEvent.h b/src/libs/engine/events/ConnectionEvent.h index 23bedcef..ea380130 100644 --- a/src/libs/engine/events/ConnectionEvent.h +++ b/src/libs/engine/events/ConnectionEvent.h @@ -46,7 +46,7 @@ template <typename T> class TypedConnectionEvent; // helper, defined below class ConnectionEvent : public QueuedEvent { public: - ConnectionEvent(CountedPtr<Responder> responder, const string& src_port_path, const string& dst_port_path); + ConnectionEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& src_port_path, const string& dst_port_path); ~ConnectionEvent(); void pre_process(); @@ -80,7 +80,7 @@ template <typename T> class TypedConnectionEvent : public QueuedEvent { public: - TypedConnectionEvent(CountedPtr<Responder> responder, OutputPort<T>* src_port, InputPort<T>* dst_port); + TypedConnectionEvent(CountedPtr<Responder> responder, samplecount timestamp, OutputPort<T>* src_port, InputPort<T>* dst_port); void pre_process(); void execute(samplecount offset); diff --git a/src/libs/engine/events/CreatePatchEvent.cpp b/src/libs/engine/events/CreatePatchEvent.cpp index 61bd2827..56720b06 100644 --- a/src/libs/engine/events/CreatePatchEvent.cpp +++ b/src/libs/engine/events/CreatePatchEvent.cpp @@ -31,8 +31,8 @@ namespace Om { -CreatePatchEvent::CreatePatchEvent(CountedPtr<Responder> responder, const string& path, int poly) -: QueuedEvent(responder), +CreatePatchEvent::CreatePatchEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& path, int poly) +: QueuedEvent(responder, timestamp), m_path(path), m_patch(NULL), m_parent(NULL), @@ -116,10 +116,10 @@ CreatePatchEvent::execute(samplecount offset) void CreatePatchEvent::post_process() { - if (m_responder.get()) { + if (_responder.get()) { if (m_error == NO_ERROR) { - m_responder->respond_ok(); + _responder->respond_ok(); // Don't want to send nodes that have been added since prepare() //om->client_broadcaster()->send_node_creation_messages(m_patch); @@ -130,17 +130,17 @@ CreatePatchEvent::post_process() } else if (m_error == OBJECT_EXISTS) { string msg = "Unable to create patch: "; msg += m_path += " already exists."; - m_responder->respond_error(msg); + _responder->respond_error(msg); } else if (m_error == PARENT_NOT_FOUND) { string msg = "Unable to create patch: Parent "; msg += m_path.parent() += " not found."; - m_responder->respond_error(msg); + _responder->respond_error(msg); } else if (m_error == INVALID_POLY) { string msg = "Unable to create patch "; msg.append(m_path).append(": ").append("Invalid polyphony respondered."); - m_responder->respond_error(msg); + _responder->respond_error(msg); } else { - m_responder->respond_error("Unable to load patch."); + _responder->respond_error("Unable to load patch."); } } } diff --git a/src/libs/engine/events/CreatePatchEvent.h b/src/libs/engine/events/CreatePatchEvent.h index 4583efd9..f83def15 100644 --- a/src/libs/engine/events/CreatePatchEvent.h +++ b/src/libs/engine/events/CreatePatchEvent.h @@ -39,7 +39,7 @@ class Plugin; class CreatePatchEvent : public QueuedEvent { public: - CreatePatchEvent(CountedPtr<Responder> responder, const string& path, int poly); + CreatePatchEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& path, int poly); void pre_process(); void execute(samplecount offset); diff --git a/src/libs/engine/events/DSSIConfigureEvent.cpp b/src/libs/engine/events/DSSIConfigureEvent.cpp index a16ebe4c..9e045c9c 100644 --- a/src/libs/engine/events/DSSIConfigureEvent.cpp +++ b/src/libs/engine/events/DSSIConfigureEvent.cpp @@ -25,8 +25,8 @@ namespace Om { -DSSIConfigureEvent::DSSIConfigureEvent(CountedPtr<Responder> responder, const string& node_path, const string& key, const string& val) -: QueuedEvent(responder), +DSSIConfigureEvent::DSSIConfigureEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& node_path, const string& key, const string& val) +: QueuedEvent(responder, timestamp), m_node_path(node_path), m_key(key), m_val(val), diff --git a/src/libs/engine/events/DSSIConfigureEvent.h b/src/libs/engine/events/DSSIConfigureEvent.h index f8ef2aa6..19baf7d6 100644 --- a/src/libs/engine/events/DSSIConfigureEvent.h +++ b/src/libs/engine/events/DSSIConfigureEvent.h @@ -30,7 +30,7 @@ namespace Om { class DSSIConfigureEvent : public QueuedEvent { public: - DSSIConfigureEvent(CountedPtr<Responder> responder, const string& node_path, const string& key, const string& val); + DSSIConfigureEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& node_path, const string& key, const string& val); void pre_process(); void execute(samplecount offset); diff --git a/src/libs/engine/events/DSSIControlEvent.cpp b/src/libs/engine/events/DSSIControlEvent.cpp index f326ca72..fc7dc6b5 100644 --- a/src/libs/engine/events/DSSIControlEvent.cpp +++ b/src/libs/engine/events/DSSIControlEvent.cpp @@ -24,8 +24,8 @@ namespace Om { -DSSIControlEvent::DSSIControlEvent(CountedPtr<Responder> responder, const string& node_path, int port_num, sample val) -: QueuedEvent(responder), +DSSIControlEvent::DSSIControlEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& node_path, int port_num, sample val) +: QueuedEvent(responder, timestamp), m_node_path(node_path), m_port_num(port_num), m_val(val), diff --git a/src/libs/engine/events/DSSIControlEvent.h b/src/libs/engine/events/DSSIControlEvent.h index de636445..95048d0a 100644 --- a/src/libs/engine/events/DSSIControlEvent.h +++ b/src/libs/engine/events/DSSIControlEvent.h @@ -32,7 +32,7 @@ namespace Om { class DSSIControlEvent : public QueuedEvent { public: - DSSIControlEvent(CountedPtr<Responder> responder, const string& node_path, int port_num, sample val); + DSSIControlEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& node_path, int port_num, sample val); void pre_process(); void execute(samplecount offset); diff --git a/src/libs/engine/events/DSSIProgramEvent.cpp b/src/libs/engine/events/DSSIProgramEvent.cpp index 9a869c73..3f64d3d2 100644 --- a/src/libs/engine/events/DSSIProgramEvent.cpp +++ b/src/libs/engine/events/DSSIProgramEvent.cpp @@ -29,8 +29,8 @@ using std::cout; using std::cerr; using std::endl; namespace Om { -DSSIProgramEvent::DSSIProgramEvent(CountedPtr<Responder> responder, const string& node_path, int bank, int program) -: QueuedEvent(responder), +DSSIProgramEvent::DSSIProgramEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& node_path, int bank, int program) +: QueuedEvent(responder, timestamp), m_node_path(node_path), m_bank(bank), m_program(program), diff --git a/src/libs/engine/events/DSSIProgramEvent.h b/src/libs/engine/events/DSSIProgramEvent.h index 49207ca1..9868d2ce 100644 --- a/src/libs/engine/events/DSSIProgramEvent.h +++ b/src/libs/engine/events/DSSIProgramEvent.h @@ -30,7 +30,7 @@ namespace Om { class DSSIProgramEvent : public QueuedEvent { public: - DSSIProgramEvent(CountedPtr<Responder> responder, const string& node_path, int bank, int program); + DSSIProgramEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& node_path, int bank, int program); void pre_process(); void execute(samplecount offset); diff --git a/src/libs/engine/events/DSSIUpdateEvent.cpp b/src/libs/engine/events/DSSIUpdateEvent.cpp index d32466d4..8cb7e4bc 100644 --- a/src/libs/engine/events/DSSIUpdateEvent.cpp +++ b/src/libs/engine/events/DSSIUpdateEvent.cpp @@ -28,8 +28,8 @@ using std::cerr; using std::endl; namespace Om { -DSSIUpdateEvent::DSSIUpdateEvent(CountedPtr<Responder> responder, const string& path, const string& url) -: QueuedEvent(responder), +DSSIUpdateEvent::DSSIUpdateEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& path, const string& url) +: QueuedEvent(responder, timestamp), m_path(path), m_url(url), m_node(NULL) diff --git a/src/libs/engine/events/DSSIUpdateEvent.h b/src/libs/engine/events/DSSIUpdateEvent.h index 25a77f02..a48cd7b4 100644 --- a/src/libs/engine/events/DSSIUpdateEvent.h +++ b/src/libs/engine/events/DSSIUpdateEvent.h @@ -36,7 +36,7 @@ class DSSINode; class DSSIUpdateEvent : public QueuedEvent { public: - DSSIUpdateEvent(CountedPtr<Responder> responder, const string& path, const string& url); + DSSIUpdateEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& path, const string& url); void pre_process(); void execute(samplecount offset); diff --git a/src/libs/engine/events/DeactivateEvent.cpp b/src/libs/engine/events/DeactivateEvent.cpp index 22434cbe..fef3ece6 100644 --- a/src/libs/engine/events/DeactivateEvent.cpp +++ b/src/libs/engine/events/DeactivateEvent.cpp @@ -22,8 +22,8 @@ namespace Om { -DeactivateEvent::DeactivateEvent(CountedPtr<Responder> responder) -: QueuedEvent(responder) +DeactivateEvent::DeactivateEvent(CountedPtr<Responder> responder, samplecount timestamp) +: QueuedEvent(responder, timestamp) { } @@ -45,7 +45,7 @@ DeactivateEvent::execute(samplecount offset) void DeactivateEvent::post_process() { - m_responder->respond_ok(); + _responder->respond_ok(); om->deactivate(); } diff --git a/src/libs/engine/events/DeactivateEvent.h b/src/libs/engine/events/DeactivateEvent.h index 35c96e78..7e540ba8 100644 --- a/src/libs/engine/events/DeactivateEvent.h +++ b/src/libs/engine/events/DeactivateEvent.h @@ -29,7 +29,7 @@ namespace Om { class DeactivateEvent : public QueuedEvent { public: - DeactivateEvent(CountedPtr<Responder> responder); + DeactivateEvent(CountedPtr<Responder> responder, samplecount timestamp); void pre_process(); void execute(samplecount offset); diff --git a/src/libs/engine/events/DestroyEvent.cpp b/src/libs/engine/events/DestroyEvent.cpp index 383f1d34..fec3f3c0 100644 --- a/src/libs/engine/events/DestroyEvent.cpp +++ b/src/libs/engine/events/DestroyEvent.cpp @@ -35,7 +35,7 @@ namespace Om { -DestroyEvent::DestroyEvent(CountedPtr<Responder> responder, QueuedEventSource* source, const string& path, bool lock_mutex) +DestroyEvent::DestroyEvent(CountedPtr<Responder> responder, samplecount timestamp, QueuedEventSource* source, const string& path, bool lock_mutex) : QueuedEvent(responder, true, source), m_path(path), m_node(NULL), @@ -48,7 +48,7 @@ DestroyEvent::DestroyEvent(CountedPtr<Responder> responder, QueuedEventSource* s } -DestroyEvent::DestroyEvent(CountedPtr<Responder> responder, Node* node, bool lock_mutex) +DestroyEvent::DestroyEvent(CountedPtr<Responder> responder, samplecount timestamp, Node* node, bool lock_mutex) : QueuedEvent(responder, true), m_path(node->path()), m_node(node), @@ -139,17 +139,17 @@ DestroyEvent::execute(samplecount offset) void DestroyEvent::post_process() { - assert(m_source); - m_source->unblock(); + assert(_source); + _source->unblock(); if (m_node == NULL) { if (m_path == "/") - m_responder->respond_error("You can not destroy the root patch (/)"); + _responder->respond_error("You can not destroy the root patch (/)"); else - m_responder->respond_error("Could not find node to destroy"); + _responder->respond_error("Could not find node to destroy"); } else if (m_patch_listnode != NULL) { m_node->deactivate(); - m_responder->respond_ok(); + _responder->respond_ok(); if (m_disconnect_event != NULL) m_disconnect_event->post_process(); if (m_parent_disconnect_event != NULL) @@ -158,7 +158,7 @@ DestroyEvent::post_process() om->maid()->push(m_patch_listnode); om->maid()->push(m_node); } else { - m_responder->respond_error("Unable to destroy object"); + _responder->respond_error("Unable to destroy object"); } } diff --git a/src/libs/engine/events/DestroyEvent.h b/src/libs/engine/events/DestroyEvent.h index 1f26ed90..1fcbd171 100644 --- a/src/libs/engine/events/DestroyEvent.h +++ b/src/libs/engine/events/DestroyEvent.h @@ -44,8 +44,8 @@ class DisconnectPortEvent; class DestroyEvent : public QueuedEvent { public: - DestroyEvent(CountedPtr<Responder> responder, QueuedEventSource* source, const string& path, bool lock_mutex = true); - DestroyEvent(CountedPtr<Responder> responder, Node* node, bool lock_mutex = true); + DestroyEvent(CountedPtr<Responder> responder, samplecount timestamp, QueuedEventSource* source, const string& path, bool lock_mutex = true); + DestroyEvent(CountedPtr<Responder> responder, samplecount timestamp, Node* node, bool lock_mutex = true); ~DestroyEvent(); void pre_process(); diff --git a/src/libs/engine/events/DisablePatchEvent.cpp b/src/libs/engine/events/DisablePatchEvent.cpp index c896d943..67f84fa2 100644 --- a/src/libs/engine/events/DisablePatchEvent.cpp +++ b/src/libs/engine/events/DisablePatchEvent.cpp @@ -27,8 +27,8 @@ namespace Om { -DisablePatchEvent::DisablePatchEvent(CountedPtr<Responder> responder, const string& patch_path) -: QueuedEvent(responder), +DisablePatchEvent::DisablePatchEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& patch_path) +: QueuedEvent(responder, timestamp), m_patch_path(patch_path), m_patch(NULL) { @@ -58,10 +58,10 @@ void DisablePatchEvent::post_process() { if (m_patch != NULL) { - m_responder->respond_ok(); + _responder->respond_ok(); om->client_broadcaster()->send_patch_disable(m_patch_path); } else { - m_responder->respond_error(string("Patch ") + m_patch_path + " not found"); + _responder->respond_error(string("Patch ") + m_patch_path + " not found"); } } diff --git a/src/libs/engine/events/DisablePatchEvent.h b/src/libs/engine/events/DisablePatchEvent.h index 708e269b..6df64e40 100644 --- a/src/libs/engine/events/DisablePatchEvent.h +++ b/src/libs/engine/events/DisablePatchEvent.h @@ -34,7 +34,7 @@ class Patch; class DisablePatchEvent : public QueuedEvent { public: - DisablePatchEvent(CountedPtr<Responder> responder, const string& patch_path); + DisablePatchEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& patch_path); void pre_process(); void execute(samplecount offset); diff --git a/src/libs/engine/events/DisconnectNodeEvent.cpp b/src/libs/engine/events/DisconnectNodeEvent.cpp index 22c2459e..5f2a483a 100644 --- a/src/libs/engine/events/DisconnectNodeEvent.cpp +++ b/src/libs/engine/events/DisconnectNodeEvent.cpp @@ -39,8 +39,8 @@ using std::cerr; using std::endl; namespace Om { -DisconnectNodeEvent::DisconnectNodeEvent(CountedPtr<Responder> responder, const string& node_path) -: QueuedEvent(responder), +DisconnectNodeEvent::DisconnectNodeEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& node_path) +: QueuedEvent(responder, timestamp), m_node_path(node_path), m_patch(NULL), m_node(NULL), @@ -99,7 +99,8 @@ DisconnectNodeEvent::pre_process() for (ConnectionListIterator i = m_patch->connections().begin(); i != m_patch->connections().end(); ++i) { c = (*i); if ((c->src_port()->parent_node() == m_node || c->dst_port()->parent_node() == m_node) && !c->pending_disconnection()) { - DisconnectionEvent* ev = new DisconnectionEvent(CountedPtr<Responder>(new Responder()), c->src_port(), c->dst_port()); + DisconnectionEvent* ev = new DisconnectionEvent(CountedPtr<Responder>(new Responder()), _time_stamp, + c->src_port(), c->dst_port()); ev->pre_process(); m_disconnection_events.push_back(new ListNode<DisconnectionEvent*>(ev)); c->pending_disconnection(true); @@ -127,13 +128,13 @@ void DisconnectNodeEvent::post_process() { if (m_succeeded) { - if (m_responder) - m_responder->respond_ok(); + if (_responder) + _responder->respond_ok(); for (List<DisconnectionEvent*>::iterator i = m_disconnection_events.begin(); i != m_disconnection_events.end(); ++i) (*i)->post_process(); } else { - if (m_responder) - m_responder->respond_error("Unable to disconnect all ports."); + if (_responder) + _responder->respond_error("Unable to disconnect all ports."); } } diff --git a/src/libs/engine/events/DisconnectNodeEvent.h b/src/libs/engine/events/DisconnectNodeEvent.h index 40e6c086..31c32f2e 100644 --- a/src/libs/engine/events/DisconnectNodeEvent.h +++ b/src/libs/engine/events/DisconnectNodeEvent.h @@ -42,7 +42,7 @@ template <typename T> class OutputPort; class DisconnectNodeEvent : public QueuedEvent { public: - DisconnectNodeEvent(CountedPtr<Responder> responder, const string& node_path); + DisconnectNodeEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& node_path); DisconnectNodeEvent(Node* node); ~DisconnectNodeEvent(); diff --git a/src/libs/engine/events/DisconnectPortEvent.cpp b/src/libs/engine/events/DisconnectPortEvent.cpp index 2ec408d6..bfb238c6 100644 --- a/src/libs/engine/events/DisconnectPortEvent.cpp +++ b/src/libs/engine/events/DisconnectPortEvent.cpp @@ -39,8 +39,8 @@ using std::cerr; using std::endl; namespace Om { -DisconnectPortEvent::DisconnectPortEvent(CountedPtr<Responder> responder, const string& port_path) -: QueuedEvent(responder), +DisconnectPortEvent::DisconnectPortEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& port_path) +: QueuedEvent(responder, timestamp), m_port_path(port_path), m_patch(NULL), m_port(NULL), @@ -104,7 +104,8 @@ DisconnectPortEvent::pre_process() for (List<Connection*>::const_iterator i = m_patch->connections().begin(); i != m_patch->connections().end(); ++i) { c = (*i); if ((c->src_port() == m_port || c->dst_port() == m_port) && !c->pending_disconnection()) { - DisconnectionEvent* ev = new DisconnectionEvent(CountedPtr<Responder>(new Responder()), c->src_port(), c->dst_port()); + DisconnectionEvent* ev = new DisconnectionEvent(CountedPtr<Responder>(new Responder()), _time_stamp, + c->src_port(), c->dst_port()); ev->pre_process(); m_disconnection_events.push_back(new ListNode<DisconnectionEvent*>(ev)); c->pending_disconnection(true); @@ -132,11 +133,11 @@ void DisconnectPortEvent::post_process() { if (m_succeeded) { - m_responder->respond_ok(); + _responder->respond_ok(); for (List<DisconnectionEvent*>::iterator i = m_disconnection_events.begin(); i != m_disconnection_events.end(); ++i) (*i)->post_process(); } else { - m_responder->respond_error("Unable to disconnect port."); + _responder->respond_error("Unable to disconnect port."); } } diff --git a/src/libs/engine/events/DisconnectPortEvent.h b/src/libs/engine/events/DisconnectPortEvent.h index 82e0ef90..31113a63 100644 --- a/src/libs/engine/events/DisconnectPortEvent.h +++ b/src/libs/engine/events/DisconnectPortEvent.h @@ -43,7 +43,7 @@ using std::string; class DisconnectPortEvent : public QueuedEvent { public: - DisconnectPortEvent(CountedPtr<Responder> responder, const string& port_path); + DisconnectPortEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& port_path); DisconnectPortEvent(Port* port); ~DisconnectPortEvent(); diff --git a/src/libs/engine/events/DisconnectionEvent.cpp b/src/libs/engine/events/DisconnectionEvent.cpp index 3d7a16d8..7bd5edd9 100644 --- a/src/libs/engine/events/DisconnectionEvent.cpp +++ b/src/libs/engine/events/DisconnectionEvent.cpp @@ -36,8 +36,8 @@ namespace Om { //// DisconnectionEvent //// -DisconnectionEvent::DisconnectionEvent(CountedPtr<Responder> responder, const string& src_port_path, const string& dst_port_path) -: QueuedEvent(responder), +DisconnectionEvent::DisconnectionEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& src_port_path, const string& dst_port_path) +: QueuedEvent(responder, timestamp), m_src_port_path(src_port_path), m_dst_port_path(dst_port_path), m_patch(NULL), @@ -50,8 +50,8 @@ DisconnectionEvent::DisconnectionEvent(CountedPtr<Responder> responder, const st } -DisconnectionEvent::DisconnectionEvent(CountedPtr<Responder> responder, Port* const src_port, Port* const dst_port) -: QueuedEvent(responder), +DisconnectionEvent::DisconnectionEvent(CountedPtr<Responder> responder, samplecount timestamp, Port* const src_port, Port* const dst_port) +: QueuedEvent(responder, timestamp), m_src_port_path(src_port->path()), m_dst_port_path(dst_port->path()), m_patch(src_port->parent_node()->parent_patch()), @@ -113,10 +113,10 @@ DisconnectionEvent::pre_process() // Create the typed event to actually do the work const DataType type = m_src_port->type(); if (type == DataType::FLOAT) { - m_typed_event = new TypedDisconnectionEvent<sample>(m_responder, + m_typed_event = new TypedDisconnectionEvent<sample>(_responder, _time_stamp, dynamic_cast<OutputPort<sample>*>(m_src_port), dynamic_cast<InputPort<sample>*>(m_dst_port)); } else if (type == DataType::MIDI) { - m_typed_event = new TypedDisconnectionEvent<MidiMessage>(m_responder, + m_typed_event = new TypedDisconnectionEvent<MidiMessage>(_responder, _time_stamp, dynamic_cast<OutputPort<MidiMessage>*>(m_src_port), dynamic_cast<InputPort<MidiMessage>*>(m_dst_port)); } else { m_error = TYPE_MISMATCH; @@ -150,7 +150,7 @@ DisconnectionEvent::post_process() // FIXME: better error messages string msg = "Unable to disconnect "; msg.append(m_src_port_path + " -> " + m_dst_port_path); - m_responder->respond_error(msg); + _responder->respond_error(msg); } } @@ -160,8 +160,8 @@ DisconnectionEvent::post_process() template <typename T> -TypedDisconnectionEvent<T>::TypedDisconnectionEvent(CountedPtr<Responder> responder, OutputPort<T>* src_port, InputPort<T>* dst_port) -: QueuedEvent(responder), +TypedDisconnectionEvent<T>::TypedDisconnectionEvent(CountedPtr<Responder> responder, samplecount timestamp, OutputPort<T>* src_port, InputPort<T>* dst_port) +: QueuedEvent(responder, timestamp), m_src_port(src_port), m_dst_port(dst_port), m_patch(NULL), @@ -270,11 +270,11 @@ TypedDisconnectionEvent<T>::post_process() { if (m_succeeded) { - m_responder->respond_ok(); + _responder->respond_ok(); om->client_broadcaster()->send_disconnection(m_src_port->path(), m_dst_port->path()); } else { - m_responder->respond_error("Unable to disconnect ports."); + _responder->respond_error("Unable to disconnect ports."); } } diff --git a/src/libs/engine/events/DisconnectionEvent.h b/src/libs/engine/events/DisconnectionEvent.h index 43b2d841..cf37976d 100644 --- a/src/libs/engine/events/DisconnectionEvent.h +++ b/src/libs/engine/events/DisconnectionEvent.h @@ -46,8 +46,8 @@ template <typename T> class TypedDisconnectionEvent; // helper, defined below class DisconnectionEvent : public QueuedEvent { public: - DisconnectionEvent(CountedPtr<Responder> responder, const string& src_port_path, const string& dst_port_path); - DisconnectionEvent(CountedPtr<Responder> responder, Port* const src_port, Port* const dst_port); + DisconnectionEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& src_port_path, const string& dst_port_path); + DisconnectionEvent(CountedPtr<Responder> responder, samplecount timestamp, Port* const src_port, Port* const dst_port); ~DisconnectionEvent(); void pre_process(); @@ -82,7 +82,7 @@ template <typename T> class TypedDisconnectionEvent : public QueuedEvent { public: - TypedDisconnectionEvent(CountedPtr<Responder> responder, OutputPort<T>* src_port, InputPort<T>* dst_port); + TypedDisconnectionEvent(CountedPtr<Responder> responder, samplecount timestamp, OutputPort<T>* src_port, InputPort<T>* dst_port); void pre_process(); void execute(samplecount offset); diff --git a/src/libs/engine/events/EnablePatchEvent.cpp b/src/libs/engine/events/EnablePatchEvent.cpp index eee50dac..7ce7dd27 100644 --- a/src/libs/engine/events/EnablePatchEvent.cpp +++ b/src/libs/engine/events/EnablePatchEvent.cpp @@ -26,8 +26,8 @@ namespace Om { -EnablePatchEvent::EnablePatchEvent(CountedPtr<Responder> responder, const string& patch_path) -: QueuedEvent(responder), +EnablePatchEvent::EnablePatchEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& patch_path) +: QueuedEvent(responder, timestamp), m_patch_path(patch_path), m_patch(NULL), m_process_order(NULL) @@ -70,10 +70,10 @@ void EnablePatchEvent::post_process() { if (m_patch != NULL) { - m_responder->respond_ok(); + _responder->respond_ok(); om->client_broadcaster()->send_patch_enable(m_patch_path); } else { - m_responder->respond_error(string("Patch ") + m_patch_path + " not found"); + _responder->respond_error(string("Patch ") + m_patch_path + " not found"); } } diff --git a/src/libs/engine/events/EnablePatchEvent.h b/src/libs/engine/events/EnablePatchEvent.h index 0c86a100..75b751aa 100644 --- a/src/libs/engine/events/EnablePatchEvent.h +++ b/src/libs/engine/events/EnablePatchEvent.h @@ -37,7 +37,7 @@ class Node; class EnablePatchEvent : public QueuedEvent { public: - EnablePatchEvent(CountedPtr<Responder> responder, const string& patch_path); + EnablePatchEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& patch_path); void pre_process(); void execute(samplecount offset); diff --git a/src/libs/engine/events/LashRestoreDoneEvent.h b/src/libs/engine/events/LashRestoreDoneEvent.h index ed3933a5..31713c4b 100644 --- a/src/libs/engine/events/LashRestoreDoneEvent.h +++ b/src/libs/engine/events/LashRestoreDoneEvent.h @@ -39,11 +39,11 @@ class Port; class LashRestoreDoneEvent : public QueuedEvent { public: - LashRestoreDoneEvent(CountedPtr<Responder> responder) : QueuedEvent(responder) {} + LashRestoreDoneEvent(CountedPtr<Responder> responder, samplecount timestamp) : QueuedEvent(responder, timestamp) {} void post_process() { - m_responder->respond_ok(); + _responder->respond_ok(); lash_driver->restore_finished(); } }; diff --git a/src/libs/engine/events/LoadPluginsEvent.cpp b/src/libs/engine/events/LoadPluginsEvent.cpp index 93099ef0..d1939a6b 100644 --- a/src/libs/engine/events/LoadPluginsEvent.cpp +++ b/src/libs/engine/events/LoadPluginsEvent.cpp @@ -20,23 +20,24 @@ #include "OmApp.h" #include "NodeFactory.h" +#include <iostream> +using std::cerr; + namespace Om { -LoadPluginsEvent::LoadPluginsEvent(CountedPtr<Responder> responder) -: QueuedEvent(responder) +LoadPluginsEvent::LoadPluginsEvent(CountedPtr<Responder> responder, samplecount timestamp) +: QueuedEvent(responder, timestamp) { + cerr << "LOADING PLUGINS\n"; + om->node_factory()->load_plugins(); } void LoadPluginsEvent::post_process() { - // Why is this done here and not in pre_process()??? - om->node_factory()->load_plugins(); - m_responder->respond_ok(); - - //cerr << "Load plugins post finished\n"; + _responder->respond_ok(); } diff --git a/src/libs/engine/events/LoadPluginsEvent.h b/src/libs/engine/events/LoadPluginsEvent.h index 10970cec..b17eb262 100644 --- a/src/libs/engine/events/LoadPluginsEvent.h +++ b/src/libs/engine/events/LoadPluginsEvent.h @@ -29,7 +29,7 @@ namespace Om { class LoadPluginsEvent : public QueuedEvent { public: - LoadPluginsEvent(CountedPtr<Responder> responder); + LoadPluginsEvent(CountedPtr<Responder> responder, samplecount timestamp); void post_process(); }; diff --git a/src/libs/engine/events/MidiLearnEvent.cpp b/src/libs/engine/events/MidiLearnEvent.cpp index cd9fd8f2..6c7c8613 100644 --- a/src/libs/engine/events/MidiLearnEvent.cpp +++ b/src/libs/engine/events/MidiLearnEvent.cpp @@ -38,8 +38,8 @@ MidiLearnResponseEvent::post_process() // MidiLearnEvent -MidiLearnEvent::MidiLearnEvent(CountedPtr<Responder> responder, const string& node_path) -: QueuedEvent(responder), +MidiLearnEvent::MidiLearnEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& node_path) +: QueuedEvent(responder, timestamp), m_node_path(node_path), m_node(NULL), m_response_event(NULL) @@ -51,7 +51,7 @@ void MidiLearnEvent::pre_process() { m_node = om->object_store()->find_node(m_node_path); - m_response_event = new MidiLearnResponseEvent(m_node_path + "/Controller Number"); + m_response_event = new MidiLearnResponseEvent(m_node_path + "/Controller_Number", _time_stamp); QueuedEvent::pre_process(); } @@ -74,11 +74,11 @@ void MidiLearnEvent::post_process() { if (m_node != NULL) { - m_responder->respond_ok(); + _responder->respond_ok(); } else { string msg = "Did not find node '"; msg.append(m_node_path).append("' for MIDI learn."); - m_responder->respond_error(msg); + _responder->respond_error(msg); } } diff --git a/src/libs/engine/events/MidiLearnEvent.h b/src/libs/engine/events/MidiLearnEvent.h index de0dfbe3..320b20c3 100644 --- a/src/libs/engine/events/MidiLearnEvent.h +++ b/src/libs/engine/events/MidiLearnEvent.h @@ -37,8 +37,8 @@ class ControlChangeEvent; class MidiLearnResponseEvent : public Event { public: - MidiLearnResponseEvent(const string& port_path) - : Event(CountedPtr<Responder>(NULL)), + MidiLearnResponseEvent(const string& port_path, samplecount timestamp) + : Event(NULL, timestamp), m_port_path(port_path), m_value(0.0f) {} @@ -64,7 +64,7 @@ private: class MidiLearnEvent : public QueuedEvent { public: - MidiLearnEvent(CountedPtr<Responder> responder, const string& node_path); + MidiLearnEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& node_path); void pre_process(); void execute(samplecount offset); diff --git a/src/libs/engine/events/NoteOffEvent.cpp b/src/libs/engine/events/NoteOffEvent.cpp index a84317a5..f4a54d13 100644 --- a/src/libs/engine/events/NoteOffEvent.cpp +++ b/src/libs/engine/events/NoteOffEvent.cpp @@ -28,8 +28,8 @@ namespace Om { /** Note off with patch explicitly passed - triggered by MIDI. */ -NoteOffEvent::NoteOffEvent(CountedPtr<Responder> responder, Node* node, uchar note_num) -: Event(responder), +NoteOffEvent::NoteOffEvent(CountedPtr<Responder> responder, samplecount timestamp, Node* node, uchar note_num) +: Event(responder, timestamp), m_node(node), m_note_num(note_num) { @@ -38,8 +38,8 @@ NoteOffEvent::NoteOffEvent(CountedPtr<Responder> responder, Node* node, uchar no /** Note off event with lookup - triggered by OSC. */ -NoteOffEvent::NoteOffEvent(CountedPtr<Responder> responder, const string& node_path, uchar note_num) -: Event(responder), +NoteOffEvent::NoteOffEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& node_path, uchar note_num) +: Event(responder, timestamp), m_node(NULL), m_node_path(node_path), m_note_num(note_num) @@ -67,9 +67,9 @@ void NoteOffEvent::post_process() { if (m_node != NULL) - m_responder->respond_ok(); + _responder->respond_ok(); else - m_responder->respond_error("Did not find node for note_off"); + _responder->respond_error("Did not find node for note_off"); } diff --git a/src/libs/engine/events/NoteOffEvent.h b/src/libs/engine/events/NoteOffEvent.h index 3a9f715f..05a34a0e 100644 --- a/src/libs/engine/events/NoteOffEvent.h +++ b/src/libs/engine/events/NoteOffEvent.h @@ -34,8 +34,8 @@ class Node; class NoteOffEvent : public Event { public: - NoteOffEvent(CountedPtr<Responder> responder, Node* node, uchar note_num); - NoteOffEvent(CountedPtr<Responder> responder, const string& node_path, uchar note_num); + NoteOffEvent(CountedPtr<Responder> responder, samplecount timestamp, Node* node, uchar note_num); + NoteOffEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& node_path, uchar note_num); void execute(samplecount offset); void post_process(); diff --git a/src/libs/engine/events/NoteOnEvent.cpp b/src/libs/engine/events/NoteOnEvent.cpp index 4a0ba141..7eeaa597 100644 --- a/src/libs/engine/events/NoteOnEvent.cpp +++ b/src/libs/engine/events/NoteOnEvent.cpp @@ -31,8 +31,8 @@ namespace Om { * * Used to be triggered by MIDI. Not used anymore. */ -NoteOnEvent::NoteOnEvent(CountedPtr<Responder> responder, Node* patch, uchar note_num, uchar velocity) -: Event(responder), +NoteOnEvent::NoteOnEvent(CountedPtr<Responder> responder, samplecount timestamp, Node* patch, uchar note_num, uchar velocity) +: Event(responder, timestamp), m_node(patch), m_note_num(note_num), m_velocity(velocity), @@ -45,8 +45,8 @@ NoteOnEvent::NoteOnEvent(CountedPtr<Responder> responder, Node* patch, uchar not * * Triggered by OSC. */ -NoteOnEvent::NoteOnEvent(CountedPtr<Responder> responder, const string& node_path, uchar note_num, uchar velocity) -: Event(responder), +NoteOnEvent::NoteOnEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& node_path, uchar note_num, uchar velocity) +: Event(responder, timestamp), m_node(NULL), m_node_path(node_path), m_note_num(note_num), @@ -78,9 +78,9 @@ NoteOnEvent::post_process() { if (m_is_osc_triggered) { if (m_node != NULL) - m_responder->respond_ok(); + _responder->respond_ok(); else - m_responder->respond_error("Did not find node for note_on"); + _responder->respond_error("Did not find node for note_on"); } } diff --git a/src/libs/engine/events/NoteOnEvent.h b/src/libs/engine/events/NoteOnEvent.h index af6251e9..8f57eb38 100644 --- a/src/libs/engine/events/NoteOnEvent.h +++ b/src/libs/engine/events/NoteOnEvent.h @@ -34,8 +34,8 @@ class Node; class NoteOnEvent : public Event { public: - NoteOnEvent(CountedPtr<Responder> responder, Node* patch, uchar note_num, uchar velocity); - NoteOnEvent(CountedPtr<Responder> responder, const string& node_path, uchar note_num, uchar velocity); + NoteOnEvent(CountedPtr<Responder> responder, samplecount timestamp, Node* patch, uchar note_num, uchar velocity); + NoteOnEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& node_path, uchar note_num, uchar velocity); void execute(samplecount offset); void post_process(); diff --git a/src/libs/engine/events/PingQueuedEvent.h b/src/libs/engine/events/PingQueuedEvent.h index 790cf7cc..9f575eea 100644 --- a/src/libs/engine/events/PingQueuedEvent.h +++ b/src/libs/engine/events/PingQueuedEvent.h @@ -26,16 +26,17 @@ namespace Om { class Port; -/** A "blocking" ping that travels through the event queue before responding. +/** A ping that travels through the pre-processed event queue before responding + * (useful for the order guarantee). * * \ingroup engine */ class PingQueuedEvent : public QueuedEvent { public: - PingQueuedEvent(CountedPtr<Responder> responder) : QueuedEvent(responder) {} + PingQueuedEvent(CountedPtr<Responder> responder, samplecount timestamp) : QueuedEvent(responder, timestamp) {} - void post_process() { m_responder->respond_ok(); } + void post_process() { _responder->respond_ok(); } }; diff --git a/src/libs/engine/events/RegisterClientEvent.cpp b/src/libs/engine/events/RegisterClientEvent.cpp index d2ea41ab..53a9cda9 100644 --- a/src/libs/engine/events/RegisterClientEvent.cpp +++ b/src/libs/engine/events/RegisterClientEvent.cpp @@ -24,9 +24,10 @@ namespace Om { RegisterClientEvent::RegisterClientEvent(CountedPtr<Responder> responder, + samplecount timestamp, ClientKey key, CountedPtr<ClientInterface> client) -: QueuedEvent(responder) +: QueuedEvent(responder, timestamp) , _key(key) , _client(client) { @@ -45,7 +46,7 @@ RegisterClientEvent::pre_process() void RegisterClientEvent::post_process() { - m_responder->respond_ok(); + _responder->respond_ok(); } diff --git a/src/libs/engine/events/RegisterClientEvent.h b/src/libs/engine/events/RegisterClientEvent.h index 6399e5be..2e0bfe16 100644 --- a/src/libs/engine/events/RegisterClientEvent.h +++ b/src/libs/engine/events/RegisterClientEvent.h @@ -36,6 +36,7 @@ class RegisterClientEvent : public QueuedEvent { public: RegisterClientEvent(CountedPtr<Responder> responder, + samplecount timestamp, ClientKey key, CountedPtr<ClientInterface> client); diff --git a/src/libs/engine/events/RenameEvent.cpp b/src/libs/engine/events/RenameEvent.cpp index 52002774..2f654569 100644 --- a/src/libs/engine/events/RenameEvent.cpp +++ b/src/libs/engine/events/RenameEvent.cpp @@ -28,8 +28,8 @@ namespace Om { -RenameEvent::RenameEvent(CountedPtr<Responder> responder, const string& path, const string& name) -: QueuedEvent(responder), +RenameEvent::RenameEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& path, const string& name) +: QueuedEvent(responder, timestamp), m_old_path(path), m_name(name), m_new_path(m_old_path.parent().base_path() + name), @@ -103,7 +103,7 @@ RenameEvent::post_process() string msg = "Unable to rename object - "; if (m_error == NO_ERROR) { - m_responder->respond_ok(); + _responder->respond_ok(); om->client_broadcaster()->send_rename(m_old_path, m_new_path); } else { if (m_error == OBJECT_EXISTS) @@ -115,7 +115,7 @@ RenameEvent::post_process() else if (m_error == INVALID_NAME) msg.append(m_name).append(" is not a valid name"); - m_responder->respond_error(msg); + _responder->respond_error(msg); } } diff --git a/src/libs/engine/events/RenameEvent.h b/src/libs/engine/events/RenameEvent.h index 41e5eec0..40f40d3c 100644 --- a/src/libs/engine/events/RenameEvent.h +++ b/src/libs/engine/events/RenameEvent.h @@ -42,7 +42,7 @@ class DisconnectPortEvent; class RenameEvent : public QueuedEvent { public: - RenameEvent(CountedPtr<Responder> responder, const string& path, const string& name); + RenameEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& path, const string& name); ~RenameEvent(); void pre_process(); diff --git a/src/libs/engine/events/RequestAllObjectsEvent.cpp b/src/libs/engine/events/RequestAllObjectsEvent.cpp index 0b8f6255..5e215914 100644 --- a/src/libs/engine/events/RequestAllObjectsEvent.cpp +++ b/src/libs/engine/events/RequestAllObjectsEvent.cpp @@ -23,8 +23,8 @@ namespace Om { -RequestAllObjectsEvent::RequestAllObjectsEvent(CountedPtr<Responder> responder) -: QueuedEvent(responder), +RequestAllObjectsEvent::RequestAllObjectsEvent(CountedPtr<Responder> responder, samplecount timestamp) +: QueuedEvent(responder, timestamp), m_client(CountedPtr<ClientInterface>(NULL)) { } @@ -33,7 +33,7 @@ RequestAllObjectsEvent::RequestAllObjectsEvent(CountedPtr<Responder> responder) void RequestAllObjectsEvent::pre_process() { - m_client = m_responder->find_client(); + m_client = _responder->find_client(); QueuedEvent::pre_process(); } @@ -43,10 +43,10 @@ void RequestAllObjectsEvent::post_process() { if (m_client) { - m_responder->respond_ok(); + _responder->respond_ok(); ObjectSender::send_all(m_client.get()); } else { - m_responder->respond_error("Invalid URL"); + _responder->respond_error("Invalid URL"); } } diff --git a/src/libs/engine/events/RequestAllObjectsEvent.h b/src/libs/engine/events/RequestAllObjectsEvent.h index b5d43f59..70dbc4a3 100644 --- a/src/libs/engine/events/RequestAllObjectsEvent.h +++ b/src/libs/engine/events/RequestAllObjectsEvent.h @@ -35,7 +35,7 @@ namespace Shared { class RequestAllObjectsEvent : public QueuedEvent { public: - RequestAllObjectsEvent(CountedPtr<Responder> responder); + RequestAllObjectsEvent(CountedPtr<Responder> responder, samplecount timestamp); void pre_process(); void post_process(); diff --git a/src/libs/engine/events/RequestMetadataEvent.cpp b/src/libs/engine/events/RequestMetadataEvent.cpp index 0590f3b3..c492d0dd 100644 --- a/src/libs/engine/events/RequestMetadataEvent.cpp +++ b/src/libs/engine/events/RequestMetadataEvent.cpp @@ -28,8 +28,8 @@ using std::string; namespace Om { -RequestMetadataEvent::RequestMetadataEvent(CountedPtr<Responder> responder, const string& node_path, const string& key) -: QueuedEvent(responder), +RequestMetadataEvent::RequestMetadataEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& node_path, const string& key) +: QueuedEvent(responder, timestamp), m_path(node_path), m_key(key), m_value(""), @@ -42,7 +42,7 @@ RequestMetadataEvent::RequestMetadataEvent(CountedPtr<Responder> responder, cons void RequestMetadataEvent::pre_process() { - m_client = m_responder->find_client(); + m_client = _responder->find_client(); if (m_client) { m_object = om->object_store()->find(m_path); @@ -65,13 +65,13 @@ RequestMetadataEvent::post_process() if (m_value == "") { string msg = "Unable to find object "; msg += m_path; - m_responder->respond_error(msg); + _responder->respond_error(msg); } else { - m_responder->respond_ok(); + _responder->respond_ok(); m_client->metadata_update(m_path, m_key, m_value); } } else { - m_responder->respond_error("Unknown client"); + _responder->respond_error("Unknown client"); } } diff --git a/src/libs/engine/events/RequestMetadataEvent.h b/src/libs/engine/events/RequestMetadataEvent.h index d086d7da..97ac46ab 100644 --- a/src/libs/engine/events/RequestMetadataEvent.h +++ b/src/libs/engine/events/RequestMetadataEvent.h @@ -37,7 +37,7 @@ namespace Shared { class RequestMetadataEvent : public QueuedEvent { public: - RequestMetadataEvent(CountedPtr<Responder> responder, const string& path, const string& key); + RequestMetadataEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& path, const string& key); void pre_process(); void post_process(); diff --git a/src/libs/engine/events/RequestPluginsEvent.cpp b/src/libs/engine/events/RequestPluginsEvent.cpp index 984bddf6..fc29c846 100644 --- a/src/libs/engine/events/RequestPluginsEvent.cpp +++ b/src/libs/engine/events/RequestPluginsEvent.cpp @@ -23,8 +23,8 @@ namespace Om { -RequestPluginsEvent::RequestPluginsEvent(CountedPtr<Responder> responder) -: QueuedEvent(responder), +RequestPluginsEvent::RequestPluginsEvent(CountedPtr<Responder> responder, samplecount timestamp) +: QueuedEvent(responder, timestamp), m_client(CountedPtr<ClientInterface>(NULL)) { } @@ -33,7 +33,7 @@ RequestPluginsEvent::RequestPluginsEvent(CountedPtr<Responder> responder) void RequestPluginsEvent::pre_process() { - m_client = m_responder->find_client(); + m_client = _responder->find_client(); QueuedEvent::pre_process(); } @@ -44,9 +44,9 @@ RequestPluginsEvent::post_process() { if (m_client) { om->client_broadcaster()->send_plugins_to(m_client.get()); - m_responder->respond_ok(); + _responder->respond_ok(); } else { - m_responder->respond_error("Invalid URL"); + _responder->respond_error("Invalid URL"); } } diff --git a/src/libs/engine/events/RequestPluginsEvent.h b/src/libs/engine/events/RequestPluginsEvent.h index b8c76362..0d97deaf 100644 --- a/src/libs/engine/events/RequestPluginsEvent.h +++ b/src/libs/engine/events/RequestPluginsEvent.h @@ -36,7 +36,7 @@ namespace Shared { class RequestPluginsEvent : public QueuedEvent { public: - RequestPluginsEvent(CountedPtr<Responder> responder); + RequestPluginsEvent(CountedPtr<Responder> responder, samplecount timestamp); void pre_process(); void post_process(); diff --git a/src/libs/engine/events/RequestPortValueEvent.cpp b/src/libs/engine/events/RequestPortValueEvent.cpp index ac690883..f8036447 100644 --- a/src/libs/engine/events/RequestPortValueEvent.cpp +++ b/src/libs/engine/events/RequestPortValueEvent.cpp @@ -29,8 +29,8 @@ using std::string; namespace Om { -RequestPortValueEvent::RequestPortValueEvent(CountedPtr<Responder> responder, const string& port_path) -: QueuedEvent(responder), +RequestPortValueEvent::RequestPortValueEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& port_path) +: QueuedEvent(responder, timestamp), m_port_path(port_path), m_port(NULL), m_value(0.0), @@ -42,7 +42,7 @@ RequestPortValueEvent::RequestPortValueEvent(CountedPtr<Responder> responder, co void RequestPortValueEvent::pre_process() { - m_client = m_responder->find_client(); + m_client = _responder->find_client(); m_port = om->object_store()->find_port(m_port_path); QueuedEvent::pre_process(); @@ -66,12 +66,12 @@ RequestPortValueEvent::post_process() { string msg; if (m_port) { - m_responder->respond_error("Unable to find port for get_value responder."); + _responder->respond_error("Unable to find port for get_value responder."); } else if (m_client) { - m_responder->respond_ok(); + _responder->respond_ok(); m_client->control_change(m_port_path, m_value); } else { - m_responder->respond_error("Invalid URL"); + _responder->respond_error("Invalid URL"); } } diff --git a/src/libs/engine/events/RequestPortValueEvent.h b/src/libs/engine/events/RequestPortValueEvent.h index fd915c3b..bfb87790 100644 --- a/src/libs/engine/events/RequestPortValueEvent.h +++ b/src/libs/engine/events/RequestPortValueEvent.h @@ -37,7 +37,7 @@ using Shared::ClientInterface; class RequestPortValueEvent : public QueuedEvent { public: - RequestPortValueEvent(CountedPtr<Responder> responder, const string& port_path); + RequestPortValueEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& port_path); void pre_process(); void execute(samplecount offset); diff --git a/src/libs/engine/events/SetMetadataEvent.cpp b/src/libs/engine/events/SetMetadataEvent.cpp index 37e164c1..35ea2b47 100644 --- a/src/libs/engine/events/SetMetadataEvent.cpp +++ b/src/libs/engine/events/SetMetadataEvent.cpp @@ -28,8 +28,8 @@ using std::string; namespace Om { -SetMetadataEvent::SetMetadataEvent(CountedPtr<Responder> responder, const string& path, const string& key, const string& value) -: QueuedEvent(responder), +SetMetadataEvent::SetMetadataEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& path, const string& key, const string& value) +: QueuedEvent(responder, timestamp), m_path(path), m_key(key), m_value(value), @@ -68,9 +68,9 @@ SetMetadataEvent::post_process() if (m_object == NULL) { string msg = "Unable to find object "; msg += m_path; - m_responder->respond_error(msg); + _responder->respond_error(msg); } else { - m_responder->respond_ok(); + _responder->respond_ok(); om->client_broadcaster()->send_metadata_update(m_path, m_key, m_value); } } diff --git a/src/libs/engine/events/SetMetadataEvent.h b/src/libs/engine/events/SetMetadataEvent.h index faa9ae72..82e14ea2 100644 --- a/src/libs/engine/events/SetMetadataEvent.h +++ b/src/libs/engine/events/SetMetadataEvent.h @@ -34,7 +34,7 @@ class GraphObject; class SetMetadataEvent : public QueuedEvent { public: - SetMetadataEvent(CountedPtr<Responder> responder, const string& path, const string& key, const string& value); + SetMetadataEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& path, const string& key, const string& value); void pre_process(); void execute(samplecount offset); diff --git a/src/libs/engine/events/SetPortValueEvent.cpp b/src/libs/engine/events/SetPortValueEvent.cpp index 6401689b..8b861a58 100644 --- a/src/libs/engine/events/SetPortValueEvent.cpp +++ b/src/libs/engine/events/SetPortValueEvent.cpp @@ -28,8 +28,8 @@ namespace Om { /** Voice-specific control setting */ -SetPortValueEvent::SetPortValueEvent(CountedPtr<Responder> responder, size_t voice_num, const string& port_path, sample val) -: Event(responder), +SetPortValueEvent::SetPortValueEvent(CountedPtr<Responder> responder, samplecount timestamp, size_t voice_num, const string& port_path, sample val) +: Event(responder, timestamp), m_voice_num(voice_num), m_port_path(port_path), m_val(val), @@ -39,8 +39,8 @@ SetPortValueEvent::SetPortValueEvent(CountedPtr<Responder> responder, size_t voi } -SetPortValueEvent::SetPortValueEvent(CountedPtr<Responder> responder, const string& port_path, sample val) -: Event(responder), +SetPortValueEvent::SetPortValueEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& port_path, sample val) +: Event(responder, timestamp), m_voice_num(-1), m_port_path(port_path), m_val(val), @@ -76,7 +76,7 @@ SetPortValueEvent::post_process() if (m_error == NO_ERROR) { assert(m_port != NULL); - m_responder->respond_ok(); + _responder->respond_ok(); om->client_broadcaster()->send_control_change(m_port_path, m_val); // Send patch port control change, if this is a bridge port @@ -89,12 +89,12 @@ SetPortValueEvent::post_process() } else if (m_error == PORT_NOT_FOUND) { string msg = "Unable to find port "; msg.append(m_port_path).append(" for set_port_value"); - m_responder->respond_error(msg); + _responder->respond_error(msg); } else if (m_error == TYPE_MISMATCH) { string msg = "Attempt to set "; msg.append(m_port_path).append(" to incompatible type"); - m_responder->respond_error(msg); + _responder->respond_error(msg); } } diff --git a/src/libs/engine/events/SetPortValueEvent.h b/src/libs/engine/events/SetPortValueEvent.h index 0606e546..33c9cbd9 100644 --- a/src/libs/engine/events/SetPortValueEvent.h +++ b/src/libs/engine/events/SetPortValueEvent.h @@ -34,8 +34,8 @@ class Port; class SetPortValueEvent : public Event { public: - SetPortValueEvent(CountedPtr<Responder> responder, const string& port_path, sample val); - SetPortValueEvent(CountedPtr<Responder> responder, size_t voice_num, const string& port_path, sample val); + SetPortValueEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& port_path, sample val); + SetPortValueEvent(CountedPtr<Responder> responder, samplecount timestamp, size_t voice_num, const string& port_path, sample val); void execute(samplecount offset); void post_process(); diff --git a/src/libs/engine/events/SetPortValueQueuedEvent.cpp b/src/libs/engine/events/SetPortValueQueuedEvent.cpp index 6ef39d55..21c1d104 100644 --- a/src/libs/engine/events/SetPortValueQueuedEvent.cpp +++ b/src/libs/engine/events/SetPortValueQueuedEvent.cpp @@ -29,8 +29,8 @@ namespace Om { /** Voice-specific control setting */ -SetPortValueQueuedEvent::SetPortValueQueuedEvent(CountedPtr<Responder> responder, size_t voice_num, const string& port_path, sample val) -: QueuedEvent(responder), +SetPortValueQueuedEvent::SetPortValueQueuedEvent(CountedPtr<Responder> responder, samplecount timestamp, size_t voice_num, const string& port_path, sample val) +: QueuedEvent(responder, timestamp), m_voice_num(voice_num), m_port_path(port_path), m_val(val), @@ -40,8 +40,8 @@ SetPortValueQueuedEvent::SetPortValueQueuedEvent(CountedPtr<Responder> responder } -SetPortValueQueuedEvent::SetPortValueQueuedEvent(CountedPtr<Responder> responder, const string& port_path, sample val) -: QueuedEvent(responder), +SetPortValueQueuedEvent::SetPortValueQueuedEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& port_path, sample val) +: QueuedEvent(responder, timestamp), m_voice_num(-1), m_port_path(port_path), m_val(val), @@ -88,7 +88,7 @@ SetPortValueQueuedEvent::post_process() if (m_error == NO_ERROR) { assert(m_port != NULL); - m_responder->respond_ok(); + _responder->respond_ok(); om->client_broadcaster()->send_control_change(m_port_path, m_val); // Send patch port control change, if this is a bridge port @@ -101,12 +101,12 @@ SetPortValueQueuedEvent::post_process() } else if (m_error == PORT_NOT_FOUND) { string msg = "Unable to find port "; msg.append(m_port_path).append(" for set_port_value_slow"); - m_responder->respond_error(msg); + _responder->respond_error(msg); } else if (m_error == TYPE_MISMATCH) { string msg = "Attempt to set "; msg.append(m_port_path).append(" to incompatible type"); - m_responder->respond_error(msg); + _responder->respond_error(msg); } } diff --git a/src/libs/engine/events/SetPortValueQueuedEvent.h b/src/libs/engine/events/SetPortValueQueuedEvent.h index d29f424b..035cb414 100644 --- a/src/libs/engine/events/SetPortValueQueuedEvent.h +++ b/src/libs/engine/events/SetPortValueQueuedEvent.h @@ -34,8 +34,8 @@ class Port; class SetPortValueQueuedEvent : public QueuedEvent { public: - SetPortValueQueuedEvent(CountedPtr<Responder> responder, const string& port_path, sample val); - SetPortValueQueuedEvent(CountedPtr<Responder> responder, size_t voice_num, const string& port_path, sample val); + SetPortValueQueuedEvent(CountedPtr<Responder> responder, samplecount timestamp, const string& port_path, sample val); + SetPortValueQueuedEvent(CountedPtr<Responder> responder, samplecount timestamp, size_t voice_num, const string& port_path, sample val); void pre_process(); void execute(samplecount offset); diff --git a/src/libs/engine/events/UnregisterClientEvent.cpp b/src/libs/engine/events/UnregisterClientEvent.cpp index 10696640..175543c9 100644 --- a/src/libs/engine/events/UnregisterClientEvent.cpp +++ b/src/libs/engine/events/UnregisterClientEvent.cpp @@ -24,8 +24,8 @@ namespace Om { -UnregisterClientEvent::UnregisterClientEvent(CountedPtr<Responder> responder, ClientKey key) -: QueuedEvent(responder) +UnregisterClientEvent::UnregisterClientEvent(CountedPtr<Responder> responder, samplecount timestamp, ClientKey key) +: QueuedEvent(responder, timestamp) , _key(key) { } @@ -35,9 +35,9 @@ void UnregisterClientEvent::post_process() { if (om->client_broadcaster()->unregister_client(_key)) - m_responder->respond_ok(); + _responder->respond_ok(); else - m_responder->respond_error("Unable to unregister client"); + _responder->respond_error("Unable to unregister client"); } diff --git a/src/libs/engine/events/UnregisterClientEvent.h b/src/libs/engine/events/UnregisterClientEvent.h index 56556629..e7c6a996 100644 --- a/src/libs/engine/events/UnregisterClientEvent.h +++ b/src/libs/engine/events/UnregisterClientEvent.h @@ -39,7 +39,7 @@ using Shared::ClientKey; class UnregisterClientEvent : public QueuedEvent { public: - UnregisterClientEvent(CountedPtr<Responder> responder, ClientKey key); + UnregisterClientEvent(CountedPtr<Responder> responder, samplecount timestamp, ClientKey key); void post_process(); |