From 5c686c8adcc473cbdbb14e4b2d736f9123210ee6 Mon Sep 17 00:00:00 2001 From: Rainer Gerhards 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... --- omfwd.c | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'omfwd.c') diff --git a/omfwd.c b/omfwd.c index a4a546df..66b8a055 100644 --- a/omfwd.c +++ b/omfwd.c @@ -201,7 +201,7 @@ static rsRetVal UDPSend(instanceData *pData, char *msg, size_t len) } } - return iRet; + RETiRet; } /* CODE FOR SENDING TCP MESSAGES */ @@ -241,7 +241,7 @@ static rsRetVal TCPSendFrame(void *pvData, char *msg, size_t len) /* TODO: we need to revisit this code -- rgerhards, 2007-12-28 */ } - return iRet; + RETiRet; } @@ -274,7 +274,7 @@ static rsRetVal TCPSendInit(void *pvData) iRet = RS_RET_TCP_SOCKCREATE_ERR; } - return iRet; + RETiRet; } @@ -322,7 +322,7 @@ static rsRetVal doTryResume(instanceData *pData) break; } - return iRet; + RETiRet; } -- cgit