4 files changed, 135 insertions, 0 deletions
diff --git a/src/uscxml/concurrency/eventqueue/DelayedEventQueue.cpp b/src/uscxml/concurrency/DelayedEventQueue.cpp
index 642c4a0..642c4a0 100644
--- a/src/uscxml/concurrency/eventqueue/DelayedEventQueue.cpp
+++ b/src/uscxml/concurrency/DelayedEventQueue.cpp
diff --git a/src/uscxml/concurrency/eventqueue/DelayedEventQueue.h b/src/uscxml/concurrency/DelayedEventQueue.h
index 2248c47..2248c47 100644
--- a/src/uscxml/concurrency/eventqueue/DelayedEventQueue.h
+++ b/src/uscxml/concurrency/DelayedEventQueue.h
diff --git a/src/uscxml/concurrency/EventBase.cpp b/src/uscxml/concurrency/EventBase.cpp
new file mode 100644
index 0000000..b5c1308
--- /dev/null
+++ b/src/uscxml/concurrency/EventBase.cpp
@@ -0,0 +1,74 @@
+/**
+ *  @file
+ *  @author     2012-2014 Stefan Radomski (stefan.radomski@cs.tu-darmstadt.de)
+ *  @copyright  Simplified BSD
+ *
+ *  @cond
+ *  This program is free software: you can redistribute it and/or modify
+ *  it under the terms of the FreeBSD license as published by the FreeBSD
+ *  project.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ *  You should have received a copy of the FreeBSD license along with this
+ *  program. If not, see <http://www.opensource.org/licenses/bsd-license>.
+ *  @endcond
+ */
+
+#include "EventBase.h"
+
+namespace uscxml {
+
+std::map<std::string, boost::weak_ptr<EventBase> > EventBase::_eventBases;
+tthread::recursive_mutex EventBase::_instanceMutex;
+
+boost::shared_ptr<EventBase> EventBase::get(const std::string& name) {
+	tthread::lock_guard<tthread::recursive_mutex> lock(_instanceMutex);
+
+	std::map<std::string, boost::weak_ptr<EventBase> >::const_iterator instIter = _eventBases.begin();
+	while(instIter != _eventBases.end()) {
+		if (!instIter->second.lock()) {
+			_eventBases.erase(instIter++);
+		} else {
+			instIter++;
+		}
+	}
+
+	instIter = _eventBases.find(name);
+	boost::shared_ptr<EventBase> instance = instIter->second.lock();
+	if (instance)
+		return instance;
+
+	instance = boost::shared_ptr<EventBase>(new EventBase());
+	_eventBases.insert(std::make_pair(name, instance));
+
+	return instance;
+}
+
+EventBase::EventBase() {
+	base = event_base_new();
+	_isStarted = true;
+	_thread = new tthread::thread(EventBase::run, this);
+}
+
+void EventBase::run(void* arg) {
+	EventBase* INSTANCE = (EventBase*)arg;
+	int result;
+
+	while(INSTANCE->_isStarted) {
+		result = event_base_loop(INSTANCE->base, EVLOOP_NO_EXIT_ON_EMPTY);
+		(void)result;
+	}
+}
+
+EventBase::~EventBase() {
+	_isStarted = false;
+	event_base_loopbreak(base);
+	_thread->join();
+	event_base_free(base);
+	delete _thread;
+}
+
+}
+\ No newline at end of file
diff --git a/src/uscxml/concurrency/EventBase.h b/src/uscxml/concurrency/EventBase.h
new file mode 100644
index 0000000..22bd664
--- /dev/null
+++ b/src/uscxml/concurrency/EventBase.h
@@ -0,0 +1,61 @@
+/**
+ *  @file
+ *  @author     2012-2014 Stefan Radomski (stefan.radomski@cs.tu-darmstadt.de)
+ *  @copyright  Simplified BSD
+ *
+ *  @cond
+ *  This program is free software: you can redistribute it and/or modify
+ *  it under the terms of the FreeBSD license as published by the FreeBSD
+ *  project.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ *  You should have received a copy of the FreeBSD license along with this
+ *  program. If not, see <http://www.opensource.org/licenses/bsd-license>.
+ *  @endcond
+ */
+
+#ifndef EVENTBASE_H_C479DA74
+#define EVENTBASE_H_C479DA74
+
+#include "uscxml/Common.h"
+#include "uscxml/concurrency/tinythread.h"
+
+extern "C" {
+#include <event2/event.h>
+#include <event2/buffer.h>
+#include <event2/bufferevent.h>
+}
+
+#include <boost/shared_ptr.hpp>
+#include <boost/weak_ptr.hpp>
+#include <map>
+#include <string>
+
+namespace uscxml {
+
+class USCXML_API EventBase {
+public:
+	EventBase();
+	virtual ~EventBase();
+
+	static boost::shared_ptr<EventBase> get(const std::string& name);
+	struct event_base* base;
+
+protected:
+
+	static void run(void*);
+
+	tthread::thread* _thread;
+	bool _isStarted;
+
+	static std::map<std::string, boost::weak_ptr<EventBase> > _eventBases;
+	static tthread::recursive_mutex _instanceMutex;
+
+};
+
+}
+
+#endif /* end of include guard: EVENTBASE_H_C479DA74 */