1 files changed, 73 insertions, 0 deletions
diff --git a/src/server/InternalBlock.cpp b/src/server/InternalBlock.cpp
new file mode 100644
index 00000000..cf57e6b2
--- /dev/null
+++ b/src/server/InternalBlock.cpp
@@ -0,0 +1,73 @@
+/*
+  This file is part of Ingen.
+  Copyright 2007-2016 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/>.
+*/
+
+#include "Buffer.hpp"
+#include "Engine.hpp"
+#include "InternalBlock.hpp"
+#include "InternalPlugin.hpp"
+#include "PortImpl.hpp"
+
+namespace ingen {
+namespace server {
+
+InternalBlock::InternalBlock(PluginImpl*         plugin,
+                             const Raul::Symbol& symbol,
+                             bool                poly,
+                             GraphImpl*          parent,
+                             SampleRate          rate)
+	: BlockImpl(plugin, symbol, poly, parent, rate)
+{}
+
+BlockImpl*
+InternalBlock::duplicate(Engine&             engine,
+                         const Raul::Symbol& symbol,
+                         GraphImpl*          parent)
+{
+	BufferFactory& bufs = *engine.buffer_factory();
+
+	BlockImpl* copy = reinterpret_cast<InternalPlugin*>(_plugin)->instantiate(
+		bufs, symbol, _polyphonic, parent, engine, nullptr);
+
+	for (size_t i = 0; i < num_ports(); ++i) {
+		const Atom& value = port_impl(i)->value();
+		copy->port_impl(i)->set_property(bufs.uris().ingen_value, value);
+		copy->port_impl(i)->set_value(value);
+	}
+
+	return copy;
+}
+
+void
+InternalBlock::pre_process(RunContext& context)
+{
+	for (uint32_t i = 0; i < num_ports(); ++i) {
+		PortImpl* const port = _ports->at(i);
+		if (port->is_input()) {
+			port->pre_process(context);
+		} else if (port->buffer_type() == _plugin->uris().atom_Sequence) {
+			/* Output sequences are initialized in LV2 format, an atom:Chunk
+			   with size set to the capacity of the buffer.  Internal nodes
+			   don't care, so clear to an empty sequences so appending events
+			   results in a valid output. */
+			for (uint32_t v = 0; v < port->poly(); ++v) {
+				port->buffer(v)->clear();
+			}
+		}
+	}
+}
+
+} // namespace server
+} // namespace ingen