1 files changed, 109 insertions, 0 deletions
diff --git a/src/JackDriver.hpp b/src/JackDriver.hpp
new file mode 100644
index 0000000..875bd61
--- /dev/null
+++ b/src/JackDriver.hpp
@@ -0,0 +1,109 @@
+/* This file is part of Patchage.
+ * Copyright 2007-2014 David Robillard <http://drobilla.net>
+ *
+ * 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 3 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 Patchage.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+#ifndef PATCHAGE_JACKDRIVER_HPP
+#define PATCHAGE_JACKDRIVER_HPP
+
+#include <string>
+
+#include <jack/jack.h>
+
+#include <glibmm/thread.h>
+
+#include "Driver.hpp"
+#include "Queue.hpp"
+
+class Patchage;
+class PatchageEvent;
+class PatchageCanvas;
+class PatchagePort;
+class PatchageModule;
+
+/** Handles all externally driven functionality, registering ports etc.
+ *
+ * Jack callbacks and connect methods and things like that live here.
+ * Right now just for jack ports, but that will change...
+ */
+class JackDriver : public Driver
+{
+public:
+	explicit JackDriver(Patchage* app);
+	~JackDriver();
+
+	void attach(bool launch_daemon);
+	void detach();
+
+	bool is_attached() const { return (_client != NULL); }
+	bool is_realtime() const { return _client && jack_is_realtime(_client); }
+
+	void refresh();
+	void destroy_all();
+
+	bool port_names(const PortID& id,
+	                std::string&  module_name,
+	                std::string&  port_name);
+
+	PatchagePort* create_port_view(Patchage*     patchage,
+	                               const PortID& id);
+
+	bool connect(PatchagePort* src,
+	             PatchagePort* dst);
+
+	bool disconnect(PatchagePort* src,
+	                PatchagePort* dst);
+
+	uint32_t get_xruns() { return _xruns; }
+	void     reset_xruns();
+	float    get_max_dsp_load();
+	void     reset_max_dsp_load();
+
+	jack_client_t* client() { return _client; }
+
+	jack_nframes_t sample_rate() { return jack_get_sample_rate(_client); }
+	jack_nframes_t buffer_size();
+	bool           set_buffer_size(jack_nframes_t size);
+
+	void process_events(Patchage* app);
+
+private:
+	PatchagePort* create_port(
+		PatchageModule& parent,
+		jack_port_t*    port,
+		PortID          id);
+
+	void shutdown();
+
+	static void jack_client_registration_cb(const char* name, int registered, void* me);
+	static void jack_port_registration_cb(jack_port_id_t port_id, int registered, void* me);
+	static void jack_port_connect_cb(jack_port_id_t src, jack_port_id_t dst, int connect, void* me);
+	static int  jack_xrun_cb(void* me);
+	static void jack_shutdown_cb(void* me);
+
+	Patchage*      _app;
+	jack_client_t* _client;
+
+	Queue<PatchageEvent> _events;
+
+	Glib::Mutex _shutdown_mutex;
+
+	jack_position_t _last_pos;
+	jack_nframes_t  _buffer_size;
+	uint32_t        _xruns;
+	float           _xrun_delay;
+	bool            _is_activated :1;
+};
+
+#endif // PATCHAGE_JACKDRIVER_HPP