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:
        [[nodiscard]] bool isRegistered(EventType type, EventListener* listener) const;
 
private:
        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