aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authordec05eba <0xdec05eba@gmail.com>2018-10-19 23:10:36 +0200
committerdec05eba <0xdec05eba@gmail.com>2018-10-19 23:10:40 +0200
commit0554e4bfdf2e24419c2b9facceaecc6e9d4764ec (patch)
treeaad26dfc43eeaf4d9ee353fa829f7ec6a7428107
parentef3e340e83dda6cefd0a3d16839615bc9878772d (diff)
Add put retry
m---------depends/sibs-pubsub0
-rw-r--r--src/Database.cpp8
2 files changed, 0 insertions, 8 deletions
diff --git a/depends/sibs-pubsub b/depends/sibs-pubsub
-Subproject 3565289c19974ca874f87429cc74a87558249c8
+Subproject 54254462e432dcc6ef2bb306a9ee773d21314d1
diff --git a/src/Database.cpp b/src/Database.cpp
index 50b5044..4422e1c 100644
--- a/src/Database.cpp
+++ b/src/Database.cpp
@@ -647,9 +647,6 @@ namespace odhtdb
{
InfoHash responseKey = receiveMessageKey;
++responseKey[0];
-
- if(!bootstrapConnection.areWeListeningOnKey(responseKey.getKey()))
- bootstrapConnection.listen(responseKey.getKey(), nullptr);
return bootstrapConnection.listen(receiveMessageKey.getKey(), [callbackFunc, this, responseKey](const sibs::DirectConnectionPeer *peer, const void *data, const usize size)
{
@@ -664,11 +661,6 @@ 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);
}