Program Listing for File HsmEventDispatcherGLib.hpp

↰ Return to documentation for file (include/hsmcpp/HsmEventDispatcherGLib.hpp)

// Copyright (C) 2021 Igor Krechetov
// Distributed under MIT license. See file LICENSE for details

#ifndef HSMCPP_HSMEVENTDISPATCHERGLIB_HPP
#define HSMCPP_HSMEVENTDISPATCHERGLIB_HPP

#include <glib.h>

#include <condition_variable>
#include <map>

#include "HsmEventDispatcherBase.hpp"

namespace hsmcpp {

class HsmEventDispatcherGLib : public HsmEventDispatcherBase {
private:
    using TimerData_t = std::pair<HsmEventDispatcherGLib*, TimerID_t>;

public:
    static std::shared_ptr<HsmEventDispatcherGLib> create(const size_t eventsCacheSize = DISPATCHER_DEFAULT_EVENTS_CACHESIZE);

    static std::shared_ptr<HsmEventDispatcherGLib> create(GMainContext* context,
                                                          const size_t eventsCacheSize = DISPATCHER_DEFAULT_EVENTS_CACHESIZE);

    bool start() override;

    void stop() override;

    void emitEvent(const HandlerID_t handlerID) override;

private:
    explicit HsmEventDispatcherGLib(const size_t eventsCacheSize = DISPATCHER_DEFAULT_EVENTS_CACHESIZE);

    HsmEventDispatcherGLib(GMainContext* context, const size_t eventsCacheSize = DISPATCHER_DEFAULT_EVENTS_CACHESIZE);

    virtual ~HsmEventDispatcherGLib();

    bool deleteSafe() override;

    void unregisterAllTimerHandlers();

    void startTimerImpl(const TimerID_t timerID, const unsigned int intervalMs, const bool isSingleShot) override;
    void stopTimerImpl(const TimerID_t timerID) override;

    static gboolean onTimerEvent(const TimerData_t* timerData);
    static void onFreeTimerData(void* timerData);

    void notifyDispatcherAboutEvent() override;
    static gboolean onPipeDataAvailable(GIOChannel* gio, GIOCondition condition, gpointer data);

private:
    GMainContext* mContext = nullptr;
    GIOChannel* mReadChannel = nullptr;
    GSource* mIoSource = nullptr;
    std::mutex mPipeSync;
    int mPipeFD[2] = {-1, -1};
    bool mDispatchingIterationRunning = false;
    std::mutex mDispatchingSync;
    std::condition_variable mDispatchingDoneEvent;
    std::map<TimerID_t, GSource*> mNativeTimerHandlers; // protected by mRunningTimersSync
};

}  // namespace hsmcpp

#endif  // HSMCPP_HSMEVENTDISPATCHERGLIB_HPP