DeviceWatcher_p.h

Go to the documentation of this file.

 
#pragma once
 
#include <QtCore/qglobal.h>
#define CONFIG_SOCKETNOTIFIER 1
#define CONFIG_TCPSOCKET 0 //QtNetwork
#if defined(Q_OS_WINCE)
    #define CONFIG_THREAD 1
#elif defined(Q_OS_LINUX)
    #define CONFIG_THREAD (!CONFIG_SOCKETNOTIFIER && !CONFIG_TCPSOCKET)
    #if CONFIG_TCPSOCKET
        class QTcpSocket;
    #elif CONFIG_SOCKETNOTIFIER
        class QSocketNotifier;
    #endif
#elif defined Q_OS_MAC //OSX or MACX
#define CONFIG_THREAD 1
#include <DiskArbitration/DiskArbitration.h>
#else
#define CONFIG_THREAD 0
#endif
 
#if CONFIG_DEBUG
#define zDebug(fmt, ...) qDebug("%s: " #fmt, __FUNCTION__, ##__VA_ARGS__)
#else
#define zDebug(fmt, ...)
#endif //CONFIG_DEBUG
 
#ifdef Q_OS_WIN
#include <qt_windows.h>
#else
#include <QtCore/QBuffer>
#endif //Q_OS_WIN
#include <QtCore/QList>
#include <QtCore/QThread>
namespace NDEVR
{
    class DeviceWatcher;
    class DeviceWatcherPrivate
#if CONFIG_THREAD
        : public QThread
#else
        : public QObject
#endif //CONFIG_THREAD
    {
        Q_OBJECT
    public:
        DeviceWatcherPrivate(QObject * parent = 0)
            :
    #if CONFIG_THREAD
            QThread(parent)
    #else
            QObject(parent)
    #endif //CONFIG_THREAD
        {
            //init();
        }
        virtual ~DeviceWatcherPrivate();
 
        void setWatcher(DeviceWatcher* w) { watcher = w; }
        bool start(); //conflict with QThread::start()
        bool stop();
 
        //Do not use Qt::DirectConnection. this thread is not watcher's thread!
        void emitDeviceAdded(const QString& dev);
        void emitDeviceChanged(const QString& dev); //Linux: when umounting the device
        void emitDeviceRemoved(const QString& dev);
        void emitDeviceAction(const QString& dev, const QString& action);
 
        QList<QObject*> event_receivers;
 
    private slots:
        void parseDeviceInfo();
 
    private:
        DeviceWatcher* watcher = nullptr;
 
        bool init();
    #if CONFIG_THREAD
        virtual void run();
    #endif //CONFIG_THREAD
    #if defined(Q_OS_LINUX)
        QBuffer buffer;
        void parseLine(const QByteArray& line);
    #if CONFIG_TCPSOCKET
        QTcpSocket* tcp_socket;
    #elif CONFIG_SOCKETNOTIFIER
        QSocketNotifier* socket_notifier;
    #endif
 
        QString bus_name;
        int netlink_socket;
    #elif defined(Q_OS_WIN32)
        HWND hwnd = NULL;
    #elif defined(Q_OS_WINCE)
        HANDLE mQueueHandle;
        HANDLE mNotificationHandle;
    #endif
    #ifdef Q_OS_MAC
        volatile bool mStop;
        DASessionRef mSession;
    #endif //Q_OS_MAC
    };
}