summaryrefslogtreecommitdiffstats
path: root/src/engine/InputPort.cpp
diff options
context:
space:
mode:
authorDavid Robillard <d@drobilla.net>2006-06-10 01:52:02 +0000
committerDavid Robillard <d@drobilla.net>2006-06-10 01:52:02 +0000
commit98fe0e7056e6697396249531785d3899f94d79be (patch)
tree233319008d4bfb6c8bdc546bdf4a81b87ecf7f3a /src/engine/InputPort.cpp
parent6c8eaee73b0ea66216744f49b452e22e26fe83e1 (diff)
downloadingen-98fe0e7056e6697396249531785d3899f94d79be.tar.gz
ingen-98fe0e7056e6697396249531785d3899f94d79be.tar.bz2
ingen-98fe0e7056e6697396249531785d3899f94d79be.zip
More juggling
git-svn-id: http://svn.drobilla.net/lad/grauph@15 a436a847-0d15-0410-975c-d299462d15a1
Diffstat (limited to 'src/engine/InputPort.cpp')
-rw-r--r--src/engine/InputPort.cpp352
1 files changed, 0 insertions, 352 deletions
diff --git a/src/engine/InputPort.cpp b/src/engine/InputPort.cpp
deleted file mode 100644
index 3837da1b..00000000
--- a/src/engine/InputPort.cpp
+++ /dev/null
@@ -1,352 +0,0 @@
-/* This file is part of Om. 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.,
- * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
- */
-
-#include "InputPort.h"
-#include <iostream>
-#include <cstdlib>
-#include <cassert>
-#include "ConnectionBase.h"
-#include "OutputPort.h"
-#include "PortInfo.h"
-#include "Node.h"
-#include "Om.h"
-#include "util.h"
-
-using std::cerr; using std::cout; using std::endl;
-
-
-namespace Om {
-
-
-template <typename T>
-InputPort<T>::InputPort(Node* node, const string& name, size_t index, size_t poly, PortInfo* port_info, size_t buffer_size)
-: PortBase<T>(node, name, index, poly, port_info, buffer_size)
-{
- assert(port_info->is_input() && !port_info->is_output());
-}
-template InputPort<sample>::InputPort(Node* node, const string& name, size_t index, size_t poly, PortInfo* port_info, size_t buffer_size);
-template InputPort<MidiMessage>::InputPort(Node* node, const string& name, size_t index, size_t poly, PortInfo* port_info, size_t buffer_size);
-
-
-/** Add a connection. Realtime safe.
- *
- * The buffer of this port will be set directly to the connection's buffer
- * if there is only one connection, since no mixing needs to take place.
- */
-template<typename T>
-void
-InputPort<T>::add_connection(ListNode<ConnectionBase<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) {
- if (m_connections.size() == 1) {
- // Use buffer directly to avoid copying
- for (size_t i=0; i < m_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));
- assert(m_buffers.at(i)->data() == c->elem()->buffer(i)->data());
- }
- } else if (m_connections.size() == 2) {
- // Used to directly use single connection buffer, now there's two
- // so have to use local ones again and mix down
- for (size_t i=0; i < m_poly; ++i) {
- m_buffers.at(i)->unjoin();
- 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());
-}
-template void InputPort<sample>::add_connection(ListNode<ConnectionBase<sample>*>* const c);
-template void InputPort<MidiMessage>::add_connection(ListNode<ConnectionBase<MidiMessage>*>* const c);
-
-
-/** Remove a connection. Realtime safe.
- */
-template <typename T>
-ListNode<ConnectionBase<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();
-
- typedef typename List<ConnectionBase<T>*>::iterator ConnectionBaseListIterator;
- bool found = false;
- ListNode<ConnectionBase<T>*>* connection = NULL;
- for (ConnectionBaseListIterator i = m_connections.begin(); i != m_connections.end(); ++i) {
- if ((*i)->src_port()->path() == src_port->path()) {
- connection = m_connections.remove(i);
- found = true;
- }
- }
-
- if ( ! found) {
- cerr << "WARNING: [InputPort<T>::remove_connection] Connection not found !" << endl;
- exit(EXIT_FAILURE);
- } else {
- if (m_connections.size() == 0) {
- for (size_t i=0; i < m_poly; ++i) {
- // Use a local buffer
- 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));
- }
- } else if (modify_buffers && m_connections.size() == 1) {
- // Share a buffer
- for (size_t i=0; i < m_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 (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());
-
- return connection;
-}
-template ListNode<ConnectionBase<sample>*>*
-InputPort<sample>::remove_connection(const OutputPort<sample>* const src_port);
-template ListNode<ConnectionBase<MidiMessage>*>*
-InputPort<MidiMessage>::remove_connection(const OutputPort<MidiMessage>* const src_port);
-
-
-/** Update any changed buffers with the plugin this is a port on.
- *
- * This calls ie the LADSPA connect_port function when buffers have been changed
- * due to a connection or disconnection.
- */
-template <typename T>
-void
-InputPort<T>::update_buffers()
-{
- for (size_t i=0; i < m_poly; ++i)
- InputPort<T>::parent_node()->set_port_buffer(i, m_index, m_buffers.at(i)->data());
-}
-template void InputPort<sample>::update_buffers();
-template void InputPort<MidiMessage>::update_buffers();
-
-
-/** Returns whether this port is connected to the passed port.
- */
-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)
- if ((*i)->src_port() == port)
- return true;
-
- return false;
-}
-template bool InputPort<sample>::is_connected_to(const OutputPort<sample>* const port) const;
-template bool InputPort<MidiMessage>::is_connected_to(const OutputPort<MidiMessage>* const port) const;
-
-
-/** "Ties" this port to an OutputPort, so they share the same buffer.
- *
- * 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)
-{
- assert((Port*)port != (Port*)this);
- assert(port->poly() == this->poly());
- assert(!m_is_tied);
- assert(m_tied_port == NULL);
-
- if (Port::parent_node() != NULL) {
- assert(m_poly == port->poly());
-
- for (size_t i=0; i < m_poly; ++i)
- port->buffer(i)->join(m_buffers.at(i));
- }
- m_is_tied = true;
- m_tied_port = port;
- port->set_tied_port(this);
-
- assert(m_buffers.at(0)->data() == port->buffer(0)->data());
-
- //cerr << "*** Tied " << this->path() << " <-> " << port->path() << endl;
-}
-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,
- */
-template<>
-void
-InputPort<sample>::prepare_buffers(size_t nframes)
-{
- assert(!m_is_tied || m_tied_port != NULL);
-
- typedef List<ConnectionBase<sample>*>::iterator ConnectionBaseListIterator;
- bool do_mixdown = true;
-
- if (m_connections.size() == 0) return;
-
- for (ConnectionBaseListIterator 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())) {
- // 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));
- do_mixdown = false;
- }
- } else {
- do_mixdown = false;
- }
- update_buffers();
- }
-
- if (!do_mixdown) {
- assert(m_buffers.at(0)->data() == (*m_connections.begin())->buffer(0)->data());
- return;
- }
-
- 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 < m_poly; ++voice) {
- m_buffers.at(voice)->copy((*m_connections.begin())->buffer(voice), 0, m_buffer_size-1);
-
- if (m_connections.size() > 1) {
- // Copy first connection
- ConnectionBaseListIterator c = m_connections.begin();
-
- // Add all other connections
- for (++c; c != m_connections.end(); ++c)
- m_buffers.at(voice)->accumulate((*c)->buffer(voice), 0, m_buffer_size-1);
- }
- }
-}
-
-
-/** Prepare buffer for access, realtime safe.
- *
- * MIDI mixing not yet implemented.
- */
-template <>
-void
-InputPort<MidiMessage>::prepare_buffers(size_t nframes)
-{
- 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;
- assert(m_poly == 1);
-
- for (ConnectionBaseListIterator c = m_connections.begin(); c != m_connections.end(); ++c)
- (*c)->prepare_buffers();
-
-
- // If only one connection, buffer is used directly (no copying)
- 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())) {
- // 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));
- 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(do_mixdown || m_buffers.at(0)->filled_size() ==
- (*m_connections.begin())->src_port()->buffer(0)->filled_size());
- }
-
- // Get valid buffer size from inbound connections, unless a port on a top-level
- // patch (which will be fed by the MidiDriver)
- if (m_parent->parent() != NULL) {
- if (num_ins == 1) {
- 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());
-
- assert(m_buffers.at(0)->filled_size() ==
- (*m_connections.begin())->src_port()->buffer(0)->filled_size());
- } else {
- // Mixing not implemented
- m_buffers.at(0)->clear();
- }
- }
-
- 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;
-
- //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());
-
- if (num_ins > 0)
- for (size_t i=0; i < m_buffers.at(0)->filled_size(); ++i)
- m_buffers.at(0)[i] = (*m_connections.begin())->buffer(0)[i];
-}
-
-
-} // namespace Om
-