From da4c1fcad194f4f3f399f6a4a731df34567c95ef Mon Sep 17 00:00:00 2001
From: David Robillard <d@drobilla.net>
Date: Thu, 16 Aug 2012 00:59:35 +0000
Subject: Remove Raul::Slave class. Merge Thread::stop() and Thread::join().
 Clean thread shut down without the use of pthread_cancel().

git-svn-id: http://svn.drobilla.net/lad/trunk/ingen@4708 a436a847-0d15-0410-975c-d299462d15a1
---
 src/server/PreProcessor.cpp | 25 ++++++++++++++-----------
 1 file changed, 14 insertions(+), 11 deletions(-)

(limited to 'src/server/PreProcessor.cpp')

diff --git a/src/server/PreProcessor.cpp b/src/server/PreProcessor.cpp
index 9db13fd1..13746113 100644
--- a/src/server/PreProcessor.cpp
+++ b/src/server/PreProcessor.cpp
@@ -26,14 +26,14 @@ namespace Ingen {
 namespace Server {
 
 PreProcessor::PreProcessor()
-	: Raul::Slave("PreProcessor")
+	: Raul::Thread("PreProcessor")
+	, _sem(0)
 {
 	start();
 }
 
 PreProcessor::~PreProcessor()
 {
-	stop();
 }
 
 void
@@ -61,7 +61,7 @@ PreProcessor::event(Event* const ev)
 		_prepared_back = ev;
 	}
 
-	whip();
+	_sem.post();
 }
 
 unsigned
@@ -110,18 +110,21 @@ PreProcessor::process(ProcessContext& context, PostProcessor& dest, bool limit)
 
 /** Pre-process a single event */
 void
-PreProcessor::_whipped()
+PreProcessor::_run()
 {
 	ThreadManager::set_flag(THREAD_PRE_PROCESS);
-	Event* ev = _prepared_back.get();
-	if (!ev)
-		return;
+	while (_sem.wait() && !_exit_flag) {
+		Event* const ev = _prepared_back.get();
+		if (!ev) {
+			return;
+		}
 
-	assert(!ev->is_prepared());
-	ev->pre_process();
-	assert(ev->is_prepared());
+		assert(!ev->is_prepared());
+		ev->pre_process();
+		assert(ev->is_prepared());
 
-	_prepared_back = (Event*)ev->next();
+		_prepared_back = (Event*)ev->next();
+	}
 }
 
 } // namespace Server
-- 
cgit v1.2.1