EventDistributor.hh

Go to the documentation of this file.

#ifndef EVENTDISTRIBUTOR_HH
#define EVENTDISTRIBUTOR_HH

#include "Event.hh"
#include <condition_variable>
#include <memory>
#include <mutex>
#include <utility>
#include <vector>

namespace openmsx {

class Reactor;
class EventListener;

class EventDistributor
{
public:
        using EventPtr = std::shared_ptr<const Event>;

        enum Priority {
                OTHER,
                CONSOLE,
                HOTKEY,
                MSX,
        };

        explicit EventDistributor(Reactor& reactor);

        void registerEventListener(EventType type, EventListener& listener,
                                   Priority priority = OTHER);

        void unregisterEventListener(EventType type, EventListener& listener);

        void distributeEvent(const EventPtr& event);

        void deliverEvents();

        bool sleep(unsigned us);

private:
        bool isRegistered(EventType type, EventListener* listener) const;

        Reactor& reactor;

        using PriorityMap = std::vector<std::pair<Priority, EventListener*>>; // sorted on priority
        PriorityMap listeners[NUM_EVENT_TYPES];
        using EventQueue = std::vector<EventPtr>;
        EventQueue scheduledEvents;
        std::mutex mutex; // lock datastructures
        std::mutex cvMutex; // lock condition_variable
        std::condition_variable condition;
};

} // namespace openmsx

#endif