From 28eb36734e8315b4c11f6c51629071c3df4ade10 Mon Sep 17 00:00:00 2001
From: dec05eba <dec05eba@protonmail.com>
Date: Sat, 9 Jun 2018 06:08:40 +0200
Subject: Add debug, fix multithreading issue

---
 src/BootstrapConnection.cpp | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

(limited to 'src/BootstrapConnection.cpp')

diff --git a/src/BootstrapConnection.cpp b/src/BootstrapConnection.cpp
index 2920440..27c64bb 100644
--- a/src/BootstrapConnection.cpp
+++ b/src/BootstrapConnection.cpp
@@ -60,7 +60,6 @@ namespace sibs
                 newPeerAddress.address.sin_addr.s_addr = ipv4Address;
                 newPeerAddress.address.sin_port = port;
                 memset(newPeerAddress.address.sin_zero, 0, sizeof(newPeerAddress.address.sin_zero));
-                // TODO: Move connection to thread and add callback function, just like @receiveData and @send
                 connections.connect(newPeerAddress, [this, pubsubKey](std::shared_ptr<DirectConnectionPeer> newPeer, PubSubResult result, const std::string &resultStr)
                 {
                     if(result == PubSubResult::OK)
@@ -104,14 +103,12 @@ namespace sibs
                 listenCallbackFuncIt->second(data->data(), data->size());
         }
         
-        subscribedPeersMutex.lock();
+        std::lock_guard<std::mutex> lock(subscribedPeersMutex);
         auto peersIt = subscribedPeers.find(pubsubKey);
         if(peersIt == subscribedPeers.end())
         {
-            subscribedPeersMutex.unlock();
             return;
         }
-        subscribedPeersMutex.unlock();
         
         for(auto &peer : peersIt->second)
         {
-- 
cgit v1.2.3