summaryrefslogtreecommitdiff
path: root/implementation/endpoints/include/endpoint_manager_impl.hpp
diff options
context:
space:
mode:
Diffstat (limited to 'implementation/endpoints/include/endpoint_manager_impl.hpp')
-rw-r--r--implementation/endpoints/include/endpoint_manager_impl.hpp13
1 files changed, 11 insertions, 2 deletions
diff --git a/implementation/endpoints/include/endpoint_manager_impl.hpp b/implementation/endpoints/include/endpoint_manager_impl.hpp
index a7d28c6..3354947 100644
--- a/implementation/endpoints/include/endpoint_manager_impl.hpp
+++ b/implementation/endpoints/include/endpoint_manager_impl.hpp
@@ -82,6 +82,8 @@ public:
// 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,
+ 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,
@@ -113,8 +115,15 @@ private:
std::map<bool, std::shared_ptr<endpoint>>>> remote_services_t;
remote_services_t remote_services_;
- typedef std::map<boost::asio::ip::address, std::map<uint16_t,
- std::map<bool, std::shared_ptr<endpoint>>>> client_endpoints_by_ip_t;
+ typedef std::map<boost::asio::ip::address,
+ std::map<uint16_t,
+ std::map<bool,
+ std::map<partition_id_t,
+ std::shared_ptr<endpoint>
+ >
+ >
+ >
+ > client_endpoints_by_ip_t;
client_endpoints_by_ip_t client_endpoints_by_ip_;
std::map<service_t, std::map<endpoint *, instance_t> > service_instances_;