From 8ce21af2486b2da3273d554ffdf058cb07f49a8f Mon Sep 17 00:00:00 2001 From: dec05eba <0xdec05eba@gmail.com> Date: Sun, 14 Oct 2018 03:36:47 +0200 Subject: Another test --- src/BootstrapNode.cpp | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) (limited to 'src/BootstrapNode.cpp') diff --git a/src/BootstrapNode.cpp b/src/BootstrapNode.cpp index 9edf008..e62e48d 100644 --- a/src/BootstrapNode.cpp +++ b/src/BootstrapNode.cpp @@ -14,6 +14,7 @@ namespace sibs { BootstrapNode::BootstrapNode(const Ipv4 &address) : + connections(27130), socket(connections.createSocket(address, false, true)) { if(UDT::listen(socket, 10) == UDT::ERROR) @@ -66,7 +67,7 @@ namespace sibs connections.peersMutex.unlock(); } } - + void BootstrapNode::peerSubscribe(std::shared_ptr newPeer, const void *data, const usize size) { Log::debug("BootstrapNode: Received peer subscribe from (ip: %s, port: %d)", newPeer->address.getAddress().c_str(), newPeer->address.getPort()); @@ -77,7 +78,7 @@ namespace sibs auto &peers = subscribedPeers[pubsubKey]; for(auto &peer : peers) { - if(peer->address.address.sin_addr.s_addr == newPeer->address.address.sin_addr.s_addr) + if(peer->address == newPeer->address) return; } -- cgit v1.2.3