aboutsummaryrefslogtreecommitdiff
path: root/src/fs/gnunet-service-fs.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-03-25 08:49:47 +0000
committerChristian Grothoff <christian@grothoff.org>2011-03-25 08:49:47 +0000
commit390a68296dd89f61461bdca02060d36e2e02af2b (patch)
tree9aa86841d2052cdd4080f6a4e2003313bf9670bf /src/fs/gnunet-service-fs.c
parent78469082de0b7fa49724504b7e21bb2e9b4bef05 (diff)
downloadgnunet-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.c18
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
1344dht_put_continuation (void *cls, 1344dht_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