fujin/rtorrent
1
0
Fork 0
mirror of https://github.com/rakshasa/rtorrent.git synced 2026-10-13 20:56:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

Refactor full save scheduling with early return

Browse Source
This commit is contained in:
PiloUnk
2026-03-15 23:20:00 +01:00
committed by Jari Sundell
parent de163293ab
commit 6f27159627
1 changed files with 7 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/session/session_manager.cc
+7 -10
View File
@@ -104,8 +104,6 @@ SessionManager::save_full_download(core::Download* download) {
storer.libtorrent_stream()
};
bool should_schedule = false;
{
std::unique_lock<std::mutex> lock(m_mutex);
@@ -116,17 +114,16 @@ SessionManager::save_full_download(core::Download* download) {
if (replace_save_request_unsafe(save_request)) {
LT_LOG("updated pending save request with full save data : download:%p", download);
should_schedule = true;
} else {
m_save_requests.push_back(std::move(save_request));
m_save_request_counter = m_save_requests.size();
LT_LOG("queued new full save request : download:%p", download);
should_schedule = true;
return;
}
m_save_requests.push_back(std::move(save_request));
m_save_request_counter = m_save_requests.size();
LT_LOG("queued new full save request : download:%p", download);
}
if (should_schedule && !m_processing_saves_callback_scheduled.exchange(true))
if (!m_processing_saves_callback_scheduled.exchange(true))
session_thread::callback(this, [this]() { process_save_request(); });
}