diff options
author | Christian Grothoff <christian@grothoff.org> | 2012-10-07 18:19:32 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2012-10-07 18:19:32 +0000 |
commit | a60b958f984d08525b636a2c7eae564ebec54ae6 (patch) | |
tree | 6dcbbf91d734834f804b2fd9ab790244e2d60e6c /src/fs | |
parent | decf459805cdb3f6811f979df4831bc2ce9a2858 (diff) | |
download | gnunet-a60b958f984d08525b636a2c7eae564ebec54ae6.tar.gz gnunet-a60b958f984d08525b636a2c7eae564ebec54ae6.zip |
-chaning multihashmap API to allow option for avoiding key allocation
Diffstat (limited to 'src/fs')
-rw-r--r-- | src/fs/fs_api.c | 4 | ||||
-rw-r--r-- | src/fs/fs_download.c | 2 | ||||
-rw-r--r-- | src/fs/fs_namespace.c | 3 | ||||
-rw-r--r-- | src/fs/fs_search.c | 4 | ||||
-rw-r--r-- | src/fs/fs_sharetree.c | 4 | ||||
-rw-r--r-- | src/fs/gnunet-auto-share.c | 2 | ||||
-rw-r--r-- | src/fs/gnunet-service-fs_cp.c | 4 | ||||
-rw-r--r-- | src/fs/gnunet-service-fs_indexing.c | 2 | ||||
-rw-r--r-- | src/fs/gnunet-service-fs_pe.c | 4 | ||||
-rw-r--r-- | src/fs/gnunet-service-fs_pr.c | 2 |
10 files changed, 16 insertions, 15 deletions
diff --git a/src/fs/fs_api.c b/src/fs/fs_api.c index c99131d94..059c70ba6 100644 --- a/src/fs/fs_api.c +++ b/src/fs/fs_api.c | |||
@@ -2681,7 +2681,7 @@ deserialize_download (struct GNUNET_FS_Handle *h, | |||
2681 | } | 2681 | } |
2682 | dc->options = (enum GNUNET_FS_DownloadOptions) options; | 2682 | dc->options = (enum GNUNET_FS_DownloadOptions) options; |
2683 | dc->active = | 2683 | dc->active = |
2684 | GNUNET_CONTAINER_multihashmap_create (1 + 2 * (dc->length / DBLOCK_SIZE)); | 2684 | GNUNET_CONTAINER_multihashmap_create (1 + 2 * (dc->length / DBLOCK_SIZE), GNUNET_NO); |
2685 | dc->has_finished = (int) status; | 2685 | dc->has_finished = (int) status; |
2686 | dc->treedepth = | 2686 | dc->treedepth = |
2687 | GNUNET_FS_compute_depth (GNUNET_FS_uri_chk_get_file_size (dc->uri)); | 2687 | GNUNET_FS_compute_depth (GNUNET_FS_uri_chk_get_file_size (dc->uri)); |
@@ -2804,7 +2804,7 @@ deserialize_search (struct GNUNET_FS_Handle *h, | |||
2804 | goto cleanup; | 2804 | goto cleanup; |
2805 | } | 2805 | } |
2806 | sc->options = (enum GNUNET_FS_SearchOptions) options; | 2806 | sc->options = (enum GNUNET_FS_SearchOptions) options; |
2807 | sc->master_result_map = GNUNET_CONTAINER_multihashmap_create (16); | 2807 | sc->master_result_map = GNUNET_CONTAINER_multihashmap_create (16, GNUNET_NO); |
2808 | dn = get_serialization_file_name_in_dir (h, | 2808 | dn = get_serialization_file_name_in_dir (h, |
2809 | (sc->psearch_result == | 2809 | (sc->psearch_result == |
2810 | NULL) ? | 2810 | NULL) ? |
diff --git a/src/fs/fs_download.c b/src/fs/fs_download.c index e9839cc2d..ecb5c5f8a 100644 --- a/src/fs/fs_download.c +++ b/src/fs/fs_download.c | |||
@@ -2101,7 +2101,7 @@ create_download_context (struct GNUNET_FS_Handle *h, | |||
2101 | dc->anonymity = anonymity; | 2101 | dc->anonymity = anonymity; |
2102 | dc->options = options; | 2102 | dc->options = options; |
2103 | dc->active = | 2103 | dc->active = |
2104 | GNUNET_CONTAINER_multihashmap_create (1 + 2 * (length / DBLOCK_SIZE)); | 2104 | GNUNET_CONTAINER_multihashmap_create (1 + 2 * (length / DBLOCK_SIZE), GNUNET_NO); |
2105 | dc->treedepth = | 2105 | dc->treedepth = |
2106 | GNUNET_FS_compute_depth (GNUNET_FS_uri_chk_get_file_size (dc->uri)); | 2106 | GNUNET_FS_compute_depth (GNUNET_FS_uri_chk_get_file_size (dc->uri)); |
2107 | if ((NULL == filename) && (is_recursive_download (dc))) | 2107 | if ((NULL == filename) && (is_recursive_download (dc))) |
diff --git a/src/fs/fs_namespace.c b/src/fs/fs_namespace.c index af1200dc4..eaff8a6d2 100644 --- a/src/fs/fs_namespace.c +++ b/src/fs/fs_namespace.c | |||
@@ -853,7 +853,8 @@ GNUNET_FS_namespace_list_updateable (struct GNUNET_FS_Namespace *ns, | |||
853 | ns->update_map = | 853 | ns->update_map = |
854 | GNUNET_CONTAINER_multihashmap_create (2 + | 854 | GNUNET_CONTAINER_multihashmap_create (2 + |
855 | 3 * ns->update_node_count / | 855 | 3 * ns->update_node_count / |
856 | 4); | 856 | 4, |
857 | GNUNET_NO); | ||
857 | for (i = 0; i < ns->update_node_count; i++) | 858 | for (i = 0; i < ns->update_node_count; i++) |
858 | { | 859 | { |
859 | nsn = ns->update_nodes[i]; | 860 | nsn = ns->update_nodes[i]; |
diff --git a/src/fs/fs_search.c b/src/fs/fs_search.c index a5b2d3643..370fd2f5c 100644 --- a/src/fs/fs_search.c +++ b/src/fs/fs_search.c | |||
@@ -1202,7 +1202,7 @@ search_start (struct GNUNET_FS_Handle *h, const struct GNUNET_FS_Uri *uri, | |||
1202 | sc->psearch_result = psearch; | 1202 | sc->psearch_result = psearch; |
1203 | psearch->update_search = sc; | 1203 | psearch->update_search = sc; |
1204 | } | 1204 | } |
1205 | sc->master_result_map = GNUNET_CONTAINER_multihashmap_create (16); | 1205 | sc->master_result_map = GNUNET_CONTAINER_multihashmap_create (16, GNUNET_NO); |
1206 | sc->client_info = cctx; | 1206 | sc->client_info = cctx; |
1207 | if (GNUNET_OK != GNUNET_FS_search_start_searching_ (sc)) | 1207 | if (GNUNET_OK != GNUNET_FS_search_start_searching_ (sc)) |
1208 | { | 1208 | { |
@@ -1256,7 +1256,7 @@ GNUNET_FS_search_start_searching_ (struct GNUNET_FS_SearchContext *sc) | |||
1256 | sc->requests[i].mandatory = (sc->uri->data.ksk.keywords[i][0] == '+'); | 1256 | sc->requests[i].mandatory = (sc->uri->data.ksk.keywords[i][0] == '+'); |
1257 | if (sc->requests[i].mandatory) | 1257 | if (sc->requests[i].mandatory) |
1258 | sc->mandatory_count++; | 1258 | sc->mandatory_count++; |
1259 | sc->requests[i].results = GNUNET_CONTAINER_multihashmap_create (4); | 1259 | sc->requests[i].results = GNUNET_CONTAINER_multihashmap_create (4, GNUNET_NO); |
1260 | GNUNET_CRYPTO_hash (keyword, strlen (keyword), &sc->requests[i].key); | 1260 | GNUNET_CRYPTO_hash (keyword, strlen (keyword), &sc->requests[i].key); |
1261 | } | 1261 | } |
1262 | } | 1262 | } |
diff --git a/src/fs/fs_sharetree.c b/src/fs/fs_sharetree.c index f75571c46..5e96390ce 100644 --- a/src/fs/fs_sharetree.c +++ b/src/fs/fs_sharetree.c | |||
@@ -415,8 +415,8 @@ GNUNET_FS_share_tree_trim (struct GNUNET_FS_ShareTreeItem *toplevel) | |||
415 | 415 | ||
416 | if (toplevel == NULL) | 416 | if (toplevel == NULL) |
417 | return; | 417 | return; |
418 | tc.keywordcounter = GNUNET_CONTAINER_multihashmap_create (1024); | 418 | tc.keywordcounter = GNUNET_CONTAINER_multihashmap_create (1024, GNUNET_NO); |
419 | tc.metacounter = GNUNET_CONTAINER_multihashmap_create (1024); | 419 | tc.metacounter = GNUNET_CONTAINER_multihashmap_create (1024, GNUNET_NO); |
420 | share_tree_trim (&tc, toplevel); | 420 | share_tree_trim (&tc, toplevel); |
421 | GNUNET_CONTAINER_multihashmap_destroy (tc.keywordcounter); | 421 | GNUNET_CONTAINER_multihashmap_destroy (tc.keywordcounter); |
422 | GNUNET_CONTAINER_multihashmap_destroy (tc.metacounter); | 422 | GNUNET_CONTAINER_multihashmap_destroy (tc.metacounter); |
diff --git a/src/fs/gnunet-auto-share.c b/src/fs/gnunet-auto-share.c index 1a6e74b8c..886e0ba69 100644 --- a/src/fs/gnunet-auto-share.c +++ b/src/fs/gnunet-auto-share.c | |||
@@ -690,7 +690,7 @@ run (void *cls, char *const *args, const char *cfgfile, | |||
690 | cfg_filename = GNUNET_strdup (cfgfile); | 690 | cfg_filename = GNUNET_strdup (cfgfile); |
691 | cfg = c; | 691 | cfg = c; |
692 | dir_name = args[0]; | 692 | dir_name = args[0]; |
693 | work_finished = GNUNET_CONTAINER_multihashmap_create (1024); | 693 | work_finished = GNUNET_CONTAINER_multihashmap_create (1024, GNUNET_NO); |
694 | load_state (); | 694 | load_state (); |
695 | run_task = GNUNET_SCHEDULER_add_with_priority (GNUNET_SCHEDULER_PRIORITY_IDLE, | 695 | run_task = GNUNET_SCHEDULER_add_with_priority (GNUNET_SCHEDULER_PRIORITY_IDLE, |
696 | &scan, NULL); | 696 | &scan, NULL); |
diff --git a/src/fs/gnunet-service-fs_cp.c b/src/fs/gnunet-service-fs_cp.c index 4ff6432b0..3de45ff48 100644 --- a/src/fs/gnunet-service-fs_cp.c +++ b/src/fs/gnunet-service-fs_cp.c | |||
@@ -615,7 +615,7 @@ GSF_peer_connect_handler_ (const struct GNUNET_PeerIdentity *peer, | |||
615 | (sizeof (respect) == GNUNET_DISK_fn_read (fn, &respect, sizeof (respect)))) | 615 | (sizeof (respect) == GNUNET_DISK_fn_read (fn, &respect, sizeof (respect)))) |
616 | cp->disk_respect = cp->ppd.respect = ntohl (respect); | 616 | cp->disk_respect = cp->ppd.respect = ntohl (respect); |
617 | GNUNET_free (fn); | 617 | GNUNET_free (fn); |
618 | cp->request_map = GNUNET_CONTAINER_multihashmap_create (128); | 618 | cp->request_map = GNUNET_CONTAINER_multihashmap_create (128, GNUNET_NO); |
619 | GNUNET_break (GNUNET_OK == | 619 | GNUNET_break (GNUNET_OK == |
620 | GNUNET_CONTAINER_multihashmap_put (cp_map, &peer->hashPubKey, | 620 | GNUNET_CONTAINER_multihashmap_put (cp_map, &peer->hashPubKey, |
621 | cp, | 621 | cp, |
@@ -1811,7 +1811,7 @@ cron_flush_respect (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
1811 | void | 1811 | void |
1812 | GSF_connected_peer_init_ () | 1812 | GSF_connected_peer_init_ () |
1813 | { | 1813 | { |
1814 | cp_map = GNUNET_CONTAINER_multihashmap_create (128); | 1814 | cp_map = GNUNET_CONTAINER_multihashmap_create (128, GNUNET_NO); |
1815 | ats = GNUNET_ATS_performance_init (GSF_cfg, NULL, NULL); | 1815 | ats = GNUNET_ATS_performance_init (GSF_cfg, NULL, NULL); |
1816 | GNUNET_assert (GNUNET_OK == | 1816 | GNUNET_assert (GNUNET_OK == |
1817 | GNUNET_CONFIGURATION_get_value_filename (GSF_cfg, "fs", | 1817 | GNUNET_CONFIGURATION_get_value_filename (GSF_cfg, "fs", |
diff --git a/src/fs/gnunet-service-fs_indexing.c b/src/fs/gnunet-service-fs_indexing.c index 7bd8316ab..1324b22d7 100644 --- a/src/fs/gnunet-service-fs_indexing.c +++ b/src/fs/gnunet-service-fs_indexing.c | |||
@@ -613,7 +613,7 @@ GNUNET_FS_indexing_init (const struct GNUNET_CONFIGURATION_Handle *c, | |||
613 | { | 613 | { |
614 | cfg = c; | 614 | cfg = c; |
615 | dsh = d; | 615 | dsh = d; |
616 | ifm = GNUNET_CONTAINER_multihashmap_create (128); | 616 | ifm = GNUNET_CONTAINER_multihashmap_create (128, GNUNET_NO); |
617 | read_index_list (); | 617 | read_index_list (); |
618 | return GNUNET_OK; | 618 | return GNUNET_OK; |
619 | } | 619 | } |
diff --git a/src/fs/gnunet-service-fs_pe.c b/src/fs/gnunet-service-fs_pe.c index dbaab7d48..bc08eebe7 100644 --- a/src/fs/gnunet-service-fs_pe.c +++ b/src/fs/gnunet-service-fs_pe.c | |||
@@ -572,7 +572,7 @@ GSF_plan_add_ (struct GSF_ConnectedPeer *cp, struct GSF_PendingRequest *pr) | |||
572 | if (NULL == pp) | 572 | if (NULL == pp) |
573 | { | 573 | { |
574 | pp = GNUNET_malloc (sizeof (struct PeerPlan)); | 574 | pp = GNUNET_malloc (sizeof (struct PeerPlan)); |
575 | pp->plan_map = GNUNET_CONTAINER_multihashmap_create (128); | 575 | pp->plan_map = GNUNET_CONTAINER_multihashmap_create (128, GNUNET_NO); |
576 | pp->priority_heap = | 576 | pp->priority_heap = |
577 | GNUNET_CONTAINER_heap_create (GNUNET_CONTAINER_HEAP_ORDER_MAX); | 577 | GNUNET_CONTAINER_heap_create (GNUNET_CONTAINER_HEAP_ORDER_MAX); |
578 | pp->delay_heap = | 578 | pp->delay_heap = |
@@ -760,7 +760,7 @@ GSF_plan_notify_request_done_ (struct GSF_PendingRequest *pr) | |||
760 | void | 760 | void |
761 | GSF_plan_init () | 761 | GSF_plan_init () |
762 | { | 762 | { |
763 | plans = GNUNET_CONTAINER_multihashmap_create (256); | 763 | plans = GNUNET_CONTAINER_multihashmap_create (256, GNUNET_NO); |
764 | } | 764 | } |
765 | 765 | ||
766 | 766 | ||
diff --git a/src/fs/gnunet-service-fs_pr.c b/src/fs/gnunet-service-fs_pr.c index ceb034ba0..265784348 100644 --- a/src/fs/gnunet-service-fs_pr.c +++ b/src/fs/gnunet-service-fs_pr.c | |||
@@ -1627,7 +1627,7 @@ GSF_pending_request_init_ () | |||
1627 | active_to_migration = | 1627 | active_to_migration = |
1628 | GNUNET_CONFIGURATION_get_value_yesno (GSF_cfg, "FS", "CONTENT_CACHING"); | 1628 | GNUNET_CONFIGURATION_get_value_yesno (GSF_cfg, "FS", "CONTENT_CACHING"); |
1629 | datastore_put_load = GNUNET_LOAD_value_init (DATASTORE_LOAD_AUTODECLINE); | 1629 | datastore_put_load = GNUNET_LOAD_value_init (DATASTORE_LOAD_AUTODECLINE); |
1630 | pr_map = GNUNET_CONTAINER_multihashmap_create (32 * 1024); | 1630 | pr_map = GNUNET_CONTAINER_multihashmap_create (32 * 1024, GNUNET_NO); |
1631 | requests_by_expiration_heap = | 1631 | requests_by_expiration_heap = |
1632 | GNUNET_CONTAINER_heap_create (GNUNET_CONTAINER_HEAP_ORDER_MIN); | 1632 | GNUNET_CONTAINER_heap_create (GNUNET_CONTAINER_HEAP_ORDER_MIN); |
1633 | } | 1633 | } |