mirror of
https://github.com/tomahawk-player/tomahawk.git
synced 2025-10-04 17:41:42 +02:00
Move ScanManager into libtomahawk. It's core functionality, non-GUI, and
this lets things in libtomahawk call scan functions easily
This commit is contained in:
Jeff Mitchell
230
src/libtomahawk/filemetadata/ScanManager.cpp
Normal file
230
src/libtomahawk/filemetadata/ScanManager.cpp
Normal file
@@ -0,0 +1,230 @@
|
||||
/* === This file is part of Tomahawk Player - <http://tomahawk-player.org> ===
|
||||
*
|
||||
* Copyright 2010-2011, Christian Muehlhaeuser <muesli@tomahawk-player.org>
|
||||
* Copyright 2010-2012, Jeff Mitchell <jeff@tomahawk-player.org>
|
||||
*
|
||||
* Tomahawk is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* Tomahawk is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with Tomahawk. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
|
||||
#include "ScanManager.h"
|
||||
|
||||
#include <QtCore/QThread>
|
||||
#include <QtCore/QCoreApplication>
|
||||
#include <QtCore/QTimer>
|
||||
|
||||
#include "MusicScanner.h"
|
||||
#include "TomahawkSettings.h"
|
||||
#include "utils/TomahawkUtils.h"
|
||||
#include "libtomahawk/SourceList.h"
|
||||
|
||||
#include "database/Database.h"
|
||||
#include "database/DatabaseCommand_FileMTimes.h"
|
||||
#include "database/DatabaseCommand_DeleteFiles.h"
|
||||
|
||||
#include "utils/Logger.h"
|
||||
|
||||
ScanManager* ScanManager::s_instance = 0;
|
||||
|
||||
|
||||
ScanManager*
|
||||
ScanManager::instance()
|
||||
{
|
||||
return s_instance;
|
||||
}
|
||||
|
||||
|
||||
ScanManager::ScanManager( QObject* parent )
|
||||
: QObject( parent )
|
||||
, m_musicScannerThreadController( 0 )
|
||||
, m_currScannerPaths()
|
||||
{
|
||||
s_instance = this;
|
||||
|
||||
m_scanTimer = new QTimer( this );
|
||||
m_scanTimer->setSingleShot( false );
|
||||
m_scanTimer->setInterval( TomahawkSettings::instance()->scannerTime() * 1000 );
|
||||
|
||||
connect( TomahawkSettings::instance(), SIGNAL( changed() ), SLOT( onSettingsChanged() ) );
|
||||
connect( m_scanTimer, SIGNAL( timeout() ), SLOT( scanTimerTimeout() ) );
|
||||
|
||||
if ( TomahawkSettings::instance()->hasScannerPaths() )
|
||||
{
|
||||
m_currScannerPaths = TomahawkSettings::instance()->scannerPaths();
|
||||
m_scanTimer->start();
|
||||
if ( TomahawkSettings::instance()->watchForChanges() )
|
||||
QTimer::singleShot( 1000, this, SLOT( runStartupScan() ) );
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
ScanManager::~ScanManager()
|
||||
{
|
||||
qDebug() << Q_FUNC_INFO;
|
||||
|
||||
if ( !m_scanner.isNull() )
|
||||
{
|
||||
m_musicScannerThreadController->quit();
|
||||
m_musicScannerThreadController->wait( 60000 );
|
||||
|
||||
delete m_scanner.data();
|
||||
delete m_musicScannerThreadController;
|
||||
m_musicScannerThreadController = 0;
|
||||
}
|
||||
qDebug() << Q_FUNC_INFO << "scanner thread controller finished, exiting ScanManager";
|
||||
}
|
||||
|
||||
|
||||
void
|
||||
ScanManager::onSettingsChanged()
|
||||
{
|
||||
if ( !TomahawkSettings::instance()->watchForChanges() && m_scanTimer->isActive() )
|
||||
m_scanTimer->stop();
|
||||
|
||||
m_scanTimer->setInterval( TomahawkSettings::instance()->scannerTime() * 1000 );
|
||||
|
||||
if ( TomahawkSettings::instance()->hasScannerPaths() &&
|
||||
m_currScannerPaths != TomahawkSettings::instance()->scannerPaths() )
|
||||
{
|
||||
m_currScannerPaths = TomahawkSettings::instance()->scannerPaths();
|
||||
runScan();
|
||||
}
|
||||
|
||||
if ( TomahawkSettings::instance()->watchForChanges() && !m_scanTimer->isActive() )
|
||||
m_scanTimer->start();
|
||||
}
|
||||
|
||||
|
||||
void
|
||||
ScanManager::runStartupScan()
|
||||
{
|
||||
qDebug() << Q_FUNC_INFO;
|
||||
if ( !Database::instance() || ( Database::instance() && !Database::instance()->isReady() ) )
|
||||
QTimer::singleShot( 1000, this, SLOT( runStartupScan() ) );
|
||||
else
|
||||
runScan();
|
||||
}
|
||||
|
||||
|
||||
void
|
||||
ScanManager::scanTimerTimeout()
|
||||
{
|
||||
qDebug() << Q_FUNC_INFO;
|
||||
if ( !TomahawkSettings::instance()->watchForChanges() ||
|
||||
!Database::instance() ||
|
||||
( Database::instance() && !Database::instance()->isReady() ) )
|
||||
return;
|
||||
else
|
||||
runScan();
|
||||
}
|
||||
|
||||
|
||||
void
|
||||
ScanManager::runScan( bool manualFull )
|
||||
{
|
||||
qDebug() << Q_FUNC_INFO;
|
||||
if ( !Database::instance() || ( Database::instance() && !Database::instance()->isReady() ) )
|
||||
return;
|
||||
|
||||
if ( !m_musicScannerThreadController && m_scanner.isNull() ) //still running if these are not zero
|
||||
{
|
||||
if ( manualFull )
|
||||
{
|
||||
DatabaseCommand_DeleteFiles *cmd = new DatabaseCommand_DeleteFiles( SourceList::instance()->getLocal() );
|
||||
connect( cmd, SIGNAL( finished() ), SLOT( filesDeleted() ) );
|
||||
Database::instance()->enqueue( QSharedPointer< DatabaseCommand >( cmd ) );
|
||||
return;
|
||||
}
|
||||
|
||||
DatabaseCommand_FileMtimes *cmd = new DatabaseCommand_FileMtimes( true );
|
||||
connect( cmd, SIGNAL( done( const QMap< QString, QMap< unsigned int, unsigned int > >& ) ),
|
||||
SLOT( fileMtimesCheck( const QMap< QString, QMap< unsigned int, unsigned int > >& ) ) );
|
||||
|
||||
Database::instance()->enqueue( QSharedPointer< DatabaseCommand >( cmd ) );
|
||||
}
|
||||
else
|
||||
{
|
||||
qDebug() << "Could not run dir scan, old scan still running";
|
||||
return;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
void
|
||||
ScanManager::fileMtimesCheck( const QMap< QString, QMap< unsigned int, unsigned int > >& mtimes )
|
||||
{
|
||||
if ( !mtimes.isEmpty() && TomahawkSettings::instance()->scannerPaths().isEmpty() )
|
||||
{
|
||||
DatabaseCommand_DeleteFiles *cmd = new DatabaseCommand_DeleteFiles( SourceList::instance()->getLocal() );
|
||||
connect( cmd, SIGNAL( finished() ), SLOT( filesDeleted() ) );
|
||||
Database::instance()->enqueue( QSharedPointer< DatabaseCommand >( cmd ) );
|
||||
return;
|
||||
}
|
||||
|
||||
runDirScan();
|
||||
}
|
||||
|
||||
|
||||
void
|
||||
ScanManager::filesDeleted()
|
||||
{
|
||||
if ( !TomahawkSettings::instance()->scannerPaths().isEmpty() )
|
||||
runDirScan();
|
||||
else
|
||||
scannerFinished();
|
||||
}
|
||||
|
||||
|
||||
void
|
||||
ScanManager::runDirScan()
|
||||
{
|
||||
qDebug() << Q_FUNC_INFO;
|
||||
|
||||
QStringList paths = TomahawkSettings::instance()->scannerPaths();
|
||||
|
||||
if ( !m_musicScannerThreadController && m_scanner.isNull() ) //still running if these are not zero
|
||||
{
|
||||
m_scanTimer->stop();
|
||||
m_musicScannerThreadController = new QThread( this );
|
||||
m_scanner = QWeakPointer< MusicScanner >( new MusicScanner( paths ) );
|
||||
m_scanner.data()->moveToThread( m_musicScannerThreadController );
|
||||
connect( m_scanner.data(), SIGNAL( finished() ), SLOT( scannerFinished() ) );
|
||||
m_musicScannerThreadController->start( QThread::IdlePriority );
|
||||
QMetaObject::invokeMethod( m_scanner.data(), "startScan" );
|
||||
}
|
||||
else
|
||||
{
|
||||
qDebug() << "Could not run dir scan, old scan still running";
|
||||
return;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
void
|
||||
ScanManager::scannerFinished()
|
||||
{
|
||||
tDebug() << "deleting scanner";
|
||||
if ( !m_scanner.isNull() )
|
||||
{
|
||||
m_musicScannerThreadController->quit();
|
||||
m_musicScannerThreadController->wait( 60000 );
|
||||
|
||||
delete m_scanner.data();
|
||||
delete m_musicScannerThreadController;
|
||||
m_musicScannerThreadController = 0;
|
||||
}
|
||||
|
||||
m_scanTimer->start();
|
||||
SourceList::instance()->getLocal()->scanningFinished( 0 );
|
||||
emit finished();
|
||||
}
|
||||
Reference in New Issue
Block a user