From: Leon de Rooij <leon@scarlet-internet.nl>
Date: Wed, 22 Apr 2009 13:40:58 +0000 (+0200)
Subject: freeswitch plugin: Added initial pthread stuff
X-Git-Url: https://git.octo.it/?p=collectd.git;a=commitdiff_plain;h=73ec178272aca3c471e58a6799dbae7bb41f75f5

freeswitch plugin: Added initial pthread stuff
---

diff --git a/src/freeswitch.c b/src/freeswitch.c
index 27a7d9f3..efab9751 100644
--- a/src/freeswitch.c
+++ b/src/freeswitch.c
@@ -26,6 +26,7 @@
 /*
 #include "utils_match.h"
 */
+#include <pthread.h>
 #include <esl.h>
 
 #define FREESWITCH_DEF_HOST "127.0.0.1"
@@ -46,6 +47,9 @@ typedef struct profilename
 	struct profilename *next;
 } profilename_t;
 
+static pthread_t esl_thread;
+static int esl_thread_init = 0;
+
 // static profilename_t *first_profilename = NULL;
 static char *freeswitch_host = NULL;
 static char freeswitch_port[16];
@@ -140,8 +144,44 @@ static int freeswitch_config (const char *key, const char *value)
         return (0);
 } /* int freeswitch_config */
 
+static void *esl_child_loop (void __attribute__((unused)) *dummy)
+{
+
+	DEBUG ("child is exiting");
+
+	esl_thread_init = 0;
+	pthread_exit (NULL);
+
+	return (NULL);
+} /* void *esl_child_loop */
+
 static int freeswitch_init (void)
 {
+	/* clean up an old thread */
+	int status;
+
+/*
+        pthread_mutex_lock (&traffic_mutex);
+        tr_queries   = 0;
+        tr_responses = 0;
+        pthread_mutex_unlock (&traffic_mutex);
+*/
+
+	if (esl_thread_init != 0)
+		return (-1);
+
+	status = pthread_create (&esl_thread, NULL, esl_child_loop,
+			(void *) 0);
+	if (status != 0)
+	{
+		char errbuf[1024];
+		ERROR ("freeswitch plugin: pthread_create failed: %s",
+			sstrerror (errno, errbuf, sizeof (errbuf)));
+		return (-1);
+	}
+
+	esl_thread_init = 1;
+
 	return(0);
 } /* int freeswitch_init */