diff options
| author | dec05eba <0xdec05eba@gmail.com> | 2018-10-14 03:36:47 +0200 |
|---|---|---|
| committer | dec05eba <0xdec05eba@gmail.com> | 2018-10-14 03:36:51 +0200 |
| commit | 8ce21af2486b2da3273d554ffdf058cb07f49a8f (patch) | |
| tree | c4e4425e78cb5c9c300e9b2281b1b1818c80a3dd /src/BootstrapNode.cpp | |
| parent | a5b3db69c366866398aaa30053f5b83e8e7e491a (diff) | |
Another test
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; } |