diff options
Diffstat (limited to 'src/BootstrapNode.cpp')
| -rw-r--r-- | src/BootstrapNode.cpp | 5 |
1 files changed, 3 insertions, 2 deletions
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<DirectConnectionPeer> 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; } |