[GNUnet-SVN] r6786 - GNUnet/src/applications/fs/gap

[gnunet]

Author: grothoff
Date: 2008-05-06 18:30:24 -0600 (Tue, 06 May 2008)
New Revision: 6786

Modified:
   GNUnet/src/applications/fs/gap/gap.c
Log:
fix

Modified: GNUnet/src/applications/fs/gap/gap.c
===================================================================
--- GNUnet/src/applications/fs/gap/gap.c        2008-05-06 12:44:07 UTC (rev 
6785)
+++ GNUnet/src/applications/fs/gap/gap.c        2008-05-07 00:30:24 UTC (rev 
6786)
@@ -467,7 +467,8 @@
           GNUNET_FS_PT_resolve (rl->response_target, &target);
           GNUNET_GE_ASSERT (NULL, block_count <= MAX_ENTRIES_PER_SLOT);
           blocked[block_count++] = rl->response_target;
-          /* queue response */
+         GNUNET_FS_PT_change_rc (rl->response_target, 1);
+         /* queue response */
           msg = GNUNET_malloc (sizeof (P2P_gap_reply_MESSAGE) + size);
           msg->header.type = htons (GNUNET_P2P_PROTO_GAP_RESULT);
           msg->header.size = htons (sizeof (P2P_gap_reply_MESSAGE) + size);
@@ -512,7 +513,7 @@
     GNUNET_FS_MIGRATION_inject (primary_query,
                                 size, data, expiration, block_count, blocked);
   GNUNET_mutex_unlock (GNUNET_FS_lock);
-  GNUNET_FS_PT_change_rc (rid, -1);
+  GNUNET_FS_PT_decrement_rcs(blocked, block_count); /* includes rid */
   return value;
 }
 
@@ -691,7 +692,8 @@
 
   GNUNET_cron_del_job (coreAPI->cron,
                        &have_more_processor, HAVE_MORE_FREQUENCY, NULL);
-
+  GNUNET_cron_stop (cron);
+  GNUNET_cron_destroy (cron);
   for (i = 0; i < table_size; i++)
     {
       while (NULL != (rl = table[i]))
@@ -709,8 +711,6 @@
                     (&cleanup_on_peer_disconnect, NULL));
   coreAPI->service_release (datastore);
   datastore = NULL;
-  GNUNET_cron_stop (cron);
-  GNUNET_cron_destroy (cron);
   if (stats != NULL)
     {
       coreAPI->service_release (stats);