[GNUnet-SVN] r1350 - gnunet-gtk/src/plugins/stats

[grothoff]

Author: grothoff
Date: 2005-07-09 07:17:25 -0700 (Sat, 09 Jul 2005)
New Revision: 1350

Modified:
   gnunet-gtk/src/plugins/stats/functions.c
Log:
lock

Modified: gnunet-gtk/src/plugins/stats/functions.c
===================================================================
--- gnunet-gtk/src/plugins/stats/functions.c    2005-07-09 14:06:45 UTC (rev 
1349)
+++ gnunet-gtk/src/plugins/stats/functions.c    2005-07-09 14:17:25 UTC (rev 
1350)
@@ -34,6 +34,8 @@
 
 static GNUNET_TCP_SOCKET * sock;
 
+static Mutex lock;
+
 static int getStatValue(long long * value,
                        long long * lvalue,
                        cron_t * dtime,
@@ -68,9 +70,11 @@
   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 @@
     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 @@
     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 @@
 
   cronTime(&now);
   delta = now - lastUpdate;
+  MUTEX_LOCK(&lock);
   if (OK == requestStatistics(sock,
                              &statsProcessor,
                              &delta)) 
     lastUpdate = now;  
+  MUTEX_UNLOCK(&lock);
 }
 
 
@@ -369,6 +379,7 @@
   if (UPDATE_INTERVAL == 0)
     UPDATE_INTERVAL = 30 * cronSECONDS;
   sock = getClientSocket();
+  MUTEX_CREATE(&lock);
   addCronJob(&updateStatValues,
             UPDATE_INTERVAL,
             UPDATE_INTERVAL,
@@ -379,6 +390,7 @@
   delCronJob(&updateStatValues,
             UPDATE_INTERVAL,
             NULL);
+  MUTEX_DESTROY(&lock);
   releaseClientSocket(sock);
   sock = NULL;
 }