diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-03-25 08:49:47 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-03-25 08:49:47 +0000 |
commit | 390a68296dd89f61461bdca02060d36e2e02af2b (patch) | |
tree | 9aa86841d2052cdd4080f6a4e2003313bf9670bf /src/fs/gnunet-service-fs.c | |
parent | 78469082de0b7fa49724504b7e21bb2e9b4bef05 (diff) | |
download | gnunet-390a68296dd89f61461bdca02060d36e2e02af2b.tar.gz gnunet-390a68296dd89f61461bdca02060d36e2e02af2b.zip |
adapt to new API
Diffstat (limited to 'src/fs/gnunet-service-fs.c')
-rw-r--r-- | src/fs/gnunet-service-fs.c | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/src/fs/gnunet-service-fs.c b/src/fs/gnunet-service-fs.c index ab16bc834..687f131d1 100644 --- a/src/fs/gnunet-service-fs.c +++ b/src/fs/gnunet-service-fs.c | |||
@@ -1297,7 +1297,7 @@ process_migration_content (void *cls, | |||
1297 | MIN_MIGRATION_CONTENT_LIFETIME.rel_value) | 1297 | MIN_MIGRATION_CONTENT_LIFETIME.rel_value) |
1298 | { | 1298 | { |
1299 | /* content will expire soon, don't bother */ | 1299 | /* content will expire soon, don't bother */ |
1300 | GNUNET_DATASTORE_get_next (dsh, GNUNET_YES); | 1300 | GNUNET_DATASTORE_get_next (dsh); |
1301 | return; | 1301 | return; |
1302 | } | 1302 | } |
1303 | if (type == GNUNET_BLOCK_TYPE_FS_ONDEMAND) | 1303 | if (type == GNUNET_BLOCK_TYPE_FS_ONDEMAND) |
@@ -1309,7 +1309,7 @@ process_migration_content (void *cls, | |||
1309 | &process_migration_content, | 1309 | &process_migration_content, |
1310 | NULL)) | 1310 | NULL)) |
1311 | { | 1311 | { |
1312 | GNUNET_DATASTORE_get_next (dsh, GNUNET_YES); | 1312 | GNUNET_DATASTORE_get_next (dsh); |
1313 | } | 1313 | } |
1314 | return; | 1314 | return; |
1315 | } | 1315 | } |
@@ -1333,7 +1333,7 @@ process_migration_content (void *cls, | |||
1333 | GNUNET_CONTAINER_multihashmap_iterate (connected_peers, | 1333 | GNUNET_CONTAINER_multihashmap_iterate (connected_peers, |
1334 | &consider_migration, | 1334 | &consider_migration, |
1335 | mb); | 1335 | mb); |
1336 | GNUNET_DATASTORE_get_next (dsh, GNUNET_YES); | 1336 | GNUNET_DATASTORE_get_next (dsh); |
1337 | } | 1337 | } |
1338 | 1338 | ||
1339 | 1339 | ||
@@ -1344,7 +1344,7 @@ static void | |||
1344 | dht_put_continuation (void *cls, | 1344 | dht_put_continuation (void *cls, |
1345 | const struct GNUNET_SCHEDULER_TaskContext *tc) | 1345 | const struct GNUNET_SCHEDULER_TaskContext *tc) |
1346 | { | 1346 | { |
1347 | GNUNET_DATASTORE_get_next (dsh, GNUNET_YES); | 1347 | GNUNET_DATASTORE_get_next (dsh); |
1348 | } | 1348 | } |
1349 | 1349 | ||
1350 | 1350 | ||
@@ -3984,7 +3984,7 @@ process_local_reply (void *cls, | |||
3984 | pr)) | 3984 | pr)) |
3985 | if (pr->qe != NULL) | 3985 | if (pr->qe != NULL) |
3986 | { | 3986 | { |
3987 | GNUNET_DATASTORE_get_next (dsh, GNUNET_YES); | 3987 | GNUNET_DATASTORE_get_next (dsh); |
3988 | } | 3988 | } |
3989 | return; | 3989 | return; |
3990 | } | 3990 | } |
@@ -4007,7 +4007,7 @@ process_local_reply (void *cls, | |||
4007 | -1, -1, | 4007 | -1, -1, |
4008 | GNUNET_TIME_UNIT_FOREVER_REL, | 4008 | GNUNET_TIME_UNIT_FOREVER_REL, |
4009 | NULL, NULL); | 4009 | NULL, NULL); |
4010 | GNUNET_DATASTORE_get_next (dsh, GNUNET_YES); | 4010 | GNUNET_DATASTORE_get_next (dsh); |
4011 | return; | 4011 | return; |
4012 | } | 4012 | } |
4013 | prq.type = type; | 4013 | prq.type = type; |
@@ -4026,7 +4026,7 @@ process_local_reply (void *cls, | |||
4026 | if (prq.eval == GNUNET_BLOCK_EVALUATION_OK_LAST) | 4026 | if (prq.eval == GNUNET_BLOCK_EVALUATION_OK_LAST) |
4027 | { | 4027 | { |
4028 | pr->local_only = GNUNET_YES; /* do not forward */ | 4028 | pr->local_only = GNUNET_YES; /* do not forward */ |
4029 | GNUNET_DATASTORE_get_next (dsh, GNUNET_NO); | 4029 | GNUNET_DATASTORE_get_next (dsh); |
4030 | return; | 4030 | return; |
4031 | } | 4031 | } |
4032 | if ( (pr->client_request_list == NULL) && | 4032 | if ( (pr->client_request_list == NULL) && |
@@ -4041,10 +4041,10 @@ process_local_reply (void *cls, | |||
4041 | gettext_noop ("# processing result set cut short due to load"), | 4041 | gettext_noop ("# processing result set cut short due to load"), |
4042 | 1, | 4042 | 1, |
4043 | GNUNET_NO); | 4043 | GNUNET_NO); |
4044 | GNUNET_DATASTORE_get_next (dsh, GNUNET_NO); | 4044 | GNUNET_DATASTORE_get_next (dsh); |
4045 | return; | 4045 | return; |
4046 | } | 4046 | } |
4047 | GNUNET_DATASTORE_get_next (dsh, GNUNET_YES); | 4047 | GNUNET_DATASTORE_get_next (dsh); |
4048 | } | 4048 | } |
4049 | 4049 | ||
4050 | 4050 | ||