From f942405184c2d6067fb5303b58a225edf7e452b1 Mon Sep 17 00:00:00 2001
From: LaG1924 <12997935+LaG1924@users.noreply.github.com>
Date: Sat, 29 Jul 2017 19:55:16 +0500
Subject: 2017-07-29

---
 old/core/Event.cpp | 76 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 76 insertions(+)
 create mode 100644 old/core/Event.cpp

(limited to 'old/core/Event.cpp')

diff --git a/old/core/Event.cpp b/old/core/Event.cpp
new file mode 100644
index 0000000..3b2cc7f
--- /dev/null
+++ b/old/core/Event.cpp
@@ -0,0 +1,76 @@
+#include "Event.hpp"
+#include <easylogging++.h>
+
+std::queue <Event> EventAgregator::eventsToHandle;
+std::mutex EventAgregator::queueMutex;
+bool EventAgregator::isStarted = false;
+std::vector<EventListener*> EventAgregator::listeners;
+std::mutex EventAgregator::listenersMutex;
+
+void EventAgregator::EventHandlingLoop() {
+    while (true) {
+        queueMutex.lock();
+        if (!eventsToHandle.empty()) {
+            auto queue = eventsToHandle;
+            while (!eventsToHandle.empty())
+                eventsToHandle.pop();
+            queueMutex.unlock();
+
+            while (!queue.empty()) {
+                auto event = queue.front();
+                listenersMutex.lock();
+                for (auto& listener : listeners) {
+                    LOG(INFO)<<"Listener notified about event";
+                    listener->PushEvent(event);
+                }
+                listenersMutex.unlock();
+                queue.pop();
+            }
+
+            queueMutex.lock();
+        }
+        queueMutex.unlock();
+    }
+}
+
+void EventAgregator::RegisterListener(EventListener &listener) {
+    listenersMutex.lock();
+    LOG(INFO)<<"Registered handler "<<&listener;
+    listeners.push_back(&listener);
+    listenersMutex.unlock();
+}
+
+void EventAgregator::UnregisterListener(EventListener &listener) {
+    listenersMutex.lock();
+    LOG(INFO)<<"Unregistered handler "<<&listener;
+    listeners.erase(std::find(listeners.begin(), listeners.end(), &listener));
+    listenersMutex.unlock();
+}
+
+
+
+EventListener::EventListener() {
+    EventAgregator::RegisterListener(*this);
+}
+
+EventListener::~EventListener() {
+    EventAgregator::UnregisterListener(*this);
+}
+
+void EventListener::PushEvent(Event event) {
+    eventsMutex.lock();
+    LOG(INFO)<<"Pushed event to queue";
+    events.push(event);
+    eventsMutex.unlock();
+}
+
+/*void EventListener::RegisterHandler(EventType type, std::function<void(void*)> handler) {
+    handlers[type] = handler;
+}*/
+
+bool EventListener::IsEventsQueueIsNotEmpty() {
+    eventsMutex.lock();
+    bool value = !events.empty();
+    eventsMutex.unlock();
+    return value;
+}
\ No newline at end of file
-- 
cgit v1.2.3