diff options
Diffstat (limited to 'implementation/routing/include/event.hpp')
| -rw-r--r-- | implementation/routing/include/event.hpp | 83 |
1 files changed, 48 insertions, 35 deletions
diff --git a/implementation/routing/include/event.hpp b/implementation/routing/include/event.hpp index 668bbf4..684a49b 100644 --- a/implementation/routing/include/event.hpp +++ b/implementation/routing/include/event.hpp @@ -3,9 +3,10 @@ // License, v. 2.0. If a copy of the MPL was not distributed with this // file, You can obtain one at http://mozilla.org/MPL/2.0/. -#ifndef VSOMEIP_EVENT_IMPL_HPP -#define VSOMEIP_EVENT_IMPL_HPP +#ifndef VSOMEIP_V3_EVENT_IMPL_HPP_ +#define VSOMEIP_V3_EVENT_IMPL_HPP_ +#include <list> #include <map> #include <memory> #include <mutex> @@ -20,7 +21,13 @@ #include <vsomeip/function_types.hpp> #include <vsomeip/payload.hpp> -namespace vsomeip { +#ifdef ANDROID +#include "../../configuration/include/internal_android.hpp" +#else +#include "../../configuration/include/internal.hpp" +#endif // ANDROID + +namespace vsomeip_v3 { class endpoint; class endpoint_definition; @@ -28,7 +35,8 @@ class message; class payload; class routing_manager; -class event: public std::enable_shared_from_this<event> { +class event + : public std::enable_shared_from_this<event> { public: event(routing_manager *_routing, bool _is_shadow = false); @@ -47,21 +55,25 @@ public: const std::shared_ptr<payload> get_payload() const; void set_payload(const std::shared_ptr<payload> &_payload, - const client_t _client, bool _force, bool _flush); + const client_t _client, bool _force); void set_payload(const std::shared_ptr<payload> &_payload, - const std::shared_ptr<endpoint_definition> _target, - bool _force, bool _flush); + const client_t _client, + const std::shared_ptr<endpoint_definition>& _target, bool _force); bool set_payload_dont_notify(const std::shared_ptr<payload> &_payload); + bool set_payload_notify_pending(const std::shared_ptr<payload> &_payload); - void set_payload(const std::shared_ptr<payload> &_payload, - bool _force, bool _flush); + void set_payload(const std::shared_ptr<payload> &_payload, bool _force); void unset_payload(bool _force = false); - bool is_field() const; - void set_field(bool _is_field); + event_type_e get_type() const; + void set_type(const event_type_e _type); + + reliability_type_e get_reliability() const; + void set_reliability(const reliability_type_e _reliability); + bool is_field() const; bool is_provided() const; void set_provided(bool _is_provided); @@ -75,25 +87,30 @@ public: void set_update_on_change(bool _is_active); // SIP_RPC_359 (epsilon change) - void set_epsilon_change_function(const epsilon_change_func_t &_epsilon_change_func); + void set_epsilon_change_function( + const epsilon_change_func_t &_epsilon_change_func); const std::set<eventgroup_t> get_eventgroups() const; std::set<eventgroup_t> get_eventgroups(client_t _client) const; void add_eventgroup(eventgroup_t _eventgroup); void set_eventgroups(const std::set<eventgroup_t> &_eventgroups); - void notify_one(const std::shared_ptr<endpoint_definition> &_target, bool _flush); - void notify_one(client_t _client, bool _flush); + void notify_one(client_t _client, + const std::shared_ptr<endpoint_definition> &_target); + void notify_one(client_t _client); + bool add_subscriber(eventgroup_t _eventgroup, client_t _client, bool _force); void remove_subscriber(eventgroup_t _eventgroup, client_t _client); bool has_subscriber(eventgroup_t _eventgroup, client_t _client); std::set<client_t> get_subscribers(); + std::set<client_t> get_subscribers(eventgroup_t _eventgroup); void clear_subscribers(); void add_ref(client_t _client, bool _is_provided); void remove_ref(client_t _client, bool _is_provided); bool has_ref(); + bool has_ref(client_t _client, bool _is_provided); bool is_shadow() const; void set_shadow(bool _shadow); @@ -101,40 +118,36 @@ public: bool is_cache_placeholder() const; void set_cache_placeholder(bool _is_cache_place_holder); - bool has_ref(client_t _client, bool _is_provided); - - std::set<client_t> get_subscribers(eventgroup_t _eventgroup); - bool is_subscribed(client_t _client); - bool is_reliable() const; - void set_reliable(bool _is_reliable); - - bool get_remote_notification_pending(); - void set_remote_notification_pending(bool _value); + void remove_pending(const std::shared_ptr<endpoint_definition> &_target); private: void update_cbk(boost::system::error_code const &_error); - void notify(bool _flush); - void notify(client_t _client, const std::shared_ptr<endpoint_definition> &_target); + void notify(); + void notify(client_t _client, + const std::shared_ptr<endpoint_definition> &_target); void start_cycle(); void stop_cycle(); - bool compare(const std::shared_ptr<payload> &_lhs, const std::shared_ptr<payload> &_rhs) const; + bool compare(const std::shared_ptr<payload> &_lhs, + const std::shared_ptr<payload> &_rhs) const; - bool set_payload_helper(const std::shared_ptr<payload> &_payload, bool _force); + bool set_payload_helper(const std::shared_ptr<payload> &_payload, + bool _force); void reset_payload(const std::shared_ptr<payload> &_payload); - void notify_one_unlocked(const std::shared_ptr<endpoint_definition> &_target, bool _flush); - void notify_one_unlocked(client_t _client, bool _flush); + void notify_one_unlocked(client_t _client); + void notify_one_unlocked(client_t _client, + const std::shared_ptr<endpoint_definition> &_target); private: routing_manager *routing_; mutable std::mutex mutex_; std::shared_ptr<message> message_; - std::atomic<bool> is_field_; + std::atomic<event_type_e> type_; boost::asio::steady_timer cycle_timer_; std::chrono::milliseconds cycle_; @@ -143,7 +156,7 @@ private: std::atomic<bool> is_updating_on_change_; mutable std::mutex eventgroups_mutex_; - std::map<eventgroup_t, std::set<client_t>> eventgroups_; + std::map<eventgroup_t, std::set<client_t> > eventgroups_; std::atomic<bool> is_set_; std::atomic<bool> is_provided_; @@ -156,11 +169,11 @@ private: epsilon_change_func_t epsilon_change_func_; - std::atomic<bool> is_reliable_; + std::atomic<reliability_type_e> reliability_; - std::atomic<bool> remote_notification_pending_; + std::set<std::shared_ptr<endpoint_definition> > pending_; }; -} // namespace vsomeip +} // namespace vsomeip_v3 -#endif // VSOMEIP_EVENT_IMPL_HPP +#endif // VSOMEIP_V3_EVENT_IMPL_HPP_ |