aboutsummaryrefslogtreecommitdiff
path: root/src/dht
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-03-11 16:58:27 +0000
committerChristian Grothoff <christian@grothoff.org>2011-03-11 16:58:27 +0000
commit562b33143ee9fa431a68ea6741e4feb3ba388f83 (patch)
tree6318eb2c56ff76730708a4791804842c63cf1f81 /src/dht
parent64821d4ae43b03b30de3dd136137598c0d5a2ab2 (diff)
downloadgnunet-562b33143ee9fa431a68ea6741e4feb3ba388f83.tar.gz
gnunet-562b33143ee9fa431a68ea6741e4feb3ba388f83.zip
changing heap remove node api to not pass heap; more fs hacking
Diffstat (limited to 'src/dht')
-rw-r--r--src/dht/gnunet-dht-driver.c4
-rw-r--r--src/dht/gnunet-service-dht.c7
2 files changed, 4 insertions, 7 deletions
diff --git a/src/dht/gnunet-dht-driver.c b/src/dht/gnunet-dht-driver.c
index 7a1606219..d12cc91df 100644
--- a/src/dht/gnunet-dht-driver.c
+++ b/src/dht/gnunet-dht-driver.c
@@ -1243,10 +1243,8 @@ do_get(void *cls, const struct GNUNET_SCHEDULER_TaskContext * tc);
1243static int 1243static int
1244remove_peer_count(void *cls, const GNUNET_HashCode * key, void *value) 1244remove_peer_count(void *cls, const GNUNET_HashCode * key, void *value)
1245{ 1245{
1246 struct FindPeerContext *find_peer_ctx = cls;
1247 struct PeerCount *peer_count = value; 1246 struct PeerCount *peer_count = value;
1248 GNUNET_CONTAINER_heap_remove_node (find_peer_ctx->peer_min_heap, 1247 GNUNET_CONTAINER_heap_remove_node (peer_count->heap_node);
1249 peer_count->heap_node);
1250 GNUNET_free(peer_count); 1248 GNUNET_free(peer_count);
1251 1249
1252 return GNUNET_YES; 1250 return GNUNET_YES;
diff --git a/src/dht/gnunet-service-dht.c b/src/dht/gnunet-service-dht.c
index e455cbc30..08cc7dc88 100644
--- a/src/dht/gnunet-service-dht.c
+++ b/src/dht/gnunet-service-dht.c
@@ -2115,8 +2115,7 @@ remove_forward_entry (void *cls,
2115 struct DHTRouteSource *source_info = cls; 2115 struct DHTRouteSource *source_info = cls;
2116 struct DHTQueryRecord *record; 2116 struct DHTQueryRecord *record;
2117 source_info = 2117 source_info =
2118 GNUNET_CONTAINER_heap_remove_node (forward_list.minHeap, 2118 GNUNET_CONTAINER_heap_remove_node (source_info->hnode);
2119 source_info->hnode);
2120 record = source_info->record; 2119 record = source_info->record;
2121 GNUNET_CONTAINER_DLL_remove (record->head, record->tail, source_info); 2120 GNUNET_CONTAINER_DLL_remove (record->head, record->tail, source_info);
2122 2121
@@ -3733,7 +3732,7 @@ remove_recent (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
3733 GNUNET_assert (GNUNET_YES == 3732 GNUNET_assert (GNUNET_YES ==
3734 GNUNET_CONTAINER_multihashmap_remove (recent.hashmap, &hash, 3733 GNUNET_CONTAINER_multihashmap_remove (recent.hashmap, &hash,
3735 req)); 3734 req));
3736 GNUNET_CONTAINER_heap_remove_node (recent.minHeap, req->heap_node); 3735 GNUNET_CONTAINER_heap_remove_node (req->heap_node);
3737 GNUNET_CONTAINER_bloomfilter_free (req->bloom); 3736 GNUNET_CONTAINER_bloomfilter_free (req->bloom);
3738 GNUNET_free (req); 3737 GNUNET_free (req);
3739 3738
@@ -4241,7 +4240,7 @@ find_client_records (void *cls, const GNUNET_HashCode * key, void *value)
4241 if (pos != NULL) 4240 if (pos != NULL)
4242 { 4241 {
4243 GNUNET_CONTAINER_DLL_remove (record->head, record->tail, pos); 4242 GNUNET_CONTAINER_DLL_remove (record->head, record->tail, pos);
4244 GNUNET_CONTAINER_heap_remove_node (forward_list.minHeap, pos->hnode); 4243 GNUNET_CONTAINER_heap_remove_node (pos->hnode);
4245 if (pos->delete_task != GNUNET_SCHEDULER_NO_TASK) 4244 if (pos->delete_task != GNUNET_SCHEDULER_NO_TASK)
4246 { 4245 {
4247 GNUNET_SCHEDULER_cancel (pos->delete_task); 4246 GNUNET_SCHEDULER_cancel (pos->delete_task);