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

Fix coalescing resume saves with pending full save

Browse Source
This commit is contained in:
PiloUnk
2026-03-14 19:39:59 +01:00
committed by Jari Sundell
parent 39f186e523
commit fb4e775689
1 changed files with 16 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/session/session_manager.cc
+15 -4
View File
@@ -426,11 +426,22 @@ SessionManager::replace_save_request_unsafe(SaveRequest& save_request) {
if (itr->path != save_request.path) if (itr->path != save_request.path)
throw torrent::internal_error("SessionManager::replace_save_request_unsafe() path mismatch on replace: " + itr->path + " != " + save_request.path); throw torrent::internal_error("SessionManager::replace_save_request_unsafe() path mismatch on replace: " + itr->path + " != " + save_request.path);
if (save_request.torrent_stream != nullptr) // If the existing request is a full save (created during torrent initialization),
throw torrent::internal_error("SessionManager::replace_save_request_unsafe() cannot replace full save requests."); // keep its torrent_stream but update the resume streams with newer data.
// Otherwise, replace all streams.
if (itr->torrent_stream != nullptr) {
// Keep existing full-save torrent stream, only update resume streams
if (save_request.rtorrent_stream != nullptr)
itr->rtorrent_stream = std::move(save_request.rtorrent_stream);
itr->rtorrent_stream = std::move(save_request.rtorrent_stream); if (save_request.libtorrent_stream != nullptr)
itr->libtorrent_stream = std::move(save_request.libtorrent_stream); itr->libtorrent_stream = std::move(save_request.libtorrent_stream);
} else {
// No full save pending, replace everything
itr->torrent_stream = std::move(save_request.torrent_stream);
itr->rtorrent_stream = std::move(save_request.rtorrent_stream);
itr->libtorrent_stream = std::move(save_request.libtorrent_stream);
}
return true; return true;
} }