diff options
author | David Robillard <d@drobilla.net> | 2012-05-03 02:56:09 +0000 |
---|---|---|
committer | David Robillard <d@drobilla.net> | 2012-05-03 02:56:09 +0000 |
commit | 9ae720fdc60d7e40b1b8be7c1133a57acb4e564c (patch) | |
tree | 99df6c7c38a850eba95bef35ed5a98f2a057d927 /src/server/EventWriter.hpp | |
parent | 93fb77a658d4d78fc64f3b8b84ed28dd94b3e6f8 (diff) | |
download | ingen-9ae720fdc60d7e40b1b8be7c1133a57acb4e564c.tar.gz ingen-9ae720fdc60d7e40b1b8be7c1133a57acb4e564c.tar.bz2 ingen-9ae720fdc60d7e40b1b8be7c1133a57acb4e564c.zip |
Separate EventWriter interface from EventQueue.
git-svn-id: http://svn.drobilla.net/lad/trunk/ingen@4319 a436a847-0d15-0410-975c-d299462d15a1
Diffstat (limited to 'src/server/EventWriter.hpp')
-rw-r--r-- | src/server/EventWriter.hpp | 102 |
1 files changed, 102 insertions, 0 deletions
diff --git a/src/server/EventWriter.hpp b/src/server/EventWriter.hpp new file mode 100644 index 00000000..771d22f5 --- /dev/null +++ b/src/server/EventWriter.hpp @@ -0,0 +1,102 @@ +/* + 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/>. +*/ + +#ifndef INGEN_ENGINE_EVENTWRITER_HPP +#define INGEN_ENGINE_EVENTWRITER_HPP + +#include <inttypes.h> +#include <memory> +#include <string> + +#include "ingen/Interface.hpp" +#include "ingen/Resource.hpp" +#include "raul/SharedPtr.hpp" + +#include "types.hpp" + +namespace Ingen { +namespace Server { + +class Engine; +class EventSink; + +/** An Interface that creates and writes Events to an EventSink. + * + * This is where Interface calls get turned into Events which are actually + * processed by the engine to do things. + */ +class EventWriter : public Interface +{ +public: + explicit EventWriter(Engine& engine, EventSink& sink); + virtual ~EventWriter(); + + Raul::URI uri() const { return "http://drobilla.net/ns/ingen#internal"; } + + void set_response_interface(Interface* iface) { _request_client = iface; } + + virtual void set_response_id(int32_t id); + + virtual void bundle_begin(); + + virtual void bundle_end(); + + virtual void put(const Raul::URI& path, + const Resource::Properties& properties, + const Resource::Graph g=Resource::DEFAULT); + + virtual void delta(const Raul::URI& path, + const Resource::Properties& remove, + const Resource::Properties& add); + + virtual void move(const Raul::Path& old_path, + const Raul::Path& new_path); + + virtual void connect(const Raul::Path& tail, + const Raul::Path& head); + + virtual void disconnect(const Raul::Path& tail, + const Raul::Path& head); + + virtual void set_property(const Raul::URI& subject_path, + const Raul::URI& predicate, + const Raul::Atom& value); + + virtual void del(const Raul::URI& uri); + + virtual void disconnect_all(const Raul::Path& parent_patch_path, + const Raul::Path& path); + + virtual void get(const Raul::URI& uri); + + virtual void response(int32_t id, Status status) {} ///< N/A + virtual void error(const std::string& msg) {} ///< N/A + +protected: + Interface* _request_client; + EventSink& _sink; + int32_t _request_id; + Engine& _engine; + bool _in_bundle; ///< True iff a bundle is currently being received + +private: + SampleCount now() const; +}; + +} // namespace Server +} // namespace Ingen + +#endif // INGEN_ENGINE_QUEUEDENGINEINTERFACE_HPP |