lock

1 files changed, 12 insertions, 0 deletions

diff --git a/src/plugins/stats/functions.c b/src/plugins/stats/functions.c
index d4695ddd..1a325082 100644
--- a/src/plugins/stats/functions.c
+++ b/src/plugins/stats/functions.c
@@ -34,6 +34,8 @@ static unsigned int lsv_size;
 
 static GNUNET_TCP_SOCKET * sock;
 
+static Mutex lock;
+
 static int getStatValue(long long * value,
                         long long * lvalue,
                         cron_t * dtime,
@@ -68,9 +70,11 @@ static int getConnectedNodesStat(const void * closure,
   char * cmh;
   long cval;
 
+  MUTEX_LOCK(&lock);
   cmh = getConfigurationOptionValue(sock,
                                     "gnunetd",
                                     "connection-max-hosts");
+  MUTEX_UNLOCK(&lock);
   if (cmh == NULL)
     return SYSERR;
   cval = atol(cmh);
@@ -155,9 +159,11 @@ static int getTrafficRecvStats(const void * closure,
     lqueries = 0;
   }  
   FREE(buffer);
+  MUTEX_LOCK(&lock);
   available = getConfigurationOptionValue(sock,
                                           "LOAD",
                                           "MAXNETDOWNBPSTOTAL");
+  MUTEX_UNLOCK(&lock);
   if (available == NULL)
     return SYSERR; 
   band = atol(available) * dtime / cronSECONDS;
@@ -241,9 +247,11 @@ static int getTrafficSendStats(const void * closure,
     lqueries = 0;  
   }
   FREE(buffer);
+  MUTEX_LOCK(&lock);
   available = getConfigurationOptionValue(sock,
                                           "LOAD",
                                           "MAXNETUPBPSTOTAL");
+  MUTEX_UNLOCK(&lock);
   if (available == NULL)
     return SYSERR;
   band = atol(available) * dtime / cronSECONDS;
@@ -310,10 +318,12 @@ static void updateStatValues(void * unused) {
 
   cronTime(&now);
   delta = now - lastUpdate;
+  MUTEX_LOCK(&lock);
   if (OK == requestStatistics(sock,
                               &statsProcessor,
                               &delta)) 
     lastUpdate = now;  
+  MUTEX_UNLOCK(&lock);
 }
 
 
@@ -369,6 +379,7 @@ void init_functions() {
   if (UPDATE_INTERVAL == 0)
     UPDATE_INTERVAL = 30 * cronSECONDS;
   sock = getClientSocket();
+  MUTEX_CREATE(&lock);
   addCronJob(&updateStatValues,
              UPDATE_INTERVAL,
              UPDATE_INTERVAL,
@@ -379,6 +390,7 @@ void done_functions() {
   delCronJob(&updateStatValues,
              UPDATE_INTERVAL,
              NULL);
+  MUTEX_DESTROY(&lock);
   releaseClientSocket(sock);
   sock = NULL;
 }