Rework objects extension to have "value ports" and "message ports".

Make audio and control buffers in ingen actually object buffers (towards interop).
Overhaul the hell out of ingen buffer and mixing stuff.


git-svn-id: http://svn.drobilla.net/lad/trunk/ingen@2266 a436a847-0d15-0410-975c-d299462d15a1

1 files changed, 124 insertions, 0 deletions

diff --git a/src/engine/BufferFactory.cpp b/src/engine/BufferFactory.cpp
new file mode 100644
index 00000000..63fd31ae
--- /dev/null
+++ b/src/engine/BufferFactory.cpp
@@ -0,0 +1,124 @@
+/* This file is part of Ingen.
+ * Copyright (C) 2007-2009 Dave Robillard <http://drobilla.net>
+ *
+ * Ingen 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.
+ *
+ * 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 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.,
+ * 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
+ */
+
+#include <algorithm>
+#include <iostream>
+#include "shared/LV2URIMap.hpp"
+#include "AudioBuffer.hpp"
+#include "EventBuffer.hpp"
+#include "ObjectBuffer.hpp"
+#include "BufferFactory.hpp"
+#include "Engine.hpp"
+#include "AudioDriver.hpp"
+#include "ThreadManager.hpp"
+
+namespace Ingen {
+
+using namespace Shared;
+
+BufferFactory::BufferFactory(Engine& engine, SharedPtr<Shared::LV2URIMap> map)
+	: _engine(engine)
+	, _map(map)
+{
+}
+
+struct BufferDeleter {
+	BufferDeleter(BufferFactory& bf) : _factory(bf) {}
+	void operator()(void* ptr) {
+		_factory.recycle((Buffer*)ptr);
+	}
+	BufferFactory& _factory;
+};
+
+
+SharedPtr<Buffer>
+BufferFactory::get(Shared::DataType type, size_t size)
+{
+	Raul::AtomicPtr<Buffer>& head_ptr = free_list(type);
+	Buffer* try_head;
+	Buffer* next;
+	do {
+		try_head = head_ptr.get();
+		if (!try_head)
+			break;
+		next = try_head->_next;
+	} while (!head_ptr.compare_and_exchange(try_head, next));
+
+	if (!try_head) {
+		if (ThreadManager::current_thread_id() != THREAD_PROCESS) {
+			return create(type, size);
+		} else {
+			cerr << "ERROR: Failed to obtain buffer" << endl;
+			return SharedPtr<Buffer>();
+		}
+	}
+
+	try_head->_next = NULL;
+	return SharedPtr<Buffer>(try_head, BufferDeleter(*this));
+}
+
+
+SharedPtr<Buffer>
+BufferFactory::create(Shared::DataType type, size_t size)
+{
+	assert(ThreadManager::current_thread_id() != THREAD_PROCESS);
+
+	Buffer* buffer = NULL;
+
+	if (type.is_control()) {
+		if (size == 0)
+			size = sizeof(LV2_Object) + sizeof(float);
+		AudioBuffer* ret = new AudioBuffer(type, size);
+		ret->object()->type = _map->object_class_vector;
+		((LV2_Vector_Body*)ret->object()->body)->elem_type = _map->object_class_float32;
+		buffer = ret;
+	} else if (type.is_audio()) {
+		if (size == 0)
+			size = sizeof(LV2_Object) + sizeof(LV2_Vector_Body)
+				+ _engine.audio_driver()->buffer_size() * sizeof(float);
+		AudioBuffer* ret = new AudioBuffer(type, size);
+		ret->object()->type = _map->object_class_float32;
+		buffer = ret;
+	} else if (type.is_events()) {
+		if (size == 0)
+			size = _engine.audio_driver()->buffer_size() * 4; // FIXME
+		buffer = new EventBuffer(size);
+	} else if (type.is_value()) {
+		if (size == 0)
+			size = 32; // FIXME
+		buffer = new ObjectBuffer(std::max(size, sizeof(LV2_Object) + sizeof(void*)));
+	} else {
+		cout << "ERROR: Failed to create buffer of unknown type" << endl;
+		return SharedPtr<Buffer>();
+	}
+
+	return SharedPtr<Buffer>(buffer, BufferDeleter(*this));
+}
+
+void
+BufferFactory::recycle(Buffer* buf)
+{
+	Raul::AtomicPtr<Buffer>& head_ptr = free_list(buf->type());
+	Buffer* try_head;
+	do {
+		try_head = head_ptr.get();
+		buf->_next = try_head;
+	} while (!head_ptr.compare_and_exchange(try_head, buf));
+}
+
+
+} // namespace Ingen