[GNUnet-SVN] r21106 - gnunet-java/src/org/gnunet/statistics

[gnunet]

Author: dold
Date: 2012-04-23 10:25:19 +0200 (Mon, 23 Apr 2012)
New Revision: 21106

Modified:
   gnunet-java/src/org/gnunet/statistics/Statistics.java
Log:
fix


Modified: gnunet-java/src/org/gnunet/statistics/Statistics.java
===================================================================
--- gnunet-java/src/org/gnunet/statistics/Statistics.java       2012-04-23 
08:17:53 UTC (rev 21105)
+++ gnunet-java/src/org/gnunet/statistics/Statistics.java       2012-04-23 
08:25:19 UTC (rev 21106)
@@ -115,6 +115,7 @@
 
         @Override
         public void transmit(Connection.MessageSink sink) {
+            currentTransmit = null;
             if (sink == null) {
                 logger.error("unable to connect to statistics service");
                 return;
@@ -126,6 +127,8 @@
             sink.send(rm);
 
             receiveHandle = client.receive(deadline.getRemaining(), new 
GetResponseHandler());
+
+            handleNextRequest();
         }
 
         @Override
@@ -145,12 +148,16 @@
 
         @Override
         public void transmit(Connection.MessageSink sink) {
+            currentTransmit = null;
+
             SetMessage sm = new SetMessage();
             sm.statisticName = name;
             sm.subsystemName = subsystem;
             sm.value = value;
             sm.flags = flags;
             sink.send(sm);
+
+            handleNextRequest();
         }
 
         @Override
@@ -175,7 +182,7 @@
      * Retrieve values from statistics.
      *
      * @param timeout   time after we give up and call receiver.onTimeout
-     * @param subsystem name of the subsistem the statistics value belongs to
+     * @param subsystem name of the subsystem the statistics value belongs to
      * @param name      name of the statistics value belongs to
      * @param receiver  callback
      * @return handle to cancel the request
@@ -211,6 +218,7 @@
             return;
         }
 
+        logger.debug("handling request");
         currentTransmit = 
client.notifyTransmitReady(request.deadline.getRemaining(), true, 0, request);
     }