Scratch commit to make SVN allow moving files (broken revision).

git-svn-id: http://svn.drobilla.net/lad/raul@262 a436a847-0d15-0410-975c-d299462d15a1

1 files changed, 209 insertions, 0 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;
+	}
+}
+