gnunet-svn
[Top][All Lists]
Advanced

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

[GNUnet-SVN] r10426 - gnunet/src/fs


From: gnunet
Subject: [GNUnet-SVN] r10426 - gnunet/src/fs
Date: Tue, 23 Feb 2010 16:03:25 +0100

Author: grothoff
Date: 2010-02-23 16:03:25 +0100 (Tue, 23 Feb 2010)
New Revision: 10426

Modified:
   gnunet/src/fs/gnunet-service-fs.c
Log:
fix

Modified: gnunet/src/fs/gnunet-service-fs.c
===================================================================
--- gnunet/src/fs/gnunet-service-fs.c   2010-02-23 14:59:29 UTC (rev 10425)
+++ gnunet/src/fs/gnunet-service-fs.c   2010-02-23 15:03:25 UTC (rev 10426)
@@ -1687,12 +1687,14 @@
   GNUNET_HashCode mhash;
   size_t msize;
   uint32_t prio;
+  int do_remove;
 
 #if DEBUG_FS
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Matched result for query `%s' with pending request\n",
              GNUNET_h2s (key));
 #endif  
+  do_remove = GNUNET_NO;
   GNUNET_CRYPTO_hash (prq->data,
                      prq->size,
                      &chash);
@@ -1708,10 +1710,7 @@
          GNUNET_FS_drq_get_cancel (pr->drq);
          pr->drq = NULL;
        }
-      GNUNET_break (GNUNET_YES ==
-                   GNUNET_CONTAINER_multihashmap_remove (query_request_map,
-                                                         key,
-                                                         pr));
+      do_remove = GNUNET_YES;
       break;
     case GNUNET_DATASTORE_BLOCKTYPE_SBLOCK:
       if (0 != memcmp (pr->namespace,
@@ -1810,8 +1809,12 @@
       memcpy (&pm[1], prq->data, prq->size);
       add_to_pending_messages_for_peer (cp, reply, pr);
     }
+  if (GNUNET_YES == do_remove)
+    GNUNET_break (GNUNET_YES ==
+                 GNUNET_CONTAINER_multihashmap_remove (query_request_map,
+                                                       key,
+                                                       pr));
 
-
   // FIXME: implement hot-path routing statistics keeping!
   return GNUNET_YES;
 }





reply via email to

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