aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
m---------depends/sibs-pubsub0
-rw-r--r--src/Database.cpp7
2 files changed, 6 insertions, 1 deletions
diff --git a/depends/sibs-pubsub b/depends/sibs-pubsub
-Subproject eda94456add9a65d1821302e343bef4021d2a77
+Subproject e0511ecead4d98ed84e18960a2f23cfe707b5a2
diff --git a/src/Database.cpp b/src/Database.cpp
index 2a7a510..5ff3460 100644
--- a/src/Database.cpp
+++ b/src/Database.cpp
@@ -661,6 +661,11 @@ namespace odhtdb
void Database::sendCustomMessage(const InfoHash &requestKey, const void *data, const usize size)
{
+ if(!bootstrapConnection.areWeListeningOnKey(requestKey.getKey()))
+ {
+ bootstrapConnection.listen(requestKey.getKey(), nullptr);
+ std::this_thread::sleep_for(std::chrono::seconds(3));
+ }
bootstrapConnection.put(requestKey.getKey(), data, size);
}
@@ -674,7 +679,7 @@ namespace odhtdb
return callbackFunc(true, data, size);
});
- bootstrapConnection.put(requestKey.getKey(), data, size);
+ sendCustomMessage(requestKey, data, size);
return listener;
}