diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/JackDriver.cpp | 209 | ||||
| -rw-r--r-- | src/Makefile.am | 5 |
2 files changed, 213 insertions, 1 deletions
diff --git a/src/JackDriver.cpp b/src/JackDriver.cpp new file mode 100644 index 0000000..0bbc24b --- /dev/null +++ b/src/JackDriver.cpp @@ -0,0 +1,209 @@ +/* This file is part of Patchage. Copyright (C) 2005 Dave Robillard. + * + * Patchage 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. + * + * Patchage 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 <cassert> +#include <cstring> +#include <string> +#include <iostream> +#include <jack/jack.h> +#include <jack/statistics.h> +#include <jack/thread.h> +#include "raul/JackDriver.h" + +using std::cerr; using std::endl; +using std::string; + + +JackDriver::JackDriver() +//: m_app(app) +: m_client(NULL) +, m_is_activated(false) +, m_xruns(0) +, m_xrun_delay(0) +{ + m_last_pos.frame = 0; + m_last_pos.valid = (jack_position_bits_t)0; +} + + +JackDriver::~JackDriver() +{ + detach(); +} + + +/** Connect to Jack. + */ +void +JackDriver::attach(const string& client_name) +{ + // Already connected + if (m_client) + return; + + jack_set_error_function(error_cb); + + m_client = jack_client_open(client_name.c_str(), JackNullOption, NULL); + if (m_client == NULL) { + //m_app->status_message("[JACK] Unable to create client"); + m_is_activated = false; + } else { + jack_set_error_function(error_cb); + jack_on_shutdown(m_client, jack_shutdown_cb, this); + jack_set_port_registration_callback(m_client, jack_port_registration_cb, this); + jack_set_graph_order_callback(m_client, jack_graph_order_cb, this); + jack_set_buffer_size_callback(m_client, jack_buffer_size_cb, this); + jack_set_xrun_callback(m_client, jack_xrun_cb, this); + + //m_is_dirty = true; + m_buffer_size = jack_get_buffer_size(m_client); + + if (!jack_activate(m_client)) { + m_is_activated = true; + //signal_attached.emit(); + //m_app->status_message("[JACK] Attached"); + } else { + //m_app->status_message("[JACK] ERROR: Failed to attach"); + m_is_activated = false; + } + } +} + + +void +JackDriver::detach() +{ + if (m_client) { + jack_deactivate(m_client); + jack_client_close(m_client); + m_client = NULL; + m_is_activated = false; + //signal_detached.emit(); + } +} + + +void +JackDriver::jack_port_registration_cb(jack_port_id_t port_id, int registered, void* jack_driver) +{ + /* shrug. */ +} + + +int +JackDriver::jack_graph_order_cb(void* jack_driver) +{ + JackDriver* me = reinterpret_cast<JackDriver*>(jack_driver); + + assert(me); + me->on_graph_order_changed(); + + return 0; +} + + +int +JackDriver::jack_buffer_size_cb(jack_nframes_t buffer_size, void* jack_driver) +{ + JackDriver* me = reinterpret_cast<JackDriver*>(jack_driver); + + assert(me); + me->reset_xruns(); + me->reset_delay(); + me->on_buffer_size_changed(buffer_size); + me->m_buffer_size = buffer_size; + + return 0; +} + + +int +JackDriver::jack_xrun_cb(void* jack_driver) +{ + JackDriver* me = reinterpret_cast<JackDriver*>(jack_driver); + + assert(me); + + me->m_xruns++; + me->m_xrun_delay = jack_get_xrun_delayed_usecs(me->m_client); + me->reset_delay(); + + me->on_xrun(); + + return 0; +} + + +void +JackDriver::jack_shutdown_cb(void* jack_driver) +{ + JackDriver* me = reinterpret_cast<JackDriver*>(jack_driver); + assert(me); + + me->reset_delay(); + me->reset_xruns(); + + me->on_shutdown(); + + me->m_client = NULL; +} + + +void +JackDriver::error_cb(const char* msg) +{ + cerr << "JACK ERROR: " << msg << endl; +} + + +jack_nframes_t +JackDriver::buffer_size() +{ + if (m_is_activated) + return m_buffer_size; + else + return jack_get_buffer_size(m_client); +} + + +void +JackDriver::reset_xruns() +{ + m_xruns = 0; + m_xrun_delay = 0; +} + + +bool +JackDriver::set_buffer_size(jack_nframes_t size) +{ + if (buffer_size() == size) { + return true; + } + + if (!m_client) { + m_buffer_size = size; + return true; + } + + if (jack_set_buffer_size(m_client, size)) { + //m_app->status_message("[JACK] ERROR: Unable to set buffer size"); + return false; + } else { + return true; + } +} + diff --git a/src/Makefile.am b/src/Makefile.am index bbbad24..d0cef87 100644 --- a/src/Makefile.am +++ b/src/Makefile.am @@ -8,6 +8,9 @@ lib_LTLIBRARIES = libraul.la libraul_la_SOURCES = \ Thread.cpp \ Path.cpp \ - RDFWriter.cpp + RDFWriter.cpp \ + JackDriver.cpp \ + RDFQuery.cpp \ + Namespaces.cpp |