mirror of
https://github.com/transmission/transmission
synced 2024-12-23 08:13:27 +00:00
951 lines
28 KiB
C++
951 lines
28 KiB
C++
// This file Copyright © 2008-2022 Mnemosyne LLC.
|
|
// It may be used under GPLv2 (SPDX: GPL-2.0-only), GPLv3 (SPDX: GPL-3.0-only),
|
|
// or any future license endorsed by Mnemosyne LLC.
|
|
// License text can be found in the licenses/ folder.
|
|
|
|
#include <array>
|
|
#include <errno.h>
|
|
#include <stdio.h> /* printf */
|
|
#include <stdlib.h> /* atoi */
|
|
#include <string_view>
|
|
|
|
#ifdef HAVE_SYSLOG
|
|
#include <syslog.h>
|
|
#endif
|
|
|
|
#ifdef _WIN32
|
|
#include <process.h> /* getpid */
|
|
#else
|
|
#include <unistd.h> /* getpid */
|
|
#endif
|
|
|
|
#include <event2/event.h>
|
|
|
|
#include <fmt/core.h>
|
|
|
|
#include <libtransmission/transmission.h>
|
|
#include <libtransmission/error.h>
|
|
#include <libtransmission/file.h>
|
|
#include <libtransmission/tr-getopt.h>
|
|
#include <libtransmission/tr-macros.h>
|
|
#include <libtransmission/log.h>
|
|
#include <libtransmission/utils.h>
|
|
#include <libtransmission/variant.h>
|
|
#include <libtransmission/version.h>
|
|
#include <libtransmission/watchdir.h>
|
|
|
|
#include "daemon.h"
|
|
|
|
#ifdef USE_SYSTEMD
|
|
|
|
#include <systemd/sd-daemon.h>
|
|
|
|
#else
|
|
|
|
static void sd_notify(int /*status*/, char const* /*str*/)
|
|
{
|
|
// no-op
|
|
}
|
|
|
|
static void sd_notifyf(int /*status*/, char const* /*fmt*/, ...)
|
|
{
|
|
// no-op
|
|
}
|
|
|
|
#endif
|
|
|
|
using namespace std::literals;
|
|
|
|
/***
|
|
****
|
|
***/
|
|
|
|
static auto constexpr CodeName = "daemon"sv;
|
|
|
|
#undef tr_logAddError
|
|
#undef tr_logAddWarn
|
|
#undef tr_logAddInfo
|
|
#undef tr_logAddDebug
|
|
#undef tr_logAddTrace
|
|
|
|
#define tr_logAddError(...) tr_logAddNamedError(CodeName, __VA_ARGS__)
|
|
#define tr_logAddWarn(...) tr_logAddNamedWarn(CodeName, __VA_ARGS__)
|
|
#define tr_logAddInfo(...) tr_logAddNamedInfo(CodeName, __VA_ARGS__)
|
|
#define tr_logAddDebug(...) tr_logAddNamedDebug(CodeName, __VA_ARGS__)
|
|
#define tr_logAddTrace(...) tr_logAddNamedTrace(CodeName, __VA_ARGS__)
|
|
|
|
/***
|
|
****
|
|
***/
|
|
|
|
static char constexpr MyName[] = "transmission-daemon";
|
|
static char constexpr Usage[] = "Transmission " LONG_VERSION_STRING
|
|
" https://transmissionbt.com/\n"
|
|
"A fast and easy BitTorrent client\n"
|
|
"\n"
|
|
"transmission-daemon is a headless Transmission session that can be\n"
|
|
"controlled via transmission-qt, transmission-remote, or its web interface.\n"
|
|
"\n"
|
|
"Usage: transmission-daemon [options]";
|
|
|
|
static auto constexpr MemK = size_t{ 1024 };
|
|
static char constexpr MemKStr[] = "KiB";
|
|
static char constexpr MemMStr[] = "MiB";
|
|
static char constexpr MemGStr[] = "GiB";
|
|
static char constexpr MemTStr[] = "TiB";
|
|
|
|
static auto constexpr DiskK = size_t{ 1000 };
|
|
static char constexpr DiskKStr[] = "kB";
|
|
static char constexpr DiskMStr[] = "MB";
|
|
static char constexpr DiskGStr[] = "GB";
|
|
static char constexpr DiskTStr[] = "TB";
|
|
|
|
static auto constexpr SpeedK = size_t{ 1000 };
|
|
static char constexpr SpeedKStr[] = "kB/s";
|
|
static char constexpr SpeedMStr[] = "MB/s";
|
|
static char constexpr SpeedGStr[] = "GB/s";
|
|
static char constexpr SpeedTStr[] = "TB/s";
|
|
|
|
static bool seenHUP = false;
|
|
static char const* logfileName = nullptr;
|
|
static tr_sys_file_t logfile = TR_BAD_SYS_FILE;
|
|
static tr_session* mySession = nullptr;
|
|
static tr_quark key_pidfile = 0;
|
|
static tr_quark key_watch_dir_force_generic = 0;
|
|
static struct event_base* ev_base = nullptr;
|
|
|
|
/***
|
|
**** Config File
|
|
***/
|
|
|
|
static auto constexpr Options = std::array<tr_option, 44>{
|
|
{ { 'a', "allowed", "Allowed IP addresses. (Default: " TR_DEFAULT_RPC_WHITELIST ")", "a", true, "<list>" },
|
|
{ 'b', "blocklist", "Enable peer blocklists", "b", false, nullptr },
|
|
{ 'B', "no-blocklist", "Disable peer blocklists", "B", false, nullptr },
|
|
{ 'c', "watch-dir", "Where to watch for new .torrent files", "c", true, "<directory>" },
|
|
{ 'C', "no-watch-dir", "Disable the watch-dir", "C", false, nullptr },
|
|
{ 941, "incomplete-dir", "Where to store new torrents until they're complete", nullptr, true, "<directory>" },
|
|
{ 942, "no-incomplete-dir", "Don't store incomplete torrents in a different location", nullptr, false, nullptr },
|
|
{ 'd', "dump-settings", "Dump the settings and exit", "d", false, nullptr },
|
|
{ 943, "default-trackers", "Trackers for public torrents to use automatically", nullptr, true, "<list>" },
|
|
{ 'e', "logfile", "Dump the log messages to this filename", "e", true, "<filename>" },
|
|
{ 'f', "foreground", "Run in the foreground instead of daemonizing", "f", false, nullptr },
|
|
{ 'g', "config-dir", "Where to look for configuration files", "g", true, "<path>" },
|
|
{ 'p', "port", "RPC port (Default: " TR_DEFAULT_RPC_PORT_STR ")", "p", true, "<port>" },
|
|
{ 't', "auth", "Require authentication", "t", false, nullptr },
|
|
{ 'T', "no-auth", "Don't require authentication", "T", false, nullptr },
|
|
{ 'u', "username", "Set username for authentication", "u", true, "<username>" },
|
|
{ 'v', "password", "Set password for authentication", "v", true, "<password>" },
|
|
{ 'V', "version", "Show version number and exit", "V", false, nullptr },
|
|
{ 810, "log-error", "Show error messages", nullptr, false, nullptr },
|
|
{ 811, "log-info", "Show error and info messages", nullptr, false, nullptr },
|
|
{ 812, "log-debug", "Show error, info, and debug messages", nullptr, false, nullptr },
|
|
{ 'w', "download-dir", "Where to save downloaded data", "w", true, "<path>" },
|
|
{ 800, "paused", "Pause all torrents on startup", nullptr, false, nullptr },
|
|
{ 'o', "dht", "Enable distributed hash tables (DHT)", "o", false, nullptr },
|
|
{ 'O', "no-dht", "Disable distributed hash tables (DHT)", "O", false, nullptr },
|
|
{ 'y', "lpd", "Enable local peer discovery (LPD)", "y", false, nullptr },
|
|
{ 'Y', "no-lpd", "Disable local peer discovery (LPD)", "Y", false, nullptr },
|
|
{ 830, "utp", "Enable uTP for peer connections", nullptr, false, nullptr },
|
|
{ 831, "no-utp", "Disable uTP for peer connections", nullptr, false, nullptr },
|
|
{ 'P', "peerport", "Port for incoming peers (Default: " TR_DEFAULT_PEER_PORT_STR ")", "P", true, "<port>" },
|
|
{ 'm', "portmap", "Enable portmapping via NAT-PMP or UPnP", "m", false, nullptr },
|
|
{ 'M', "no-portmap", "Disable portmapping", "M", false, nullptr },
|
|
{ 'L',
|
|
"peerlimit-global",
|
|
"Maximum overall number of peers (Default: " TR_DEFAULT_PEER_LIMIT_GLOBAL_STR ")",
|
|
"L",
|
|
true,
|
|
"<limit>" },
|
|
{ 'l',
|
|
"peerlimit-torrent",
|
|
"Maximum number of peers per torrent (Default: " TR_DEFAULT_PEER_LIMIT_TORRENT_STR ")",
|
|
"l",
|
|
true,
|
|
"<limit>" },
|
|
{ 910, "encryption-required", "Encrypt all peer connections", "er", false, nullptr },
|
|
{ 911, "encryption-preferred", "Prefer encrypted peer connections", "ep", false, nullptr },
|
|
{ 912, "encryption-tolerated", "Prefer unencrypted peer connections", "et", false, nullptr },
|
|
{ 'i', "bind-address-ipv4", "Where to listen for peer connections", "i", true, "<ipv4 addr>" },
|
|
{ 'I', "bind-address-ipv6", "Where to listen for peer connections", "I", true, "<ipv6 addr>" },
|
|
{ 'r', "rpc-bind-address", "Where to listen for RPC connections", "r", true, "<ip addr>" },
|
|
{ 953,
|
|
"global-seedratio",
|
|
"All torrents, unless overridden by a per-torrent setting, should seed until a specific ratio",
|
|
"gsr",
|
|
true,
|
|
"ratio" },
|
|
{ 954,
|
|
"no-global-seedratio",
|
|
"All torrents, unless overridden by a per-torrent setting, should seed regardless of ratio",
|
|
"GSR",
|
|
false,
|
|
nullptr },
|
|
{ 'x', "pid-file", "Enable PID file", "x", true, "<pid-file>" },
|
|
{ 0, nullptr, nullptr, nullptr, false, nullptr } }
|
|
};
|
|
|
|
static bool reopen_log_file(char const* filename)
|
|
{
|
|
tr_error* error = nullptr;
|
|
tr_sys_file_t const old_log_file = logfile;
|
|
tr_sys_file_t const new_log_file = tr_sys_file_open(
|
|
filename,
|
|
TR_SYS_FILE_WRITE | TR_SYS_FILE_CREATE | TR_SYS_FILE_APPEND,
|
|
0666,
|
|
&error);
|
|
|
|
if (new_log_file == TR_BAD_SYS_FILE)
|
|
{
|
|
fprintf(stderr, "Couldn't (re)open log file \"%s\": %s\n", filename, error->message);
|
|
tr_error_free(error);
|
|
return false;
|
|
}
|
|
|
|
logfile = new_log_file;
|
|
|
|
if (old_log_file != TR_BAD_SYS_FILE)
|
|
{
|
|
tr_sys_file_close(old_log_file, nullptr);
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
static char const* getConfigDir(int argc, char const* const* argv)
|
|
{
|
|
int c;
|
|
char const* configDir = nullptr;
|
|
char const* optstr;
|
|
int const ind = tr_optind;
|
|
|
|
while ((c = tr_getopt(Usage, argc, argv, std::data(Options), &optstr)) != TR_OPT_DONE)
|
|
{
|
|
if (c == 'g')
|
|
{
|
|
configDir = optstr;
|
|
break;
|
|
}
|
|
}
|
|
|
|
tr_optind = ind;
|
|
|
|
if (configDir == nullptr)
|
|
{
|
|
configDir = tr_getDefaultConfigDir(MyName);
|
|
}
|
|
|
|
return configDir;
|
|
}
|
|
|
|
static auto onFileAdded(tr_watchdir_t dir, char const* name, void* vsession)
|
|
{
|
|
auto const* session = static_cast<tr_session const*>(vsession);
|
|
|
|
if (!tr_str_has_suffix(name, ".torrent"))
|
|
{
|
|
return TR_WATCHDIR_IGNORE;
|
|
}
|
|
|
|
auto filename = tr_strvPath(tr_watchdir_get_path(dir), name);
|
|
tr_ctor* ctor = tr_ctorNew(session);
|
|
if (!tr_ctorSetMetainfoFromFile(ctor, filename.c_str(), nullptr))
|
|
{
|
|
tr_ctorFree(ctor);
|
|
return TR_WATCHDIR_RETRY;
|
|
}
|
|
|
|
if (tr_torrentNew(ctor, nullptr) == nullptr)
|
|
{
|
|
tr_logAddError(fmt::format(_("Couldn't add .torrent file '{path}'"), fmt::arg("path", name)));
|
|
}
|
|
else
|
|
{
|
|
bool trash = false;
|
|
bool const test = tr_ctorGetDeleteSource(ctor, &trash);
|
|
|
|
if (test && trash)
|
|
{
|
|
tr_error* error = nullptr;
|
|
|
|
tr_logAddInfo(fmt::format(_("Removing .torrent file '{path}'"), fmt::arg("path", name)));
|
|
|
|
if (!tr_sys_path_remove(filename.c_str(), &error))
|
|
{
|
|
tr_logAddError(fmt::format(
|
|
_("Couldn't remove '{path}': {error} ({error_code})"),
|
|
fmt::arg("path", name),
|
|
fmt::arg("error", error->message),
|
|
fmt::arg("error_code", error->code)));
|
|
tr_error_free(error);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
auto const new_filename = filename + ".added";
|
|
tr_sys_path_rename(filename.c_str(), new_filename.c_str(), nullptr);
|
|
}
|
|
}
|
|
|
|
tr_ctorFree(ctor);
|
|
return TR_WATCHDIR_ACCEPT;
|
|
}
|
|
|
|
static char const* levelName(tr_log_level level)
|
|
{
|
|
switch (level)
|
|
{
|
|
case TR_LOG_CRITICAL:
|
|
return "CRT";
|
|
case TR_LOG_ERROR:
|
|
return "ERR";
|
|
case TR_LOG_WARN:
|
|
return "WRN";
|
|
case TR_LOG_DEBUG:
|
|
return "dbg";
|
|
case TR_LOG_TRACE:
|
|
return "trc";
|
|
default:
|
|
return "inf";
|
|
}
|
|
}
|
|
|
|
static void printMessage(
|
|
tr_sys_file_t file,
|
|
tr_log_level level,
|
|
std::string_view name,
|
|
std::string_view message,
|
|
std::string_view filename,
|
|
int line)
|
|
{
|
|
auto const out = std::empty(name) ? tr_strvJoin(message, " ("sv, filename, ":"sv, std::to_string(line), ")"sv) :
|
|
tr_strvJoin(name, " "sv, message, " ("sv, filename, ":"sv, std::to_string(line), ")"sv);
|
|
|
|
if (file != TR_BAD_SYS_FILE)
|
|
{
|
|
auto timestr = std::array<char, 64>{};
|
|
tr_logGetTimeStr(std::data(timestr), std::size(timestr));
|
|
tr_sys_file_write_line(file, tr_strvJoin("["sv, std::data(timestr), "] "sv, levelName(level), " "sv, out), nullptr);
|
|
}
|
|
|
|
#ifdef HAVE_SYSLOG
|
|
|
|
else /* daemon... write to syslog */
|
|
{
|
|
int priority;
|
|
|
|
/* figure out the syslog priority */
|
|
switch (level)
|
|
{
|
|
case TR_LOG_CRITICAL:
|
|
priority = LOG_CRIT;
|
|
break;
|
|
|
|
case TR_LOG_ERROR:
|
|
priority = LOG_ERR;
|
|
break;
|
|
|
|
case TR_LOG_WARN:
|
|
priority = LOG_WARNING;
|
|
break;
|
|
|
|
case TR_LOG_INFO:
|
|
priority = LOG_INFO;
|
|
break;
|
|
|
|
default:
|
|
priority = LOG_DEBUG;
|
|
break;
|
|
}
|
|
|
|
syslog(priority, "%s", out.c_str());
|
|
}
|
|
|
|
#endif
|
|
}
|
|
|
|
static void pumpLogMessages(tr_sys_file_t file)
|
|
{
|
|
tr_log_message* list = tr_logGetQueue();
|
|
|
|
for (tr_log_message const* l = list; l != nullptr; l = l->next)
|
|
{
|
|
auto const name = std::string_view{ l->name != nullptr ? l->name : "" };
|
|
printMessage(file, l->level, name, l->message, l->file, l->line);
|
|
}
|
|
|
|
if (file != TR_BAD_SYS_FILE)
|
|
{
|
|
tr_sys_file_flush(file, nullptr);
|
|
}
|
|
|
|
tr_logFreeQueue(list);
|
|
}
|
|
|
|
static void reportStatus(void)
|
|
{
|
|
double const up = tr_sessionGetRawSpeed_KBps(mySession, TR_UP);
|
|
double const dn = tr_sessionGetRawSpeed_KBps(mySession, TR_DOWN);
|
|
|
|
if (up > 0 || dn > 0)
|
|
{
|
|
sd_notifyf(0, "STATUS=Uploading %.2f KBps, Downloading %.2f KBps.\n", up, dn);
|
|
}
|
|
else
|
|
{
|
|
sd_notify(0, "STATUS=Idle.\n");
|
|
}
|
|
}
|
|
|
|
static void periodicUpdate(evutil_socket_t /*fd*/, short /*what*/, void* /*context*/)
|
|
{
|
|
pumpLogMessages(logfile);
|
|
reportStatus();
|
|
}
|
|
|
|
static tr_rpc_callback_status on_rpc_callback(
|
|
tr_session* /*session*/,
|
|
tr_rpc_callback_type type,
|
|
tr_torrent* /*tor*/,
|
|
void* /*user_data*/)
|
|
{
|
|
if (type == TR_RPC_SESSION_CLOSE)
|
|
{
|
|
event_base_loopexit(ev_base, nullptr);
|
|
}
|
|
|
|
return TR_RPC_OK;
|
|
}
|
|
|
|
static bool parse_args(
|
|
int argc,
|
|
char const** argv,
|
|
tr_variant* settings,
|
|
bool* paused,
|
|
bool* dump_settings,
|
|
bool* foreground,
|
|
int* exit_code)
|
|
{
|
|
int c;
|
|
char const* optstr;
|
|
|
|
*paused = false;
|
|
*dump_settings = false;
|
|
*foreground = false;
|
|
|
|
tr_optind = 1;
|
|
|
|
while ((c = tr_getopt(Usage, argc, argv, std::data(Options), &optstr)) != TR_OPT_DONE)
|
|
{
|
|
switch (c)
|
|
{
|
|
case 'a':
|
|
tr_variantDictAddStr(settings, TR_KEY_rpc_whitelist, optstr);
|
|
tr_variantDictAddBool(settings, TR_KEY_rpc_whitelist_enabled, true);
|
|
break;
|
|
|
|
case 'b':
|
|
tr_variantDictAddBool(settings, TR_KEY_blocklist_enabled, true);
|
|
break;
|
|
|
|
case 'B':
|
|
tr_variantDictAddBool(settings, TR_KEY_blocklist_enabled, false);
|
|
break;
|
|
|
|
case 'c':
|
|
tr_variantDictAddStr(settings, TR_KEY_watch_dir, optstr);
|
|
tr_variantDictAddBool(settings, TR_KEY_watch_dir_enabled, true);
|
|
break;
|
|
|
|
case 'C':
|
|
tr_variantDictAddBool(settings, TR_KEY_watch_dir_enabled, false);
|
|
break;
|
|
|
|
case 941:
|
|
tr_variantDictAddStr(settings, TR_KEY_incomplete_dir, optstr);
|
|
tr_variantDictAddBool(settings, TR_KEY_incomplete_dir_enabled, true);
|
|
break;
|
|
|
|
case 942:
|
|
tr_variantDictAddBool(settings, TR_KEY_incomplete_dir_enabled, false);
|
|
break;
|
|
|
|
case 943:
|
|
tr_variantDictAddStr(settings, TR_KEY_default_trackers, optstr);
|
|
break;
|
|
|
|
case 'd':
|
|
*dump_settings = true;
|
|
break;
|
|
|
|
case 'e':
|
|
if (reopen_log_file(optstr))
|
|
{
|
|
logfileName = optstr;
|
|
}
|
|
|
|
break;
|
|
|
|
case 'f':
|
|
*foreground = true;
|
|
break;
|
|
|
|
case 'g': /* handled above */
|
|
break;
|
|
|
|
case 'V': /* version */
|
|
fprintf(stderr, "%s %s\n", MyName, LONG_VERSION_STRING);
|
|
*exit_code = 0;
|
|
return false;
|
|
|
|
case 'o':
|
|
tr_variantDictAddBool(settings, TR_KEY_dht_enabled, true);
|
|
break;
|
|
|
|
case 'O':
|
|
tr_variantDictAddBool(settings, TR_KEY_dht_enabled, false);
|
|
break;
|
|
|
|
case 'p':
|
|
tr_variantDictAddInt(settings, TR_KEY_rpc_port, atoi(optstr));
|
|
break;
|
|
|
|
case 't':
|
|
tr_variantDictAddBool(settings, TR_KEY_rpc_authentication_required, true);
|
|
break;
|
|
|
|
case 'T':
|
|
tr_variantDictAddBool(settings, TR_KEY_rpc_authentication_required, false);
|
|
break;
|
|
|
|
case 'u':
|
|
tr_variantDictAddStr(settings, TR_KEY_rpc_username, optstr);
|
|
break;
|
|
|
|
case 'v':
|
|
tr_variantDictAddStr(settings, TR_KEY_rpc_password, optstr);
|
|
break;
|
|
|
|
case 'w':
|
|
tr_variantDictAddStr(settings, TR_KEY_download_dir, optstr);
|
|
break;
|
|
|
|
case 'P':
|
|
tr_variantDictAddInt(settings, TR_KEY_peer_port, atoi(optstr));
|
|
break;
|
|
|
|
case 'm':
|
|
tr_variantDictAddBool(settings, TR_KEY_port_forwarding_enabled, true);
|
|
break;
|
|
|
|
case 'M':
|
|
tr_variantDictAddBool(settings, TR_KEY_port_forwarding_enabled, false);
|
|
break;
|
|
|
|
case 'L':
|
|
tr_variantDictAddInt(settings, TR_KEY_peer_limit_global, atoi(optstr));
|
|
break;
|
|
|
|
case 'l':
|
|
tr_variantDictAddInt(settings, TR_KEY_peer_limit_per_torrent, atoi(optstr));
|
|
break;
|
|
|
|
case 800:
|
|
*paused = true;
|
|
break;
|
|
|
|
case 910:
|
|
tr_variantDictAddInt(settings, TR_KEY_encryption, TR_ENCRYPTION_REQUIRED);
|
|
break;
|
|
|
|
case 911:
|
|
tr_variantDictAddInt(settings, TR_KEY_encryption, TR_ENCRYPTION_PREFERRED);
|
|
break;
|
|
|
|
case 912:
|
|
tr_variantDictAddInt(settings, TR_KEY_encryption, TR_CLEAR_PREFERRED);
|
|
break;
|
|
|
|
case 'i':
|
|
tr_variantDictAddStr(settings, TR_KEY_bind_address_ipv4, optstr);
|
|
break;
|
|
|
|
case 'I':
|
|
tr_variantDictAddStr(settings, TR_KEY_bind_address_ipv6, optstr);
|
|
break;
|
|
|
|
case 'r':
|
|
tr_variantDictAddStr(settings, TR_KEY_rpc_bind_address, optstr);
|
|
break;
|
|
|
|
case 953:
|
|
tr_variantDictAddReal(settings, TR_KEY_ratio_limit, atof(optstr));
|
|
tr_variantDictAddBool(settings, TR_KEY_ratio_limit_enabled, true);
|
|
break;
|
|
|
|
case 954:
|
|
tr_variantDictAddBool(settings, TR_KEY_ratio_limit_enabled, false);
|
|
break;
|
|
|
|
case 'x':
|
|
tr_variantDictAddStr(settings, key_pidfile, optstr);
|
|
break;
|
|
|
|
case 'y':
|
|
tr_variantDictAddBool(settings, TR_KEY_lpd_enabled, true);
|
|
break;
|
|
|
|
case 'Y':
|
|
tr_variantDictAddBool(settings, TR_KEY_lpd_enabled, false);
|
|
break;
|
|
|
|
case 810:
|
|
tr_variantDictAddInt(settings, TR_KEY_message_level, TR_LOG_ERROR);
|
|
break;
|
|
|
|
case 811:
|
|
tr_variantDictAddInt(settings, TR_KEY_message_level, TR_LOG_INFO);
|
|
break;
|
|
|
|
case 812:
|
|
tr_variantDictAddInt(settings, TR_KEY_message_level, TR_LOG_DEBUG);
|
|
break;
|
|
|
|
case 830:
|
|
tr_variantDictAddBool(settings, TR_KEY_utp_enabled, true);
|
|
break;
|
|
|
|
case 831:
|
|
tr_variantDictAddBool(settings, TR_KEY_utp_enabled, false);
|
|
break;
|
|
|
|
default:
|
|
tr_getopt_usage(MyName, Usage, std::data(Options));
|
|
*exit_code = 0;
|
|
return false;
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
struct daemon_data
|
|
{
|
|
tr_variant settings;
|
|
char const* configDir;
|
|
bool paused;
|
|
};
|
|
|
|
static void daemon_reconfigure(void* /*arg*/)
|
|
{
|
|
if (mySession == nullptr)
|
|
{
|
|
tr_logAddInfo(_("Deferring reload until session is fully started."));
|
|
seenHUP = true;
|
|
}
|
|
else
|
|
{
|
|
tr_variant settings;
|
|
char const* configDir;
|
|
|
|
/* reopen the logfile to allow for log rotation */
|
|
if (logfileName != nullptr)
|
|
{
|
|
reopen_log_file(logfileName);
|
|
}
|
|
|
|
configDir = tr_sessionGetConfigDir(mySession);
|
|
tr_logAddInfo(fmt::format(_("Reloading settings from '{path}'"), fmt::arg("path", configDir)));
|
|
tr_variantInitDict(&settings, 0);
|
|
tr_variantDictAddBool(&settings, TR_KEY_rpc_enabled, true);
|
|
tr_sessionLoadSettings(&settings, configDir, MyName);
|
|
tr_sessionSet(mySession, &settings);
|
|
tr_variantFree(&settings);
|
|
tr_sessionReloadBlocklists(mySession);
|
|
}
|
|
}
|
|
|
|
static void daemon_stop(void* /*arg*/)
|
|
{
|
|
event_base_loopexit(ev_base, nullptr);
|
|
}
|
|
|
|
static int daemon_start(void* varg, [[maybe_unused]] bool foreground)
|
|
{
|
|
bool boolVal;
|
|
bool pidfile_created = false;
|
|
tr_session* session = nullptr;
|
|
struct event* status_ev = nullptr;
|
|
tr_watchdir_t watchdir = nullptr;
|
|
|
|
auto* arg = static_cast<daemon_data*>(varg);
|
|
tr_variant* const settings = &arg->settings;
|
|
char const* const configDir = arg->configDir;
|
|
|
|
sd_notifyf(0, "MAINPID=%d\n", (int)getpid());
|
|
|
|
/* should go before libevent calls */
|
|
tr_net_init();
|
|
|
|
/* setup event state */
|
|
ev_base = event_base_new();
|
|
|
|
if (ev_base == nullptr)
|
|
{
|
|
char buf[256];
|
|
tr_snprintf(buf, sizeof(buf), "Couldn't initialize daemon event state: %s", tr_strerror(errno));
|
|
printMessage(logfile, TR_LOG_ERROR, MyName, buf, __FILE__, __LINE__);
|
|
return 1;
|
|
}
|
|
|
|
/* start the session */
|
|
tr_formatter_mem_init(MemK, MemKStr, MemMStr, MemGStr, MemTStr);
|
|
tr_formatter_size_init(DiskK, DiskKStr, DiskMStr, DiskGStr, DiskTStr);
|
|
tr_formatter_speed_init(SpeedK, SpeedKStr, SpeedMStr, SpeedGStr, SpeedTStr);
|
|
session = tr_sessionInit(configDir, true, settings);
|
|
tr_sessionSetRPCCallback(session, on_rpc_callback, nullptr);
|
|
tr_logAddNamedInfo(MyName, fmt::format(_("Loading settings from '{path}'"), fmt::arg("path", configDir)));
|
|
tr_sessionSaveSettings(session, configDir, settings);
|
|
|
|
auto sv = std::string_view{};
|
|
(void)tr_variantDictFindStrView(settings, key_pidfile, &sv);
|
|
auto const sz_pid_filename = std::string{ sv };
|
|
if (!std::empty(sz_pid_filename))
|
|
{
|
|
tr_error* error = nullptr;
|
|
tr_sys_file_t fp = tr_sys_file_open(
|
|
sz_pid_filename.c_str(),
|
|
TR_SYS_FILE_WRITE | TR_SYS_FILE_CREATE | TR_SYS_FILE_TRUNCATE,
|
|
0666,
|
|
&error);
|
|
|
|
if (fp != TR_BAD_SYS_FILE)
|
|
{
|
|
auto const out = std::to_string(getpid());
|
|
tr_sys_file_write(fp, std::data(out), std::size(out), nullptr, nullptr);
|
|
tr_sys_file_close(fp, nullptr);
|
|
tr_logAddInfo(fmt::format(_("Saved pidfile '{path}'"), fmt::arg("path", sz_pid_filename)));
|
|
pidfile_created = true;
|
|
}
|
|
else
|
|
{
|
|
tr_logAddError(fmt::format(
|
|
_("Couldn't save '{path}': {error} ({error_code})"),
|
|
fmt::arg("path", sz_pid_filename),
|
|
fmt::arg("error", error->message),
|
|
fmt::arg("error_code", error->code)));
|
|
tr_error_free(error);
|
|
}
|
|
}
|
|
|
|
if (tr_variantDictFindBool(settings, TR_KEY_rpc_authentication_required, &boolVal) && boolVal)
|
|
{
|
|
tr_logAddNamedInfo(MyName, _("Requiring authentication"));
|
|
}
|
|
|
|
mySession = session;
|
|
|
|
/* If we got a SIGHUP during startup, process that now. */
|
|
if (seenHUP)
|
|
{
|
|
daemon_reconfigure(arg);
|
|
}
|
|
|
|
/* maybe add a watchdir */
|
|
if (tr_variantDictFindBool(settings, TR_KEY_watch_dir_enabled, &boolVal) && boolVal)
|
|
{
|
|
auto force_generic = bool{ false };
|
|
(void)tr_variantDictFindBool(settings, key_watch_dir_force_generic, &force_generic);
|
|
|
|
auto dir = std::string_view{};
|
|
(void)tr_variantDictFindStrView(settings, TR_KEY_watch_dir, &dir);
|
|
if (!std::empty(dir))
|
|
{
|
|
tr_logAddInfo(fmt::format(_("Watching '{path}' for new .torrent files"), fmt::arg("path", dir)));
|
|
|
|
watchdir = tr_watchdir_new(dir, &onFileAdded, mySession, ev_base, force_generic);
|
|
if (watchdir == nullptr)
|
|
{
|
|
goto CLEANUP;
|
|
}
|
|
}
|
|
}
|
|
|
|
/* load the torrents */
|
|
{
|
|
tr_torrent** torrents;
|
|
tr_ctor* ctor = tr_ctorNew(mySession);
|
|
|
|
if (arg->paused)
|
|
{
|
|
tr_ctorSetPaused(ctor, TR_FORCE, true);
|
|
}
|
|
|
|
torrents = tr_sessionLoadTorrents(mySession, ctor, nullptr);
|
|
tr_free(torrents);
|
|
tr_ctorFree(ctor);
|
|
}
|
|
|
|
#ifdef HAVE_SYSLOG
|
|
|
|
if (!foreground)
|
|
{
|
|
openlog(MyName, LOG_CONS | LOG_PID, LOG_DAEMON);
|
|
}
|
|
|
|
#endif
|
|
|
|
/* Create new timer event to report daemon status */
|
|
{
|
|
constexpr auto one_sec = timeval{ 1, 0 }; // 1 second
|
|
status_ev = event_new(ev_base, -1, EV_PERSIST, &periodicUpdate, nullptr);
|
|
|
|
if (status_ev == nullptr)
|
|
{
|
|
auto const error_code = errno;
|
|
tr_logAddError(fmt::format(
|
|
_("Couldn't create status event: {error} ({error_code})"),
|
|
fmt::arg("error", tr_strerror(error_code)),
|
|
fmt::arg("error_code", error_code)));
|
|
goto CLEANUP;
|
|
}
|
|
|
|
if (event_add(status_ev, &one_sec) == -1)
|
|
{
|
|
auto const error_code = errno;
|
|
tr_logAddError(fmt::format(
|
|
_("Couldn't add status event: {error} ({error_code})"),
|
|
fmt::arg("error", tr_strerror(error_code)),
|
|
fmt::arg("error_code", error_code)));
|
|
goto CLEANUP;
|
|
}
|
|
}
|
|
|
|
sd_notify(0, "READY=1\n");
|
|
|
|
/* Run daemon event loop */
|
|
if (event_base_dispatch(ev_base) == -1)
|
|
{
|
|
auto const error_code = errno;
|
|
tr_logAddError(fmt::format(
|
|
_("Couldn't launch daemon event loop: {error} ({error_code})"),
|
|
fmt::arg("error", tr_strerror(error_code)),
|
|
fmt::arg("error_code", error_code)));
|
|
goto CLEANUP;
|
|
}
|
|
|
|
CLEANUP:
|
|
sd_notify(0, "STATUS=Closing transmission session...\n");
|
|
printf("Closing transmission session...");
|
|
|
|
tr_watchdir_free(watchdir);
|
|
|
|
if (status_ev != nullptr)
|
|
{
|
|
event_del(status_ev);
|
|
event_free(status_ev);
|
|
}
|
|
|
|
event_base_free(ev_base);
|
|
|
|
tr_sessionSaveSettings(mySession, configDir, settings);
|
|
tr_sessionClose(mySession);
|
|
pumpLogMessages(logfile);
|
|
printf(" done.\n");
|
|
|
|
/* shutdown */
|
|
#ifdef HAVE_SYSLOG
|
|
|
|
if (!foreground)
|
|
{
|
|
syslog(LOG_INFO, "%s", "Closing session");
|
|
closelog();
|
|
}
|
|
|
|
#endif
|
|
|
|
/* cleanup */
|
|
if (pidfile_created)
|
|
{
|
|
tr_sys_path_remove(sz_pid_filename.c_str(), nullptr);
|
|
}
|
|
|
|
sd_notify(0, "STATUS=\n");
|
|
|
|
return 0;
|
|
}
|
|
|
|
static bool init_daemon_data(int argc, char* argv[], struct daemon_data* data, bool* foreground, int* ret)
|
|
{
|
|
data->configDir = getConfigDir(argc, (char const* const*)argv);
|
|
|
|
/* load settings from defaults + config file */
|
|
tr_variantInitDict(&data->settings, 0);
|
|
tr_variantDictAddBool(&data->settings, TR_KEY_rpc_enabled, true);
|
|
bool const loaded = tr_sessionLoadSettings(&data->settings, data->configDir, MyName);
|
|
|
|
bool dumpSettings;
|
|
|
|
*ret = 0;
|
|
|
|
/* overwrite settings from the command line */
|
|
if (!parse_args(argc, (char const**)argv, &data->settings, &data->paused, &dumpSettings, foreground, ret))
|
|
{
|
|
goto EXIT_EARLY;
|
|
}
|
|
|
|
if (*foreground && logfile == TR_BAD_SYS_FILE)
|
|
{
|
|
logfile = tr_sys_file_get_std(TR_STD_SYS_FILE_ERR, nullptr);
|
|
}
|
|
|
|
if (!loaded)
|
|
{
|
|
printMessage(logfile, TR_LOG_ERROR, MyName, "Error loading config file -- exiting.", __FILE__, __LINE__);
|
|
*ret = 1;
|
|
goto EXIT_EARLY;
|
|
}
|
|
|
|
if (dumpSettings)
|
|
{
|
|
auto const str = tr_variantToStr(&data->settings, TR_VARIANT_FMT_JSON);
|
|
fprintf(stderr, "%s", str.c_str());
|
|
goto EXIT_EARLY;
|
|
}
|
|
|
|
return true;
|
|
|
|
EXIT_EARLY:
|
|
tr_variantFree(&data->settings);
|
|
return false;
|
|
}
|
|
|
|
int tr_main(int argc, char* argv[])
|
|
{
|
|
key_pidfile = tr_quark_new("pidfile"sv);
|
|
key_watch_dir_force_generic = tr_quark_new("watch-dir-force-generic"sv);
|
|
|
|
struct daemon_data data;
|
|
bool foreground;
|
|
int ret;
|
|
|
|
if (!init_daemon_data(argc, argv, &data, &foreground, &ret))
|
|
{
|
|
return ret;
|
|
}
|
|
|
|
auto constexpr cb = dtr_callbacks{
|
|
&daemon_start,
|
|
&daemon_stop,
|
|
&daemon_reconfigure,
|
|
};
|
|
|
|
if (tr_error* error = nullptr; !dtr_daemon(&cb, &data, foreground, &ret, &error))
|
|
{
|
|
printMessage(logfile, TR_LOG_ERROR, MyName, tr_strvJoin("Couldn't daemonize: ", error->message), __FILE__, __LINE__);
|
|
tr_error_free(error);
|
|
}
|
|
|
|
tr_variantFree(&data.settings);
|
|
return ret;
|
|
}
|