2011-04-06 13:48:02 +04:00
|
|
|
/*
|
2014-01-13 19:16:19 +04:00
|
|
|
* Copyright (C) by Klaas Freitag <freitag@owncloud.com>
|
2011-04-06 13:48:02 +04:00
|
|
|
*
|
|
|
|
* This program is free software; you can redistribute it and/or modify
|
|
|
|
* it under the terms of the GNU General Public License as published by
|
2016-10-25 12:00:07 +03:00
|
|
|
* the Free Software Foundation; either version 2 of the License, or
|
|
|
|
* (at your option) any later version.
|
2011-04-06 13:48:02 +04:00
|
|
|
*
|
|
|
|
* This program 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.
|
|
|
|
*/
|
2011-02-17 02:21:45 +03:00
|
|
|
|
2011-03-16 16:50:34 +03:00
|
|
|
// event masks
|
2014-07-11 02:31:24 +04:00
|
|
|
#include "folderwatcher.h"
|
2012-05-21 18:48:49 +04:00
|
|
|
|
2012-03-01 19:13:50 +04:00
|
|
|
#include <stdint.h>
|
2011-03-16 16:50:34 +03:00
|
|
|
|
2011-02-17 02:21:45 +03:00
|
|
|
#include <QFileInfo>
|
|
|
|
#include <QFlags>
|
|
|
|
#include <QDir>
|
|
|
|
#include <QMutexLocker>
|
|
|
|
#include <QStringList>
|
2011-03-18 15:54:32 +03:00
|
|
|
#include <QTimer>
|
2011-02-17 02:21:45 +03:00
|
|
|
|
2014-01-27 15:31:54 +04:00
|
|
|
#if defined(Q_OS_WIN)
|
2014-07-11 02:31:24 +04:00
|
|
|
#include "folderwatcher_win.h"
|
2014-01-27 15:31:54 +04:00
|
|
|
#elif defined(Q_OS_MAC)
|
2014-07-11 02:31:24 +04:00
|
|
|
#include "folderwatcher_mac.h"
|
2014-04-29 13:02:44 +04:00
|
|
|
#elif defined(Q_OS_UNIX)
|
2014-07-11 02:31:24 +04:00
|
|
|
#include "folderwatcher_linux.h"
|
2014-01-27 15:31:54 +04:00
|
|
|
#endif
|
|
|
|
|
2015-10-02 10:40:44 +03:00
|
|
|
#include "folder.h"
|
2014-01-27 15:31:54 +04:00
|
|
|
|
2014-11-10 00:34:07 +03:00
|
|
|
namespace OCC {
|
2011-02-17 02:21:45 +03:00
|
|
|
|
2017-12-28 22:33:10 +03:00
|
|
|
Q_LOGGING_CATEGORY(lcFolderWatcher, "nextcloud.gui.folderwatcher", QtInfoMsg)
|
2017-05-09 15:24:11 +03:00
|
|
|
|
2018-04-24 10:52:15 +03:00
|
|
|
FolderWatcher::FolderWatcher(Folder *folder)
|
2015-10-02 10:40:44 +03:00
|
|
|
: QObject(folder)
|
|
|
|
, _folder(folder)
|
2011-02-17 02:21:45 +03:00
|
|
|
{
|
2011-03-21 00:18:38 +03:00
|
|
|
}
|
|
|
|
|
2014-01-27 15:31:54 +04:00
|
|
|
FolderWatcher::~FolderWatcher()
|
|
|
|
{
|
|
|
|
}
|
|
|
|
|
2018-04-24 10:52:15 +03:00
|
|
|
void FolderWatcher::init(const QString &root)
|
|
|
|
{
|
|
|
|
_d.reset(new FolderWatcherPrivate(this, root));
|
|
|
|
_timer.start();
|
|
|
|
}
|
|
|
|
|
2014-01-13 18:23:38 +04:00
|
|
|
bool FolderWatcher::pathIsIgnored(const QString &path)
|
|
|
|
{
|
|
|
|
if (path.isEmpty())
|
|
|
|
return true;
|
2015-10-02 10:40:44 +03:00
|
|
|
if (!_folder)
|
|
|
|
return false;
|
2014-01-13 18:23:38 +04:00
|
|
|
|
2015-10-02 10:40:44 +03:00
|
|
|
#ifndef OWNCLOUD_TEST
|
2016-09-12 16:02:54 +03:00
|
|
|
if (_folder->isFileExcludedAbsolute(path)) {
|
2017-05-09 15:24:11 +03:00
|
|
|
qCDebug(lcFolderWatcher) << "* Ignoring file" << path;
|
2016-09-12 16:02:54 +03:00
|
|
|
return true;
|
2014-01-13 18:23:38 +04:00
|
|
|
}
|
2015-10-02 10:40:44 +03:00
|
|
|
#endif
|
2014-01-13 18:23:38 +04:00
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
2017-10-09 13:06:57 +03:00
|
|
|
bool FolderWatcher::isReliable() const
|
|
|
|
{
|
|
|
|
return _isReliable;
|
|
|
|
}
|
|
|
|
|
2014-01-11 23:35:58 +04:00
|
|
|
void FolderWatcher::changeDetected(const QString &path)
|
2011-04-05 14:16:24 +04:00
|
|
|
{
|
2014-02-18 03:36:41 +04:00
|
|
|
QStringList paths(path);
|
|
|
|
changeDetected(paths);
|
|
|
|
}
|
|
|
|
|
|
|
|
void FolderWatcher::changeDetected(const QStringList &paths)
|
|
|
|
{
|
|
|
|
// TODO: this shortcut doesn't look very reliable:
|
|
|
|
// - why is the timeout only 1 second?
|
2015-10-05 07:21:19 +03:00
|
|
|
// - what if there is more than one file being updated frequently?
|
|
|
|
// - why do we skip the file altogether instead of e.g. reducing the upload frequency?
|
2014-02-18 03:36:41 +04:00
|
|
|
|
2014-01-13 18:23:38 +04:00
|
|
|
// Check if the same path was reported within the last second.
|
2014-02-18 03:36:41 +04:00
|
|
|
QSet<QString> pathsSet = paths.toSet();
|
|
|
|
if (pathsSet == _lastPaths && _timer.elapsed() < 1000) {
|
2014-01-13 18:23:38 +04:00
|
|
|
// the same path was reported within the last second. Skip.
|
|
|
|
return;
|
|
|
|
}
|
2014-02-18 03:36:41 +04:00
|
|
|
_lastPaths = pathsSet;
|
2014-01-13 18:23:38 +04:00
|
|
|
_timer.restart();
|
|
|
|
|
2014-11-07 12:53:41 +03:00
|
|
|
QSet<QString> changedPaths;
|
2014-02-18 03:36:41 +04:00
|
|
|
|
2014-01-13 18:23:38 +04:00
|
|
|
// ------- handle ignores:
|
2014-02-18 03:36:41 +04:00
|
|
|
for (int i = 0; i < paths.size(); ++i) {
|
|
|
|
QString path = paths[i];
|
|
|
|
if (pathIsIgnored(path)) {
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
2014-11-07 12:53:41 +03:00
|
|
|
changedPaths.insert(path);
|
2014-02-18 03:36:41 +04:00
|
|
|
}
|
2014-11-07 12:53:41 +03:00
|
|
|
if (changedPaths.isEmpty()) {
|
2014-01-13 18:23:38 +04:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2017-03-30 14:46:20 +03:00
|
|
|
qCInfo(lcFolderWatcher) << "Detected changes in paths:" << changedPaths;
|
2014-11-07 12:53:41 +03:00
|
|
|
foreach (const QString &path, changedPaths) {
|
|
|
|
emit pathChanged(path);
|
2014-02-18 03:36:41 +04:00
|
|
|
}
|
2012-12-05 21:30:40 +04:00
|
|
|
}
|
|
|
|
|
2013-08-19 19:41:42 +04:00
|
|
|
void FolderWatcher::addPath(const QString &path)
|
|
|
|
{
|
|
|
|
_d->addPath(path);
|
|
|
|
}
|
|
|
|
|
|
|
|
void FolderWatcher::removePath(const QString &path)
|
|
|
|
{
|
|
|
|
_d->removePath(path);
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2014-11-10 00:34:07 +03:00
|
|
|
} // namespace OCC
|