improved session recovery when outbound tcp connection breaks, reduces

    probability of message loss at the price of a highly unlikely potential
    (single) message duplication

1 files changed, 2 insertions, 1 deletions

diff --git a/omfwd.c b/omfwd.c
index f036f173..00a3c8ed 100644
--- a/omfwd.c
+++ b/omfwd.c
@@ -259,12 +259,13 @@ static rsRetVal TCPSendFrame(void *pvData, char *msg, size_t len)
  */
 static rsRetVal TCPSendPrepRetry(void *pvData)
 {
+	DEFiRet;
 	instanceData *pData = (instanceData *) pvData;
 
 	assert(pData != NULL);
 	close(pData->sock);
 	pData->sock = -1;
-	return RS_RET_OK;
+	RETiRet;
 }