From 5dfb2ae938098ac87a2a8b8377df960fc63f2d62 Mon Sep 17 00:00:00 2001 From: rakshasa Date: Mon, 2 Mar 2026 08:47:44 +0100 Subject: [PATCH] Allow dht bootstrap nodes to be added when dht is off. --- src/command_tracker.cc | 3 --- src/rpc/scgi_task.cc | 6 +++--- 2 files changed, 3 insertions(+), 6 deletions(-) diff --git a/src/command_tracker.cc b/src/command_tracker.cc index 08fdee72..1dc47205 100644 --- a/src/command_tracker.cc +++ b/src/command_tracker.cc @@ -28,9 +28,6 @@ tracker_set_enabled(torrent::tracker::Tracker* tracker, bool state) { torrent::Object apply_dht_add_node(const std::string& arg) { - if (!torrent::runtime::network_manager()->is_dht_valid()) - throw torrent::input_error("DHT not enabled."); - int port; char dummy; char host[1024]; diff --git a/src/rpc/scgi_task.cc b/src/rpc/scgi_task.cc index 2439d4dc..1ab8c2ff 100644 --- a/src/rpc/scgi_task.cc +++ b/src/rpc/scgi_task.cc @@ -276,7 +276,7 @@ SCgiTask::receive_call(const char* buffer, uint32_t length) { auto result_callback = [this, scgi_thread](const char* b, uint32_t l) { receive_write(b, l); - scgi_thread->callback_interrupt_pollling(this, [this]() { + scgi_thread->callback_interrupt_polling(this, [this]() { // Only need to lock once here as a memory barrier. m_result_mutex.lock(); m_result_mutex.unlock(); @@ -289,7 +289,7 @@ SCgiTask::receive_call(const char* buffer, uint32_t length) { switch (content_type()) { case rpc::SCgiTask::ContentType::JSON: - torrent::main_thread::thread()->callback_interrupt_pollling(this, [buffer, length, result_callback]() { + torrent::main_thread::thread()->callback_interrupt_polling(this, [buffer, length, result_callback]() { rpc.process(RpcManager::RPCType::JSON, buffer, length, [result_callback](const char* b, uint32_t l) { result_callback(b, l); @@ -299,7 +299,7 @@ SCgiTask::receive_call(const char* buffer, uint32_t length) { break; case rpc::SCgiTask::ContentType::XML: - torrent::main_thread::thread()->callback_interrupt_pollling(this, [buffer, length, result_callback]() { + torrent::main_thread::thread()->callback_interrupt_polling(this, [buffer, length, result_callback]() { rpc.process(RpcManager::RPCType::XML, buffer, length, [result_callback](const char* b, uint32_t l) { result_callback(b, l);