diff --git a/src/libs/services/scanner/impl/ScannerService.cpp b/src/libs/services/scanner/impl/ScannerService.cpp index 96ef1c41..356cbcbb 100644 --- a/src/libs/services/scanner/impl/ScannerService.cpp +++ b/src/libs/services/scanner/impl/ScannerService.cpp @@ -20,7 +20,6 @@ #include "ScannerService.hpp" #include -#include #include "database/MediaLibrary.hpp" #include "database/TrackFeatures.hpp" @@ -70,7 +69,6 @@ namespace lms::scanner ScannerService::ScannerService(Db& db) : _db{ db } - , _dbSession{ db } { _ioService.setThreadCount(1); @@ -291,7 +289,7 @@ namespace lms::scanner LMS_LOG(DBUPDATER, INFO, "Scan " << (_abortScan ? "aborted" : "complete") << ". Changes = " << stats.nbChanges() << " (added = " << stats.additions << ", removed = " << stats.deletions << ", updated = " << stats.updates << "), Not changed = " << stats.skips << ", Scanned = " << stats.scans << " (errors = " << stats.errors.size() << "), features fetched = " << stats.featuresFetched << ", duplicates = " << stats.duplicates.size()); - _dbSession.analyze(); + _db.getTLSSession().analyze(); if (!_abortScan) { @@ -358,9 +356,9 @@ namespace lms::scanner newSettings.skipDuplicateMBID = core::Service::get()->getBool("scanner-skip-duplicate-mbid", false); { - auto transaction{ _dbSession.createReadTransaction() }; + auto transaction{ _db.getTLSSession().createReadTransaction() }; - const ScanSettings::pointer scanSettings{ ScanSettings::get(_dbSession) }; + const ScanSettings::pointer scanSettings{ ScanSettings::get(_db.getTLSSession()) }; newSettings.scanVersion = scanSettings->getScanVersion(); newSettings.startTime = scanSettings->getUpdateStartTime(); @@ -373,7 +371,7 @@ namespace lms::scanner [](const std::filesystem::path& extension) { return std::filesystem::path{ core::stringUtils::stringToLower(extension.string()) }; }); } - MediaLibrary::find(_dbSession, [&](const MediaLibrary::pointer& mediaLibrary) + MediaLibrary::find(_db.getTLSSession(), [&](const MediaLibrary::pointer& mediaLibrary) { newSettings.mediaLibraries.push_back(ScannerSettings::MediaLibraryInfo{ mediaLibrary->getId(), mediaLibrary->getPath().lexically_normal() }); }); @@ -409,5 +407,4 @@ namespace lms::scanner if (std::chrono::duration_cast(now - _lastScanInProgressEmit).count() > 1) notifyInProgress(stepStats); } - } // namespace lms::scanner diff --git a/src/libs/services/scanner/impl/ScannerService.hpp b/src/libs/services/scanner/impl/ScannerService.hpp index dec1c26c..d0beb160 100644 --- a/src/libs/services/scanner/impl/ScannerService.hpp +++ b/src/libs/services/scanner/impl/ScannerService.hpp @@ -74,11 +74,9 @@ namespace lms::scanner // Helpers void refreshScanSettings(); ScannerSettings readSettings(); - void reloadRecommendationService(); void notifyInProgressIfNeeded(const ScanStepStats& stats); void notifyInProgress(const ScanStepStats& stats); - void reloadSimilarityEngine(ScanStats& stats); std::vector> _scanSteps; @@ -89,7 +87,6 @@ namespace lms::scanner Events _events; std::chrono::system_clock::time_point _lastScanInProgressEmit{}; db::Db& _db; - db::Session _dbSession; mutable std::shared_mutex _statusMutex; State _curState{ State::NotScheduled }; diff --git a/src/libs/services/scanner/impl/ScannerStats.cpp b/src/libs/services/scanner/impl/ScannerStats.cpp index ad68a8fe..b2df60d6 100644 --- a/src/libs/services/scanner/impl/ScannerStats.cpp +++ b/src/libs/services/scanner/impl/ScannerStats.cpp @@ -19,32 +19,28 @@ #include "services/scanner/ScannerStats.hpp" -namespace lms::scanner { - -ScanError::ScanError(const std::filesystem::path& _file, ScanErrorType _error, const std::string& _systemError) -: file {_file}, -error {_error}, -systemError {_systemError} +namespace lms::scanner { -} + ScanError::ScanError(const std::filesystem::path& _file, ScanErrorType _error, const std::string& _systemError) + : file{ _file }, + error{ _error }, + systemError{ _systemError } + { + } -std::size_t -ScanStats::nbFiles() const -{ - return skips + additions + updates; -} + std::size_t ScanStats::nbFiles() const + { + return skips + additions + updates; + } -std::size_t -ScanStats::nbChanges() const -{ - return additions + deletions + updates; -} - -unsigned -ScanStepStats::progress() const -{ - return (processedElems / static_cast(totalElems ? totalElems : 1)) * 100; -} + std::size_t ScanStats::nbChanges() const + { + return additions + deletions + updates; + } + unsigned ScanStepStats::progress() const + { + return (processedElems / static_cast(totalElems ? totalElems : 1)) * 100; + } } // namespace lms::scanner