|
|
|
@ -35,6 +35,190 @@
@@ -35,6 +35,190 @@
|
|
|
|
|
#include "base/utils/fs.h" |
|
|
|
|
#include "common.h" |
|
|
|
|
|
|
|
|
|
#if (LIBTORRENT_VERSION_NUM >= 20000) |
|
|
|
|
#include <libtorrent/session.hpp> |
|
|
|
|
|
|
|
|
|
std::unique_ptr<lt::disk_interface> customDiskIOConstructor( |
|
|
|
|
lt::io_context &ioContext, const lt::settings_interface &settings, lt::counters &counters) |
|
|
|
|
{ |
|
|
|
|
return std::make_unique<customDiskIOThread>(lt::default_disk_io_constructor(ioContext, settings, counters)); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
customDiskIOThread::customDiskIOThread(std::unique_ptr<libtorrent::disk_interface> nativeDiskIOThread) |
|
|
|
|
: m_nativeDiskIO {std::move(nativeDiskIOThread)} |
|
|
|
|
{ |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
lt::storage_holder customDiskIOThread::new_torrent(const lt::storage_params &storageParams, const std::shared_ptr<void> &torrent) |
|
|
|
|
{ |
|
|
|
|
lt::storage_holder storageHolder = m_nativeDiskIO->new_torrent(storageParams, torrent); |
|
|
|
|
|
|
|
|
|
const QString savePath = Utils::Fs::expandPathAbs(QString::fromStdString(storageParams.path)); |
|
|
|
|
m_storageData[storageHolder] = { |
|
|
|
|
savePath |
|
|
|
|
, storageParams.mapped_files ? *storageParams.mapped_files : storageParams.files |
|
|
|
|
, storageParams.priorities}; |
|
|
|
|
|
|
|
|
|
return storageHolder; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void customDiskIOThread::remove_torrent(lt::storage_index_t storage) |
|
|
|
|
{ |
|
|
|
|
m_nativeDiskIO->remove_torrent(storage); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void customDiskIOThread::async_read(lt::storage_index_t storage, const lt::peer_request &peerRequest |
|
|
|
|
, std::function<void (lt::disk_buffer_holder, const lt::storage_error &)> handler |
|
|
|
|
, lt::disk_job_flags_t flags) |
|
|
|
|
{ |
|
|
|
|
m_nativeDiskIO->async_read(storage, peerRequest, std::move(handler), flags); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
bool customDiskIOThread::async_write(lt::storage_index_t storage, const lt::peer_request &peerRequest |
|
|
|
|
, const char *buf, std::shared_ptr<lt::disk_observer> diskObserver |
|
|
|
|
, std::function<void (const lt::storage_error &)> handler, lt::disk_job_flags_t flags) |
|
|
|
|
{ |
|
|
|
|
return m_nativeDiskIO->async_write(storage, peerRequest, buf, diskObserver, std::move(handler), flags); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void customDiskIOThread::async_hash(lt::storage_index_t storage, lt::piece_index_t piece |
|
|
|
|
, lt::span<lt::sha256_hash> hash, lt::disk_job_flags_t flags |
|
|
|
|
, std::function<void (lt::piece_index_t, const lt::sha1_hash &, const lt::storage_error &)> handler) |
|
|
|
|
{ |
|
|
|
|
m_nativeDiskIO->async_hash(storage, piece, hash, flags, std::move(handler)); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void customDiskIOThread::async_hash2(lt::storage_index_t storage, lt::piece_index_t piece |
|
|
|
|
, int offset, lt::disk_job_flags_t flags |
|
|
|
|
, std::function<void (lt::piece_index_t, const lt::sha256_hash &, const lt::storage_error &)> handler) |
|
|
|
|
{ |
|
|
|
|
m_nativeDiskIO->async_hash2(storage, piece, offset, flags, std::move(handler)); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void customDiskIOThread::async_move_storage(lt::storage_index_t storage, std::string path, lt::move_flags_t flags |
|
|
|
|
, std::function<void (lt::status_t, const std::string &, const lt::storage_error &)> handler) |
|
|
|
|
{ |
|
|
|
|
const QString newSavePath {Utils::Fs::expandPathAbs(QString::fromStdString(path))}; |
|
|
|
|
|
|
|
|
|
if (flags == lt::move_flags_t::dont_replace) |
|
|
|
|
handleCompleteFiles(storage, newSavePath); |
|
|
|
|
|
|
|
|
|
m_nativeDiskIO->async_move_storage(storage, path, flags |
|
|
|
|
, [=, handler = std::move(handler)](lt::status_t status, const std::string &path, const lt::storage_error &error) |
|
|
|
|
{ |
|
|
|
|
if (status != lt::status_t::fatal_disk_error) |
|
|
|
|
m_storageData[storage].savePath = newSavePath; |
|
|
|
|
|
|
|
|
|
handler(status, path, error); |
|
|
|
|
}); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void customDiskIOThread::async_release_files(lt::storage_index_t storage, std::function<void ()> handler) |
|
|
|
|
{ |
|
|
|
|
m_nativeDiskIO->async_release_files(storage, std::move(handler)); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void customDiskIOThread::async_check_files(lt::storage_index_t storage, const lt::add_torrent_params *resume_data |
|
|
|
|
, lt::aux::vector<std::string, lt::file_index_t> links |
|
|
|
|
, std::function<void (lt::status_t, const lt::storage_error &)> handler) |
|
|
|
|
{ |
|
|
|
|
handleCompleteFiles(storage, m_storageData[storage].savePath); |
|
|
|
|
m_nativeDiskIO->async_check_files(storage, resume_data, links, std::move(handler)); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void customDiskIOThread::async_stop_torrent(lt::storage_index_t storage, std::function<void ()> handler) |
|
|
|
|
{ |
|
|
|
|
m_nativeDiskIO->async_stop_torrent(storage, std::move(handler)); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void customDiskIOThread::async_rename_file(lt::storage_index_t storage, lt::file_index_t index, std::string name |
|
|
|
|
, std::function<void (const std::string &, lt::file_index_t, const lt::storage_error &)> handler) |
|
|
|
|
{ |
|
|
|
|
m_nativeDiskIO->async_rename_file(storage, index, name |
|
|
|
|
, [=, handler = std::move(handler)](const std::string &name, lt::file_index_t index, const lt::storage_error &error) |
|
|
|
|
{ |
|
|
|
|
if (!error) |
|
|
|
|
m_storageData[storage].files.rename_file(index, name); |
|
|
|
|
handler(name, index, error); |
|
|
|
|
}); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void customDiskIOThread::async_delete_files(lt::storage_index_t storage, lt::remove_flags_t options |
|
|
|
|
, std::function<void (const lt::storage_error &)> handler) |
|
|
|
|
{ |
|
|
|
|
m_nativeDiskIO->async_delete_files(storage, options, std::move(handler)); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void customDiskIOThread::async_set_file_priority(lt::storage_index_t storage, lt::aux::vector<lt::download_priority_t, lt::file_index_t> priorities |
|
|
|
|
, std::function<void (const lt::storage_error &, lt::aux::vector<lt::download_priority_t, lt::file_index_t>)> handler) |
|
|
|
|
{ |
|
|
|
|
m_nativeDiskIO->async_set_file_priority(storage, priorities |
|
|
|
|
, [=, handler = std::move(handler)](const lt::storage_error &error, lt::aux::vector<lt::download_priority_t, lt::file_index_t> priorities) |
|
|
|
|
{ |
|
|
|
|
m_storageData[storage].filePriorities = priorities; |
|
|
|
|
handler(error, priorities); |
|
|
|
|
}); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void customDiskIOThread::async_clear_piece(lt::storage_index_t storage, lt::piece_index_t index |
|
|
|
|
, std::function<void (lt::piece_index_t)> handler) |
|
|
|
|
{ |
|
|
|
|
m_nativeDiskIO->async_clear_piece(storage, index, std::move(handler)); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void customDiskIOThread::update_stats_counters(lt::counters &counters) const |
|
|
|
|
{ |
|
|
|
|
m_nativeDiskIO->update_stats_counters(counters); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
std::vector<lt::open_file_state> customDiskIOThread::get_status(lt::storage_index_t index) const |
|
|
|
|
{ |
|
|
|
|
return m_nativeDiskIO->get_status(index); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void customDiskIOThread::abort(bool wait) |
|
|
|
|
{ |
|
|
|
|
m_nativeDiskIO->abort(wait); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void customDiskIOThread::submit_jobs() |
|
|
|
|
{ |
|
|
|
|
m_nativeDiskIO->submit_jobs(); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void customDiskIOThread::settings_updated() |
|
|
|
|
{ |
|
|
|
|
m_nativeDiskIO->settings_updated(); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void customDiskIOThread::handleCompleteFiles(lt::storage_index_t storage, const QString &savePath) |
|
|
|
|
{ |
|
|
|
|
const QDir saveDir {savePath}; |
|
|
|
|
const StorageData storageData = m_storageData[storage]; |
|
|
|
|
const lt::file_storage &fileStorage = storageData.files; |
|
|
|
|
for (const lt::file_index_t fileIndex : fileStorage.file_range()) { |
|
|
|
|
// ignore files that have priority 0
|
|
|
|
|
if ((storageData.filePriorities.end_index() > fileIndex) && (storageData.filePriorities[fileIndex] == lt::dont_download)) |
|
|
|
|
continue; |
|
|
|
|
|
|
|
|
|
// ignore pad files
|
|
|
|
|
if (fileStorage.pad_file_at(fileIndex)) continue; |
|
|
|
|
|
|
|
|
|
const QString filePath = QString::fromStdString(fileStorage.file_path(fileIndex)); |
|
|
|
|
if (filePath.endsWith(QB_EXT)) { |
|
|
|
|
const QString completeFilePath = filePath.left(filePath.size() - QB_EXT.size()); |
|
|
|
|
QFile completeFile {saveDir.absoluteFilePath(completeFilePath)}; |
|
|
|
|
if (completeFile.exists()) { |
|
|
|
|
QFile incompleteFile {saveDir.absoluteFilePath(filePath)}; |
|
|
|
|
incompleteFile.remove(); |
|
|
|
|
completeFile.rename(incompleteFile.fileName()); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
#else |
|
|
|
|
|
|
|
|
|
lt::storage_interface *customStorageConstructor(const lt::storage_params ¶ms, lt::file_pool &pool) |
|
|
|
|
{ |
|
|
|
|
return new CustomStorage {params, pool}; |
|
|
|
@ -98,3 +282,4 @@ void CustomStorage::handleCompleteFiles(const QString &savePath)
@@ -98,3 +282,4 @@ void CustomStorage::handleCompleteFiles(const QString &savePath)
|
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
#endif |
|
|
|
|