mirror of
https://github.com/rakshasa/rtorrent.git
synced 2026-10-15 21:56:18 +00:00
Merge branch 'master' into ipv6
This commit is contained in:
+1
-1
@@ -100,4 +100,4 @@
|
|||||||
|
|
||||||
# Set downlad list layout style. ("full", "compact")
|
# Set downlad list layout style. ("full", "compact")
|
||||||
#
|
#
|
||||||
#torrent_list_layout = "full"
|
#ui.torrent_list.layout.set = "full"
|
||||||
|
|||||||
@@ -230,10 +230,10 @@ cmd_file_append(const torrent::Object::list_type& args) {
|
|||||||
|
|
||||||
void
|
void
|
||||||
initialize_command_local() {
|
initialize_command_local() {
|
||||||
torrent::ChunkManager* chunkManager = torrent::chunk_manager();
|
|
||||||
torrent::FileManager* fileManager = torrent::file_manager();
|
|
||||||
core::DownloadList* dList = control->core()->download_list();
|
core::DownloadList* dList = control->core()->download_list();
|
||||||
core::DownloadStore* dStore = control->core()->download_store();
|
core::DownloadStore* dStore = control->core()->download_store();
|
||||||
|
torrent::ChunkManager* chunkManager = torrent::chunk_manager();
|
||||||
|
torrent::FileManager* fileManager = torrent::file_manager();
|
||||||
|
|
||||||
CMD2_ANY ("system.hostname", std::bind(&system_hostname));
|
CMD2_ANY ("system.hostname", std::bind(&system_hostname));
|
||||||
CMD2_ANY ("system.pid", std::bind(&getpid));
|
CMD2_ANY ("system.pid", std::bind(&getpid));
|
||||||
@@ -268,6 +268,10 @@ initialize_command_local() {
|
|||||||
|
|
||||||
CMD2_VAR_BOOL ("system.daemon", false);
|
CMD2_VAR_BOOL ("system.daemon", false);
|
||||||
|
|
||||||
|
CMD2_ANY_V ("system.shutdown.normal", std::bind(&Control::receive_normal_shutdown, control));
|
||||||
|
CMD2_ANY_V ("system.shutdown.quick", std::bind(&Control::receive_quick_shutdown, control));
|
||||||
|
CMD2_REDIRECT_GENERIC_NO_EXPORT("system.shutdown", "system.shutdown.normal");
|
||||||
|
|
||||||
CMD2_ANY ("system.cwd", std::bind(&system_get_cwd));
|
CMD2_ANY ("system.cwd", std::bind(&system_get_cwd));
|
||||||
CMD2_ANY_STRING ("system.cwd.set", std::bind(&system_set_cwd, std::placeholders::_2));
|
CMD2_ANY_STRING ("system.cwd.set", std::bind(&system_set_cwd, std::placeholders::_2));
|
||||||
|
|
||||||
|
|||||||
@@ -142,7 +142,7 @@ class CurlStack : std::deque<CurlGet*> {
|
|||||||
std::string m_httpCaPath;
|
std::string m_httpCaPath;
|
||||||
std::string m_httpCaCert;
|
std::string m_httpCaCert;
|
||||||
|
|
||||||
long m_ssl_verify_host;
|
bool m_ssl_verify_host;
|
||||||
bool m_ssl_verify_peer;
|
bool m_ssl_verify_peer;
|
||||||
long m_dns_timeout;
|
long m_dns_timeout;
|
||||||
};
|
};
|
||||||
|
|||||||
+13
-13
@@ -89,7 +89,7 @@ void do_nothing() {}
|
|||||||
void do_nothing_str(const std::string&) {}
|
void do_nothing_str(const std::string&) {}
|
||||||
|
|
||||||
int
|
int
|
||||||
parse_options(Control* c, int argc, char** argv) {
|
parse_options(int argc, char** argv) {
|
||||||
try {
|
try {
|
||||||
OptionParser optionParser;
|
OptionParser optionParser;
|
||||||
|
|
||||||
@@ -117,8 +117,8 @@ parse_options(Control* c, int argc, char** argv) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
void
|
void
|
||||||
load_session_torrents(Control* c) {
|
load_session_torrents() {
|
||||||
utils::Directory entries = c->core()->download_store()->get_formated_entries();
|
utils::Directory entries = control->core()->download_store()->get_formated_entries();
|
||||||
|
|
||||||
for (utils::Directory::const_iterator first = entries.begin(), last = entries.end(); first != last; ++first) {
|
for (utils::Directory::const_iterator first = entries.begin(), last = entries.end(); first != last; ++first) {
|
||||||
// We don't really support session torrents that are links. These
|
// We don't really support session torrents that are links. These
|
||||||
@@ -127,7 +127,7 @@ load_session_torrents(Control* c) {
|
|||||||
if (!first->is_file())
|
if (!first->is_file())
|
||||||
continue;
|
continue;
|
||||||
|
|
||||||
core::DownloadFactory* f = new core::DownloadFactory(c->core());
|
core::DownloadFactory* f = new core::DownloadFactory(control->core());
|
||||||
|
|
||||||
// Replace with session torrent flag.
|
// Replace with session torrent flag.
|
||||||
f->set_session(true);
|
f->set_session(true);
|
||||||
@@ -138,10 +138,10 @@ load_session_torrents(Control* c) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
void
|
void
|
||||||
load_arg_torrents(Control* c, char** first, char** last) {
|
load_arg_torrents(char** first, char** last) {
|
||||||
//std::for_each(begin, end, std::bind1st(std::mem_fun(&core::Manager::insert), &c->get_core()));
|
//std::for_each(begin, end, std::bind1st(std::mem_fun(&core::Manager::insert), &control->get_core()));
|
||||||
for (; first != last; ++first) {
|
for (; first != last; ++first) {
|
||||||
core::DownloadFactory* f = new core::DownloadFactory(c->core());
|
core::DownloadFactory* f = new core::DownloadFactory(control->core());
|
||||||
|
|
||||||
// Replace with session torrent flag.
|
// Replace with session torrent flag.
|
||||||
f->set_start(true);
|
f->set_start(true);
|
||||||
@@ -152,9 +152,9 @@ load_arg_torrents(Control* c, char** first, char** last) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
static uint64_t
|
static uint64_t
|
||||||
client_next_timeout(Control* c) {
|
client_next_timeout() {
|
||||||
if (taskScheduler.empty())
|
if (taskScheduler.empty())
|
||||||
return (c->is_shutdown_started() ? rak::timer::from_milliseconds(100) : rak::timer::from_seconds(60)).usec();
|
return (control->is_shutdown_started() ? rak::timer::from_milliseconds(100) : rak::timer::from_seconds(60)).usec();
|
||||||
else if (taskScheduler.top()->time() <= cachedTime)
|
else if (taskScheduler.top()->time() <= cachedTime)
|
||||||
return 0;
|
return 0;
|
||||||
else
|
else
|
||||||
@@ -222,7 +222,7 @@ main(int argc, char** argv) {
|
|||||||
|
|
||||||
torrent::initialize();
|
torrent::initialize();
|
||||||
torrent::main_thread()->slot_do_work() = std::bind(&client_perform);
|
torrent::main_thread()->slot_do_work() = std::bind(&client_perform);
|
||||||
torrent::main_thread()->slot_next_timeout() = std::bind(&client_next_timeout, control);
|
torrent::main_thread()->slot_next_timeout() = std::bind(&client_next_timeout);
|
||||||
|
|
||||||
worker_thread = new ThreadWorker();
|
worker_thread = new ThreadWorker();
|
||||||
worker_thread->init_thread();
|
worker_thread->init_thread();
|
||||||
@@ -440,7 +440,7 @@ main(int argc, char** argv) {
|
|||||||
}
|
}
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
int firstArg = parse_options(control, argc, argv);
|
int firstArg = parse_options(argc, argv);
|
||||||
|
|
||||||
if (OptionParser::has_flag('n', argc, argv)) {
|
if (OptionParser::has_flag('n', argc, argv)) {
|
||||||
lt_log_print(torrent::LOG_WARN, "Ignoring rtorrent.rc.");
|
lt_log_print(torrent::LOG_WARN, "Ignoring rtorrent.rc.");
|
||||||
@@ -463,10 +463,10 @@ main(int argc, char** argv) {
|
|||||||
// Load session torrents and perform scheduled tasks to ensure
|
// Load session torrents and perform scheduled tasks to ensure
|
||||||
// session torrents are loaded before arg torrents.
|
// session torrents are loaded before arg torrents.
|
||||||
control->dht_manager()->load_dht_cache();
|
control->dht_manager()->load_dht_cache();
|
||||||
load_session_torrents(control);
|
load_session_torrents();
|
||||||
rak::priority_queue_perform(&taskScheduler, cachedTime);
|
rak::priority_queue_perform(&taskScheduler, cachedTime);
|
||||||
|
|
||||||
load_arg_torrents(control, argv + firstArg, argv + argc);
|
load_arg_torrents(argv + firstArg, argv + argc);
|
||||||
|
|
||||||
// Make sure we update the display before any scheduled tasks can
|
// Make sure we update the display before any scheduled tasks can
|
||||||
// run, so that loading of torrents doesn't look like it hangs on
|
// run, so that loading of torrents doesn't look like it hangs on
|
||||||
|
|||||||
Reference in New Issue
Block a user