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
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
|
// Copyright (C) 2014-2021 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_V3_ENDPOINT_MANAGER_IMPL_HPP_
#define VSOMEIP_V3_ENDPOINT_MANAGER_IMPL_HPP_
#include <condition_variable>
#include <queue>
#include <thread>
#include "../include/endpoint_manager_base.hpp"
namespace vsomeip_v3 {
class routing_host;
class endpoint_manager_impl : public endpoint_manager_base {
public:
endpoint_manager_impl(routing_manager_base* const _rm,
boost::asio::io_context &_io,
const std::shared_ptr<configuration>& _configuration);
~endpoint_manager_impl();
std::shared_ptr<endpoint> find_or_create_remote_client(service_t _service,
instance_t _instance,
bool _reliable);
void find_or_create_remote_client(service_t _service, instance_t _instance);
void is_remote_service_known(
service_t _service, instance_t _instance, major_version_t _major,
minor_version_t _minor,
const boost::asio::ip::address &_reliable_address,
uint16_t _reliable_port, bool* _reliable_known,
const boost::asio::ip::address &_unreliable_address,
uint16_t _unreliable_port, bool* _unreliable_known) const;
void add_remote_service_info(
service_t _service, instance_t _instance,
const std::shared_ptr<endpoint_definition>& _ep_definition);
void add_remote_service_info(
service_t _service, instance_t _instance,
const std::shared_ptr<endpoint_definition>& _ep_definition_reliable,
const std::shared_ptr<endpoint_definition>& _ep_definition_unreliable);
void clear_remote_service_info(service_t _service, instance_t _instance,
bool _reliable);
std::shared_ptr<endpoint> create_server_endpoint(uint16_t _port,
bool _reliable,
bool _start);
std::shared_ptr<endpoint> find_server_endpoint(uint16_t _port,
bool _reliable) const;
std::shared_ptr<endpoint> find_or_create_server_endpoint(
uint16_t _port, bool _reliable, bool _start, service_t _service,
instance_t _instance, bool &_is_found, bool _is_multicast = false);
bool remove_server_endpoint(uint16_t _port, bool _reliable);
void clear_client_endpoints(service_t _service, instance_t _instance,
bool _reliable);
void find_or_create_multicast_endpoint(
service_t _service, instance_t _instance,
const boost::asio::ip::address &_sender,
const boost::asio::ip::address &_address, uint16_t _port);
void clear_multicast_endpoints(service_t _service, instance_t _instance);
bool supports_selective(service_t _service, instance_t _instance) const;
void print_status() const;
bool create_routing_root(
std::shared_ptr<endpoint> &_root,
bool &_is_socket_activated,
const std::shared_ptr<routing_host> &_host);
instance_t find_instance(service_t _service,
endpoint* const _endpoint) const;
instance_t find_instance_multicast(service_t _service,
const boost::asio::ip::address &_sender) const;
bool remove_instance(service_t _service, endpoint* const _endpoint);
bool remove_instance_multicast(service_t _service, instance_t _instance);
// endpoint_host interface
void on_connect(std::shared_ptr<endpoint> _endpoint);
void on_disconnect(std::shared_ptr<endpoint> _endpoint);
bool on_bind_error(std::shared_ptr<endpoint> _endpoint,
const boost::asio::ip::address &_remote_address,
std::uint16_t _remote_port);
void on_error(const byte_t *_data, length_t _length,
endpoint* const _receiver,
const boost::asio::ip::address &_remote_address,
std::uint16_t _remote_port);
void get_used_client_ports(
const boost::asio::ip::address &_remote_address, port_t _remote_port,
std::map<bool, std::set<port_t> > &_used_ports);
void request_used_client_port(
const boost::asio::ip::address &_remote_address, port_t _remote_port,
bool _reliable, port_t _local_port);
void release_used_client_port(
const boost::asio::ip::address &_remote_address, port_t _remote_port,
bool _reliable, port_t _local_port);
// Statistics
void log_client_states() const;
void log_server_states() const;
// add join/leave options
void add_multicast_option(const multicast_option_t &_option);
private:
std::shared_ptr<endpoint> find_remote_client(service_t _service,
instance_t _instance,
bool _reliable);
std::shared_ptr<endpoint> create_remote_client(service_t _service,
instance_t _instance,
bool _reliable);
std::shared_ptr<endpoint> create_client_endpoint(
const boost::asio::ip::address &_address, uint16_t _local_port,
uint16_t _remote_port, bool _reliable);
// process join/leave options
void process_multicast_options();
private:
mutable std::recursive_mutex endpoint_mutex_;
// Client endpoints for remote services
std::map<service_t, std::map<instance_t,
std::map<bool, std::shared_ptr<endpoint_definition>>>> remote_service_info_;
using remote_services_t =
std::map<service_t, std::map<instance_t, std::map<bool, std::shared_ptr<endpoint>>>>;
remote_services_t remote_services_;
using client_endpoints_by_ip_t =
std::map<boost::asio::ip::address,
std::map<std::uint16_t,
std::map<bool, std::map<partition_id_t, std::shared_ptr<endpoint>>>>>;
client_endpoints_by_ip_t client_endpoints_by_ip_;
std::map<service_t, std::map<endpoint *, instance_t> > service_instances_;
std::map<service_t, std::map<boost::asio::ip::address, instance_t> > service_instances_multicast_;
std::map<boost::asio::ip::address,
std::map<port_t,
std::map<bool, std::set<port_t> >
>
> used_client_ports_;
std::mutex used_client_ports_mutex_;
// Server endpoints for local services
using server_endpoints_t = std::map<std::uint16_t, std::map<bool, std::shared_ptr<endpoint>>>;
server_endpoints_t server_endpoints_;
// Multicast endpoint info (notifications)
std::map<service_t, std::map<instance_t,
std::shared_ptr<endpoint_definition>>> multicast_info;
// Socket option processing (join, leave)
std::mutex options_mutex_;
bool is_processing_options_;
std::condition_variable options_condition_;
std::queue<multicast_option_t> options_queue_;
std::thread options_thread_;
};
} // namespace vsomeip_v3
#endif // VSOMEIP_V3_ENDPOINT_MANAGER_IMPL_HPP_
|
