PipeHotplugMonitor.h

#pragma once

#include <list>
#include <set>
#include <string>

#include <Poco/AtomicCounter.h>
#include <Poco/Event.h>
#include <Poco/Timespan.h>

#include "loop/StoppableRunnable.h"
#include "hotplug/AbstractHotplugMonitor.h"

namespace BeeeOn {

class FdInputStream;

class PipeHotplugMonitor :
                public StoppableRunnable,
                public AbstractHotplugMonitor {
public:
        PipeHotplugMonitor();
        ~PipeHotplugMonitor();

        void run() override;
        void stop() override;

        void setPipePath(const std::string &path);

        void setPollTimeout(const Poco::Timespan &timeout);

protected:
        int openPipe();

        void pollForEvents(FdInputStream &input);

        bool processEvent(FdInputStream &input);

        bool parseLine(const std::string &line, std::string &key, std::string &value) const;

        void fillEvent(HotplugEvent &event, const std::string &key, const std::string &value) const;

        bool skipEvent(FdInputStream &input) const;
        void fireEvent(const HotplugEvent &event, const std::string &action);

private:
        std::string m_pipePath;
        Poco::Event m_waitPipe;
        Poco::Timespan m_pollTimeout;
        Poco::AtomicCounter m_stop;
};

}