1 files changed, 148 insertions, 0 deletions
diff --git a/src/gui/ThreadedLoader.cpp b/src/gui/ThreadedLoader.cpp
new file mode 100644
index 00000000..cd7b1594
--- /dev/null
+++ b/src/gui/ThreadedLoader.cpp
@@ -0,0 +1,148 @@
+/*
+  This file is part of Ingen.
+  Copyright 2007-2015 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 <cassert>
+#include <string>
+
+#include "ingen/Log.hpp"
+#include "ingen/Module.hpp"
+#include "ingen/World.hpp"
+#include "ingen/client/GraphModel.hpp"
+
+#include "App.hpp"
+#include "ThreadedLoader.hpp"
+
+using boost::optional;
+
+namespace ingen {
+namespace gui {
+
+ThreadedLoader::ThreadedLoader(App& app, SPtr<Interface> engine)
+    : _app(app)
+    , _sem(0)
+    , _engine(std::move(engine))
+    , _exit_flag(false)
+    , _thread(&ThreadedLoader::run, this)
+{
+	if (!parser()) {
+		app.log().warn("Parser unavailable, graph loading disabled\n");
+	}
+}
+
+ThreadedLoader::~ThreadedLoader()
+{
+	_exit_flag = true;
+	_sem.post();
+	if (_thread.joinable()) {
+		_thread.join();
+	}
+}
+
+SPtr<Parser>
+ThreadedLoader::parser()
+{
+	return _app.world()->parser();
+}
+
+void
+ThreadedLoader::run()
+{
+	while (_sem.wait() && !_exit_flag) {
+		std::lock_guard<std::mutex> lock(_mutex);
+		while (!_events.empty()) {
+			_events.front()();
+			_events.pop_front();
+		}
+	}
+}
+
+void
+ThreadedLoader::load_graph(bool                   merge,
+                           const FilePath&        file_path,
+                           optional<Raul::Path>   engine_parent,
+                           optional<Raul::Symbol> engine_symbol,
+                           optional<Properties>   engine_data)
+{
+	std::lock_guard<std::mutex> lock(_mutex);
+
+	Glib::ustring engine_base = "";
+	if (engine_parent) {
+		if (merge) {
+			engine_base = engine_parent.get();
+		} else {
+			engine_base = engine_parent.get().base();
+		}
+	}
+
+	_events.push_back(sigc::hide_return(
+	        sigc::bind(sigc::mem_fun(this, &ThreadedLoader::load_graph_event),
+	                   file_path,
+	                   engine_parent,
+	                   engine_symbol,
+	                   engine_data)));
+
+	_sem.post();
+}
+
+void
+ThreadedLoader::load_graph_event(const FilePath&        file_path,
+                                 optional<Raul::Path>   engine_parent,
+                                 optional<Raul::Symbol> engine_symbol,
+                                 optional<Properties>   engine_data)
+{
+	std::lock_guard<std::mutex> lock(_app.world()->rdf_mutex());
+
+	_app.world()->parser()->parse_file(_app.world(),
+	                                   _app.world()->interface().get(),
+	                                   file_path,
+	                                   engine_parent,
+	                                   engine_symbol,
+	                                   engine_data);
+}
+
+void
+ThreadedLoader::save_graph(SPtr<const client::GraphModel> model, const URI& uri)
+{
+	std::lock_guard<std::mutex> lock(_mutex);
+
+	_events.push_back(sigc::hide_return(
+	        sigc::bind(sigc::mem_fun(this, &ThreadedLoader::save_graph_event),
+	                   model,
+	                   uri)));
+
+	_sem.post();
+}
+
+void
+ThreadedLoader::save_graph_event(SPtr<const client::GraphModel> model,
+                                 const URI&                     uri)
+{
+	assert(uri.scheme() == "file");
+	if (_app.serialiser()) {
+		std::lock_guard<std::mutex> lock(_app.world()->rdf_mutex());
+
+		if (uri.string().find(".ingen") != std::string::npos) {
+			_app.serialiser()->write_bundle(model, uri);
+		} else {
+			_app.serialiser()->start_to_file(model->path(), std::string(uri.path()));
+			_app.serialiser()->serialise(model);
+			_app.serialiser()->finish();
+		}
+	}
+}
+
+} // namespace gui
+} // namespace ingen