#include <qxrdfilebrowsermodelupdater.h>

Inheritance diagram for QxrdFileBrowserModelUpdater:

Collaboration diagram for QxrdFileBrowserModelUpdater:

Public Slots
void	changeRoot (const QString &path)

void	changeContents (const QString &path)

void	updateTimeout ()

void	needUpdate ()

void	updateContents ()

void	generateFileUpdates (int doIt)

Public Slots inherited from QcepObject
virtual void	printLine (QString line)

virtual void	printMessage (QString msg, QDateTime dt=QDateTime::currentDateTime()) const

virtual void	criticalMessage (QString msg, QDateTime ts=QDateTime::currentDateTime()) const

virtual void	statusMessage (QString msg, QDateTime ts=QDateTime::currentDateTime()) const

virtual QString	settingsScript ()

QString	scriptValueLiteral (QVariant v)

Public Member Functions
	QxrdFileBrowserModelUpdater (QxrdFileBrowserModelWPtr browser, QcepObject *parent)

virtual	~QxrdFileBrowserModelUpdater ()

bool	updateNeeded ()

Public Member Functions inherited from QcepObject
	QcepObject (QString name, QcepObject *parent)

virtual	~QcepObject ()

virtual void	writeSettings (QSettings *set, QString section)

virtual void	readSettings (QSettings *set, QString section)

QString	get_Name () const

void	set_Name (QString name)

Private Attributes
QxrdFileBrowserModelWPtr	m_BrowserModel

QString	m_RootPath

QFileSystemWatcher *	m_FileSystemWatcher

QAtomicInt	m_UpdateNeeded

QTimer	m_UpdateTimer

int	m_UpdateInterval

QVector< QFileInfo >	m_Directories

QVector< QFileInfo >	m_Files

QDateTime	m_PreviousUpdate

QAtomicInt	m_GenerateUpdates

Additional Inherited Members
Static Public Member Functions inherited from QcepObject
static int	allocatedObjects ()

static int	deletedObjects ()

static QSet< QcepObject * >	allocatedObjectsSet ()

static QString	addSlashes (QString str)

Properties inherited from QcepObject
QString	name

Detailed Description

Definition at line 13 of file qxrdfilebrowsermodelupdater.h.

Constructor & Destructor Documentation

QxrdFileBrowserModelUpdater::QxrdFileBrowserModelUpdater	(	QxrdFileBrowserModelWPtr	browser,
		QcepObject *	parent
	)

explicit

Definition at line 10 of file qxrdfilebrowsermodelupdater.cpp.

References changeContents(), changeRoot(), DEBUG_BROWSER, g_Application, m_BrowserModel, m_FileSystemWatcher, m_UpdateInterval, m_UpdateTimer, QcepApplication::printMessage(), qcepDebug(), QxrdFileBrowserModel::rootChanged(), and updateTimeout().

                                                                                                              :
   QcepObject("fileBrowserModelUpdater", parent),
   m_BrowserModel(browser),
   m_RootPath(""),
   m_FileSystemWatcher(NULL),
   m_UpdateNeeded(1),
   m_UpdateTimer(),
   m_UpdateInterval(1000),
   m_PreviousUpdate(QDateTime::currentDateTime()),
   m_GenerateUpdates(true)
 {
   if (g_Application && qcepDebug(DEBUG_BROWSER)) {
     g_Application->printMessage("Starting Browser Model Updater");
   }
 
   m_FileSystemWatcher = new QFileSystemWatcher(this);
 
   QxrdFileBrowserModelPtr model(m_BrowserModel);
 
   if (model) {
     connect(model.data(),        &QxrdFileBrowserModel::rootChanged,
             this,                &QxrdFileBrowserModelUpdater::changeRoot);
   }
 
   connect(m_FileSystemWatcher,   &QFileSystemWatcher::directoryChanged,
           this,                  &QxrdFileBrowserModelUpdater::changeContents, Qt::DirectConnection);
   connect(&m_UpdateTimer,        &QTimer::timeout,
           this,                  &QxrdFileBrowserModelUpdater::updateTimeout);
 
   m_UpdateTimer.setSingleShot(true);
   m_UpdateTimer.start(m_UpdateInterval);
 }

Here is the call graph for this function:

QxrdFileBrowserModelUpdater::~QxrdFileBrowserModelUpdater ( )

virtual

Definition at line 43 of file qxrdfilebrowsermodelupdater.cpp.

References DEBUG_APP, DEBUG_CONSTRUCTORS, QcepObject::printMessage(), and qcepDebug().

 {
 #ifndef QT_NO_DEBUG
   printf("Deleting file browser model updater\n");
 #endif
 
   if (qcepDebug(DEBUG_CONSTRUCTORS)) {
     printf("QxrdFileBrowserModelUpdater::~QxrdFileBrowserModelUpdater(%p)\n", this);
   }
 
   if (qcepDebug(DEBUG_APP)) {
     printMessage("QxrdFileBrowserModelUpdater::~QxrdFileBrowserModelUpdater");
   }
 }

Here is the call graph for this function:

Member Function Documentation

void QxrdFileBrowserModelUpdater::changeContents ( const QString & path )

slot

Definition at line 81 of file qxrdfilebrowsermodelupdater.cpp.

References DEBUG_BROWSER, g_Application, m_UpdateNeeded, QcepApplication::printMessage(), and qcepDebug().

Referenced by QxrdFileBrowserModelUpdater().

 {
   if (g_Application && qcepDebug(DEBUG_BROWSER)) {
     g_Application->printMessage(tr("QxrdFileBrowserModelUpdater::changeContents %1").arg(path));
   }
 
   m_UpdateNeeded.fetchAndStoreOrdered(1);
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void QxrdFileBrowserModelUpdater::changeRoot ( const QString & path )

slot

Definition at line 58 of file qxrdfilebrowsermodelupdater.cpp.

References DEBUG_BROWSER, g_Application, m_FileSystemWatcher, m_RootPath, QcepApplication::printMessage(), and qcepDebug().

Referenced by QxrdFileBrowserModelUpdater().

 {
   if (g_Application && qcepDebug(DEBUG_BROWSER)) {
     g_Application->printMessage(tr("QxrdFileBrowserModelUpdater::changeRoot %1").arg(path));
   }
 
   QStringList dirs = m_FileSystemWatcher->directories();
 
   if (dirs.count() >= 1) {
     m_FileSystemWatcher->removePaths(dirs);
   }
 
   if (path != "") {
     m_FileSystemWatcher->addPath(path);
     m_RootPath = path;
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void QxrdFileBrowserModelUpdater::generateFileUpdates ( int doIt )

slot

Definition at line 317 of file qxrdfilebrowsermodelupdater.cpp.

References m_GenerateUpdates, and m_PreviousUpdate.

 {
   if (doIt) {
     m_PreviousUpdate = QDateTime::currentDateTime();
   }
 
   m_GenerateUpdates = doIt;
 }

void QxrdFileBrowserModelUpdater::needUpdate ( )

slot

Definition at line 76 of file qxrdfilebrowsermodelupdater.cpp.

References m_UpdateNeeded.

 {
   m_UpdateNeeded.fetchAndStoreOrdered(1);
 }

void QxrdFileBrowserModelUpdater::updateContents ( )

slot

Definition at line 167 of file qxrdfilebrowsermodelupdater.cpp.

References DEBUG_BROWSER, fileDateGreaterThan(), fileDateLessThan(), fileNameGreaterThan(), fileNameLessThan(), fileSizeGreaterThan(), fileSizeLessThan(), g_Application, m_BrowserModel, m_Directories, m_Files, m_GenerateUpdates, m_PreviousUpdate, m_RootPath, m_UpdateNeeded, mod(), QcepApplication::printMessage(), and qcepDebug().

Referenced by updateTimeout().

 {
   QTime tic;
   tic.start();
 
   m_UpdateNeeded.fetchAndStoreOrdered(0);
 
   QxrdFileBrowserModelPtr model(m_BrowserModel);
 
   if (model) {
     QDirIterator iterd(m_RootPath);
     QDirIterator iter(m_RootPath, model->nameFilters());
     QVector<QFileInfo> dirs;
     QVector<QFileInfo> files;
 
     while (iterd.hasNext()) {
       if (m_UpdateNeeded.fetchAndAddOrdered(0)) {
         if (g_Application && qcepDebug(DEBUG_BROWSER)) {
           g_Application->printMessage("Directory list generation abandoned");
         }
 
         return;
       }
 
       QString filePath = iterd.next();
       QFileInfo fileInfo(m_RootPath, filePath);
 
       if (fileInfo.isDir()) {
         QString dirName = fileInfo.fileName();
 
         if ((dirName != ".") && (dirName != "..")) {
           dirs.append(fileInfo);
         }
       }
     }
 
     while (iter.hasNext()) {
       if (m_UpdateNeeded.fetchAndAddOrdered(0)) {
         if (g_Application && qcepDebug(DEBUG_BROWSER)) {
           g_Application->printMessage("File list generation abandoned");
         }
 
         return;
       }
 
       QString filePath = iter.next();
       QFileInfo fileInfo(m_RootPath, filePath);
 
       if (fileInfo.isDir()) {
       } else {
         files.append(fileInfo);
       }
     }
 
     m_Directories  = dirs;
     m_Files        = files;
 
     if (g_Application && qcepDebug(DEBUG_BROWSER)) {
       g_Application->printMessage(tr("Update file browser took %1 msec").arg(tic.restart()));
       g_Application->printMessage(tr("File Path %1: %2 dirs, %3 files")
                                   .arg(m_RootPath).arg(m_Directories.count()).arg(m_Files.count()));
     }
 
     if (m_GenerateUpdates.fetchAndAddOrdered(0)) {
       QDateTime latest = m_PreviousUpdate;
 
       foreach(QFileInfo file, files) {
         QDateTime mod = file.lastModified();
         if (mod > m_PreviousUpdate) {
           model->updatedFile(file);
         }
 
         if (mod > latest) {
           latest = mod;
         }
       }
 
       m_PreviousUpdate = latest;
     }
 
     int           column = model->sortedColumn();
     Qt::SortOrder order  = model->sortOrder();
 
     try {
       qStableSort(m_Directories.begin(), m_Directories.end(),
                   fileNameLessThan);
 
       switch(column) {
       case 0:
         if (order == Qt::AscendingOrder) {
           qStableSort(m_Files.begin(), m_Files.end(),
                       fileNameLessThan);
         } else {
           qStableSort(m_Files.begin(), m_Files.end(),
                       fileNameGreaterThan);
         }
         break;
 
       case 1:
         if (order == Qt::AscendingOrder) {
           qStableSort(m_Files.begin(), m_Files.end(),
                       fileSizeLessThan);
         } else {
           qStableSort(m_Files.begin(), m_Files.end(),
                       fileSizeGreaterThan);
         }
         break;
 
       case 2:
         if (order == Qt::AscendingOrder) {
           qStableSort(m_Files.begin(), m_Files.end(),
                       fileDateLessThan);
         } else {
           qStableSort(m_Files.begin(), m_Files.end(),
                       fileDateGreaterThan);
         }
         break;
       }
     }
 
     catch (...) {
       if (g_Application && qcepDebug(DEBUG_BROWSER)) {
         g_Application->printMessage("Sorting abandoned");
       }
 
       return;
     }
 
     if (g_Application && qcepDebug(DEBUG_BROWSER)) {
       g_Application->printMessage(tr("Sort file browser took %1 msec").arg(tic.elapsed()));
     }
 
     int limit = 10000;
 
     QxrdApplication *app = qobject_cast<QxrdApplication*>(g_Application);
 
     if (app) {
       limit = app->get_FileBrowserLimit();
     }
 
     int trueSize = m_Files.count();
 
     if (limit && limit < trueSize) {
       model->newDataAvailable(m_Directories, m_Files.mid(0,limit), limit, trueSize);
     } else {
       model->newDataAvailable(m_Directories, m_Files);
     }
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

bool QxrdFileBrowserModelUpdater::updateNeeded ( )

Definition at line 103 of file qxrdfilebrowsermodelupdater.cpp.

References m_UpdateNeeded.

 {
   return m_UpdateNeeded.fetchAndAddOrdered(0);
 }

void QxrdFileBrowserModelUpdater::updateTimeout ( )

slot

Definition at line 90 of file qxrdfilebrowsermodelupdater.cpp.

References DEBUG_BROWSER, g_Application, m_RootPath, m_UpdateInterval, m_UpdateNeeded, m_UpdateTimer, QcepApplication::printMessage(), qcepDebug(), and updateContents().

Referenced by QxrdFileBrowserModelUpdater().

 {
   if (m_UpdateNeeded.fetchAndStoreOrdered(0)) {
     if (g_Application && qcepDebug(DEBUG_BROWSER)) {
       g_Application->printMessage(tr("QxrdFileBrowserModelUpdater::updateTimeout update needed %1").arg(m_RootPath));
     }
 
     updateContents();
   }
 
   m_UpdateTimer.start(m_UpdateInterval);
 }