diff options
Diffstat (limited to 'implementation/routing/include/routing_manager_proxy.hpp')
| -rw-r--r-- | implementation/routing/include/routing_manager_proxy.hpp | 11 |
1 files changed, 2 insertions, 9 deletions
diff --git a/implementation/routing/include/routing_manager_proxy.hpp b/implementation/routing/include/routing_manager_proxy.hpp index b3ae769..37ec8b5 100644 --- a/implementation/routing/include/routing_manager_proxy.hpp +++ b/implementation/routing/include/routing_manager_proxy.hpp @@ -8,6 +8,7 @@ #include <map> #include <mutex> +#include <atomic> #include <boost/asio/io_service.hpp> #include <boost/asio/steady_timer.hpp> @@ -76,9 +77,6 @@ public: instance_t _instance, event_t _event, bool _is_provided); - void notify(service_t _service, instance_t _instance, event_t _event, - std::shared_ptr<payload> _payload, bool _force, bool _flush); - void on_connect(std::shared_ptr<endpoint> _endpoint); void on_disconnect(std::shared_ptr<endpoint> _endpoint); void on_message(const byte_t *_data, length_t _length, endpoint *_receiver, @@ -165,7 +163,7 @@ private: }; bool is_connected_; - bool is_started_; + std::atomic<bool> is_started_; inner_state_type_e state_; std::shared_ptr<endpoint> sender_; // --> stub @@ -212,11 +210,6 @@ private: std::map<client_t, std::set<eventgroup_data_t>> pending_ingoing_subscripitons_; std::mutex pending_ingoing_subscripitons_mutex_; - std::map<service_t, - std::map<instance_t, - std::map<event_t, - std::shared_ptr<message> > > > pending_notifications_; - std::mutex deserialize_mutex_; std::mutex state_mutex_; |