path: root/src/corelib/io/qfilesystemwatcher_kqueue.cpp

// Copyright (C) 2016 The Qt Company Ltd.// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR LGPL-3.0-only OR GPL-2.0-only OR GPL-3.0-only#include <qplatformdefs.h>#include"qfilesystemwatcher.h"#include"qfilesystemwatcher_kqueue_p.h"#include"private/qcore_unix_p.h"#include <qdebug.h>#include <qfile.h>#include <qscopeguard.h>#include <qsocketnotifier.h>#include <qvarlengtharray.h>#include <sys/types.h>#include <sys/event.h>#include <sys/stat.h>#include <sys/time.h>#include <fcntl.h> QT_BEGIN_NAMESPACE // #define KEVENT_DEBUG#ifdef KEVENT_DEBUG# define DEBUG qDebug#else# define DEBUG if(false)qDebug#endif QKqueueFileSystemWatcherEngine *QKqueueFileSystemWatcherEngine::create(QObject *parent){int kqfd =kqueue();if(kqfd == -1)return0;return newQKqueueFileSystemWatcherEngine(kqfd, parent);}QKqueueFileSystemWatcherEngine::QKqueueFileSystemWatcherEngine(int kqfd, QObject *parent):QFileSystemWatcherEngine(parent),kqfd(kqfd),notifier(kqfd,QSocketNotifier::Read,this){connect(&notifier,SIGNAL(activated(QSocketDescriptor)),SLOT(readFromKqueue()));fcntl(kqfd, F_SETFD, FD_CLOEXEC);}QKqueueFileSystemWatcherEngine::~QKqueueFileSystemWatcherEngine(){ notifier.setEnabled(false);close(kqfd);for(int id :std::as_const(pathToID))::close(id <0? -id : id);} QStringList QKqueueFileSystemWatcherEngine::addPaths(const QStringList &paths, QStringList *files, QStringList *directories){ QStringList unhandled;for(const QString &path : paths) {auto sg =qScopeGuard([&]{unhandled.push_back(path);});int fd;#if defined(O_EVTONLY) fd =qt_safe_open(QFile::encodeName(path), O_EVTONLY);#else fd =qt_safe_open(QFile::encodeName(path), O_RDONLY);#endifif(fd == -1) {perror("QKqueueFileSystemWatcherEngine::addPaths: open");continue;}if(fd >= (int)FD_SETSIZE /2&& fd < (int)FD_SETSIZE) {int fddup =qt_safe_dup(fd, FD_SETSIZE);if(fddup != -1) {::close(fd); fd = fddup;}} QT_STATBUF st;if(QT_FSTAT(fd, &st) == -1) {perror("QKqueueFileSystemWatcherEngine::addPaths: fstat");::close(fd);continue;}int id = (S_ISDIR(st.st_mode)) ? -fd : fd;if(id <0) {if(directories->contains(path)) {::close(fd);continue;}}else{if(files->contains(path)) {::close(fd);continue;}}struct kevent kev;EV_SET(&kev, fd, EVFILT_VNODE, EV_ADD | EV_ENABLE | EV_CLEAR, NOTE_DELETE | NOTE_WRITE | NOTE_EXTEND | NOTE_ATTRIB | NOTE_RENAME | NOTE_REVOKE,0,0);if(kevent(kqfd, &kev,1,0,0,0) == -1) {perror("QKqueueFileSystemWatcherEngine::addPaths: kevent");::close(fd);continue;} sg.dismiss();if(id <0) {DEBUG() <<"QKqueueFileSystemWatcherEngine: added directory path"<< path; directories->append(path);}else{DEBUG() <<"QKqueueFileSystemWatcherEngine: added file path"<< path; files->append(path);} pathToID.insert(path, id); idToPath.insert(id, path);}return unhandled;} QStringList QKqueueFileSystemWatcherEngine::removePaths(const QStringList &paths, QStringList *files, QStringList *directories){if(pathToID.isEmpty())return paths; QStringList unhandled;for(const QString &path : paths) {auto sg =qScopeGuard([&]{unhandled.push_back(path);});int id = pathToID.take(path); QString x = idToPath.take(id);if(x.isEmpty() || x != path)continue;::close(id <0? -id : id); sg.dismiss();if(id <0) directories->removeAll(path);else files->removeAll(path);}return unhandled;}voidQKqueueFileSystemWatcherEngine::readFromKqueue(){ forever {DEBUG() <<"QKqueueFileSystemWatcherEngine: polling for changes";int r;struct kevent kev;struct timespec ts = {0,0};// 0 ts, because we want to pollQT_EINTR_LOOP(r,kevent(kqfd,0,0, &kev,1, &ts));if(r <0) {perror("QKqueueFileSystemWatcherEngine: error during kevent wait");return;}else if(r ==0) {// polling returned no events, so stopbreak;}else{int fd = kev.ident;DEBUG() <<"QKqueueFileSystemWatcherEngine: processing kevent"<< kev.ident << kev.filter;int id = fd; QString path = idToPath.value(id);if(path.isEmpty()) {// perhaps a directory? id = -id; path = idToPath.value(id);if(path.isEmpty()) {DEBUG() <<"QKqueueFileSystemWatcherEngine: received a kevent for a file we're not watching";continue;}}if(kev.filter != EVFILT_VNODE) {DEBUG() <<"QKqueueFileSystemWatcherEngine: received a kevent with the wrong filter";continue;}if((kev.fflags & (NOTE_DELETE | NOTE_REVOKE | NOTE_RENAME)) !=0) {DEBUG() << path <<"removed, removing watch also"; pathToID.remove(path); idToPath.remove(id);::close(fd);if(id <0) emit directoryChanged(path,true);else emit fileChanged(path,true);}else{DEBUG() << path <<"changed";if(id <0) emit directoryChanged(path,false);else emit fileChanged(path,false);}}}} QT_END_NAMESPACE #include"moc_qfilesystemwatcher_kqueue_p.cpp"