dbusdispatcher.h

Go to the documentation of this file.

/*
 * SPDX-FileCopyrightText: (C) 2019-2022 swift Project Community / Contributors (https://swift-project.org/)
 * SPDX-FileCopyrightText: (C) 2019-2022 Lars Toenning <dev@ltoenning.de>
 * SPDX-License-Identifier: GPL-2.0-or-later
 */
 
#pragma once
 
#include "dbuscallbacks.h"
 
#include <dbus/dbus.h>
#include <event2/event.h>
 
#include <memory>
#include <unordered_map>
#include <vector>
 
namespace flightgear::swift {
 
class WatchHandler;
class TimeoutHandler;
class CDBusConnection;
class CDBusDispatcher;

class IDispatchable
{
public:
    IDispatchable() = default;

    virtual ~IDispatchable() = default;

    virtual void dispatch() = 0;
 
private:
    friend CDBusDispatcher;
};

class CDBusDispatcher
{
public:
    CDBusDispatcher();

    virtual ~CDBusDispatcher();

    void add(IDispatchable* dispatchable);

    void remove(IDispatchable* dispatchable);

    void waitAndRun();

    void runOnce();
 
private:
    friend class WatchHandler;
    friend class TimeoutHandler;
    friend class Timer;
    friend class CDBusConnection;
    friend class CDBusServer;
 
    struct EventBaseDeleter {
        void operator()(event_base* obj) const { event_base_free(obj); }
    };
 
    using WatchCallbacks = DBusAsyncCallbacks<DBusWatch>;
    using TimeoutCallbacks = DBusAsyncCallbacks<DBusTimeout>;
 
    void dispatch();
 
    dbus_bool_t dbusAddWatch(DBusWatch* watch);
    void dbusRemoveWatch(DBusWatch* watch);
    void dbusWatchToggled(DBusWatch* watch);
 
    dbus_bool_t dbusAddTimeout(DBusTimeout* timeout);
    void dbusRemoveTimeout(DBusTimeout* timeout);
    void dbusTimeoutToggled(DBusTimeout* timeout);
 
    WatchCallbacks m_watchCallbacks;
    TimeoutCallbacks m_timeoutCallbacks;
    std::unordered_multimap<evutil_socket_t, std::unique_ptr<WatchHandler>> m_watchers;
    std::vector<std::unique_ptr<TimeoutHandler>> m_timeouts;
    std::unique_ptr<event_base, EventBaseDeleter> m_eventBase;
 
    std::vector<IDispatchable*> m_dispatchList;
};
} // namespace flightgear::swift