EventDistributor.hh

Go to the documentation of this file.

#ifndef EVENTDISTRIBUTOR_HH
#define EVENTDISTRIBUTOR_HH

#include "Event.hh"
#include "Semaphore.hh"
#include "CondVar.hh"
#include "noncopyable.hh"
#include <map>
#include <memory>
#include <vector>
#include <functional>

namespace openmsx {

class Reactor;
class EventListener;

class EventDistributor : private noncopyable
{
public:
        typedef std::shared_ptr<const Event> EventPtr;

        enum Priority {
                OTHER   = 0x08,
                CONSOLE = 0x04,
                HOTKEY  = 0x02,
                MSX     = 0x01,
        };

        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;

        typedef std::multimap<Priority, EventListener*, std::greater<Priority>>
                PriorityMap; // sort from big to small
        std::map<EventType, PriorityMap> listeners;
        typedef std::vector<EventPtr> EventQueue;
        EventQueue scheduledEvents;
        Semaphore sem;
        CondVar cond;
};

} // namespace openmsx

#endif