From c6cef856f09c8e15efb2867fab6f00b7343afc41 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Adrien=20B=C3=A9raud?= <adrien.beraud@savoirfairelinux.com>
Date: Sat, 21 Apr 2018 12:23:33 -0400
Subject: [PATCH] proxy server: cleanup
---
src/dht_proxy_server.cpp | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/src/dht_proxy_server.cpp b/src/dht_proxy_server.cpp
index efd4e2c8..79f997e4 100644
--- a/src/dht_proxy_server.cpp
+++ b/src/dht_proxy_server.cpp
@@ -602,13 +602,13 @@ DhtProxyServer::put(const std::shared_ptr<restbed::Session>& session)
bool isAndroid = platform == "android";
std::unique_lock<std::mutex> lock(schedulerLock_);
scheduler_.syncTime();
- auto sPuts = puts_.emplace(infoHash, SearchPuts{}).first;
auto timeout = scheduler_.time() + proxy::OP_TIMEOUT;
auto vid = value->id;
+ auto sPuts = puts_.emplace(infoHash, SearchPuts{}).first;
auto r = sPuts->second.puts.emplace(vid, PermanentPut{});
if (r.second) {
r.first->second.expireJob = scheduler_.add(timeout, [this, infoHash, vid]{
- std::cout << "Permanent put expired" << infoHash << std::endl;
+ std::cout << "Permanent put expired: " << infoHash << std::endl;
cancelPut(infoHash, vid);
});
#if OPENDHT_PUSH_NOTIFICATIONS
@@ -616,7 +616,7 @@ DhtProxyServer::put(const std::shared_ptr<restbed::Session>& session)
r.first->second.expireNotifyJob = scheduler_.add(timeout - proxy::OP_MARGIN,
[this, infoHash, vid, pushToken, clientId, isAndroid]
{
- std::cout << "Permanent put refresh" << infoHash << std::endl;
+ std::cout << "Permanent put refresh: " << infoHash << std::endl;
Json::Value json;
json["timeout"] = infoHash.toString();
json["to"] = clientId;
--
GitLab