Separate EventWriter interface from EventQueue.

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

1 files changed, 0 insertions, 190 deletions

diff --git a/src/server/ServerInterfaceImpl.cpp b/src/server/ServerInterfaceImpl.cpp
deleted file mode 100644
index d3f151e7..00000000
--- a/src/server/ServerInterfaceImpl.cpp
+++ /dev/null
@@ -1,190 +0,0 @@
-/*
-  This file is part of Ingen.
-  Copyright 2007-2012 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 <string>
-
-#include "raul/log.hpp"
-
-#include "ingen/shared/URIs.hpp"
-
-#include "ClientBroadcaster.hpp"
-#include "Driver.hpp"
-#include "Engine.hpp"
-#include "EventQueue.hpp"
-#include "ServerInterfaceImpl.hpp"
-#include "events.hpp"
-
-#define LOG(s) s << "[ServerInterfaceImpl] "
-
-using namespace std;
-using namespace Raul;
-
-namespace Ingen {
-namespace Server {
-
-ServerInterfaceImpl::ServerInterfaceImpl(Engine& engine)
-	: EventQueue()
-	, _request_client(NULL)
-	, _request_id(-1)
-	, _engine(engine)
-	, _in_bundle(false)
-{
-	start();
-}
-
-ServerInterfaceImpl::~ServerInterfaceImpl()
-{
-	stop();
-}
-
-SampleCount
-ServerInterfaceImpl::now() const
-{
-	// Exactly one cycle latency (some could run ASAP if we get lucky, but not always, and a slight
-	// constant latency is far better than jittery lower (average) latency
-	if (_engine.driver())
-		return _engine.driver()->frame_time() + _engine.driver()->block_length();
-	else
-		return 0;
-}
-
-void
-ServerInterfaceImpl::set_response_id(int32_t id)
-{
-	if (!_request_client) {  // Kludge
-		_request_client = _engine.broadcaster()->client(
-			"http://drobilla.net/ns/ingen#internal");
-	}
-	_request_id = id;
-}
-
-/* *** ServerInterface implementation below here *** */
-
-// Bundle commands
-
-void
-ServerInterfaceImpl::bundle_begin()
-{
-	_in_bundle = true;
-}
-
-void
-ServerInterfaceImpl::bundle_end()
-{
-	_in_bundle = false;
-}
-
-// Object commands
-
-void
-ServerInterfaceImpl::put(const URI&                  uri,
-                         const Resource::Properties& properties,
-                         const Resource::Graph       ctx)
-{
-	event(new Events::SetMetadata(_engine, _request_client, _request_id, now(), true, ctx, uri, properties));
-}
-
-void
-ServerInterfaceImpl::delta(const URI&                  uri,
-                           const Resource::Properties& remove,
-                           const Resource::Properties& add)
-{
-	event(new Events::SetMetadata(_engine, _request_client, _request_id, now(), false, Resource::DEFAULT, uri, add, remove));
-}
-
-void
-ServerInterfaceImpl::move(const Path& old_path,
-                          const Path& new_path)
-{
-	event(new Events::Move(_engine, _request_client, _request_id, now(), old_path, new_path));
-}
-
-void
-ServerInterfaceImpl::del(const URI& uri)
-{
-	if (uri == "ingen:engine") {
-		if (_request_client) {
-			_request_client->response(_request_id, SUCCESS);
-		}
-		_engine.quit();
-	} else {
-		event(new Events::Delete(_engine, _request_client, _request_id, now(), uri));
-	}
-}
-
-void
-ServerInterfaceImpl::connect(const Path& tail_path,
-                             const Path& head_path)
-{
-	event(new Events::Connect(_engine, _request_client, _request_id, now(), tail_path, head_path));
-
-}
-
-void
-ServerInterfaceImpl::disconnect(const Path& src,
-                                const Path& dst)
-{
-	if (!Path::is_path(src) && !Path::is_path(dst)) {
-		LOG(Raul::error) << "Bad disconnect request " << src
-		                 << " => " << dst << std::endl;
-		return;
-	}
-
-	event(new Events::Disconnect(_engine, _request_client, _request_id, now(),
-	                                   Path(src.str()), Path(dst.str())));
-}
-
-void
-ServerInterfaceImpl::disconnect_all(const Path& patch_path,
-                                    const Path& path)
-{
-	event(new Events::DisconnectAll(_engine, _request_client, _request_id, now(), patch_path, path));
-}
-
-void
-ServerInterfaceImpl::set_property(const URI&  uri,
-                                  const URI&  predicate,
-                                  const Atom& value)
-{
-	if (uri == "ingen:engine" && predicate == "ingen:enabled"
-	    && value.type() == _engine.world()->forge().Bool) {
-		if (value.get_bool()) {
-			_engine.activate();
-			event(new Events::Ping(_engine, _request_client, _request_id, now()));
-		} else {
-			event(new Events::Deactivate(_engine, _request_client, _request_id, now()));
-		}
-	} else {
-		Resource::Properties remove;
-		remove.insert(make_pair(predicate, _engine.world()->uris()->wildcard));
-		Resource::Properties add;
-		add.insert(make_pair(predicate, value));
-		event(new Events::SetMetadata(
-			            _engine, _request_client, _request_id, now(), false, Resource::DEFAULT,
-			            uri, add, remove));
-	}
-}
-
-// Requests //
-
-void
-ServerInterfaceImpl::get(const URI& uri)
-{
-	event(new Events::Get(_engine, _request_client, _request_id, now(), uri));
-}
-
-} // namespace Server
-} // namespace Ingen