summaryrefslogtreecommitdiffstats
path: root/src/engine/JackMidiDriver.cpp
diff options
context:
space:
mode:
authorDavid Robillard <d@drobilla.net>2006-06-09 15:07:31 +0000
committerDavid Robillard <d@drobilla.net>2006-06-09 15:07:31 +0000
commitacbda29f838280ba98cf9e9e539e9d8a6e8fc6ad (patch)
treee31b37a2456e6d1e564c9a7146c88be259d338b0 /src/engine/JackMidiDriver.cpp
downloadingen-acbda29f838280ba98cf9e9e539e9d8a6e8fc6ad.tar.gz
ingen-acbda29f838280ba98cf9e9e539e9d8a6e8fc6ad.tar.bz2
ingen-acbda29f838280ba98cf9e9e539e9d8a6e8fc6ad.zip
Added Om aka Graph aka god knows what
git-svn-id: http://svn.drobilla.net/lad/grauph@9 a436a847-0d15-0410-975c-d299462d15a1
Diffstat (limited to 'src/engine/JackMidiDriver.cpp')
-rw-r--r--src/engine/JackMidiDriver.cpp217
1 files changed, 217 insertions, 0 deletions
diff --git a/src/engine/JackMidiDriver.cpp b/src/engine/JackMidiDriver.cpp
new file mode 100644
index 00000000..40054b8a
--- /dev/null
+++ b/src/engine/JackMidiDriver.cpp
@@ -0,0 +1,217 @@
+/* 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 "JackMidiDriver.h"
+#include <iostream>
+#include <cstdlib>
+#include <pthread.h>
+#include "Om.h"
+#include "OmApp.h"
+#include "util/types.h"
+#include "midi.h"
+#include "OmApp.h"
+#include "Maid.h"
+#include "AudioDriver.h"
+#include "MidiInputNode.h"
+#include "PortInfo.h"
+#include "MidiMessage.h"
+#include "PortBase.h"
+#ifdef HAVE_LASH
+#include "LashDriver.h"
+#endif
+using std::cout; using std::cerr; using std::endl;
+
+namespace Om {
+
+
+//// JackMidiPort ////
+
+JackMidiPort::JackMidiPort(JackMidiDriver* driver, PortBase<MidiMessage>* patch_port)
+: DriverPort(),
+ ListNode<JackMidiPort*>(this),
+ m_driver(driver),
+ m_jack_port(NULL),
+ m_patch_port(patch_port)
+{
+ assert(patch_port->poly() == 1);
+
+ m_jack_port = jack_port_register(m_driver->jack_client(),
+ patch_port->path().c_str(), JACK_DEFAULT_MIDI_TYPE,
+ (patch_port->port_info()->is_input()) ? JackPortIsInput : JackPortIsOutput,
+ 0);
+
+ patch_port->buffer(0)->clear();
+ patch_port->fixed_buffers(true);
+}
+
+
+JackMidiPort::~JackMidiPort()
+{
+ jack_port_unregister(m_driver->jack_client(), m_jack_port);
+}
+
+
+void
+JackMidiPort::add_to_driver()
+{
+ m_driver->add_port(this);
+}
+
+
+void
+JackMidiPort::remove_from_driver()
+{
+ m_driver->remove_port(this);
+}
+
+
+/** Prepare events for a block.
+ *
+ * This is basically trivial (as opposed to AlsaMidiPort) since Jack MIDI
+ * data is in-band with the audio thread.
+ *
+ * Prepares all events that occurred during the time interval passed
+ * (which ideally are the events from the previous cycle with an exact
+ * 1 cycle delay).
+ */
+void
+JackMidiPort::prepare_block(const samplecount block_start, const samplecount block_end)
+{
+ assert(block_end >= block_start);
+
+ const samplecount nframes = block_end - block_start;
+ void* jack_buffer = jack_port_get_buffer(m_jack_port, nframes);
+ const jack_nframes_t event_count = jack_midi_port_get_info(jack_buffer, nframes)->event_count;
+
+ assert(event_count < m_patch_port->buffer_size());
+
+ // Copy events from Jack port buffer into patch port buffer
+ for (jack_nframes_t i=0; i < event_count; ++i) {
+ jack_midi_event_t* ev = (jack_midi_event_t*)&m_patch_port->buffer(0)->value_at(i);
+ jack_midi_event_get(ev, jack_buffer, i, nframes);
+
+ // Convert note ons with velocity 0 to proper note offs
+ if (ev->buffer[0] == MIDI_CMD_NOTE_ON && ev->buffer[2] == 0)
+ ev->buffer[0] = MIDI_CMD_NOTE_OFF;
+
+ // MidiMessage and jack_midi_event_t* are the same thing :/
+ MidiMessage* const message = &m_patch_port->buffer(0)->data()[i];
+ message->time = ev->time;
+ message->size = ev->size;
+ message->buffer = ev->buffer;
+ }
+
+ //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);
+}
+
+
+
+//// JackMidiDriver ////
+
+
+bool JackMidiDriver::m_midi_thread_exit_flag = true;
+
+
+JackMidiDriver::JackMidiDriver(jack_client_t* client)
+: m_client(client),
+ m_is_activated(false),
+ m_is_enabled(false)
+{
+}
+
+
+JackMidiDriver::~JackMidiDriver()
+{
+ deactivate();
+}
+
+
+/** Launch and start the MIDI thread.
+ */
+void
+JackMidiDriver::activate()
+{
+ m_is_activated = true;
+}
+
+
+/** Terminate the MIDI thread.
+ */
+void
+JackMidiDriver::deactivate()
+{
+ m_is_activated = false;
+}
+
+
+/** Build flat arrays of events for DSSI plugins for each Port.
+ */
+void
+JackMidiDriver::prepare_block(const samplecount block_start, const samplecount block_end)
+{
+ for (List<JackMidiPort*>::iterator i = m_in_ports.begin(); i != m_in_ports.end(); ++i)
+ (*i)->prepare_block(block_start, block_end);
+}
+
+
+/** Add an Jack MIDI port.
+ *
+ * Realtime safe, this is to be called at the beginning of a process cycle to
+ * insert (and actually begin using) a new port.
+ *
+ * See create_port() and remove_port().
+ */
+void
+JackMidiDriver::add_port(JackMidiPort* port)
+{
+ if (port->patch_port()->port_info()->is_input())
+ m_in_ports.push_back(port);
+ else
+ m_out_ports.push_back(port);
+}
+
+
+/** Remove an Jack MIDI port.
+ *
+ * Realtime safe. This is to be called at the beginning of a process cycle to
+ * remove the port from the lists read by the audio thread, so the port
+ * will no longer be used and can be removed afterwards.
+ *
+ * It is the callers responsibility to delete the returned port.
+ */
+JackMidiPort*
+JackMidiDriver::remove_port(JackMidiPort* port)
+{
+ if (port->patch_port()->port_info()->is_input()) {
+ for (List<JackMidiPort*>::iterator i = m_in_ports.begin(); i != m_in_ports.end(); ++i)
+ if ((*i) == (JackMidiPort*)port)
+ return m_in_ports.remove(i)->elem();
+ } else {
+ for (List<JackMidiPort*>::iterator i = m_out_ports.begin(); i != m_out_ports.end(); ++i)
+ if ((*i) == port)
+ return m_out_ports.remove(i)->elem();
+ }
+
+ cerr << "[JackMidiDriver::remove_input] WARNING: Failed to find Jack port to remove!" << endl;
+ return NULL;
+}
+
+
+} // namespace Om
+