diff options
| author | dec05eba <dec05eba@protonmail.com> | 2018-06-09 06:08:40 +0200 |
|---|---|---|
| committer | dec05eba <dec05eba@protonmail.com> | 2020-08-18 22:56:48 +0200 |
| commit | 28eb36734e8315b4c11f6c51629071c3df4ade10 (patch) | |
| tree | 6ff65e1b179644c7c2da107f2fa265d231435319 /src/BootstrapConnection.cpp | |
| parent | 5d42dd6a18e3b8b6eb46739b8a1d15997e229de2 (diff) | |
Add debug, fix multithreading issue
Diffstat (limited to 'src/BootstrapConnection.cpp')
| -rw-r--r-- | src/BootstrapConnection.cpp | 5 |
1 files changed, 1 insertions, 4 deletions
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) { |