aboutsummaryrefslogtreecommitdiff
path: root/src/fs/gnunet-service-fs.c
diff options
context:
space:
mode:
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);