1 files changed, 108 insertions, 0 deletions
diff --git a/src/server/DirectDriver.hpp b/src/server/DirectDriver.hpp
new file mode 100644
index 00000000..706adda8
--- /dev/null
+++ b/src/server/DirectDriver.hpp
@@ -0,0 +1,108 @@
+/*
+  This file is part of Ingen.
+  Copyright 2007-2017 David Robillard <http://drobilla.net/>
+
+  Ingen is free software: you can redistribute it and/or modify it under the
+  terms of the GNU Affero General Public License as published by the Free
+  Software Foundation, either version 3 of the License, or any later version.
+
+  Ingen 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 Affero General Public License for details.
+
+  You should have received a copy of the GNU Affero General Public License
+  along with Ingen.  If not, see <http://www.gnu.org/licenses/>.
+*/
+
+#ifndef INGEN_ENGINE_DIRECT_DRIVER_HPP
+#define INGEN_ENGINE_DIRECT_DRIVER_HPP
+
+#include <boost/intrusive/slist.hpp>
+
+#include "Driver.hpp"
+#include "Engine.hpp"
+
+namespace Ingen {
+namespace Server {
+
+/** Driver for running Ingen directly as a library.
+ * \ingroup engine
+ */
+class DirectDriver : public Driver {
+public:
+	DirectDriver(Engine&     engine,
+	             double      sample_rate,
+	             SampleCount block_length,
+	             size_t      seq_size)
+		: _engine(engine)
+		, _sample_rate(sample_rate)
+		, _block_length(block_length)
+		, _seq_size(seq_size)
+	{}
+
+	virtual ~DirectDriver() {
+		_ports.clear_and_dispose([](EnginePort* p) { delete p; });
+	}
+
+	bool dynamic_ports() const { return true; }
+
+	virtual EnginePort* create_port(DuplexPort* graph_port) {
+		return new EnginePort(graph_port);
+	}
+
+	virtual EnginePort* get_port(const Raul::Path& path) {
+		for (auto& p : _ports) {
+			if (p.graph_port()->path() == path) {
+				return &p;
+			}
+		}
+
+		return NULL;
+	}
+
+	virtual void add_port(RunContext& context, EnginePort* port) {
+		_ports.push_back(*port);
+	}
+
+	virtual void remove_port(RunContext& context, EnginePort* port) {
+		_ports.erase(_ports.iterator_to(*port));
+	}
+
+	virtual void rename_port(const Raul::Path& old_path,
+	                         const Raul::Path& new_path) {}
+
+	virtual void port_property(const Raul::Path& path,
+	                           const Raul::URI&  uri,
+	                           const Atom&       value) {}
+
+	virtual void register_port(EnginePort& port) {}
+	virtual void unregister_port(EnginePort& port) {}
+
+	virtual SampleCount block_length() const { return _block_length; }
+
+	virtual size_t seq_size() const { return _seq_size; }
+
+	virtual SampleCount sample_rate() const { return _sample_rate; }
+
+	virtual SampleCount frame_time() const { return _engine.run_context().start(); }
+
+	virtual void append_time_events(RunContext& context, Buffer& buffer) {}
+
+	virtual int real_time_priority() { return 60; }
+
+private:
+	typedef boost::intrusive::slist<EnginePort,
+	                                boost::intrusive::cache_last<true>
+	                                > Ports;
+
+	Engine&     _engine;
+	Ports       _ports;
+	SampleCount _sample_rate;
+	SampleCount _block_length;
+	size_t      _seq_size;
+};
+
+} // namespace Server
+} // namespace Ingen
+
+#endif // INGEN_ENGINE_DIRECT_DRIVER_HPP