summaryrefslogtreecommitdiffstats
path: root/omfwd.c
diff options
context:
space:
mode:
Diffstat (limited to 'omfwd.c')
-rw-r--r--omfwd.c32
1 files changed, 6 insertions, 26 deletions
diff --git a/omfwd.c b/omfwd.c
index 4c9b75f8..fab95155 100644
--- a/omfwd.c
+++ b/omfwd.c
@@ -1,4 +1,3 @@
-// TODO: we currently leak the send socket!!! -- rgerhards, 2007-12-26
/* omfwd.c
* This is the implementation of the build-in forwarding output module.
*
@@ -166,6 +165,12 @@ CODESTARTfreeInstance
gss_base_service_name = NULL;
}
# endif
+
+ /* final cleanup */
+ if(pData->sock >= 0)
+ close(pData->sock);
+ if(pData->pSockArray != NULL)
+ closeUDPListenSockets(pData->pSockArray);
ENDfreeInstance
@@ -222,31 +227,6 @@ static rsRetVal UDPSend(instanceData *pData, char *msg, size_t len)
return iRet;
}
-/* Initialize UDP sockets (for sender)
- * This is done once per selector line, if not yet initialized.
- * TODO: Ipv4/v6 settings!
- */
-static rsRetVal UDPSendCreateSocket(int **ppSockArray)
-{
- DEFiRet;
-
- assert(ppSockArray != NULL);
-#if 0
-dbgprintf("ppSockArray %lx, %lx\n", ppSockArray, *ppSockArray);
- ppSockArray = (int *) malloc(sizeof(int) * 2);
-dbgprintf("ppSockArray %lx, %lx, %lx\n", ppSockArray, *ppSockArray, *ppSockArray[0]);
- *ppSockArray[0] = 1;
-dbgprintf("ppSockArray %lx, %lx, %lx\n", ppSockArray, *ppSockArray, *ppSockArray[0]);
- (*ppSockArray)[1] = socket(PF_INET, SOCK_DGRAM, 0);
-dbgprintf("UDPSendCreateSocket returns %d\n", *ppSockArray[1]);
-#endif
-
-// *ppSockArray = create_udp_socket(pData->f_hname, NULL, 0));
-
- return iRet;
-}
-
-
/* CODE FOR SENDING TCP MESSAGES */
/* Initialize TCP sockets (for sender)