diff options
Diffstat (limited to 'src/libs')
30 files changed, 248 insertions, 201 deletions
diff --git a/src/libs/client/ConnectionModel.cpp b/src/libs/client/ConnectionModel.cpp index 1c7541b9..18b6fbd7 100644 --- a/src/libs/client/ConnectionModel.cpp +++ b/src/libs/client/ConnectionModel.cpp @@ -27,8 +27,8 @@ ConnectionModel::ConnectionModel(const Path& src_port, const Path& dst_port) m_dst_port(NULL) { // Be sure connection is within one patch - assert(m_src_port_path.parent().parent() - == m_dst_port_path.parent().parent()); + //assert(m_src_port_path.parent().parent() + // == m_dst_port_path.parent().parent()); } @@ -51,4 +51,24 @@ ConnectionModel::dst_port_path() const return m_dst_port->path(); } +const Path +ConnectionModel::patch_path() const +{ + const Path& src_node = m_src_port_path.parent(); + const Path& dst_node = m_dst_port_path.parent(); + Path patch_path = src_node.parent(); + + if (src_node.parent() != dst_node.parent()) { + // Connection to a patch port from inside the patch + assert(src_node.parent() == dst_node || dst_node.parent() == src_node); + if (src_node.parent() == dst_node) + patch_path = dst_node; + else + patch_path = src_node; + } + + return patch_path; +} + + } // namespace LibOmClient diff --git a/src/libs/client/ConnectionModel.h b/src/libs/client/ConnectionModel.h index ef909850..427c5858 100644 --- a/src/libs/client/ConnectionModel.h +++ b/src/libs/client/ConnectionModel.h @@ -55,7 +55,7 @@ public: const Path& src_port_path() const; const Path& dst_port_path() const; - const Path patch_path() const { return src_port_path().parent().parent(); } + const Path patch_path() const; private: Path m_src_port_path; ///< Only used if m_src_port == NULL diff --git a/src/libs/client/PatchModel.cpp b/src/libs/client/PatchModel.cpp index 7d786301..265a17d8 100644 --- a/src/libs/client/PatchModel.cpp +++ b/src/libs/client/PatchModel.cpp @@ -163,19 +163,23 @@ void PatchModel::add_connection(CountedPtr<ConnectionModel> cm) { assert(cm); - assert(cm->src_port_path().parent().parent() == m_path); - assert(cm->dst_port_path().parent().parent() == m_path); + //assert(cm->src_port_path().parent().parent() == m_path); + //assert(cm->dst_port_path().parent().parent() == m_path); assert(cm->patch_path() == path()); + cerr << "PatchModel::add_connection: " << cm->src_port_path() << " -> " << cm->dst_port_path() << endl; + CountedPtr<ConnectionModel> existing = get_connection(cm->src_port_path(), cm->dst_port_path()); if (existing) { return; } - NodeModel* src_node = get_node(cm->src_port_path().parent().name()).get(); + NodeModel* src_node = (cm->src_port_path().parent() == path()) + ? this : get_node(cm->src_port_path().parent().name()).get(); PortModel* src_port = (src_node == NULL) ? NULL : src_node->get_port(cm->src_port_path().name()).get(); - NodeModel* dst_node = get_node(cm->dst_port_path().parent().name()).get(); + NodeModel* dst_node = (cm->dst_port_path().parent() == path()) + ? this : get_node(cm->dst_port_path().parent().name()).get(); PortModel* dst_port = (dst_node == NULL) ? NULL : dst_node->get_port(cm->dst_port_path().name()).get(); assert(src_port != NULL); diff --git a/src/libs/client/Store.cpp b/src/libs/client/Store.cpp index 542c1bc5..15f91786 100644 --- a/src/libs/client/Store.cpp +++ b/src/libs/client/Store.cpp @@ -311,24 +311,22 @@ Store::metadata_update_event(const string& subject_path, const string& predicate void -Store::connection_event(const string& src_port_path, const string& dst_port_path) +Store::connection_event(const Path& src_port_path, const Path& dst_port_path) { - const Path& src = src_port_path; - const Path& dst = dst_port_path; - - assert(src.parent().parent() == dst.parent().parent()); - const Path& patch_path = src.parent().parent(); + // ConnectionModel has the clever patch-path-figuring-out stuff in it, so + // just make one right away to get at that + ConnectionModel* cm = new ConnectionModel(src_port_path, dst_port_path); - CountedPtr<PatchModel> patch = this->patch(patch_path); + CountedPtr<PatchModel> patch = this->patch(cm->patch_path()); if (patch) - patch->add_connection(new ConnectionModel(src, dst)); + patch->add_connection(cm); else cerr << "ERROR: connection in nonexistant patch" << endl; } void -Store::disconnection_event(const string& src_port_path, const string& dst_port_path) +Store::disconnection_event(const Path& src_port_path, const Path& dst_port_path) { const Path& src = src_port_path; const Path& dst = dst_port_path; diff --git a/src/libs/client/Store.h b/src/libs/client/Store.h index 0b84d418..0e47168d 100644 --- a/src/libs/client/Store.h +++ b/src/libs/client/Store.h @@ -22,7 +22,9 @@ #include <map> #include "util/CountedPtr.h" #include <sigc++/sigc++.h> +#include "util/Path.h" using std::string; using std::map; +using Om::Path; namespace LibOmClient { @@ -71,8 +73,8 @@ private: void new_node_event(const string& plugin_type, const string& plugin_uri, const string& node_path, bool is_polyphonic, uint32_t num_ports); void new_port_event(const string& path, const string& data_type, bool is_output); void metadata_update_event(const string& subject_path, const string& predicate, const string& value); - void connection_event(const string& src_port_path, const string& dst_port_path); - void disconnection_event(const string& src_port_path, const string& dst_port_path); + void connection_event(const Path& src_port_path, const Path& dst_port_path); + void disconnection_event(const Path& src_port_path, const Path& dst_port_path); map<string, CountedPtr<ObjectModel> > m_objects; ///< Keyed by Om path map<string, CountedPtr<PluginModel> > m_plugins; ///< Keyed by URI diff --git a/src/libs/engine/Buffer.cpp b/src/libs/engine/Buffer.cpp index 963b14a5..4e94a943 100644 --- a/src/libs/engine/Buffer.cpp +++ b/src/libs/engine/Buffer.cpp @@ -39,6 +39,7 @@ Buffer<T>::Buffer(size_t size) { assert(m_size > 0); allocate(); + assert(m_data); } template Buffer<sample>::Buffer(size_t size); template Buffer<MidiMessage>::Buffer(size_t size); diff --git a/src/libs/engine/Driver.h b/src/libs/engine/Driver.h index ade50a71..11060c04 100644 --- a/src/libs/engine/Driver.h +++ b/src/libs/engine/Driver.h @@ -22,7 +22,7 @@ using std::string; namespace Om { -template <typename T> class TypedPort; +template <typename T> class DuplexPort; /** Representation of a system (outside Om, ie hardware) audio port. @@ -77,7 +77,7 @@ public: * * May return NULL if the Driver can not drive the port for some reason. */ - virtual DriverPort* create_port(TypedPort<T>* patch_port) = 0; + virtual DriverPort* create_port(DuplexPort<T>* patch_port) = 0; }; diff --git a/src/libs/engine/InputPort.cpp b/src/libs/engine/InputPort.cpp index 0e7a349d..752efde4 100644 --- a/src/libs/engine/InputPort.cpp +++ b/src/libs/engine/InputPort.cpp @@ -18,7 +18,7 @@ #include <iostream> #include <cstdlib> #include <cassert> -#include "ConnectionBase.h" +#include "TypedConnection.h" #include "OutputPort.h" #include "Node.h" #include "Om.h" @@ -46,21 +46,21 @@ template InputPort<MidiMessage>::InputPort(Node* parent, const string& name, siz */ template<typename T> void -InputPort<T>::add_connection(ListNode<ConnectionBase<T>*>* const c) +InputPort<T>::add_connection(ListNode<TypedConnection<T>*>* const c) { m_connections.push_back(c); bool modify_buffers = !m_fixed_buffers; - if (modify_buffers && m_is_tied) - modify_buffers = !m_tied_port->fixed_buffers(); + //if (modify_buffers && m_is_tied) + // modify_buffers = !m_tied_port->fixed_buffers(); if (modify_buffers) { if (m_connections.size() == 1) { // Use buffer directly to avoid copying for (size_t i=0; i < _poly; ++i) { m_buffers.at(i)->join(c->elem()->buffer(i)); - if (m_is_tied) - m_tied_port->buffer(i)->join(m_buffers.at(i)); + //if (m_is_tied) + // m_tied_port->buffer(i)->join(m_buffers.at(i)); assert(m_buffers.at(i)->data() == c->elem()->buffer(i)->data()); } } else if (m_connections.size() == 2) { @@ -68,34 +68,34 @@ InputPort<T>::add_connection(ListNode<ConnectionBase<T>*>* const c) // so have to use local ones again and mix down for (size_t i=0; i < _poly; ++i) { m_buffers.at(i)->unjoin(); - if (m_is_tied) - m_tied_port->buffer(i)->join(m_buffers.at(i)); + //if (m_is_tied) + // m_tied_port->buffer(i)->join(m_buffers.at(i)); } } update_buffers(); } - assert( ! m_is_tied || m_tied_port != NULL); - assert( ! m_is_tied || m_buffers.at(0)->data() == m_tied_port->buffer(0)->data()); + //assert( ! m_is_tied || m_tied_port != NULL); + //assert( ! m_is_tied || m_buffers.at(0)->data() == m_tied_port->buffer(0)->data()); } -template void InputPort<sample>::add_connection(ListNode<ConnectionBase<sample>*>* const c); -template void InputPort<MidiMessage>::add_connection(ListNode<ConnectionBase<MidiMessage>*>* const c); +template void InputPort<sample>::add_connection(ListNode<TypedConnection<sample>*>* const c); +template void InputPort<MidiMessage>::add_connection(ListNode<TypedConnection<MidiMessage>*>* const c); /** Remove a connection. Realtime safe. */ template <typename T> -ListNode<ConnectionBase<T>*>* +ListNode<TypedConnection<T>*>* InputPort<T>::remove_connection(const OutputPort<T>* const src_port) { bool modify_buffers = !m_fixed_buffers; - if (modify_buffers && m_is_tied) - modify_buffers = !m_tied_port->fixed_buffers(); + //if (modify_buffers && m_is_tied) + // modify_buffers = !m_tied_port->fixed_buffers(); - typedef typename List<ConnectionBase<T>*>::iterator ConnectionBaseListIterator; + typedef typename List<TypedConnection<T>*>::iterator TypedConnectionListIterator; bool found = false; - ListNode<ConnectionBase<T>*>* connection = NULL; - for (ConnectionBaseListIterator i = m_connections.begin(); i != m_connections.end(); ++i) { + ListNode<TypedConnection<T>*>* connection = NULL; + for (TypedConnectionListIterator i = m_connections.begin(); i != m_connections.end(); ++i) { if ((*i)->src_port()->path() == src_port->path()) { connection = m_connections.remove(i); found = true; @@ -112,15 +112,15 @@ InputPort<T>::remove_connection(const OutputPort<T>* const src_port) if (modify_buffers && m_buffers.at(i)->is_joined()) m_buffers.at(i)->unjoin(); m_buffers.at(i)->clear(); // Write silence - if (m_is_tied) - m_tied_port->buffer(i)->join(m_buffers.at(i)); + //if (m_is_tied) + //m_tied_port->buffer(i)->join(m_buffers.at(i)); } } else if (modify_buffers && m_connections.size() == 1) { // Share a buffer for (size_t i=0; i < _poly; ++i) { m_buffers.at(i)->join((*m_connections.begin())->buffer(i)); - if (m_is_tied) - m_tied_port->buffer(i)->join(m_buffers.at(i)); + //if (m_is_tied) + // m_tied_port->buffer(i)->join(m_buffers.at(i)); } } } @@ -128,14 +128,14 @@ InputPort<T>::remove_connection(const OutputPort<T>* const src_port) if (modify_buffers) update_buffers(); - assert( ! m_is_tied || m_tied_port != NULL); - assert( ! m_is_tied || m_buffers.at(0)->data() == m_tied_port->buffer(0)->data()); + //assert( ! m_is_tied || m_tied_port != NULL); + //assert( ! m_is_tied || m_buffers.at(0)->data() == m_tied_port->buffer(0)->data()); return connection; } -template ListNode<ConnectionBase<sample>*>* +template ListNode<TypedConnection<sample>*>* InputPort<sample>::remove_connection(const OutputPort<sample>* const src_port); -template ListNode<ConnectionBase<MidiMessage>*>* +template ListNode<TypedConnection<MidiMessage>*>* InputPort<MidiMessage>::remove_connection(const OutputPort<MidiMessage>* const src_port); @@ -161,8 +161,8 @@ template <typename T> bool InputPort<T>::is_connected_to(const OutputPort<T>* const port) const { - typedef typename List<ConnectionBase<T>*>::const_iterator ConnectionBaseListIterator; - for (ConnectionBaseListIterator i = m_connections.begin(); i != m_connections.end(); ++i) + typedef typename List<TypedConnection<T>*>::const_iterator TypedConnectionListIterator; + for (TypedConnectionListIterator i = m_connections.begin(); i != m_connections.end(); ++i) if ((*i)->src_port() == port) return true; @@ -177,6 +177,7 @@ template bool InputPort<MidiMessage>::is_connected_to(const OutputPort<MidiMessa * This is used by OutputNode and InputNode to provide two different ports * (internal and external) that share a buffer. */ +/* template <typename T> void InputPort<T>::tie(OutputPort<T>* const port) @@ -202,7 +203,7 @@ InputPort<T>::tie(OutputPort<T>* const port) } template void InputPort<sample>::tie(OutputPort<sample>* const port); template void InputPort<MidiMessage>::tie(OutputPort<MidiMessage>* const port); - +*/ /** Prepare buffer for access, mixing if necessary. Realtime safe. * FIXME: nframes parameter not used, @@ -211,21 +212,21 @@ template<> void InputPort<sample>::prepare_buffers(size_t nframes) { - assert(!m_is_tied || m_tied_port != NULL); + //assert(!m_is_tied || m_tied_port != NULL); - typedef List<ConnectionBase<sample>*>::iterator ConnectionBaseListIterator; + typedef List<TypedConnection<sample>*>::iterator TypedConnectionListIterator; bool do_mixdown = true; if (m_connections.size() == 0) return; - for (ConnectionBaseListIterator c = m_connections.begin(); c != m_connections.end(); ++c) + for (TypedConnectionListIterator c = m_connections.begin(); c != m_connections.end(); ++c) (*c)->prepare_buffers(); // If only one connection, buffer is (maybe) used directly (no copying) if (m_connections.size() == 1) { // Buffer changed since connection if (m_buffers.at(0)->data() != (*m_connections.begin())->buffer(0)->data()) { - if (m_fixed_buffers || (m_is_tied && m_tied_port->fixed_buffers())) { + if (m_fixed_buffers) { // || (m_is_tied && m_tied_port->fixed_buffers())) { // can't change buffer, must copy do_mixdown = true; } else { @@ -245,15 +246,15 @@ InputPort<sample>::prepare_buffers(size_t nframes) return; } - assert(!m_is_tied || m_tied_port != NULL); - assert(!m_is_tied || m_buffers.at(0)->data() == m_tied_port->buffer(0)->data()); + /*assert(!m_is_tied || m_tied_port != NULL); + assert(!m_is_tied || m_buffers.at(0)->data() == m_tied_port->buffer(0)->data());*/ for (size_t voice=0; voice < _poly; ++voice) { m_buffers.at(voice)->copy((*m_connections.begin())->buffer(voice), 0, _buffer_size-1); if (m_connections.size() > 1) { // Copy first connection - ConnectionBaseListIterator c = m_connections.begin(); + TypedConnectionListIterator c = m_connections.begin(); // Add all other connections for (++c; c != m_connections.end(); ++c) @@ -271,17 +272,17 @@ template <> void InputPort<MidiMessage>::prepare_buffers(size_t nframes) { - assert(!m_is_tied || m_tied_port != NULL); + //assert(!m_is_tied || m_tied_port != NULL); const size_t num_ins = m_connections.size(); bool do_mixdown = true; assert(num_ins == 0 || num_ins == 1); - typedef List<ConnectionBase<MidiMessage>*>::iterator ConnectionBaseListIterator; + typedef List<TypedConnection<MidiMessage>*>::iterator TypedConnectionListIterator; assert(_poly == 1); - for (ConnectionBaseListIterator c = m_connections.begin(); c != m_connections.end(); ++c) + for (TypedConnectionListIterator c = m_connections.begin(); c != m_connections.end(); ++c) (*c)->prepare_buffers(); @@ -289,24 +290,24 @@ InputPort<MidiMessage>::prepare_buffers(size_t nframes) if (num_ins == 1) { // Buffer changed since connection if (m_buffers.at(0) != (*m_connections.begin())->buffer(0)) { - if (m_fixed_buffers || (m_is_tied && m_tied_port->fixed_buffers())) { + if (m_fixed_buffers) { // || (m_is_tied && m_tied_port->fixed_buffers())) { // can't change buffer, must copy do_mixdown = true; } else { // zero-copy assert(m_buffers.at(0)->is_joined()); m_buffers.at(0)->join((*m_connections.begin())->buffer(0)); - if (m_is_tied) - m_tied_port->buffer(0)->join(m_buffers.at(0)); + //if (m_is_tied) + // m_tied_port->buffer(0)->join(m_buffers.at(0)); do_mixdown = false; } update_buffers(); } else { do_mixdown = false; } - assert(!m_is_tied || m_tied_port != NULL); - assert(!m_is_tied || m_buffers.at(0)->data() == m_tied_port->buffer(0)->data()); - assert(!m_is_tied || m_buffers.at(0)->filled_size() == m_tied_port->buffer(0)->filled_size()); + //assert(!m_is_tied || m_tied_port != NULL); + //assert(!m_is_tied || m_buffers.at(0)->data() == m_tied_port->buffer(0)->data()); + //assert(!m_is_tied || m_buffers.at(0)->filled_size() == m_tied_port->buffer(0)->filled_size()); assert(do_mixdown || m_buffers.at(0)->filled_size() == (*m_connections.begin())->src_port()->buffer(0)->filled_size()); } @@ -318,8 +319,8 @@ InputPort<MidiMessage>::prepare_buffers(size_t nframes) m_buffers.at(0)->filled_size( (*m_connections.begin())->src_port()->buffer(0)->filled_size()); - if (m_is_tied) - m_tied_port->buffer(0)->filled_size(m_buffers.at(0)->filled_size()); + //if (m_is_tied) + // m_tied_port->buffer(0)->filled_size(m_buffers.at(0)->filled_size()); assert(m_buffers.at(0)->filled_size() == (*m_connections.begin())->src_port()->buffer(0)->filled_size()); @@ -329,7 +330,7 @@ InputPort<MidiMessage>::prepare_buffers(size_t nframes) } } - assert(!m_is_tied || m_buffers.at(0)->data() == m_tied_port->buffer(0)->data()); + //assert(!m_is_tied || m_buffers.at(0)->data() == m_tied_port->buffer(0)->data()); if (!do_mixdown || m_buffers.at(0)->filled_size() == 0 || num_ins == 0) return; @@ -337,8 +338,8 @@ InputPort<MidiMessage>::prepare_buffers(size_t nframes) //cerr << path() << " - Copying MIDI buffer" << endl; // Be sure buffers are the same as tied port's, if joined - assert(!m_is_tied || m_tied_port != NULL); - assert(!m_is_tied || m_buffers.at(0)->data() == m_tied_port->buffer(0)->data()); + //assert(!m_is_tied || m_tied_port != NULL); + //assert(!m_is_tied || m_buffers.at(0)->data() == m_tied_port->buffer(0)->data()); if (num_ins > 0) for (size_t i=0; i < m_buffers.at(0)->filled_size(); ++i) diff --git a/src/libs/engine/InputPort.h b/src/libs/engine/InputPort.h index 8c677b26..60e96167 100644 --- a/src/libs/engine/InputPort.h +++ b/src/libs/engine/InputPort.h @@ -27,7 +27,7 @@ using std::string; namespace Om { -template <typename T> class ConnectionBase; +template <typename T> class TypedConnection; template <typename T> class OutputPort; class Node; @@ -44,16 +44,16 @@ class Node; * \ingroup engine */ template <typename T> -class InputPort : public TypedPort<T> +class InputPort : virtual public TypedPort<T> { public: InputPort(Node* parent, const string& name, size_t index, size_t poly, DataType type, size_t buffer_size); virtual ~InputPort() {} - void add_connection(ListNode<ConnectionBase<T>*>* const c); - ListNode<ConnectionBase<T>*>* remove_connection(const OutputPort<T>* const src_port); + void add_connection(ListNode<TypedConnection<T>*>* const c); + ListNode<TypedConnection<T>*>* remove_connection(const OutputPort<T>* const src_port); - const List<ConnectionBase<T>*>& connections() { return m_connections; } + const List<TypedConnection<T>*>& connections() { return m_connections; } void prepare_buffers(size_t nframes); @@ -72,11 +72,11 @@ private: void update_buffers(); - List<ConnectionBase<T>*> m_connections; + List<TypedConnection<T>*> m_connections; // This is just stupid... - using TypedPort<T>::m_is_tied; - using TypedPort<T>::m_tied_port; + //using TypedPort<T>::m_is_tied; + //using TypedPort<T>::m_tied_port; using TypedPort<T>::m_buffers; using TypedPort<T>::_poly; using TypedPort<T>::_index; diff --git a/src/libs/engine/JackAudioDriver.cpp b/src/libs/engine/JackAudioDriver.cpp index e6ef502e..5fc786f2 100644 --- a/src/libs/engine/JackAudioDriver.cpp +++ b/src/libs/engine/JackAudioDriver.cpp @@ -32,7 +32,7 @@ #include "Port.h" #include "MidiDriver.h" #include "List.h" -#include "TypedPort.h" +#include "DuplexPort.h" #ifdef HAVE_LASH #include "LashDriver.h" #endif @@ -45,7 +45,7 @@ namespace Om { //// JackAudioPort //// -JackAudioPort::JackAudioPort(JackAudioDriver* driver, TypedPort<sample>* patch_port) +JackAudioPort::JackAudioPort(JackAudioDriver* driver, DuplexPort<sample>* patch_port) : DriverPort(), ListNode<JackAudioPort*>(this), m_driver(driver), @@ -53,7 +53,7 @@ JackAudioPort::JackAudioPort(JackAudioDriver* driver, TypedPort<sample>* patch_p m_jack_buffer(NULL), m_patch_port(patch_port) { - assert(patch_port->tied_port() != NULL); + //assert(patch_port->tied_port() != NULL); assert(patch_port->poly() == 1); m_jack_port = jack_port_register(m_driver->jack_client(), @@ -93,17 +93,17 @@ JackAudioPort::prepare_buffer(jack_nframes_t nframes) m_jack_buffer->set_data((jack_default_audio_sample_t*) jack_port_get_buffer(m_jack_port, nframes)); - assert(m_patch_port->tied_port() != NULL); + //assert(m_patch_port->tied_port() != NULL); // FIXME: fixed_buffers switch on/off thing can be removed once this shit // gets figured out and assertions can go away m_patch_port->fixed_buffers(false); m_patch_port->buffer(0)->join(m_jack_buffer); - m_patch_port->tied_port()->buffer(0)->join(m_jack_buffer); + //m_patch_port->tied_port()->buffer(0)->join(m_jack_buffer); m_patch_port->fixed_buffers(true); - assert(m_patch_port->buffer(0)->data() == m_patch_port->tied_port()->buffer(0)->data()); + //assert(m_patch_port->buffer(0)->data() == m_patch_port->tied_port()->buffer(0)->data()); assert(m_patch_port->buffer(0)->data() == m_jack_buffer->data()); } @@ -241,7 +241,7 @@ JackAudioDriver::remove_port(JackAudioPort* port) DriverPort* -JackAudioDriver::create_port(TypedPort<sample>* patch_port) +JackAudioDriver::create_port(DuplexPort<sample>* patch_port) { if (patch_port->buffer_size() == m_buffer_size) return new JackAudioPort(this, patch_port); diff --git a/src/libs/engine/JackAudioDriver.h b/src/libs/engine/JackAudioDriver.h index a01624ed..abb74825 100644 --- a/src/libs/engine/JackAudioDriver.h +++ b/src/libs/engine/JackAudioDriver.h @@ -27,7 +27,7 @@ namespace Om { class Patch; class Port; -template <typename T> class TypedPort; +template <typename T> class DuplexPort; class JackAudioDriver; typedef jack_default_audio_sample_t jack_sample_t; @@ -39,7 +39,7 @@ typedef jack_default_audio_sample_t jack_sample_t; class JackAudioPort : public DriverPort, public ListNode<JackAudioPort*> { public: - JackAudioPort(JackAudioDriver* driver, TypedPort<sample>* patch_port); + JackAudioPort(JackAudioDriver* driver, DuplexPort<sample>* patch_port); ~JackAudioPort(); void add_to_driver(); @@ -51,7 +51,7 @@ public: jack_port_t* jack_port() const { return m_jack_port; } DriverBuffer<sample>* buffer() const { return m_jack_buffer; } void jack_buffer(jack_sample_t* s) { m_jack_buffer->set_data(s); } - TypedPort<sample>* patch_port() const { return m_patch_port; } + DuplexPort<sample>* patch_port() const { return m_patch_port; } private: // Prevent copies (undefined) @@ -61,7 +61,7 @@ private: JackAudioDriver* m_driver; jack_port_t* m_jack_port; DriverBuffer<sample>* m_jack_buffer; - TypedPort<sample>* m_patch_port; + DuplexPort<sample>* m_patch_port; }; @@ -88,7 +88,7 @@ public: void process_events(jack_nframes_t block_start, jack_nframes_t block_end); - DriverPort* create_port(TypedPort<sample>* patch_port); + DriverPort* create_port(DuplexPort<sample>* patch_port); Patch* root_patch() { return m_root_patch; } void set_root_patch(Patch* patch) { m_root_patch = patch; } diff --git a/src/libs/engine/JackMidiDriver.cpp b/src/libs/engine/JackMidiDriver.cpp index f55f0422..7c9ca9f4 100644 --- a/src/libs/engine/JackMidiDriver.cpp +++ b/src/libs/engine/JackMidiDriver.cpp @@ -26,7 +26,7 @@ #include "Maid.h" #include "AudioDriver.h" #include "MidiMessage.h" -#include "TypedPort.h" +#include "DuplexPort.h" #ifdef HAVE_LASH #include "LashDriver.h" #endif @@ -37,7 +37,7 @@ namespace Om { //// JackMidiPort //// -JackMidiPort::JackMidiPort(JackMidiDriver* driver, TypedPort<MidiMessage>* patch_port) +JackMidiPort::JackMidiPort(JackMidiDriver* driver, DuplexPort<MidiMessage>* patch_port) : DriverPort(), ListNode<JackMidiPort*>(this), m_driver(driver), @@ -115,7 +115,7 @@ JackMidiPort::prepare_block(const samplecount block_start, const samplecount blo //cerr << "Jack MIDI got " << event_count << " events." << endl; m_patch_port->buffer(0)->filled_size(event_count); - m_patch_port->tied_port()->buffer(0)->filled_size(event_count); + //m_patch_port->tied_port()->buffer(0)->filled_size(event_count); } diff --git a/src/libs/engine/JackMidiDriver.h b/src/libs/engine/JackMidiDriver.h index 33b4a0e1..f080833c 100644 --- a/src/libs/engine/JackMidiDriver.h +++ b/src/libs/engine/JackMidiDriver.h @@ -29,7 +29,7 @@ namespace Om { class Node; class SetPortValueEvent; class JackMidiDriver; -template <typename T> class TypedPort; +template <typename T> class DuplexPort; /** Representation of an JACK MIDI port. @@ -39,7 +39,7 @@ template <typename T> class TypedPort; class JackMidiPort : public DriverPort, public ListNode<JackMidiPort*> { public: - JackMidiPort(JackMidiDriver* driver, TypedPort<MidiMessage>* port); + JackMidiPort(JackMidiDriver* driver, DuplexPort<MidiMessage>* port); virtual ~JackMidiPort(); void prepare_block(const samplecount block_start, const samplecount block_end); @@ -48,16 +48,16 @@ public: void remove_from_driver(); void set_name(const string& name) { jack_port_set_name(m_jack_port, name.c_str()); }; - TypedPort<MidiMessage>* patch_port() const { return m_patch_port; } + DuplexPort<MidiMessage>* patch_port() const { return m_patch_port; } private: // Prevent copies (undefined) JackMidiPort(const JackMidiPort&); JackMidiPort& operator=(const JackMidiPort&); - JackMidiDriver* m_driver; - jack_port_t* m_jack_port; - TypedPort<MidiMessage>* m_patch_port; + JackMidiDriver* m_driver; + jack_port_t* m_jack_port; + DuplexPort<MidiMessage>* m_patch_port; }; @@ -84,7 +84,7 @@ public: void prepare_block(const samplecount block_start, const samplecount block_end); - JackMidiPort* create_port(TypedPort<MidiMessage>* patch_port) + JackMidiPort* create_port(DuplexPort<MidiMessage>* patch_port) { return new JackMidiPort(this, patch_port); } jack_client_t* jack_client() { return m_client; } diff --git a/src/libs/engine/Makefile.am b/src/libs/engine/Makefile.am index 09098e10..56b7724c 100644 --- a/src/libs/engine/Makefile.am +++ b/src/libs/engine/Makefile.am @@ -47,6 +47,8 @@ libom_la_SOURCES = \ InputPort.cpp \ OutputPort.h \ OutputPort.cpp \ + DuplexPort.h \ + DuplexPort.cpp \ MidiMessage.h \ MidiNoteNode.h \ MidiNoteNode.cpp \ @@ -76,8 +78,8 @@ libom_la_SOURCES = \ PostProcessor.cpp \ Connection.h \ Connection.cpp \ - ConnectionBase.h \ - ConnectionBase.cpp \ + TypedConnection.h \ + TypedConnection.cpp \ ObjectStore.h \ ObjectStore.cpp \ TransportNode.h \ diff --git a/src/libs/engine/MidiDriver.h b/src/libs/engine/MidiDriver.h index ed9d6e18..b037d52b 100644 --- a/src/libs/engine/MidiDriver.h +++ b/src/libs/engine/MidiDriver.h @@ -66,7 +66,7 @@ public: void enable() {} void disable() {} - DriverPort* create_port(TypedPort<MidiMessage>* patch_port) { return NULL; } + DriverPort* create_port(DuplexPort<MidiMessage>* patch_port) { return NULL; } void prepare_block(const samplecount block_start, const samplecount block_end) {} }; diff --git a/src/libs/engine/ObjectSender.cpp b/src/libs/engine/ObjectSender.cpp index 567beabe..354820f7 100644 --- a/src/libs/engine/ObjectSender.cpp +++ b/src/libs/engine/ObjectSender.cpp @@ -72,7 +72,7 @@ ObjectSender::send_patch(ClientInterface* client, const Patch* patch) // Control port, send value if (port->type() == DataType::FLOAT && port->buffer_size() == 1) - client->control_change(port->path(), ((TypedPort<sample>*)port)->buffer(0)->value_at(0)); + client->control_change(port->path(), dynamic_cast<TypedPort<sample>*>(port)->buffer(0)->value_at(0)); } // Send metadata diff --git a/src/libs/engine/OutputPort.cpp b/src/libs/engine/OutputPort.cpp index 35cb84b4..d713726a 100644 --- a/src/libs/engine/OutputPort.cpp +++ b/src/libs/engine/OutputPort.cpp @@ -28,22 +28,22 @@ OutputPort<T>::OutputPort(Node* parent, const string& name, size_t index, size_t template OutputPort<sample>::OutputPort(Node* parent, const string& name, size_t index, size_t poly, DataType type, size_t buffer_size); template OutputPort<MidiMessage>::OutputPort(Node* parent, const string& name, size_t index, size_t poly, DataType type, size_t buffer_size); - +#if 0 template<typename T> void OutputPort<T>::set_tied_port(InputPort<T>* port) { - assert(!m_is_tied); - assert(m_tied_port == NULL); + //assert(!m_is_tied); + //assert(m_tied_port == NULL); assert(static_cast<TypedPort<T>*>(port) != static_cast<TypedPort<T>*>(this)); assert(port != NULL); - m_is_tied = true; - m_tied_port = (TypedPort<T>*)port; + //m_is_tied = true; + //m_tied_port = (TypedPort<T>*)port; } template void OutputPort<sample>::set_tied_port(InputPort<sample>* port); template void OutputPort<MidiMessage>::set_tied_port(InputPort<MidiMessage>* port); - +#endif } // namespace Om diff --git a/src/libs/engine/OutputPort.h b/src/libs/engine/OutputPort.h index 269a4524..25a03325 100644 --- a/src/libs/engine/OutputPort.h +++ b/src/libs/engine/OutputPort.h @@ -39,7 +39,7 @@ template <typename T> class InputPort; * \ingroup engine */ template <typename T> -class OutputPort : public TypedPort<T> +class OutputPort : virtual public TypedPort<T> { public: OutputPort(Node* parent, const string& name, size_t index, size_t poly, DataType type, size_t buffer_size); @@ -55,8 +55,8 @@ private: OutputPort(const OutputPort& copy); OutputPort<T>& operator=(const OutputPort<T>&); - using TypedPort<T>::m_is_tied; - using TypedPort<T>::m_tied_port; + //using TypedPort<T>::m_is_tied; + //using TypedPort<T>::m_tied_port; }; diff --git a/src/libs/engine/Patch.cpp b/src/libs/engine/Patch.cpp index b24377e0..7d22c673 100644 --- a/src/libs/engine/Patch.cpp +++ b/src/libs/engine/Patch.cpp @@ -30,6 +30,7 @@ #include "ObjectStore.h" #include "InputPort.h" #include "OutputPort.h" +#include "DuplexPort.h" #include "interface/ClientInterface.h" using std::cerr; using std::cout; using std::endl; @@ -45,8 +46,8 @@ Patch::Patch(const string& path, size_t poly, Patch* parent, samplerate srate, s { assert(internal_poly >= 1); - _plugin.plug_label("om_patch"); - _plugin.name("Om Patch"); + //_plugin->plug_label("om_patch"); + //_plugin->name("Om Patch"); //std::cerr << "Creating patch " << _name << ", poly = " << poly // << ", internal poly = " << internal_poly << std::endl; @@ -110,10 +111,8 @@ Patch::process(bool p) assert((*i)->as_port() != NULL); if ((*i)->as_port()->port_info()->is_output()) (*i)->as_port()->clear_buffers();*/ - for (List<Port*>::iterator i = _patch_ports.begin(); i != _patch_ports.end(); ++i) { - if ((*i)->is_output()) - (*i)->clear_buffers(); - } + for (List<Port*>::iterator i = _output_ports.begin(); i != _output_ports.end(); ++i) + (*i)->clear_buffers(); } _process = p; } @@ -132,9 +131,8 @@ Patch::run(size_t nframes) // FIXME: This is far too slow, too much checking every cycle // Prepare input ports for nodes to consume - for (List<Port*>::iterator i = _patch_ports.begin(); i != _patch_ports.end(); ++i) - if ((*i)->is_input()) - (*i)->prepare_buffers(nframes); + for (List<Port*>::iterator i = _input_ports.begin(); i != _input_ports.end(); ++i) + (*i)->prepare_buffers(nframes); // Run all nodes (consume input ports) for (size_t i=0; i < _process_order->size(); ++i) { @@ -145,7 +143,7 @@ Patch::run(size_t nframes) } // Prepare output ports (for caller to consume) - for (List<Port*>::iterator i = _patch_ports.begin(); i != _patch_ports.end(); ++i) + for (List<Port*>::iterator i = _output_ports.begin(); i != _output_ports.end(); ++i) if ((*i)->is_output()) (*i)->prepare_buffers(nframes); } @@ -299,10 +297,11 @@ Patch::create_port(const string& name, DataType type, size_t buffer_size, bool i assert( !(type == DataType::UNKNOWN) ); - if (is_output) - return new OutputPort<MidiMessage>(this, name, 0, _poly, type, buffer_size); - else - return new InputPort<MidiMessage>(this, name, 0, _poly, type, buffer_size); + // FIXME: is it possible to just "pass" the type directly as the template parameter somehow? + if (type == DataType::FLOAT) + return new DuplexPort<sample>(this, name, 0, _poly, type, buffer_size, is_output); + else if (type == DataType::MIDI) + return new DuplexPort<MidiMessage>(this, name, 0, _poly, type, buffer_size, is_output); } @@ -313,9 +312,17 @@ Patch::remove_port(const Port* port) { bool found = false; ListNode<Port*>* ret = NULL; - for (List<Port*>::iterator i = _patch_ports.begin(); i != _patch_ports.end(); ++i) { + for (List<Port*>::iterator i = _input_ports.begin(); i != _input_ports.end(); ++i) { + if ((*i) == port) { + ret = _input_ports.remove(i); + found = true; + } + } + + if (!found) + for (List<Port*>::iterator i = _output_ports.begin(); i != _output_ports.end(); ++i) { if ((*i) == port) { - ret = _patch_ports.remove(i); + ret = _output_ports.remove(i); found = true; } } @@ -347,7 +354,7 @@ Patch::build_process_order() const (*i)->traversed(false); // Traverse backwards starting at outputs - for (List<Port*>::const_iterator p = _patch_ports.begin(); p != _patch_ports.end(); ++p) { + for (List<Port*>::const_iterator p = _output_ports.begin(); p != _output_ports.end(); ++p) { /*const Port* const port = (*p); if (port->port_info()->is_output()) { for (List<Connection*>::const_iterator c = port->connections().begin(); diff --git a/src/libs/engine/Patch.h b/src/libs/engine/Patch.h index edde636e..f0e06368 100644 --- a/src/libs/engine/Patch.h +++ b/src/libs/engine/Patch.h @@ -74,10 +74,9 @@ public: const List<Node*>& nodes() const { return _nodes; } const List<Connection*>& connections() const { return _connections; } - //void add_bridge_node(ListNode<InternalNode*>* n) { _bridge_nodes.push_back(n); } - //ListNode<InternalNode*>* remove_bridge_node(const InternalNode* n); Port* create_port(const string& name, DataType type, size_t buffer_size, bool is_output); - void add_port(ListNode<Port*>* port) { _patch_ports.push_back(port); } + void add_input(ListNode<Port*>* port) { _input_ports.push_back(port); } ///< Preprocesser thread + void add_output(ListNode<Port*>* port) { _output_ports.push_back(port); } ///< Preprocessor thread ListNode<Port*>* remove_port(const Port* p); void add_connection(ListNode<Connection*>* c) { _connections.push_back(c); } @@ -96,8 +95,6 @@ public: void process(bool p); size_t internal_poly() const { return _internal_poly; } - - const Plugin* plugin() const { return &_plugin; } private: // Prevent copies (undefined) @@ -109,11 +106,10 @@ private: size_t _internal_poly; Array<Node*>* _process_order; ///< Accessed in audio thread only List<Connection*> _connections; ///< Accessed in audio thread only - List<Port*> _patch_ports; ///< Accessed in preprocessing thread only + List<Port*> _input_ports; ///< Accessed in preprocessing thread only + List<Port*> _output_ports; ///< Accessed in preprocessing thread only List<Node*> _nodes; ///< Accessed in preprocessing thread only bool _process; - - Plugin _plugin; }; diff --git a/src/libs/engine/ConnectionBase.cpp b/src/libs/engine/TypedConnection.cpp index c8936818..ccfd36a1 100644 --- a/src/libs/engine/ConnectionBase.cpp +++ b/src/libs/engine/TypedConnection.cpp @@ -14,7 +14,7 @@ * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ -#include "ConnectionBase.h" +#include "TypedConnection.h" #include "util.h" #include "InputPort.h" #include "OutputPort.h" @@ -31,7 +31,7 @@ namespace Om { * user (InputPort). */ template <typename T> -ConnectionBase<T>::ConnectionBase(OutputPort<T>* const src_port, InputPort<T>* const dst_port) +TypedConnection<T>::TypedConnection(OutputPort<T>* const src_port, InputPort<T>* const dst_port) : Connection(src_port, dst_port), m_local_buffer(NULL), m_is_poly_to_mono( (src_port->parent_node()->poly() > dst_port->parent_node()->poly()) ), @@ -44,22 +44,22 @@ ConnectionBase<T>::ConnectionBase(OutputPort<T>* const src_port, InputPort<T>* c if (m_is_poly_to_mono) // Poly -> Mono connection, need a buffer to mix in to m_local_buffer = new Buffer<T>(m_buffer_size); } -template ConnectionBase<sample>::ConnectionBase(OutputPort<sample>* const src_port, InputPort<sample>* const dst_port); -template ConnectionBase<MidiMessage>::ConnectionBase(OutputPort<MidiMessage>* const src_port, InputPort<MidiMessage>* const dst_port); +template TypedConnection<sample>::TypedConnection(OutputPort<sample>* const src_port, InputPort<sample>* const dst_port); +template TypedConnection<MidiMessage>::TypedConnection(OutputPort<MidiMessage>* const src_port, InputPort<MidiMessage>* const dst_port); template <typename T> -ConnectionBase<T>::~ConnectionBase() +TypedConnection<T>::~TypedConnection() { delete m_local_buffer; } -template ConnectionBase<sample>::~ConnectionBase(); -template ConnectionBase<MidiMessage>::~ConnectionBase(); +template TypedConnection<sample>::~TypedConnection(); +template TypedConnection<MidiMessage>::~TypedConnection(); template <typename sample> void -ConnectionBase<sample>::prepare_buffers() +TypedConnection<sample>::prepare_buffers() { /* Thought: A poly output port can be connected to multiple mono input * ports, which means this mix down would have to happen many times. @@ -81,13 +81,13 @@ ConnectionBase<sample>::prepare_buffers() m_local_buffer->scale(1.0f/(float)src_port()->poly(), 0, m_buffer_size-1); } } -template void ConnectionBase<sample>::prepare_buffers(); +template void TypedConnection<sample>::prepare_buffers(); // FIXME: MIDI mixing not implemented template <> void -ConnectionBase<MidiMessage>::prepare_buffers() +TypedConnection<MidiMessage>::prepare_buffers() { } diff --git a/src/libs/engine/ConnectionBase.h b/src/libs/engine/TypedConnection.h index 80d7bd84..953c77e9 100644 --- a/src/libs/engine/ConnectionBase.h +++ b/src/libs/engine/TypedConnection.h @@ -14,8 +14,8 @@ * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ -#ifndef CONNECTIONBASE_H -#define CONNECTIONBASE_H +#ifndef TYPEDCONNECTION_H +#define TYPEDCONNECTION_H #include "types.h" #include "OutputPort.h" @@ -33,23 +33,23 @@ template <typename T> class InputPort; * \ingroup engine */ template <typename T> -class ConnectionBase : public Connection +class TypedConnection : public Connection { public: - ConnectionBase(OutputPort<T>* const src_port, InputPort<T>* const dst_port); - virtual ~ConnectionBase(); + TypedConnection(OutputPort<T>* const src_port, InputPort<T>* const dst_port); + virtual ~TypedConnection(); void prepare_buffers(); - inline OutputPort<T>* src_port() const { return (OutputPort<T>*)m_src_port; } - inline InputPort<T>* dst_port() const { return (InputPort<T>*)m_dst_port; } + inline OutputPort<T>* src_port() const { return dynamic_cast<OutputPort<T>*>(m_src_port); } + inline InputPort<T>* dst_port() const { return dynamic_cast<InputPort<T>*>(m_dst_port); } /** Used by some (recursive) events to prevent double disconnections */ bool pending_disconnection() { return m_pending_disconnection; } void pending_disconnection(bool b) { m_pending_disconnection = b; } /** Get the buffer for a particular voice. - * A ConnectionBase is smart - it knows the destination port respondering the + * A TypedConnection is smart - it knows the destination port respondering the * buffer, and will return accordingly (ie the same buffer for every voice * in a mono->poly connection). */ @@ -57,8 +57,8 @@ public: private: // Disallow copies (undefined) - ConnectionBase(const ConnectionBase& copy); - ConnectionBase& operator=(const ConnectionBase&); + TypedConnection(const TypedConnection& copy); + TypedConnection& operator=(const TypedConnection&); Buffer<T>* m_local_buffer; ///< Only used for poly->mono connections bool m_is_poly_to_mono; @@ -69,7 +69,7 @@ private: template <> inline Buffer<sample>* -ConnectionBase<sample>::buffer(size_t voice) const +TypedConnection<sample>::buffer(size_t voice) const { TypedPort<sample>* const src_port = (TypedPort<sample>*)m_src_port; @@ -86,7 +86,7 @@ ConnectionBase<sample>::buffer(size_t voice) const template <> inline Buffer<MidiMessage>* -ConnectionBase<MidiMessage>::buffer(size_t voice) const +TypedConnection<MidiMessage>::buffer(size_t voice) const { // No such thing as polyphonic MIDI ports assert(m_src_port->poly() == 1); @@ -97,9 +97,9 @@ ConnectionBase<MidiMessage>::buffer(size_t voice) const } -template class ConnectionBase<sample>; -template class ConnectionBase<MidiMessage>; +template class TypedConnection<sample>; +template class TypedConnection<MidiMessage>; } // namespace Om -#endif // CONNECTIONBASE_H +#endif // TYPEDCONNECTION_H diff --git a/src/libs/engine/TypedPort.cpp b/src/libs/engine/TypedPort.cpp index 0ebb05eb..4fb1dfa7 100644 --- a/src/libs/engine/TypedPort.cpp +++ b/src/libs/engine/TypedPort.cpp @@ -31,10 +31,10 @@ namespace Om { */ template <typename T> TypedPort<T>::TypedPort(Node* parent, const string& name, size_t index, size_t poly, DataType type, size_t buffer_size) -: Port(parent, name, index, poly, type, buffer_size), - m_fixed_buffers(false), - m_is_tied(false), - m_tied_port(NULL) +: Port(parent, name, index, poly, type, buffer_size) +, m_fixed_buffers(false) +/*, m_is_tied(false) +, m_tied_port(NULL)*/ { allocate_buffers(); clear_buffers(); diff --git a/src/libs/engine/TypedPort.h b/src/libs/engine/TypedPort.h index e2ccaff4..332741a6 100644 --- a/src/libs/engine/TypedPort.h +++ b/src/libs/engine/TypedPort.h @@ -14,8 +14,8 @@ * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ -#ifndef PORTBASE_H -#define PORTBASE_H +#ifndef TYPEDPORT_H +#define TYPEDPORT_H #include <string> #include "types.h" @@ -52,8 +52,8 @@ public: virtual void prepare_buffers(size_t nframes); virtual void clear_buffers(); - TypedPort* tied_port() const { return m_tied_port; } - void untie() { m_is_tied = false; m_tied_port = NULL; } + //TypedPort* tied_port() const { return m_tied_port; } + //void untie() { m_is_tied = false; m_tied_port = NULL; } /** Used by drivers to prevent port from changing buffers */ void fixed_buffers(bool b) { m_fixed_buffers = b; } @@ -68,9 +68,9 @@ protected: void allocate_buffers(); - bool m_fixed_buffers; - bool m_is_tied; - TypedPort* m_tied_port; + bool m_fixed_buffers; + //bool m_is_tied; + //TypedPort* m_tied_port; Array<Buffer<T>*> m_buffers; }; @@ -81,4 +81,4 @@ template class TypedPort<MidiMessage>; } // namespace Om -#endif // PORTBASE_H +#endif // TYPEDPORT_H diff --git a/src/libs/engine/events/ConnectionEvent.cpp b/src/libs/engine/events/ConnectionEvent.cpp index fcfa3bbc..1d5b3ba1 100644 --- a/src/libs/engine/events/ConnectionEvent.cpp +++ b/src/libs/engine/events/ConnectionEvent.cpp @@ -19,7 +19,7 @@ #include "Responder.h" #include "Om.h" #include "OmApp.h" -#include "ConnectionBase.h" +#include "TypedConnection.h" #include "InputPort.h" #include "OutputPort.h" #include "Patch.h" @@ -58,7 +58,9 @@ ConnectionEvent::~ConnectionEvent() void ConnectionEvent::pre_process() { - if (m_src_port_path.parent().parent() != m_dst_port_path.parent().parent()) { + if (m_src_port_path.parent().parent() != m_dst_port_path.parent().parent() + && m_src_port_path.parent() != m_dst_port_path.parent().parent() + && m_src_port_path.parent().parent() != m_dst_port_path.parent()) { m_error = PARENT_PATCH_DIFFERENT; QueuedEvent::pre_process(); return; @@ -72,22 +74,22 @@ ConnectionEvent::pre_process() return; }*/ - Port* port1 = om->object_store()->find_port(m_src_port_path); - Port* port2 = om->object_store()->find_port(m_dst_port_path); + m_src_port = om->object_store()->find_port(m_src_port_path); + m_dst_port = om->object_store()->find_port(m_dst_port_path); - if (port1 == NULL || port2 == NULL) { + if (m_src_port == NULL || m_dst_port == NULL) { m_error = PORT_NOT_FOUND; QueuedEvent::pre_process(); return; } - if (port1->type() != port2->type()) { + if (m_src_port->type() != m_dst_port->type() || m_src_port->buffer_size() != m_dst_port->buffer_size()) { m_error = TYPE_MISMATCH; QueuedEvent::pre_process(); return; } - if (port1->is_output() && port2->is_input()) { + /*if (port1->is_output() && port2->is_input()) { m_src_port = port1; m_dst_port = port2; } else if (port2->is_output() && port1->is_input()) { @@ -97,16 +99,16 @@ ConnectionEvent::pre_process() m_error = TYPE_MISMATCH; QueuedEvent::pre_process(); return; - } + }*/ // Create the typed event to actually do the work - const DataType type = port1->type(); + const DataType type = m_src_port->type(); if (type == DataType::FLOAT) { m_typed_event = new TypedConnectionEvent<sample>(m_responder, - (OutputPort<sample>*)m_src_port, (InputPort<sample>*)m_dst_port); + 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, - (OutputPort<MidiMessage>*)m_src_port, (InputPort<MidiMessage>*)m_dst_port); + dynamic_cast<OutputPort<MidiMessage>*>(m_src_port), dynamic_cast<InputPort<MidiMessage>*>(m_dst_port)); } else { m_error = TYPE_MISMATCH; QueuedEvent::pre_process(); @@ -177,23 +179,37 @@ TypedConnectionEvent<T>::pre_process() { Node* const src_node = m_src_port->parent_node(); Node* const dst_node = m_dst_port->parent_node(); - - m_patch = src_node->parent_patch(); + + if (src_node->parent_patch() != dst_node->parent_patch()) { + // Connection to a patch port from inside the patch + assert(src_node->parent() == dst_node || dst_node->parent() == src_node); + if (src_node->parent() == dst_node) + m_patch = dynamic_cast<Patch*>(dst_node); + else + m_patch = dynamic_cast<Patch*>(src_node); + } else { + // Normal connection between nodes with the same parent + m_patch = src_node->parent_patch(); + } + + assert(m_patch); if (src_node == NULL || dst_node == NULL) { + cerr << "ERR 1\n"; m_succeeded = false; QueuedEvent::pre_process(); return; } - if (src_node->parent() != m_patch || dst_node->parent() != m_patch) { + if (src_node->parent() != m_patch && dst_node->parent() != m_patch) { + cerr << "ERR 2\n"; m_succeeded = false; QueuedEvent::pre_process(); return; } - m_connection = new ConnectionBase<T>(m_src_port, m_dst_port); - m_port_listnode = new ListNode<ConnectionBase<T>*>(m_connection); + m_connection = new TypedConnection<T>(m_src_port, m_dst_port); + m_port_listnode = new ListNode<TypedConnection<T>*>(m_connection); m_patch_listnode = new ListNode<Connection*>(m_connection); dst_node->providers()->push_back(new ListNode<Node*>(src_node)); diff --git a/src/libs/engine/events/ConnectionEvent.h b/src/libs/engine/events/ConnectionEvent.h index 369a3903..e2a50d53 100644 --- a/src/libs/engine/events/ConnectionEvent.h +++ b/src/libs/engine/events/ConnectionEvent.h @@ -33,7 +33,7 @@ class Node; class Connection; class MidiMessage; class Port; -template <typename T> class ConnectionBase; +template <typename T> class TypedConnection; template <typename T> class InputPort; template <typename T> class OutputPort; template <typename T> class TypedConnectionEvent; // helper, defined below @@ -93,9 +93,9 @@ private: Patch* m_patch; Array<Node*>* m_process_order; ///< New process order for Patch - ConnectionBase<T>* m_connection; + TypedConnection<T>* m_connection; ListNode<Connection*>* m_patch_listnode; - ListNode<ConnectionBase<T>*>* m_port_listnode; + ListNode<TypedConnection<T>*>* m_port_listnode; bool m_succeeded; }; diff --git a/src/libs/engine/events/DisconnectNodeEvent.cpp b/src/libs/engine/events/DisconnectNodeEvent.cpp index 4c4e19a7..e430acc5 100644 --- a/src/libs/engine/events/DisconnectNodeEvent.cpp +++ b/src/libs/engine/events/DisconnectNodeEvent.cpp @@ -22,7 +22,7 @@ #include "Maid.h" #include "List.h" #include "Node.h" -#include "ConnectionBase.h" +#include "TypedConnection.h" #include "DisconnectionEvent.h" #include "Port.h" #include "Array.h" diff --git a/src/libs/engine/events/DisconnectNodeEvent.h b/src/libs/engine/events/DisconnectNodeEvent.h index a82fbaec..4bcbdf94 100644 --- a/src/libs/engine/events/DisconnectNodeEvent.h +++ b/src/libs/engine/events/DisconnectNodeEvent.h @@ -29,7 +29,7 @@ class DisconnectionEvent; class Patch; class Node; class Connection; -template <typename T> class ConnectionBase; +template <typename T> class TypedConnection; class Port; template <typename T> class InputPort; template <typename T> class OutputPort; diff --git a/src/libs/engine/events/DisconnectionEvent.cpp b/src/libs/engine/events/DisconnectionEvent.cpp index 0a3a4f7b..34570537 100644 --- a/src/libs/engine/events/DisconnectionEvent.cpp +++ b/src/libs/engine/events/DisconnectionEvent.cpp @@ -19,7 +19,7 @@ #include "Responder.h" #include "Om.h" #include "OmApp.h" -#include "ConnectionBase.h" +#include "TypedConnection.h" #include "InputPort.h" #include "OutputPort.h" #include "Patch.h" @@ -124,10 +124,10 @@ DisconnectionEvent::pre_process() const DataType type = m_src_port->type(); if (type == DataType::FLOAT) { m_typed_event = new TypedDisconnectionEvent<sample>(m_responder, - (OutputPort<sample>*)m_src_port, (InputPort<sample>*)m_dst_port); + 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, - (OutputPort<MidiMessage>*)m_src_port, (InputPort<MidiMessage>*)m_dst_port); + dynamic_cast<OutputPort<MidiMessage>*>(m_src_port), dynamic_cast<InputPort<MidiMessage>*>(m_dst_port)); } else { m_error = TYPE_MISMATCH; QueuedEvent::pre_process(); @@ -250,7 +250,7 @@ TypedDisconnectionEvent<T>::execute(samplecount offset) { if (m_succeeded) { - ListNode<ConnectionBase<T>*>* const port_connection + ListNode<TypedConnection<T>*>* const port_connection = m_dst_port->remove_connection(m_src_port); if (port_connection != NULL) { diff --git a/src/libs/engine/events/DisconnectionEvent.h b/src/libs/engine/events/DisconnectionEvent.h index 77d4aabe..445815dd 100644 --- a/src/libs/engine/events/DisconnectionEvent.h +++ b/src/libs/engine/events/DisconnectionEvent.h @@ -33,7 +33,7 @@ class Node; class Connection; class MidiMessage; class Port; -template <typename T> class ConnectionBase; +template <typename T> class TypedConnection; template <typename T> class InputPort; template <typename T> class OutputPort; template <typename T> class TypedDisconnectionEvent; // helper, defined below |