summaryrefslogtreecommitdiffstats
path: root/src/server
diff options
context:
space:
mode:
Diffstat (limited to 'src/server')
-rw-r--r--src/server/EventSource.cpp1
-rw-r--r--src/server/PostProcessor.cpp4
2 files changed, 4 insertions, 1 deletions
diff --git a/src/server/EventSource.cpp b/src/server/EventSource.cpp
index abbd33dd..a8eb3ec4 100644
--- a/src/server/EventSource.cpp
+++ b/src/server/EventSource.cpp
@@ -98,6 +98,7 @@ EventSource::process(PostProcessor& dest, ProcessContext& context, bool limit)
if (num_events_processed > 0) {
Event* next = (Event*)last->next();
last->next(NULL);
+ assert(!last->next());
dest.append(_head.get(), last);
_head = next;
if (!next)
diff --git a/src/server/PostProcessor.cpp b/src/server/PostProcessor.cpp
index 316c6f0f..3a8ee612 100644
--- a/src/server/PostProcessor.cpp
+++ b/src/server/PostProcessor.cpp
@@ -20,10 +20,11 @@
#include "Driver.hpp"
#include "Engine.hpp"
+#include "Event.hpp"
#include "Notification.hpp"
#include "PostProcessor.hpp"
#include "ProcessContext.hpp"
-#include "Event.hpp"
+#include "ThreadManager.hpp"
using namespace std;
using namespace Raul;
@@ -44,6 +45,7 @@ PostProcessor::~PostProcessor()
void
PostProcessor::append(Event* first, Event* last)
{
+ ThreadManager::assert_thread(THREAD_PROCESS);
assert(first);
assert(last);
assert(!last->next());