Skip to content
Snippets Groups Projects
Commit dd3c7899 authored by Adrien Béraud's avatar Adrien Béraud
Browse files

proxy server: 0-initialize fields

parent 333087bc
Branches
Tags
No related merge requests found
...@@ -76,9 +76,9 @@ struct OPENDHT_PUBLIC NodeStats { ...@@ -76,9 +76,9 @@ struct OPENDHT_PUBLIC NodeStats {
struct OPENDHT_PUBLIC NodeInfo { struct OPENDHT_PUBLIC NodeInfo {
InfoHash id; InfoHash id;
InfoHash node_id; InfoHash node_id;
NodeStats ipv4; NodeStats ipv4 {};
NodeStats ipv6; NodeStats ipv6 {};
size_t ongoing_ops; size_t ongoing_ops {0};
#ifdef OPENDHT_JSONCPP #ifdef OPENDHT_JSONCPP
/** /**
......
...@@ -54,8 +54,6 @@ class DhtRunner; ...@@ -54,8 +54,6 @@ class DhtRunner;
using RestRouter = restinio::router::express_router_t<>; using RestRouter = restinio::router::express_router_t<>;
using RequestStatus = restinio::request_handling_status_t; using RequestStatus = restinio::request_handling_status_t;
using ResponseByParts = restinio::chunked_output_t;
using ResponseByPartsBuilder = restinio::response_builder_t<ResponseByParts>;
/** /**
* Describes the REST API * Describes the REST API
...@@ -87,15 +85,15 @@ public: ...@@ -87,15 +85,15 @@ public:
struct ServerStats { struct ServerStats {
/** Current number of listen operations */ /** Current number of listen operations */
size_t listenCount; size_t listenCount {0};
/** Current number of permanent put operations */ /** Current number of permanent put operations */
size_t putCount; size_t putCount {0};
/** Current number of push tokens with at least one listen operation */ /** Current number of push tokens with at least one listen operation */
size_t pushListenersCount; size_t pushListenersCount {0};
/** Average requests per second */ /** Average requests per second */
double requestRate; double requestRate {0};
/** Node Info **/ /** Node Info **/
NodeInfo nodeInfo; NodeInfo nodeInfo {};
std::string toString() const { std::string toString() const {
std::ostringstream ss; std::ostringstream ss;
......
...@@ -68,6 +68,9 @@ constexpr char RESP_MSG_NO_TOKEN[] = "{\"err\":\"No token\"}"; ...@@ -68,6 +68,9 @@ constexpr char RESP_MSG_NO_TOKEN[] = "{\"err\":\"No token\"}";
constexpr const std::chrono::minutes PRINT_STATS_PERIOD {2}; constexpr const std::chrono::minutes PRINT_STATS_PERIOD {2};
using ResponseByParts = restinio::chunked_output_t;
using ResponseByPartsBuilder = restinio::response_builder_t<ResponseByParts>;
class opendht_logger_t class opendht_logger_t
{ {
public: public:
...@@ -1003,7 +1006,6 @@ DhtProxyServer::put(restinio::request_handle_t request, ...@@ -1003,7 +1006,6 @@ DhtProxyServer::put(restinio::request_handle_t request,
if (pput.expireNotifyTimer) if (pput.expireNotifyTimer)
pput.expireNotifyTimer->expires_at(timeout - proxy::OP_MARGIN); pput.expireNotifyTimer->expires_at(timeout - proxy::OP_MARGIN);
} }
lock.unlock();
} }
dht_->put(infoHash, value, [this, request, value](bool ok){ dht_->put(infoHash, value, [this, request, value](bool ok){
if (ok){ if (ok){
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment