improving datastore API --- not working yet

1 files changed, 28 insertions, 28 deletions

diff --git a/src/fs/gnunet-service-fs.c b/src/fs/gnunet-service-fs.c
index caf534140..35d89c50f 100644
--- a/src/fs/gnunet-service-fs.c
+++ b/src/fs/gnunet-service-fs.c
@@ -1297,7 +1297,7 @@ process_migration_content (void *cls,
       MIN_MIGRATION_CONTENT_LIFETIME.rel_value)
     {
       /* content will expire soon, don't bother */
-      GNUNET_DATASTORE_get_next (dsh);
+      GNUNET_DATASTORE_iterate_get_next (dsh);
       return;
     }
   if (type == GNUNET_BLOCK_TYPE_FS_ONDEMAND)
@@ -1309,7 +1309,7 @@ process_migration_content (void *cls,
                                             &process_migration_content,
                                             NULL))
         {
-          GNUNET_DATASTORE_get_next (dsh);
+          GNUNET_DATASTORE_iterate_get_next (dsh);
         }
       return;
     }
@@ -1333,7 +1333,7 @@ process_migration_content (void *cls,
   GNUNET_CONTAINER_multihashmap_iterate (connected_peers,
                                          &consider_migration,
                                          mb);
-  GNUNET_DATASTORE_get_next (dsh);
+  GNUNET_DATASTORE_iterate_get_next (dsh);
 }
 
 
@@ -1344,7 +1344,7 @@ static void
 dht_put_continuation (void *cls,
                       const struct GNUNET_SCHEDULER_TaskContext *tc)
 {
-  GNUNET_DATASTORE_get_next (dsh);
+  GNUNET_DATASTORE_iterate_get_next (dsh);
 }
 
 
@@ -1455,10 +1455,10 @@ gather_dht_put_blocks (void *cls,
     {
       if (dht_put_type == GNUNET_BLOCK_TYPE_FS_ONDEMAND)
         dht_put_type = GNUNET_BLOCK_TYPE_FS_KBLOCK;
-      dht_qe = GNUNET_DATASTORE_get_zero_anonymity (dsh, 0, UINT_MAX,
-                                                    GNUNET_TIME_UNIT_FOREVER_REL,
-                                                    dht_put_type++,
-                                                    &process_dht_put_content, NULL);
+      dht_qe = GNUNET_DATASTORE_iterate_zero_anonymity (dsh, 0, UINT_MAX,
+                                                        GNUNET_TIME_UNIT_FOREVER_REL,
+                                                        dht_put_type++,
+                                                        &process_dht_put_content, NULL);
       GNUNET_assert (dht_qe != NULL);
     }
 }
@@ -3991,7 +3991,7 @@ process_local_reply (void *cls,
                                             pr))
       if (pr->qe != NULL)
         {
-          GNUNET_DATASTORE_get_next (dsh);
+          GNUNET_DATASTORE_iterate_get_next (dsh);
         }
       return;
     }
@@ -4014,7 +4014,7 @@ process_local_reply (void *cls,
                                -1, -1, 
                                GNUNET_TIME_UNIT_FOREVER_REL,
                                NULL, NULL);
-      GNUNET_DATASTORE_get_next (dsh);
+      GNUNET_DATASTORE_iterate_get_next (dsh);
       return;
     }
   prq.type = type;
@@ -4033,7 +4033,7 @@ process_local_reply (void *cls,
   if (prq.eval == GNUNET_BLOCK_EVALUATION_OK_LAST)
     {
       pr->local_only = GNUNET_YES; /* do not forward */
-      GNUNET_DATASTORE_get_next (dsh);
+      GNUNET_DATASTORE_iterate_get_next (dsh);
       return;
     }
   if ( (pr->client_request_list == NULL) &&
@@ -4048,10 +4048,10 @@ process_local_reply (void *cls,
                                 gettext_noop ("# processing result set cut short due to load"),
                                 1,
                                 GNUNET_NO);
-      GNUNET_DATASTORE_get_next (dsh);
+      GNUNET_DATASTORE_iterate_get_next (dsh);
       return;
     }
-  GNUNET_DATASTORE_get_next (dsh);
+  GNUNET_DATASTORE_iterate_get_next (dsh);
 }
 
 
@@ -4412,14 +4412,14 @@ handle_p2p_get (void *cls,
                   "Handing request for `%s' to datastore\n",
                   GNUNET_h2s (&gm->query));
 #endif
-      pr->qe = GNUNET_DATASTORE_get (dsh,
-                                     &gm->query,
-                                     type,                             
-                                     pr->priority + 1,
-                                     MAX_DATASTORE_QUEUE,                                
-                                     timeout,
-                                     &process_local_reply,
-                                     pr);
+      pr->qe = GNUNET_DATASTORE_iterate_key (dsh,
+                                             &gm->query,
+                                             type,                             
+                                             pr->priority + 1,
+                                             MAX_DATASTORE_QUEUE,
+                                             timeout,
+                                             &process_local_reply,
+                                             pr);
       if (NULL == pr->qe)
         {
           GNUNET_STATISTICS_update (stats,
@@ -4617,13 +4617,13 @@ handle_start_search (void *cls,
                                                    GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE));
   if (type == GNUNET_BLOCK_TYPE_FS_DBLOCK)
     type = GNUNET_BLOCK_TYPE_ANY; /* get on-demand blocks too! */
-  pr->qe = GNUNET_DATASTORE_get (dsh,
-                                 &sm->query,
-                                 type,
-                                 -3, -1,
-                                 GNUNET_CONSTANTS_SERVICE_TIMEOUT,                             
-                                 &process_local_reply,
-                                 pr);
+  pr->qe = GNUNET_DATASTORE_iterate_key (dsh,
+                                         &sm->query,
+                                         type,
+                                         -3, -1,
+                                         GNUNET_CONSTANTS_SERVICE_TIMEOUT,                             
+                                         &process_local_reply,
+                                         pr);
 }