From 5c686c8adcc473cbdbb14e4b2d736f9123210ee6 Mon Sep 17 00:00:00 2001
From: Rainer Gerhards <rgerhards@adiscon.com>
Date: Thu, 24 Jan 2008 17:55:09 +0000
Subject: redesigned queue to utilize helper classes for threading support.
 This is     finally in a running state for regular (non disk-assisted)
 queues, with     a minor nit at shutdown. So I can finally commit the work
 again to     CVS...

---
 threads.c | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

(limited to 'threads.c')

diff --git a/threads.c b/threads.c
index 8ce5515d..c7b5f4e4 100644
--- a/threads.c
+++ b/threads.c
@@ -143,6 +143,7 @@ static void* thrdStarter(void *arg)
 	iRet = pThis->pUsrThrdMain(pThis);
 
 	dbgprintf("thrdStarter: usrThrdMain 0x%lx returned with iRet %d, exiting now.\n", (unsigned long) pThis->thrdID, iRet);
+	ENDfunc
 	pthread_exit(0);
 }
 
@@ -166,7 +167,7 @@ rsRetVal thrdCreate(rsRetVal (*thrdMain)(thrdInfo_t*), rsRetVal(*afterRun)(thrdI
 	CHKiRet(llAppend(&llThrds, NULL, pThis));
 
 finalize_it:
-	return iRet;
+	RETiRet;
 }
 
 
@@ -195,7 +196,7 @@ rsRetVal thrdInit(void)
 	sigAct.sa_handler = sigusr2Dummy;
 	sigaction(SIGUSR2, &sigAct, NULL);
 
-	return iRet;
+	RETiRet;
 }
 
 
@@ -208,7 +209,7 @@ rsRetVal thrdExit(void)
 
 	iRet = llDestroy(&llThrds);
 
-	return iRet;
+	RETiRet;
 }
 
 
@@ -232,7 +233,7 @@ thrdSleep(thrdInfo_t *pThis, int iSeconds, int iuSeconds)
 	select(1, NULL, NULL, NULL, &tvSelectTimeout);
 	if(pThis->bShallStop)
 		iRet = RS_RET_TERMINATE_NOW;
-	return iRet;
+	RETiRet;
 }
 
 
-- 
cgit