ukui-search/libsearch/index/inotify-watch.h

#ifndef INOTIFYWATCH_H
#define INOTIFYWATCH_H

#include <QThread>
#include <QBuffer>
#include <QSocketNotifier>
#include <QDataStream>
#include <QSharedMemory>
#include <QSystemSemaphore>

#include <sys/prctl.h>
#include <sys/wait.h>
#include <sys/inotify.h>
#include <unistd.h>

#include "traverse_bfs.h"
#include "ukui-search-qdbus.h"
#include "index-status-recorder.h"
#include "file-utils.h"
#include "pending-file-queue.h"
#include "common.h"
namespace UkuiSearch {
class InotifyWatch : public QThread, public Traverse_BFS
{
    Q_OBJECT
public:
    static InotifyWatch* getInstance();
    bool addWatch(const QString &path);
    bool removeWatch(const QString &path, bool removeFromDatabase = true);
    virtual void work(const QFileInfo &info) final;

    void firstTraverse(QStringList pathList = {}, QStringList blockList = {});
    void stopWatch();
    void addIndexPath(const QString path, const QStringList blockList);
    void removeIndexPath(const QString &path, bool fileIndexEnable);
protected:
    void run() override;

private Q_SLOTS:
    void slotEvent(char *buf, ssize_t len);
private:
    explicit InotifyWatch();
    ~InotifyWatch();
    char * filter();
    void eventProcess(int socket);
    void eventProcess(const char *buffer, ssize_t len);

    int m_inotifyFd;
    QSocketNotifier* m_notifier = nullptr;
    QSharedMemory *m_sharedMemory = nullptr;
    QMap<int, QString> m_pathMap;
    QMutex m_pathMapLock;
    QSystemSemaphore m_semaphore;

};
}
#endif // INOTIFYWATCH_H