diff --git a/src/dht.cpp b/src/dht.cpp index 367582a9..0148e207 100644 --- a/src/dht.cpp +++ b/src/dht.cpp @@ -2377,7 +2377,6 @@ Dht::exportValues() const ve.first = h.id; serialize(h.values.size(), ve.second); for (const auto& v : h.values) { - Blob vde; serialize(v.time, ve.second); v.data->pack(ve.second); } diff --git a/src/dhtrunner.cpp b/src/dhtrunner.cpp index d8f5f39c..a74ccde9 100644 --- a/src/dhtrunner.cpp +++ b/src/dhtrunner.cpp @@ -222,7 +222,6 @@ DhtRunner::get(InfoHash hash, Dht::GetCallback vcb, Dht::DoneCallback dcb, Value { std::lock_guard lck(storage_mtx); pending_ops.emplace([=](SecureDht& dht) { - std::cout << "Processing get (" << hash << ")" << std::endl; dht.get(hash, vcb, dcb, f); }); cv.notify_all(); @@ -240,7 +239,6 @@ DhtRunner::listen(InfoHash hash, Dht::GetCallback vcb, Value::Filter f) std::lock_guard lck(storage_mtx); auto ret_token = std::make_shared>(); pending_ops.emplace([=](SecureDht& dht) { - std::cout << "Processing listen (" << hash << ")" << std::endl; ret_token->set_value(dht.listen(hash, vcb, f)); }); cv.notify_all(); @@ -258,7 +256,6 @@ DhtRunner::cancelListen(InfoHash h, size_t token) { std::lock_guard lck(storage_mtx); pending_ops.emplace([=](SecureDht& dht) { - std::cout << "Processing cancelListen " << h << std::endl; dht.cancelListen(h, token); }); cv.notify_all(); @@ -269,9 +266,7 @@ DhtRunner::cancelListen(InfoHash h, std::shared_future token) { std::lock_guard lck(storage_mtx); pending_ops.emplace([=](SecureDht& dht) { - std::cout << "Processing cancelListen (shared_future) " << h << std::endl; auto tk = token.get(); - std::cout << "token is " << tk << std::endl; dht.cancelListen(h, tk); }); cv.notify_all(); @@ -283,7 +278,6 @@ DhtRunner::put(InfoHash hash, Value&& value, Dht::DoneCallback cb) std::lock_guard lck(storage_mtx); auto sv = std::make_shared(std::move(value)); pending_ops.emplace([=](SecureDht& dht) { - std::cout << "Processing put " << hash << " -> " << *sv << std::endl; dht.put(hash, sv, cb); }); cv.notify_all(); @@ -300,7 +294,6 @@ DhtRunner::cancelPut(const InfoHash& h , const Value::Id& id) { std::lock_guard lck(storage_mtx); pending_ops.emplace([=](SecureDht& dht) { - std::cout << "Processing cancelPut " << h << " / " << id << std::endl; dht.cancelPut(h, id); }); cv.notify_all(); @@ -312,7 +305,6 @@ DhtRunner::putSigned(InfoHash hash, Value&& value, Dht::DoneCallback cb) std::lock_guard lck(storage_mtx); auto sv = std::make_shared(std::move(value)); pending_ops.emplace([=](SecureDht& dht) { - std::cout << "Processing signed put " << hash << " -> " << *sv << std::endl; dht.putSigned(hash, sv, cb); }); cv.notify_all(); @@ -330,7 +322,6 @@ DhtRunner::putEncrypted(InfoHash hash, InfoHash to, Value&& value, Dht::DoneCall std::lock_guard lck(storage_mtx); auto sv = std::make_shared(std::move(value)); pending_ops.emplace([=](SecureDht& dht) { - std::cout << "Processing encrypted put at " << hash << " for " << to << " -> " << *sv << std::endl; dht.putEncrypted(hash, to, sv, cb); }); cv.notify_all();