aboutsummaryrefslogtreecommitdiff
path: root/src/BootstrapConnection.cpp
diff options
context:
space:
mode:
authordec05eba <0xdec05eba@gmail.com>2018-10-14 04:17:54 +0200
committerdec05eba <0xdec05eba@gmail.com>2018-10-14 04:18:00 +0200
commit55405854c27417ec33797c9e2b438ce17ac70bf2 (patch)
tree2bd3941f879089b32a913203131cd0acae3d968d /src/BootstrapConnection.cpp
parent2a0fa173a0007e549589ed9c1a34a2db3be34361 (diff)
Add peer to listen callback
Diffstat (limited to 'src/BootstrapConnection.cpp')
-rw-r--r--src/BootstrapConnection.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/BootstrapConnection.cpp b/src/BootstrapConnection.cpp
index 9a19943..421dfe1 100644
--- a/src/BootstrapConnection.cpp
+++ b/src/BootstrapConnection.cpp
@@ -85,7 +85,7 @@ namespace sibs
void BootstrapConnection::receiveDataFromPeer(BoostrapConnectionListenCallbackFunc listenCallbackFunc, std::shared_ptr<DirectConnectionPeer> peer, const void *data, const usize size)
{
if(listenCallbackFunc)
- listenCallbackFunc(data, size);
+ listenCallbackFunc(peer.get(), data, size);
}
void BootstrapConnection::listen(const PubsubKey &pubsubKey, BoostrapConnectionListenCallbackFunc callbackFunc)
@@ -109,7 +109,7 @@ namespace sibs
std::lock_guard<std::mutex> lock(listenerCallbackFuncMutex);
auto listenCallbackFuncIt = listenCallbackFuncs.find(pubsubKey);
if(listenCallbackFuncIt != listenCallbackFuncs.end() && listenCallbackFuncIt->second)
- listenCallbackFuncIt->second(data->data(), data->size());
+ listenCallbackFuncIt->second(nullptr, data->data(), data->size());
}
std::lock_guard<std::mutex> lock(subscribedPeersMutex);