From e8f35bb025c25839a52fb502e452393831e4e6f0 Mon Sep 17 00:00:00 2001
From: Christian Grothoff <christian@grothoff.org>
Date: Sun, 3 Apr 2011 20:00:42 +0000
Subject: improving datastore API --- not working yet

---
 src/fs/gnunet-service-fs.c | 56 +++++++++++++++++++++++-----------------------
 1 file changed, 28 insertions(+), 28 deletions(-)

(limited to 'src/fs/gnunet-service-fs.c')

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);
 }
 
 
-- 
cgit v1.2.3