Cleaned up Useless session
This commit is contained in:
@@ -20,7 +20,6 @@
|
|||||||
#include "ScannerService.hpp"
|
#include "ScannerService.hpp"
|
||||||
|
|
||||||
#include <ctime>
|
#include <ctime>
|
||||||
#include <boost/asio/placeholders.hpp>
|
|
||||||
|
|
||||||
#include "database/MediaLibrary.hpp"
|
#include "database/MediaLibrary.hpp"
|
||||||
#include "database/TrackFeatures.hpp"
|
#include "database/TrackFeatures.hpp"
|
||||||
@@ -70,7 +69,6 @@ namespace lms::scanner
|
|||||||
|
|
||||||
ScannerService::ScannerService(Db& db)
|
ScannerService::ScannerService(Db& db)
|
||||||
: _db{ db }
|
: _db{ db }
|
||||||
, _dbSession{ db }
|
|
||||||
{
|
{
|
||||||
_ioService.setThreadCount(1);
|
_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());
|
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)
|
if (!_abortScan)
|
||||||
{
|
{
|
||||||
@@ -358,9 +356,9 @@ namespace lms::scanner
|
|||||||
|
|
||||||
newSettings.skipDuplicateMBID = core::Service<core::IConfig>::get()->getBool("scanner-skip-duplicate-mbid", false);
|
newSettings.skipDuplicateMBID = core::Service<core::IConfig>::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.scanVersion = scanSettings->getScanVersion();
|
||||||
newSettings.startTime = scanSettings->getUpdateStartTime();
|
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()) }; });
|
[](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() });
|
newSettings.mediaLibraries.push_back(ScannerSettings::MediaLibraryInfo{ mediaLibrary->getId(), mediaLibrary->getPath().lexically_normal() });
|
||||||
});
|
});
|
||||||
@@ -409,5 +407,4 @@ namespace lms::scanner
|
|||||||
if (std::chrono::duration_cast<std::chrono::seconds>(now - _lastScanInProgressEmit).count() > 1)
|
if (std::chrono::duration_cast<std::chrono::seconds>(now - _lastScanInProgressEmit).count() > 1)
|
||||||
notifyInProgress(stepStats);
|
notifyInProgress(stepStats);
|
||||||
}
|
}
|
||||||
|
|
||||||
} // namespace lms::scanner
|
} // namespace lms::scanner
|
||||||
|
|||||||
@@ -74,11 +74,9 @@ namespace lms::scanner
|
|||||||
// Helpers
|
// Helpers
|
||||||
void refreshScanSettings();
|
void refreshScanSettings();
|
||||||
ScannerSettings readSettings();
|
ScannerSettings readSettings();
|
||||||
void reloadRecommendationService();
|
|
||||||
|
|
||||||
void notifyInProgressIfNeeded(const ScanStepStats& stats);
|
void notifyInProgressIfNeeded(const ScanStepStats& stats);
|
||||||
void notifyInProgress(const ScanStepStats& stats);
|
void notifyInProgress(const ScanStepStats& stats);
|
||||||
void reloadSimilarityEngine(ScanStats& stats);
|
|
||||||
|
|
||||||
std::vector<std::unique_ptr<IScanStep>> _scanSteps;
|
std::vector<std::unique_ptr<IScanStep>> _scanSteps;
|
||||||
|
|
||||||
@@ -89,7 +87,6 @@ namespace lms::scanner
|
|||||||
Events _events;
|
Events _events;
|
||||||
std::chrono::system_clock::time_point _lastScanInProgressEmit{};
|
std::chrono::system_clock::time_point _lastScanInProgressEmit{};
|
||||||
db::Db& _db;
|
db::Db& _db;
|
||||||
db::Session _dbSession;
|
|
||||||
|
|
||||||
mutable std::shared_mutex _statusMutex;
|
mutable std::shared_mutex _statusMutex;
|
||||||
State _curState{ State::NotScheduled };
|
State _curState{ State::NotScheduled };
|
||||||
|
|||||||
@@ -19,32 +19,28 @@
|
|||||||
|
|
||||||
#include "services/scanner/ScannerStats.hpp"
|
#include "services/scanner/ScannerStats.hpp"
|
||||||
|
|
||||||
namespace lms::scanner {
|
namespace lms::scanner
|
||||||
|
|
||||||
ScanError::ScanError(const std::filesystem::path& _file, ScanErrorType _error, const std::string& _systemError)
|
|
||||||
: file {_file},
|
|
||||||
error {_error},
|
|
||||||
systemError {_systemError}
|
|
||||||
{
|
{
|
||||||
}
|
ScanError::ScanError(const std::filesystem::path& _file, ScanErrorType _error, const std::string& _systemError)
|
||||||
|
: file{ _file },
|
||||||
|
error{ _error },
|
||||||
|
systemError{ _systemError }
|
||||||
|
{
|
||||||
|
}
|
||||||
|
|
||||||
std::size_t
|
std::size_t ScanStats::nbFiles() const
|
||||||
ScanStats::nbFiles() const
|
{
|
||||||
{
|
return skips + additions + updates;
|
||||||
return skips + additions + updates;
|
}
|
||||||
}
|
|
||||||
|
|
||||||
std::size_t
|
std::size_t ScanStats::nbChanges() const
|
||||||
ScanStats::nbChanges() const
|
{
|
||||||
{
|
return additions + deletions + updates;
|
||||||
return additions + deletions + updates;
|
}
|
||||||
}
|
|
||||||
|
|
||||||
unsigned
|
|
||||||
ScanStepStats::progress() const
|
|
||||||
{
|
|
||||||
return (processedElems / static_cast<float>(totalElems ? totalElems : 1)) * 100;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
unsigned ScanStepStats::progress() const
|
||||||
|
{
|
||||||
|
return (processedElems / static_cast<float>(totalElems ? totalElems : 1)) * 100;
|
||||||
|
}
|
||||||
} // namespace lms::scanner
|
} // namespace lms::scanner
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user