diff options
Diffstat (limited to 'src/server/Broadcaster.hpp')
-rw-r--r-- | src/server/Broadcaster.hpp | 126 |
1 files changed, 126 insertions, 0 deletions
diff --git a/src/server/Broadcaster.hpp b/src/server/Broadcaster.hpp new file mode 100644 index 00000000..6942a578 --- /dev/null +++ b/src/server/Broadcaster.hpp @@ -0,0 +1,126 @@ +/* + 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_CLIENTBROADCASTER_HPP +#define INGEN_ENGINE_CLIENTBROADCASTER_HPP + +#include <list> +#include <map> +#include <string> + +#include <glibmm/thread.h> + +#include "raul/SharedPtr.hpp" + +#include "ingen/Interface.hpp" + +#include "NodeFactory.hpp" + +namespace Ingen { +namespace Server { + +class GraphObjectImpl; + +/** Broadcaster for all clients. + * + * This is an Interface that forwards all messages to all registered + * clients (for updating all clients on state changes in the engine). + * + * \ingroup engine + */ +class Broadcaster : public Interface +{ +public: + void register_client(const Raul::URI& uri, SharedPtr<Interface> client); + bool unregister_client(const Raul::URI& uri); + + SharedPtr<Interface> client(const Raul::URI& uri); + + void send_plugins(const NodeFactory::Plugins& plugin_list); + void send_plugins_to(Interface*, const NodeFactory::Plugins& plugin_list); + + void send_object(const GraphObjectImpl* p, bool recursive); + +#define BROADCAST(msg, ...) \ + Glib::Mutex::Lock lock(_clients_mutex); \ + for (Clients::const_iterator i = _clients.begin(); i != _clients.end(); ++i) \ + (*i).second->msg(__VA_ARGS__) + + void bundle_begin() { BROADCAST(bundle_begin); } + void bundle_end() { BROADCAST(bundle_end); } + + void put(const Raul::URI& uri, + const Resource::Properties& properties, + Resource::Graph ctx=Resource::DEFAULT) { + BROADCAST(put, uri, properties); + } + + void delta(const Raul::URI& uri, + const Resource::Properties& remove, + const Resource::Properties& add) { + BROADCAST(delta, uri, remove, add); + } + + void move(const Raul::Path& old_path, + const Raul::Path& new_path) { + BROADCAST(move, old_path, new_path); + } + + void del(const Raul::URI& uri) { + BROADCAST(del, uri); + } + + void connect(const Raul::Path& tail, + const Raul::Path& head) { + BROADCAST(connect, tail, head); + } + + void disconnect(const Raul::Path& tail, + const Raul::Path& head) { + BROADCAST(disconnect, tail, head); + } + + void disconnect_all(const Raul::Path& parent_patch_path, + const Raul::Path& path) { + BROADCAST(disconnect_all, parent_patch_path, path); + } + + void set_property(const Raul::URI& subject, + const Raul::URI& predicate, + const Raul::Atom& value) { + BROADCAST(set_property, subject, predicate, value); + } + + Raul::URI uri() const { return "http://drobilla.net/ns/ingen#broadcaster"; } ///< N/A + + void set_response_id(int32_t id) {} ///< N/A + void get(const Raul::URI& uri) {} ///< N/A + void response(int32_t id, Status status) {} ///< N/A + + void error(const std::string& msg) { BROADCAST(error, msg); } + +private: + typedef std::map< Raul::URI, SharedPtr<Interface> > Clients; + + Glib::Mutex _clients_mutex; + Clients _clients; +}; + +} // namespace Server +} // namespace Ingen + +#endif // INGEN_ENGINE_CLIENTBROADCASTER_HPP + |