[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r6786 - GNUnet/src/applications/fs/gap
From: |
gnunet |
Subject: |
[GNUnet-SVN] r6786 - GNUnet/src/applications/fs/gap |
Date: |
Tue, 6 May 2008 18:30:24 -0600 (MDT) |
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);
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r6786 - GNUnet/src/applications/fs/gap,
gnunet <=