From ee814eede9b65fb469c12a3effc432e38a33442d Mon Sep 17 00:00:00 2001 From: LaG1924 <12997935+LaG1924@users.noreply.github.com> Date: Sun, 10 Dec 2017 14:35:25 +0500 Subject: Removed previous implementation of event-system --- src/Event.cpp | 130 ---------------------------------------------------------- 1 file changed, 130 deletions(-) (limited to 'src/Event.cpp') diff --git a/src/Event.cpp b/src/Event.cpp index 1f3a9e8..00f67c0 100644 --- a/src/Event.cpp +++ b/src/Event.cpp @@ -1,131 +1 @@ #include "Event.hpp" - -#include - -#include "Utility.hpp" - -std::queue EventAgregator::eventsToHandle; -std::mutex EventAgregator::queueMutex; -bool EventAgregator::isStarted = false; -std::vector EventAgregator::listeners; -std::mutex EventAgregator::listenersMutex; - -EventListener::EventListener() { - EventAgregator::RegisterListener(*this); -} - -EventListener::~EventListener() { - EventAgregator::UnregisterListener(*this); -} - -void EventListener::PushEvent(Event event) { - eventsMutex.lock(); - handlersMutex.lock(); - if (handlers[event.type]) { - events.push(event); - } - handlersMutex.unlock(); - eventsMutex.unlock(); -} - -void EventListener::DirectCall(Event event) -{ - handlersMutex.lock(); - if (handlers[event.type]) - handlers[event.type](event.data); - handlersMutex.unlock(); -} - -bool EventListener::IsEventsQueueIsNotEmpty() { - eventsMutex.lock(); - bool value = !events.empty(); - eventsMutex.unlock(); - return value; -} - - -void EventListener::RegisterHandler(EventType type, EventListener::HandlerFunc handler) { - handlersMutex.lock(); - handlers[type] = handler; - handlersMutex.unlock(); -} - -void EventListener::HandleEvent() { - eventsMutex.lock(); - if (events.empty()) { - eventsMutex.unlock(); - return; - } - Event event = events.front(); - events.pop(); - eventsMutex.unlock(); - handlersMutex.lock(); - auto function = handlers[event.type]; - handlersMutex.unlock(); - function(event.data); -} - - -void EventAgregator::RegisterListener(EventListener &listener) { - listenersMutex.lock(); - //LOG(WARNING) << "Registered handler " << &listener; - listeners.push_back(&listener); - listenersMutex.unlock(); -} - -void EventAgregator::UnregisterListener(EventListener &listener) { - listenersMutex.lock(); - //LOG(WARNING) << "Unregistered handler " << &listener; - listeners.erase(std::find(listeners.begin(), listeners.end(), &listener)); - listenersMutex.unlock(); -} - -void EventAgregator::PushEvent(EventType type, EventData data) { - Event event; - event.type = type; - event.data = data; - queueMutex.lock(); - eventsToHandle.push(event); - queueMutex.unlock(); - if (!isStarted) { - isStarted = true; - std::thread(&EventAgregator::EventHandlingLoop).detach(); - } -} - -void EventAgregator::DirectEventCall(EventType type, EventData data) -{ - Event event {type, data}; - listenersMutex.lock(); - for (auto &listener : listeners) { - listenersMutex.unlock(); - listener->DirectCall(event); - listenersMutex.lock(); - } - listenersMutex.unlock(); -} - -void EventAgregator::EventHandlingLoop() { - LoopExecutionTimeController timer(std::chrono::milliseconds(5)); - while (true) { - queueMutex.lock(); - if (!eventsToHandle.empty()) { - auto queue = std::move(eventsToHandle); - queueMutex.unlock(); - - while (!queue.empty()) { - auto event = queue.front(); - listenersMutex.lock(); - for (auto &listener : listeners) { - listener->PushEvent(event); - } - listenersMutex.unlock(); - queue.pop(); - } - - queueMutex.lock(); - } - queueMutex.unlock(); - timer.Update(); - } -} \ No newline at end of file -- cgit v1.2.3