gnunet-svn
[Top][All Lists]
Advanced

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[GNUnet-SVN] r9044 - gnunet/src/datastore


From: gnunet
Subject: [GNUnet-SVN] r9044 - gnunet/src/datastore
Date: Tue, 29 Sep 2009 16:15:57 -0600

Author: grothoff
Date: 2009-09-29 16:15:57 -0600 (Tue, 29 Sep 2009)
New Revision: 9044

Modified:
   gnunet/src/datastore/gnunet-service-datastore.c
   gnunet/src/datastore/test_datastore_api_management.c
Log:
bugfix

Modified: gnunet/src/datastore/gnunet-service-datastore.c
===================================================================
--- gnunet/src/datastore/gnunet-service-datastore.c     2009-09-29 21:50:36 UTC 
(rev 9043)
+++ gnunet/src/datastore/gnunet-service-datastore.c     2009-09-29 22:15:57 UTC 
(rev 9044)
@@ -899,6 +899,7 @@
                  "Empty result set for `%s' request.\n",
                  "GET");
 #endif 
+      GNUNET_SERVER_client_keep (client);
       transmit_item (client,
                     NULL, NULL, 0, NULL, 0, 0, 0, 
                     GNUNET_TIME_UNIT_ZERO_ABS, 0);

Modified: gnunet/src/datastore/test_datastore_api_management.c
===================================================================
--- gnunet/src/datastore/test_datastore_api_management.c        2009-09-29 
21:50:36 UTC (rev 9043)
+++ gnunet/src/datastore/test_datastore_api_management.c        2009-09-29 
22:15:57 UTC (rev 9044)
@@ -202,11 +202,10 @@
             expiration, uint64_t uid)
 {
   struct CpsRunContext *crc = cls;
+
   GNUNET_assert (key == NULL);
-  if (crc->i == 0)
-    {
-      crc->phase = RP_DONE;
-    }
+  if (0 == --crc->i)
+    crc->phase = RP_DONE;
   GNUNET_SCHEDULER_add_continuation (crc->sched,
                                     GNUNET_NO,
                                     &run_continuation,
@@ -284,6 +283,7 @@
                            TIMEOUT);
       break;
     case RP_DONE:
+      GNUNET_assert (0 == crc->i);
 #if VERBOSE
       GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                  "Finished, disconnecting\n");





reply via email to

[Prev in Thread] Current Thread [Next in Thread]