From: Christian Grothoff Date: Fri, 26 Feb 2010 11:55:36 +0000 (+0000) Subject: fix X-Git-Tag: initial-import-from-subversion-38251~22604 X-Git-Url: https://git.librecmc.org/?a=commitdiff_plain;h=a66d1289f9f6ff900a3b18ea931ba1fb45b7b302;p=oweals%2Fgnunet.git fix --- diff --git a/src/fs/fs_test_lib_data.conf b/src/fs/fs_test_lib_data.conf index 7ca0166a1..e53e8a90c 100644 --- a/src/fs/fs_test_lib_data.conf +++ b/src/fs/fs_test_lib_data.conf @@ -47,7 +47,7 @@ PORT = 43471 HOSTNAME = localhost DEBUG = YES PREFIX = valgrind --tool=memcheck --leak-check=yes -#BINARY = /home/grothoff/bin/gnunet-service-fs +BINARY = /home/grothoff/bin/gnunet-service-fs #PREFIX = xterm -e gdb -x cmd --args [testing] diff --git a/src/fs/gnunet-service-fs.c b/src/fs/gnunet-service-fs.c index 926284123..27ab420a8 100644 --- a/src/fs/gnunet-service-fs.c +++ b/src/fs/gnunet-service-fs.c @@ -78,7 +78,7 @@ typedef void (*TransmissionContinuation)(void * cls, /** - * Information we keep for each pending reply. The + * Information we keep for each pending message (GET/PUT). The * actual message follows at the end of this struct. */ struct PendingMessage @@ -842,7 +842,7 @@ handle_client_disconnect (void *cls, struct ClientResponseMessage *creply; if (client == NULL) - return; /* huh? is this allowed? */ + return; prev = NULL; pos = client_list; while ( (NULL != pos) && @@ -1463,7 +1463,7 @@ transmit_reply_continuation (void *cls, GNUNET_PEER_Id tpid) { struct PendingRequest *pr = cls; - + switch (pr->type) { case GNUNET_DATASTORE_BLOCKTYPE_DBLOCK: @@ -1955,13 +1955,13 @@ process_local_reply (void *cls, GNUNET_HashCode mhash; GNUNET_HashCode query; - pr->drq = NULL; if (NULL == key) { #if DEBUG_FS GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Done processing local replies, forwarding request to other peers.\n"); #endif + pr->drq = NULL; if (pr->client_request_list != NULL) GNUNET_SERVER_receive_done (pr->client_request_list->client_list->client, GNUNET_YES);