diff options
Diffstat (limited to 'src/BootstrapConnection.cpp')
| -rw-r--r-- | src/BootstrapConnection.cpp | 31 |
1 files changed, 15 insertions, 16 deletions
diff --git a/src/BootstrapConnection.cpp b/src/BootstrapConnection.cpp index 1e1ac43..df0a947 100644 --- a/src/BootstrapConnection.cpp +++ b/src/BootstrapConnection.cpp @@ -123,29 +123,28 @@ namespace sibs Log::debug("BootstrapConnection::receiveDataFromServer: received subscriber (ip: %s, port: %d) from bootstrap node", newPeerAddress.getAddress().c_str(), newPeerAddress.getPort()); connections.connect(newPeerAddress, [this, pubsubKey](std::shared_ptr<DirectConnectionPeer> peer, PubSubResult result, const std::string &resultStr) { - if(result == PubSubResult::RESULT_OK) + std::lock_guard<std::recursive_mutex> lock(subscribeDataMutex); + auto subscribeDataIt = subscribeData.find(pubsubKey); + if(subscribeDataIt == subscribeData.end()) + { + Log::warn("BootstrapConnection::receiveDataFromServer: No listener found for key '%s', ignoring...", pubsubKey.toString().c_str()); + return; + } + + for(auto existingPeer : subscribeDataIt->second.peers) { - std::lock_guard<std::recursive_mutex> lock(subscribeDataMutex); - auto subscribeDataIt = subscribeData.find(pubsubKey); - if(subscribeDataIt == subscribeData.end()) + if(peer == existingPeer) { - Log::warn("BootstrapConnection::receiveDataFromServer: No listener found for key '%s', ignoring...", pubsubKey.toString().c_str()); + Log::debug("BootstrapConnection::receiveDataFromServer: Already connected to peer (ip: %s, port: %d) for pubsub key %s", peer->address.getAddress().c_str(), peer->address.getPort(), pubsubKey.toString().c_str()); return; } + } - for(auto existingPeer : subscribeDataIt->second.peers) - { - if(peer == existingPeer) - { - Log::debug("BootstrapConnection::receiveDataFromServer: Already connected to peer (ip: %s, port: %d)", peer->address.getAddress().c_str(), peer->address.getPort()); - return; - } - } - subscribeDataIt->second.peers.push_back(peer); + subscribeDataIt->second.peers.push_back(peer); + if(result == PubSubResult::RESULT_OK) Log::debug("BootstrapConnection::receiveDataFromServer: Connected to peer (ip: %s, port: %d) given by bootstrap node", peer->address.getAddress().c_str(), peer->address.getPort()); - } else - Log::error("BootstrapConnection::receiveDataFromServer: Failed to connect to peer given by bootstrap node, error: %s", resultStr.c_str()); + Log::warn("BootstrapConnection::receiveDataFromServer: Failed to connect to peer given by bootstrap node, error: %s. Routing data through bootstrap node", resultStr.c_str()); }, std::bind(&BootstrapConnection::receiveDataFromPeer, this, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3, std::placeholders::_4)); } else |