diff --git a/src/network_engine.cpp b/src/network_engine.cpp index 9fbc806aeeefa2f4eea6dd8c3c8f44899f277dbe..cb305e170ab12bb91aaeea92c3147918eabaffab 100644 --- a/src/network_engine.cpp +++ b/src/network_engine.cpp @@ -140,7 +140,7 @@ RequestAnswer::RequestAnswer(ParsedMessage&& msg) {} NetworkEngine::NetworkEngine(Logger& log, Scheduler& scheduler, const int& s, const int& s6) - : myid(zeroes), DHT_LOG(log), scheduler(scheduler), dht_socket(s), dht_socket6(s6) + : myid(zeroes), DHT_LOG(log), dht_socket(s), dht_socket6(s6), scheduler(scheduler) {} NetworkEngine::NetworkEngine(InfoHash& myid, NetId net, const int& s, const int& s6, Logger& log, Scheduler& scheduler, decltype(NetworkEngine::onError) onError, @@ -610,6 +610,7 @@ NetworkEngine::process(std::unique_ptr<ParsedMessage>&& msg, const SockAddr& fro DHT_LOG.d(msg->info_hash, node->id, "[node %s] got 'listen' request for %s", node->toString().c_str(), msg->info_hash.toString().c_str()); ++in_stats.listen; RequestAnswer answer = onListen(node, msg->info_hash, msg->token, msg->socket_id, std::move(msg->query)); + auto nnodes = bufferNodes(from.getFamily(), msg->info_hash, msg->want, answer.nodes4, answer.nodes6); sendListenConfirmation(from, msg->tid); break; }