1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
|
// Copyright (C) 2014-2017 Bayerische Motoren Werke Aktiengesellschaft (BMW AG)
// This Source Code Form is subject to the terms of the Mozilla Public
// 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
#include <map>
#include <memory>
#include <mutex>
#include <set>
#include <atomic>
#include <boost/asio/io_service.hpp>
#include <boost/asio/ip/address.hpp>
#include <boost/asio/steady_timer.hpp>
#include <vsomeip/primitive_types.hpp>
#include <vsomeip/function_types.hpp>
#include <vsomeip/payload.hpp>
namespace vsomeip {
class endpoint;
class endpoint_definition;
class message;
class payload;
class routing_manager;
class event: public std::enable_shared_from_this<event> {
public:
event(routing_manager *_routing, bool _is_shadow = false);
service_t get_service() const;
void set_service(service_t _service);
instance_t get_instance() const;
void set_instance(instance_t _instance);
major_version_t get_version() const;
void set_version(major_version_t _major);
event_t get_event() const;
void set_event(event_t _event);
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);
void set_payload(const std::shared_ptr<payload> &_payload,
const std::shared_ptr<endpoint_definition> _target,
bool _force, bool _flush);
void set_payload_dont_notify(const std::shared_ptr<payload> &_payload);
void set_payload(const std::shared_ptr<payload> &_payload,
bool _force, bool _flush);
void unset_payload(bool _force = false);
bool is_field() const;
void set_field(bool _is_field);
bool is_provided() const;
void set_provided(bool _is_provided);
bool is_set() const;
// SIP_RPC_357
void set_update_cycle(std::chrono::milliseconds &_cycle);
void set_change_resets_cycle(bool _change_resets_cycle);
// SIP_RPC_358
void set_update_on_change(bool _is_on);
// SIP_RPC_359 (epsilon change)
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);
bool add_subscriber(eventgroup_t _eventgroup, client_t _client);
void remove_subscriber(eventgroup_t _eventgroup, client_t _client);
bool has_subscriber(eventgroup_t _eventgroup, client_t _client);
std::set<client_t> get_subscribers();
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 is_shadow() const;
void set_shadow(bool _shadow);
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);
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 start_cycle();
void stop_cycle();
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);
void reset_payload(const std::shared_ptr<payload> &_payload);
private:
routing_manager *routing_;
mutable std::mutex mutex_;
std::shared_ptr<message> message_;
std::atomic<bool> is_field_;
boost::asio::steady_timer cycle_timer_;
std::chrono::milliseconds cycle_;
std::atomic<bool> change_resets_cycle_;
std::atomic<bool> is_updating_on_change_;
mutable std::mutex eventgroups_mutex_;
std::map<eventgroup_t, std::set<client_t>> eventgroups_;
std::atomic<bool> is_set_;
std::atomic<bool> is_provided_;
std::mutex refs_mutex_;
std::map<client_t, std::map<bool, uint32_t>> refs_;
std::atomic<bool> is_shadow_;
std::atomic<bool> is_cache_placeholder_;
epsilon_change_func_t epsilon_change_func_;
};
} // namespace vsomeip
#endif // VSOMEIP_EVENT_IMPL_HPP
|
