aboutsummaryrefslogtreecommitdiff
path: root/src/fs/gnunet-service-fs.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-04-03 13:47:56 +0000
committerChristian Grothoff <christian@grothoff.org>2011-04-03 13:47:56 +0000
commit8c23a185ee8d3c16c5552668dced851f82986041 (patch)
tree83f59d2190ffadcdc5643ba36578b2c6766b0e42 /src/fs/gnunet-service-fs.c
parent1888cd7da7ae5e2c32faf66d3bef47ac7d225b35 (diff)
downloadgnunet-8c23a185ee8d3c16c5552668dced851f82986041.tar.gz
gnunet-8c23a185ee8d3c16c5552668dced851f82986041.zip
changing datastore API to support replication level --- not fully implemented --- and adding GNUNET_FS_BlockOptions struct to replace prio/anonymity/expiration+replication args
Diffstat (limited to 'src/fs/gnunet-service-fs.c')
-rw-r--r--src/fs/gnunet-service-fs.c10
1 files changed, 6 insertions, 4 deletions
diff --git a/src/fs/gnunet-service-fs.c b/src/fs/gnunet-service-fs.c
index 74a88e7b2..caf534140 100644
--- a/src/fs/gnunet-service-fs.c
+++ b/src/fs/gnunet-service-fs.c
@@ -1432,9 +1432,9 @@ gather_migration_blocks (void *cls,
1432 mig_task = GNUNET_SCHEDULER_NO_TASK; 1432 mig_task = GNUNET_SCHEDULER_NO_TASK;
1433 if (dsh != NULL) 1433 if (dsh != NULL)
1434 { 1434 {
1435 mig_qe = GNUNET_DATASTORE_get_random (dsh, 0, UINT_MAX, 1435 mig_qe = GNUNET_DATASTORE_get_for_replication (dsh, 0, UINT_MAX,
1436 GNUNET_TIME_UNIT_FOREVER_REL, 1436 GNUNET_TIME_UNIT_FOREVER_REL,
1437 &process_migration_content, NULL); 1437 &process_migration_content, NULL);
1438 GNUNET_assert (mig_qe != NULL); 1438 GNUNET_assert (mig_qe != NULL);
1439 } 1439 }
1440} 1440}
@@ -3764,8 +3764,10 @@ handle_p2p_put (void *cls,
3764 GNUNET_DATASTORE_put (dsh, 3764 GNUNET_DATASTORE_put (dsh,
3765 0, &query, dsize, &put[1], 3765 0, &query, dsize, &put[1],
3766 type, prq.priority, 1 /* anonymity */, 3766 type, prq.priority, 1 /* anonymity */,
3767 0 /* replication */,
3767 expiration, 3768 expiration,
3768 1 + prq.priority, MAX_DATASTORE_QUEUE, 3769 1 + prq.priority,
3770 MAX_DATASTORE_QUEUE,
3769 GNUNET_CONSTANTS_SERVICE_TIMEOUT, 3771 GNUNET_CONSTANTS_SERVICE_TIMEOUT,
3770 &put_migration_continuation, 3772 &put_migration_continuation,
3771 start); 3773 start);