mirror of
https://github.com/rakshasa/rtorrent.git
synced 2026-10-13 12:46:18 +00:00
Moved NetworkConfig to runtime.
This commit is contained in:
@@ -8,8 +8,8 @@
|
|||||||
#include <torrent/data/file_manager.h>
|
#include <torrent/data/file_manager.h>
|
||||||
#include <torrent/download/resource_manager.h>
|
#include <torrent/download/resource_manager.h>
|
||||||
#include <torrent/net/http_stack.h>
|
#include <torrent/net/http_stack.h>
|
||||||
#include <torrent/net/network_config.h>
|
|
||||||
#include <torrent/net/socket_address.h>
|
#include <torrent/net/socket_address.h>
|
||||||
|
#include <torrent/runtime/network_config.h>
|
||||||
#include <torrent/tracker/tracker.h>
|
#include <torrent/tracker/tracker.h>
|
||||||
#include <torrent/utils/log.h>
|
#include <torrent/utils/log.h>
|
||||||
#include <torrent/utils/option_strings.h>
|
#include <torrent/utils/option_strings.h>
|
||||||
@@ -31,18 +31,18 @@
|
|||||||
|
|
||||||
torrent::Object
|
torrent::Object
|
||||||
apply_encryption(const torrent::Object::list_type& args) {
|
apply_encryption(const torrent::Object::list_type& args) {
|
||||||
uint32_t options_mask = torrent::net::NetworkConfig::encryption_none;
|
uint32_t options_mask = torrent::runtime::NetworkConfig::encryption_none;
|
||||||
|
|
||||||
for (const auto& arg : args) {
|
for (const auto& arg : args) {
|
||||||
uint32_t opt = torrent::option_find_string(torrent::OPTION_ENCRYPTION, arg.as_string().c_str());
|
uint32_t opt = torrent::option_find_string(torrent::OPTION_ENCRYPTION, arg.as_string().c_str());
|
||||||
|
|
||||||
if (opt == torrent::net::NetworkConfig::encryption_none)
|
if (opt == torrent::runtime::NetworkConfig::encryption_none)
|
||||||
options_mask = torrent::net::NetworkConfig::encryption_none;
|
options_mask = torrent::runtime::NetworkConfig::encryption_none;
|
||||||
else
|
else
|
||||||
options_mask |= opt;
|
options_mask |= opt;
|
||||||
}
|
}
|
||||||
|
|
||||||
torrent::config::network_config()->set_encryption_options(options_mask);
|
torrent::runtime::network_config()->set_encryption_options(options_mask);
|
||||||
|
|
||||||
return torrent::Object();
|
return torrent::Object();
|
||||||
}
|
}
|
||||||
@@ -54,7 +54,7 @@ apply_tos(const torrent::Object::string_type& arg) {
|
|||||||
if (!rpc::parse_whole_value_nothrow(arg.c_str(), &value, 16, 1))
|
if (!rpc::parse_whole_value_nothrow(arg.c_str(), &value, 16, 1))
|
||||||
value = torrent::option_find_string(torrent::OPTION_IP_TOS, arg.c_str());
|
value = torrent::option_find_string(torrent::OPTION_IP_TOS, arg.c_str());
|
||||||
|
|
||||||
torrent::config::network_config()->set_priority(value);
|
torrent::runtime::network_config()->set_priority(value);
|
||||||
|
|
||||||
return torrent::Object();
|
return torrent::Object();
|
||||||
}
|
}
|
||||||
@@ -215,10 +215,10 @@ apply_xmlrpc_dialect(const std::string& arg) {
|
|||||||
|
|
||||||
void
|
void
|
||||||
initialize_command_network() {
|
initialize_command_network() {
|
||||||
auto cm = torrent::connection_manager();
|
auto cm = torrent::connection_manager();
|
||||||
auto file_manager = torrent::file_manager();
|
auto file_manager = torrent::file_manager();
|
||||||
auto http_stack = torrent::net_thread::http_stack();
|
auto http_stack = torrent::net_thread::http_stack();
|
||||||
auto nw_config = torrent::config::network_config();
|
auto nw_config = torrent::runtime::network_config();
|
||||||
|
|
||||||
CMD2_ANY_STRING ("encoding.add", std::bind(&apply_encoding_list, std::placeholders::_2));
|
CMD2_ANY_STRING ("encoding.add", std::bind(&apply_encoding_list, std::placeholders::_2));
|
||||||
|
|
||||||
|
|||||||
@@ -3,8 +3,8 @@
|
|||||||
#include <cassert>
|
#include <cassert>
|
||||||
#include <cstdio>
|
#include <cstdio>
|
||||||
#include <netdb.h>
|
#include <netdb.h>
|
||||||
#include <torrent/net/network_config.h>
|
|
||||||
#include <torrent/net/resolver.h>
|
#include <torrent/net/resolver.h>
|
||||||
|
#include <torrent/runtime/network_config.h>
|
||||||
#include <torrent/runtime/network_manager.h>
|
#include <torrent/runtime/network_manager.h>
|
||||||
#include <torrent/tracker/dht_controller.h>
|
#include <torrent/tracker/dht_controller.h>
|
||||||
#include <torrent/tracker/tracker.h>
|
#include <torrent/tracker/tracker.h>
|
||||||
@@ -146,8 +146,8 @@ initialize_command_tracker() {
|
|||||||
CMD2_ANY_VALUE_V ("dht.port.set", [](auto, auto) {
|
CMD2_ANY_VALUE_V ("dht.port.set", [](auto, auto) {
|
||||||
lt_log_print(torrent::LOG_DHT_ERROR, "dht.port.set is no longer supported, use dht.override_port.set", 0);
|
lt_log_print(torrent::LOG_DHT_ERROR, "dht.port.set is no longer supported, use dht.override_port.set", 0);
|
||||||
});
|
});
|
||||||
CMD2_ANY ("dht.override_port", std::bind(&torrent::net::NetworkConfig::override_dht_port, torrent::config::network_config()));
|
CMD2_ANY ("dht.override_port", std::bind(&torrent::runtime::NetworkConfig::override_dht_port, torrent::runtime::network_config()));
|
||||||
CMD2_ANY_VALUE_V ("dht.override_port.set", std::bind(&torrent::net::NetworkConfig::set_override_dht_port, torrent::config::network_config(), std::placeholders::_2));
|
CMD2_ANY_VALUE_V ("dht.override_port.set", std::bind(&torrent::runtime::NetworkConfig::set_override_dht_port, torrent::runtime::network_config(), std::placeholders::_2));
|
||||||
|
|
||||||
CMD2_ANY_STRING ("dht.add_node", std::bind(&apply_dht_add_node, std::placeholders::_2));
|
CMD2_ANY_STRING ("dht.add_node", std::bind(&apply_dht_add_node, std::placeholders::_2));
|
||||||
CMD2_ANY ("dht.statistics", std::bind(&core::DhtManager::dht_statistics, dht_manager));
|
CMD2_ANY ("dht.statistics", std::bind(&core::DhtManager::dht_statistics, dht_manager));
|
||||||
|
|||||||
+2
-2
@@ -17,8 +17,8 @@
|
|||||||
#include <torrent/object_stream.h>
|
#include <torrent/object_stream.h>
|
||||||
#include <torrent/throttle.h>
|
#include <torrent/throttle.h>
|
||||||
#include <torrent/net/http_stack.h>
|
#include <torrent/net/http_stack.h>
|
||||||
#include <torrent/net/network_config.h>
|
|
||||||
#include <torrent/net/socket_address.h>
|
#include <torrent/net/socket_address.h>
|
||||||
|
#include <torrent/runtime/network_config.h>
|
||||||
#include <torrent/runtime/network_manager.h>
|
#include <torrent/runtime/network_manager.h>
|
||||||
#include <torrent/utils/log.h>
|
#include <torrent/utils/log.h>
|
||||||
#include <torrent/utils/string_manip.h>
|
#include <torrent/utils/string_manip.h>
|
||||||
@@ -219,7 +219,7 @@ Manager::set_proxy_address(const std::string& addr) {
|
|||||||
|
|
||||||
try {
|
try {
|
||||||
torrent::sa_set_port(sa.get(), port);
|
torrent::sa_set_port(sa.get(), port);
|
||||||
torrent::config::network_config()->set_proxy_address(sa.get());
|
torrent::runtime::network_config()->set_proxy_address(sa.get());
|
||||||
|
|
||||||
} catch (torrent::input_error& e) {
|
} catch (torrent::input_error& e) {
|
||||||
throw e;
|
throw e;
|
||||||
|
|||||||
@@ -16,9 +16,9 @@
|
|||||||
#include <torrent/data/file_manager.h>
|
#include <torrent/data/file_manager.h>
|
||||||
#include <torrent/download/resource_manager.h>
|
#include <torrent/download/resource_manager.h>
|
||||||
#include <torrent/net/http_stack.h>
|
#include <torrent/net/http_stack.h>
|
||||||
#include <torrent/net/network_config.h>
|
|
||||||
#include <torrent/net/socket_address.h>
|
#include <torrent/net/socket_address.h>
|
||||||
#include <torrent/peer/client_info.h>
|
#include <torrent/peer/client_info.h>
|
||||||
|
#include <torrent/runtime/network_config.h>
|
||||||
|
|
||||||
#include "control.h"
|
#include "control.h"
|
||||||
#include "globals.h"
|
#include "globals.h"
|
||||||
@@ -376,7 +376,7 @@ print_status_info(char* first, char* last) {
|
|||||||
first = print_buffer(first, last, " KB]");
|
first = print_buffer(first, last, " KB]");
|
||||||
first = print_buffer(first, last, " [Port: %i]", (unsigned int)torrent::runtime::listen_port());
|
first = print_buffer(first, last, " [Port: %i]", (unsigned int)torrent::runtime::listen_port());
|
||||||
|
|
||||||
auto local_address = torrent::config::network_config()->local_address_best_match();
|
auto local_address = torrent::runtime::network_config()->local_address_best_match();
|
||||||
|
|
||||||
if (!torrent::sa_is_any(local_address.get())) {
|
if (!torrent::sa_is_any(local_address.get())) {
|
||||||
first = print_buffer(first, last, " [Local ");
|
first = print_buffer(first, last, " [Local ");
|
||||||
@@ -387,8 +387,8 @@ print_status_info(char* first, char* last) {
|
|||||||
if (first > last)
|
if (first > last)
|
||||||
throw torrent::internal_error("print_status_info(...) wrote past end of the buffer.");
|
throw torrent::internal_error("print_status_info(...) wrote past end of the buffer.");
|
||||||
|
|
||||||
auto bind_inet_address = torrent::config::network_config()->bind_inet_address();
|
auto bind_inet_address = torrent::runtime::network_config()->bind_inet_address();
|
||||||
auto bind_inet6_address = torrent::config::network_config()->bind_inet6_address();
|
auto bind_inet6_address = torrent::runtime::network_config()->bind_inet6_address();
|
||||||
bool show_bind_inet = !torrent::sa_is_any(bind_inet_address.get());
|
bool show_bind_inet = !torrent::sa_is_any(bind_inet_address.get());
|
||||||
bool show_bind_inet6 = !torrent::sa_is_any(bind_inet6_address.get());
|
bool show_bind_inet6 = !torrent::sa_is_any(bind_inet6_address.get());
|
||||||
|
|
||||||
|
|||||||
@@ -4,7 +4,7 @@
|
|||||||
|
|
||||||
#include <array>
|
#include <array>
|
||||||
#include <torrent/exceptions.h>
|
#include <torrent/exceptions.h>
|
||||||
#include <torrent/net/network_config.h>
|
#include <torrent/runtime/network_config.h>
|
||||||
#include <torrent/utils/log.h>
|
#include <torrent/utils/log.h>
|
||||||
#include <torrent/utils/option_strings.h>
|
#include <torrent/utils/option_strings.h>
|
||||||
|
|
||||||
@@ -178,11 +178,11 @@ TestParseOptions::test_flag_libtorrent() {
|
|||||||
|
|
||||||
void
|
void
|
||||||
TestParseOptions::test_flags_libtorrent() {
|
TestParseOptions::test_flags_libtorrent() {
|
||||||
FLAGS_LT_ENCRYPTION_ASSERT("", torrent::net::NetworkConfig::encryption_none);
|
FLAGS_LT_ENCRYPTION_ASSERT("", torrent::runtime::NetworkConfig::encryption_none);
|
||||||
FLAGS_LT_ENCRYPTION_ASSERT("none", torrent::net::NetworkConfig::encryption_none);
|
FLAGS_LT_ENCRYPTION_ASSERT("none", torrent::runtime::NetworkConfig::encryption_none);
|
||||||
FLAGS_LT_ENCRYPTION_ASSERT("require_rc4", torrent::net::NetworkConfig::encryption_require_RC4);
|
FLAGS_LT_ENCRYPTION_ASSERT("require_rc4", torrent::runtime::NetworkConfig::encryption_require_RC4);
|
||||||
FLAGS_LT_ENCRYPTION_ASSERT("require_RC4", torrent::net::NetworkConfig::encryption_require_RC4);
|
FLAGS_LT_ENCRYPTION_ASSERT("require_RC4", torrent::runtime::NetworkConfig::encryption_require_RC4);
|
||||||
FLAGS_LT_ENCRYPTION_ASSERT("require_RC4 | enable_retry", torrent::net::NetworkConfig::encryption_require_RC4 | torrent::net::NetworkConfig::encryption_enable_retry);
|
FLAGS_LT_ENCRYPTION_ASSERT("require_RC4 | enable_retry", torrent::runtime::NetworkConfig::encryption_require_RC4 | torrent::runtime::NetworkConfig::encryption_enable_retry);
|
||||||
|
|
||||||
FLAGS_LT_ENCRYPTION_ASSERT_ERROR("require_");
|
FLAGS_LT_ENCRYPTION_ASSERT_ERROR("require_");
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user