From f240b08a1799b3aa6a29701c90388d51c0c1b2ce Mon Sep 17 00:00:00 2001
From: David Robillard <d@drobilla.net>
Date: Sat, 18 Feb 2017 18:32:02 +0100
Subject: Add experimental PortAudio driver

---
 src/server/PortAudioDriver.hpp | 127 +++++++++++++++++++++++++++++++++++++++++
 1 file changed, 127 insertions(+)
 create mode 100644 src/server/PortAudioDriver.hpp

(limited to 'src/server/PortAudioDriver.hpp')

diff --git a/src/server/PortAudioDriver.hpp b/src/server/PortAudioDriver.hpp
new file mode 100644
index 00000000..5c5c2445
--- /dev/null
+++ b/src/server/PortAudioDriver.hpp
@@ -0,0 +1,127 @@
+/*
+  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_PORTAUDIODRIVER_HPP
+#define INGEN_ENGINE_PORTAUDIODRIVER_HPP
+
+#include "ingen_config.h"
+
+#include <atomic>
+#include <portaudio.h>
+#include <string>
+
+#include "raul/Semaphore.hpp"
+
+#include "lv2/lv2plug.in/ns/ext/atom/forge.h"
+
+#include "Driver.hpp"
+#include "EnginePort.hpp"
+
+namespace Raul { class Path; }
+
+namespace Ingen {
+namespace Server {
+
+class DuplexPort;
+class Engine;
+class GraphImpl;
+class PortAudioDriver;
+class PortImpl;
+
+class PortAudioDriver : public Driver
+{
+public:
+	explicit PortAudioDriver(Engine& engine);
+	~PortAudioDriver();
+
+	bool attach();
+
+	bool activate();
+	void deactivate();
+
+	EnginePort* create_port(DuplexPort* graph_port);
+	EnginePort* get_port(const Raul::Path& path);
+
+	void rename_port(const Raul::Path& old_path, const Raul::Path& new_path);
+	void port_property(const Raul::Path& path, const Raul::URI& uri, const Atom& value);
+	void add_port(RunContext& context, EnginePort* port);
+	void remove_port(RunContext& context, EnginePort* port);
+	void register_port(EnginePort& port);
+	void unregister_port(EnginePort& port);
+
+	void append_time_events(RunContext& context, Buffer& buffer) {}
+
+	SampleCount frame_time() const;
+
+	int real_time_priority() { return 80; }
+
+	SampleCount    block_length() const { return _block_length; }
+	size_t         seq_size()     const { return _seq_size; }
+	SampleCount    sample_rate()  const { return _sample_rate; }
+
+private:
+	friend class PortAudioPort;
+
+	inline static int
+	pa_process_cb(const void*                     inputs,
+	              void*                           outputs,
+	              unsigned long                   nframes,
+	              const PaStreamCallbackTimeInfo* time,
+	              PaStreamCallbackFlags           flags,
+	              void*                           handle) {
+		return ((PortAudioDriver*)handle)->process_cb(
+			inputs, outputs, nframes, time, flags);
+	}
+
+	int
+	process_cb(const void*                     inputs,
+	           void*                           outputs,
+	           unsigned long                   nframes,
+	           const PaStreamCallbackTimeInfo* time,
+	           PaStreamCallbackFlags           flags);
+
+	void pre_process_port(RunContext&  context,
+	                      EnginePort*  port,
+	                      const void*  inputs,
+	                      void*        outputs);
+
+	void post_process_port(RunContext& context,
+	                       EnginePort* port,
+	                       const void* inputs,
+	                       void*       outputs);
+
+protected:
+	typedef boost::intrusive::list<EnginePort> Ports;
+
+	Engine&            _engine;
+	Ports              _ports;
+	PaStreamParameters _inputParameters;
+	PaStreamParameters _outputParameters;
+	Raul::Semaphore    _sem;
+	std::atomic<bool>  _flag;
+	PaStream*          _stream;
+	size_t             _seq_size;
+	uint32_t           _block_length;
+	uint32_t           _sample_rate;
+	uint32_t           _n_inputs;
+	uint32_t           _n_outputs;
+	bool               _is_activated;
+};
+
+} // namespace Server
+} // namespace Ingen
+
+#endif // INGEN_ENGINE_PORTAUDIODRIVER_HPP
-- 
cgit v1.2.1