diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-04-03 13:47:56 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-04-03 13:47:56 +0000 |
commit | 8c23a185ee8d3c16c5552668dced851f82986041 (patch) | |
tree | 83f59d2190ffadcdc5643ba36578b2c6766b0e42 /src/fs/gnunet-service-fs.c | |
parent | 1888cd7da7ae5e2c32faf66d3bef47ac7d225b35 (diff) | |
download | gnunet-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.c | 10 |
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); |