gnunet-svn
[Top][All Lists]
Advanced

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

[GNUnet-SVN] r25963 - gnunet/src/testbed


From: gnunet
Subject: [GNUnet-SVN] r25963 - gnunet/src/testbed
Date: Thu, 31 Jan 2013 13:08:58 +0100

Author: harsha
Date: 2013-01-31 13:08:58 +0100 (Thu, 31 Jan 2013)
New Revision: 25963

Modified:
   gnunet/src/testbed/gnunet-service-testbed_hc.c
Log:
- fixes

Modified: gnunet/src/testbed/gnunet-service-testbed_hc.c
===================================================================
--- gnunet/src/testbed/gnunet-service-testbed_hc.c      2013-01-31 12:02:43 UTC 
(rev 25962)
+++ gnunet/src/testbed/gnunet-service-testbed_hc.c      2013-01-31 12:08:58 UTC 
(rev 25963)
@@ -324,7 +324,11 @@
      in cache; we will however disconnect the core and transport handles */
   GNUNET_assert (0 == entry->demand);
   if ((NULL != entry->next) || (NULL != entry->prev))
+  {
+    GNUNET_assert (0 < lru_cache_size);
     GNUNET_CONTAINER_DLL_remove (lru_cache_head, lru_cache_tail, entry);
+    lru_cache_size--;
+  }
   while (NULL != (ctxt = entry->nctxt_qhead))
   {
     GNUNET_CONTAINER_DLL_remove (entry->nctxt_qhead, entry->nctxt_qtail, ctxt);
@@ -648,7 +652,11 @@
   {
     GNUNET_assert (NULL != entry);
     if (0 == entry->demand)
+    {
+      GNUNET_assert (0 < lru_cache_size);
       GNUNET_CONTAINER_DLL_remove (lru_cache_head, lru_cache_tail, entry);
+      lru_cache_size--;
+    }
   }
   if (NULL == entry)
     entry = add_entry (&key, peer_id);
@@ -791,19 +799,21 @@
     GNUNET_CONTAINER_DLL_remove (entry->nctxt_qhead, entry->nctxt_qtail, 
cgh->nctxt);
     GNUNET_free (cgh->nctxt);
   }
-  
+  GNUNET_free (cgh);  
   if (0 == entry->demand)
   {
     GNUNET_CONTAINER_DLL_insert_tail (lru_cache_head, lru_cache_tail, entry);
+    lru_cache_size++;
     if (lru_cache_size > lru_cache_threshold_size)
       cache_remove (lru_cache_head);
   }
   else
   {
-    if (GNUNET_NO == entry->cgh_qhead->notify_called)
+    struct GSTCacheGetHandle *cgh2;
+
+    if (NULL != (cgh2 = search_suitable_cgh (entry, entry->cgh_qhead)))
       entry->notify_task = GNUNET_SCHEDULER_add_now (&call_cgh_cb, entry);
   }
-  GNUNET_free (cgh);
 }
 
 




reply via email to

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