summaryrefslogtreecommitdiffstats
path: root/src/Common
diff options
context:
space:
mode:
Diffstat (limited to 'src/Common')
-rw-r--r--src/Common/ActionManager.cpp85
-rw-r--r--src/Common/ActionManager.h61
-rw-r--r--src/Common/Makefile.am12
-rw-r--r--src/Common/Makefile.in20
4 files changed, 165 insertions, 13 deletions
diff --git a/src/Common/ActionManager.cpp b/src/Common/ActionManager.cpp
new file mode 100644
index 0000000..c6c4e41
--- /dev/null
+++ b/src/Common/ActionManager.cpp
@@ -0,0 +1,85 @@
+/*
+ * ActionManager.cpp
+ *
+ * Copyright (C) 2008 Matthias Schiffer <matthias@gamezock.de>
+ *
+ * This program is free software: you can redistribute it and/or modify it
+ * under the terms of the GNU General Public License as published by the
+ * Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * 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.
+ * See the GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+#include "ActionManager.h"
+#include <Net/FdManager.h>
+
+#include <fcntl.h>
+#include <signal.h>
+
+#include <sigc++/hide.h>
+
+namespace Mad {
+namespace Common {
+
+ActionManager ActionManager::actionManager;
+
+
+void ActionManager::doInit() {
+ // TODO Error handling
+
+ pipe(notifyPipe);
+
+ fcntl(notifyPipe[0], F_SETFL, fcntl(notifyPipe[0], F_GETFL) | O_NONBLOCK);
+ fcntl(notifyPipe[1], F_SETFL, fcntl(notifyPipe[1], F_GETFL) | O_NONBLOCK);
+
+ Net::FdManager::get()->registerFd(notifyPipe[0], sigc::hide(sigc::mem_fun(this, &ActionManager::run)), POLLIN);
+}
+
+void ActionManager::doDeinit() {
+ Net::FdManager::get()->unregisterFd(notifyPipe[0]);
+
+ close(notifyPipe[0]);
+ close(notifyPipe[1]);
+}
+
+
+void ActionManager::run() {
+ while(true) {
+ sigset_t set, oldset;
+ sigfillset(&set);
+ sigprocmask(SIG_SETMASK, &set, &oldset);
+
+ if(actions.empty()) {
+ sigprocmask(SIG_SETMASK, &oldset, 0);
+ return;
+ }
+
+ sigc::slot<void> action = actions.front();
+ actions.pop();
+
+ sigprocmask(SIG_SETMASK, &oldset, 0);
+
+ action();
+ }
+}
+
+void ActionManager::add(const sigc::slot<void> &action) {
+ sigset_t set, oldset;
+ sigfillset(&set);
+ sigprocmask(SIG_SETMASK, &set, &oldset);
+
+ actions.push(action);
+ write(notifyPipe[1], "", 1);
+
+ sigprocmask(SIG_SETMASK, &oldset, 0);
+}
+
+}
+}
diff --git a/src/Common/ActionManager.h b/src/Common/ActionManager.h
new file mode 100644
index 0000000..e47652e
--- /dev/null
+++ b/src/Common/ActionManager.h
@@ -0,0 +1,61 @@
+/*
+ * ActionManager.h
+ *
+ * Copyright (C) 2008 Matthias Schiffer <matthias@gamezock.de>
+ *
+ * This program is free software: you can redistribute it and/or modify it
+ * under the terms of the GNU General Public License as published by the
+ * Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * 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.
+ * See the GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+#ifndef MAD_COMMON_ACTIONMANAGER_H_
+#define MAD_COMMON_ACTIONMANAGER_H_
+
+#include "Initializable.h"
+
+#include <queue>
+#include <unistd.h>
+
+#include <sigc++/slot.h>
+
+namespace Mad {
+namespace Common {
+
+class ActionManager : public Initializable {
+ private:
+ std::queue<sigc::slot<void> > actions;
+ int notifyPipe[2];
+
+ static ActionManager actionManager;
+
+ ActionManager() {}
+
+ protected:
+ void doInit();
+ void doDeinit();
+
+ public:
+ void run();
+ void add(const sigc::slot<void> &action);
+
+ static ActionManager *get() {
+ if(!actionManager.isInitialized())
+ actionManager.init();
+
+ return &actionManager;
+ }
+};
+
+}
+}
+
+#endif /* MAD_COMMON_ACTIONMANAGER_H_ */
diff --git a/src/Common/Makefile.am b/src/Common/Makefile.am
index e41b63b..0f2fb39 100644
--- a/src/Common/Makefile.am
+++ b/src/Common/Makefile.am
@@ -1,10 +1,12 @@
SUBDIRS = Requests RequestHandlers
noinst_LTLIBRARIES = libcommon.la
-libcommon_la_SOURCES = ConfigEntry.cpp ConfigManager.cpp Exception.cpp Initializable.cpp Logger.cpp \
- LogManager.cpp ModuleManager.cpp RequestManager.cpp SystemBackend.cpp Tokenizer.cpp
+libcommon_la_SOURCES = ActionManager.cpp ConfigEntry.cpp ConfigManager.cpp Exception.cpp Initializable.cpp \
+ Logger.cpp LogManager.cpp ModuleManager.cpp RequestManager.cpp \
+ SystemBackend.cpp Tokenizer.cpp
libcommon_la_LIBADD = Requests/librequests.la RequestHandlers/librequesthandlers.la
-noinst_HEADERS = ConfigEntry.h ConfigManager.h Configurable.h Exception.h HostInfo.h Initializable.h \
- Logger.h LoggerBase.h LogManager.h ModuleManager.h RemoteLogger.h Request.h \
- RequestBase.h RequestHandler.h RequestManager.h SystemBackend.h Tokenizer.h
+noinst_HEADERS = ActionManager.h ConfigEntry.h ConfigManager.h Configurable.h Exception.h HostInfo.h \
+ Initializable.h Logger.h LoggerBase.h LogManager.h ModuleManager.h \
+ RemoteLogger.h Request.h RequestBase.h RequestHandler.h RequestManager.h \
+ SystemBackend.h Tokenizer.h
diff --git a/src/Common/Makefile.in b/src/Common/Makefile.in
index 665d78a..e787215 100644
--- a/src/Common/Makefile.in
+++ b/src/Common/Makefile.in
@@ -51,9 +51,10 @@ CONFIG_CLEAN_FILES =
LTLIBRARIES = $(noinst_LTLIBRARIES)
libcommon_la_DEPENDENCIES = Requests/librequests.la \
RequestHandlers/librequesthandlers.la
-am_libcommon_la_OBJECTS = ConfigEntry.lo ConfigManager.lo Exception.lo \
- Initializable.lo Logger.lo LogManager.lo ModuleManager.lo \
- RequestManager.lo SystemBackend.lo Tokenizer.lo
+am_libcommon_la_OBJECTS = ActionManager.lo ConfigEntry.lo \
+ ConfigManager.lo Exception.lo Initializable.lo Logger.lo \
+ LogManager.lo ModuleManager.lo RequestManager.lo \
+ SystemBackend.lo Tokenizer.lo
libcommon_la_OBJECTS = $(am_libcommon_la_OBJECTS)
DEFAULT_INCLUDES = -I.@am__isrc@ -I$(top_builddir)
depcomp = $(SHELL) $(top_srcdir)/config/depcomp
@@ -227,13 +228,15 @@ top_builddir = @top_builddir@
top_srcdir = @top_srcdir@
SUBDIRS = Requests RequestHandlers
noinst_LTLIBRARIES = libcommon.la
-libcommon_la_SOURCES = ConfigEntry.cpp ConfigManager.cpp Exception.cpp Initializable.cpp Logger.cpp \
- LogManager.cpp ModuleManager.cpp RequestManager.cpp SystemBackend.cpp Tokenizer.cpp
+libcommon_la_SOURCES = ActionManager.cpp ConfigEntry.cpp ConfigManager.cpp Exception.cpp Initializable.cpp \
+ Logger.cpp LogManager.cpp ModuleManager.cpp RequestManager.cpp \
+ SystemBackend.cpp Tokenizer.cpp
libcommon_la_LIBADD = Requests/librequests.la RequestHandlers/librequesthandlers.la
-noinst_HEADERS = ConfigEntry.h ConfigManager.h Configurable.h Exception.h HostInfo.h Initializable.h \
- Logger.h LoggerBase.h LogManager.h ModuleManager.h RemoteLogger.h Request.h \
- RequestBase.h RequestHandler.h RequestManager.h SystemBackend.h Tokenizer.h
+noinst_HEADERS = ActionManager.h ConfigEntry.h ConfigManager.h Configurable.h Exception.h HostInfo.h \
+ Initializable.h Logger.h LoggerBase.h LogManager.h ModuleManager.h \
+ RemoteLogger.h Request.h RequestBase.h RequestHandler.h RequestManager.h \
+ SystemBackend.h Tokenizer.h
all: all-recursive
@@ -286,6 +289,7 @@ mostlyclean-compile:
distclean-compile:
-rm -f *.tab.c
+@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/ActionManager.Plo@am__quote@
@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/ConfigEntry.Plo@am__quote@
@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/ConfigManager.Plo@am__quote@
@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/Exception.Plo@am__quote@
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-23 05:53:43 +0100