mirror of
https://github.com/transmission/transmission
synced 2025-03-13 07:33:02 +00:00
7e87adcd91
* fix: operator== should return bool in tr_strbuf Fixes build error with C++20/C++23 error: return type 'auto' of selected 'operator==' function for rewritten '!=' comparison is not 'bool' Signed-off-by: Dzmitry Neviadomski <nevack.d@gmail.com> * fix: explicitly specify Blocklist::size() return type as size_t Fixes building with C++20/C++23 error: no matching function for call to 'size' function 'size' with deduced return type cannot be used before it is defined Signed-off-by: Dzmitry Neviadomski <nevack.d@gmail.com> * fix: wrap runtime format strings with fmt::runtime in library, daemon and cli fmt::format_string ctor is consteval with C++20 See https://github.com/fmtlib/fmt/issues/2438 Signed-off-by: Dzmitry Neviadomski <nevack.d@gmail.com> * fix: wrap runtime format strings with fmt::runtime for GTK client Signed-off-by: Dzmitry Neviadomski <nevack.d@gmail.com> * fix: allow to override C and CXX standard via cmdline or env Signed-off-by: Dzmitry Neviadomski <nevack.d@gmail.com> * fix: add job to check if transmission compiles with C++23 Signed-off-by: Dzmitry Neviadomski <nevack.d@gmail.com> * Address code review by mikedld Signed-off-by: Dzmitry Neviadomski <nevack.d@gmail.com> * fix new found fmt build errors Signed-off-by: Dzmitry Neviadomski <nevack.d@gmail.com> * Address code review by tearfur Signed-off-by: Dzmitry Neviadomski <nevack.d@gmail.com> * fix: make tr_net_init_mgr singleton buildable with C++23 Signed-off-by: Dzmitry Neviadomski <nevack.d@gmail.com> --------- Signed-off-by: Dzmitry Neviadomski <nevack.d@gmail.com> Co-authored-by: Charles Kerr <charles@charleskerr.com>
126 lines
3.2 KiB
C++
126 lines
3.2 KiB
C++
// This file Copyright © 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 <chrono>
|
|
#include <string>
|
|
#include <string_view>
|
|
|
|
#include <fmt/core.h>
|
|
|
|
#define LIBTRANSMISSION_WATCHDIR_MODULE
|
|
|
|
#include "libtransmission/error-types.h"
|
|
#include "libtransmission/error.h"
|
|
#include "libtransmission/file.h"
|
|
#include "libtransmission/log.h"
|
|
#include "libtransmission/tr-strbuf.h"
|
|
#include "libtransmission/utils.h" // for _()
|
|
#include "libtransmission/watchdir-base.h"
|
|
|
|
using namespace std::literals;
|
|
|
|
namespace libtransmission
|
|
{
|
|
namespace
|
|
{
|
|
|
|
[[nodiscard]] constexpr std::string_view actionToString(Watchdir::Action action)
|
|
{
|
|
switch (action)
|
|
{
|
|
case Watchdir::Action::Retry:
|
|
return "retry";
|
|
|
|
case Watchdir::Action::Done:
|
|
return "done";
|
|
}
|
|
|
|
return "???";
|
|
}
|
|
|
|
[[nodiscard]] bool isRegularFile(std::string_view dir, std::string_view name)
|
|
{
|
|
auto const path = tr_pathbuf{ dir, '/', name };
|
|
|
|
auto error = tr_error{};
|
|
auto const info = tr_sys_path_get_info(path, 0, &error);
|
|
if (error && !tr_error_is_enoent(error.code()))
|
|
{
|
|
tr_logAddWarn(fmt::format(
|
|
fmt::runtime(_("Skipping '{path}': {error} ({error_code})")),
|
|
fmt::arg("path", path),
|
|
fmt::arg("error", error.message()),
|
|
fmt::arg("error_code", error.code())));
|
|
}
|
|
|
|
return info && info->isFile();
|
|
}
|
|
|
|
} // namespace
|
|
|
|
namespace impl
|
|
{
|
|
|
|
void BaseWatchdir::processFile(std::string_view basename)
|
|
{
|
|
if (!isRegularFile(dirname_, basename) || handled_.count(basename) != 0)
|
|
{
|
|
return;
|
|
}
|
|
|
|
auto const action = callback_(dirname_, basename);
|
|
tr_logAddDebug(fmt::format("Callback decided to {:s} file '{:s}'", actionToString(action), basename));
|
|
if (action == Action::Retry)
|
|
{
|
|
auto const [iter, added] = pending_.try_emplace(std::string{ basename });
|
|
|
|
auto const now = std::chrono::steady_clock::now();
|
|
auto& info = iter->second;
|
|
++info.strikes;
|
|
info.last_kick_at = now;
|
|
|
|
if (info.first_kick_at == Timestamp{})
|
|
{
|
|
info.first_kick_at = now;
|
|
}
|
|
|
|
if (now - info.first_kick_at > timeoutDuration())
|
|
{
|
|
tr_logAddWarn(fmt::format(fmt::runtime(_("Couldn't add torrent file '{path}'")), fmt::arg("path", basename)));
|
|
pending_.erase(iter);
|
|
}
|
|
else
|
|
{
|
|
setNextKickTime(info);
|
|
restartTimerIfPending();
|
|
}
|
|
}
|
|
else if (action == Action::Done)
|
|
{
|
|
handled_.emplace(basename);
|
|
}
|
|
}
|
|
|
|
void BaseWatchdir::scan()
|
|
{
|
|
auto error = tr_error{};
|
|
|
|
for (auto const& file : tr_sys_dir_get_files(dirname_, tr_basename_is_not_dotfile, &error))
|
|
{
|
|
processFile(file);
|
|
}
|
|
|
|
if (error)
|
|
{
|
|
tr_logAddWarn(fmt::format(
|
|
fmt::runtime(_("Couldn't read '{path}': {error} ({error_code})")),
|
|
fmt::arg("path", dirname()),
|
|
fmt::arg("error", error.message()),
|
|
fmt::arg("error_code", error.code())));
|
|
}
|
|
}
|
|
|
|
} // namespace impl
|
|
} // namespace libtransmission
|