diff options
Diffstat (limited to 'src/server/EventWriter.cpp')
| -rw-r--r-- | src/server/EventWriter.cpp | 188 |
1 files changed, 188 insertions, 0 deletions
diff --git a/src/server/EventWriter.cpp b/src/server/EventWriter.cpp new file mode 100644 index 00000000..4725835b --- /dev/null +++ b/src/server/EventWriter.cpp @@ -0,0 +1,188 @@ +/* + 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 "EventWriter.hpp" +#include "events.hpp" + +#define LOG(s) s << "[EventWriter] " + +using namespace std; +using namespace Raul; + +namespace Ingen { +namespace Server { + +EventWriter::EventWriter(Engine& engine, EventSink& sink) + : _request_client(NULL) + , _sink(sink) + , _request_id(-1) + , _engine(engine) + , _in_bundle(false) +{ +} + +EventWriter::~EventWriter() +{ +} + +SampleCount +EventWriter::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 +EventWriter::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 +EventWriter::bundle_begin() +{ + _in_bundle = true; +} + +void +EventWriter::bundle_end() +{ + _in_bundle = false; +} + +// Object commands + +void +EventWriter::put(const URI& uri, + const Resource::Properties& properties, + const Resource::Graph ctx) +{ + _sink.event(new Events::SetMetadata(_engine, _request_client, _request_id, now(), true, ctx, uri, properties)); +} + +void +EventWriter::delta(const URI& uri, + const Resource::Properties& remove, + const Resource::Properties& add) +{ + _sink.event(new Events::SetMetadata(_engine, _request_client, _request_id, now(), false, Resource::DEFAULT, uri, add, remove)); +} + +void +EventWriter::move(const Path& old_path, + const Path& new_path) +{ + _sink.event(new Events::Move(_engine, _request_client, _request_id, now(), old_path, new_path)); +} + +void +EventWriter::del(const URI& uri) +{ + if (uri == "ingen:engine") { + if (_request_client) { + _request_client->response(_request_id, SUCCESS); + } + _engine.quit(); + } else { + _sink.event(new Events::Delete(_engine, _request_client, _request_id, now(), uri)); + } +} + +void +EventWriter::connect(const Path& tail_path, + const Path& head_path) +{ + _sink.event(new Events::Connect(_engine, _request_client, _request_id, now(), tail_path, head_path)); + +} + +void +EventWriter::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; + } + + _sink.event(new Events::Disconnect(_engine, _request_client, _request_id, now(), + Path(src.str()), Path(dst.str()))); +} + +void +EventWriter::disconnect_all(const Path& patch_path, + const Path& path) +{ + _sink.event(new Events::DisconnectAll(_engine, _request_client, _request_id, now(), patch_path, path)); +} + +void +EventWriter::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(); + _sink.event(new Events::Ping(_engine, _request_client, _request_id, now())); + } else { + _sink.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)); + _sink.event(new Events::SetMetadata( + _engine, _request_client, _request_id, now(), false, Resource::DEFAULT, + uri, add, remove)); + } +} + +// Requests // + +void +EventWriter::get(const URI& uri) +{ + _sink.event(new Events::Get(_engine, _request_client, _request_id, now(), uri)); +} + +} // namespace Server +} // namespace Ingen |