diff options
author | dec05eba <0xdec05eba@gmail.com> | 2018-10-14 04:17:54 +0200 |
---|---|---|
committer | dec05eba <0xdec05eba@gmail.com> | 2018-10-14 04:18:00 +0200 |
commit | 55405854c27417ec33797c9e2b438ce17ac70bf2 (patch) | |
tree | 2bd3941f879089b32a913203131cd0acae3d968d /src/BootstrapConnection.cpp | |
parent | 2a0fa173a0007e549589ed9c1a34a2db3be34361 (diff) |
Add peer to listen callback
Diffstat (limited to 'src/BootstrapConnection.cpp')
-rw-r--r-- | src/BootstrapConnection.cpp | 4 |
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); |