[GNUnet-SVN] r37284 - gnunet/src/peerstore

[gnunet]

Author: schanzen
Date: 2016-06-18 23:49:23 +0200 (Sat, 18 Jun 2016)
New Revision: 37284

Modified:
   gnunet/src/peerstore/perf_peerstore_store.c
   gnunet/src/peerstore/test_peerstore_api_iterate.c
   gnunet/src/peerstore/test_peerstore_api_sync.c
   gnunet/src/peerstore/test_peerstore_api_watch.c
   gnunet/src/peerstore/test_plugin_peerstore.c
Log:
-fix

Modified: gnunet/src/peerstore/perf_peerstore_store.c
===================================================================
--- gnunet/src/peerstore/perf_peerstore_store.c 2016-06-18 21:20:00 UTC (rev 
37283)
+++ gnunet/src/peerstore/perf_peerstore_store.c 2016-06-18 21:49:23 UTC (rev 
37284)
@@ -60,7 +60,7 @@
 }
 
 
-static int
+static void
 watch_cb (void *cls, const struct GNUNET_PEERSTORE_Record *record,
           const char *emsg)
 {
@@ -72,7 +72,6 @@
   }
   else
     store ();
-  return GNUNET_YES;
 }
 
 

Modified: gnunet/src/peerstore/test_peerstore_api_iterate.c
===================================================================
--- gnunet/src/peerstore/test_peerstore_api_iterate.c   2016-06-18 21:20:00 UTC 
(rev 37283)
+++ gnunet/src/peerstore/test_peerstore_api_iterate.c   2016-06-18 21:49:23 UTC 
(rev 37284)
@@ -29,6 +29,7 @@
 static int ok = 1;
 
 static struct GNUNET_PEERSTORE_Handle *h;
+static struct GNUNET_PEERSTORE_IterateContext *ic;
 
 static char *ss = "test_peerstore_api_iterate";
 static struct GNUNET_PeerIdentity p1;
@@ -40,60 +41,66 @@
 static int count = 0;
 
 
-static int
+static void
 iter3_cb (void *cls, const struct GNUNET_PEERSTORE_Record *record,
           const char *emsg)
 {
   if (NULL != emsg)
-    return GNUNET_NO;
+  {
+    GNUNET_PEERSTORE_iterate_cancel (ic);
+    return;
+  }
   if (NULL != record)
   {
     count++;
-    return GNUNET_YES;
+    return;
   }
   GNUNET_assert (count == 3);
   ok = 0;
   GNUNET_PEERSTORE_disconnect (h, GNUNET_NO);
   GNUNET_SCHEDULER_shutdown ();
-  return GNUNET_YES;
 }
 
 
-static int
+static void
 iter2_cb (void *cls, const struct GNUNET_PEERSTORE_Record *record,
           const char *emsg)
 {
   if (NULL != emsg)
-    return GNUNET_NO;
+  {
+    GNUNET_PEERSTORE_iterate_cancel (ic);
+    return;
+  }
   if (NULL != record)
   {
     count++;
-    return GNUNET_YES;
+    return;
   }
   GNUNET_assert (count == 2);
   count = 0;
-  GNUNET_PEERSTORE_iterate (h, ss, NULL, NULL, GNUNET_TIME_UNIT_FOREVER_REL,
+  ic = GNUNET_PEERSTORE_iterate (h, ss, NULL, NULL, 
GNUNET_TIME_UNIT_FOREVER_REL,
                             iter3_cb, NULL);
-  return GNUNET_YES;
 }
 
 
-static int
+static void
 iter1_cb (void *cls, const struct GNUNET_PEERSTORE_Record *record,
           const char *emsg)
 {
   if (NULL != emsg)
-    return GNUNET_NO;
+  {
+    GNUNET_PEERSTORE_iterate_cancel (ic);
+    return;
+  }
   if (NULL != record)
   {
     count++;
-    return GNUNET_YES;
+    return;
   }
   GNUNET_assert (count == 1);
   count = 0;
-  GNUNET_PEERSTORE_iterate (h, ss, &p1, NULL, GNUNET_TIME_UNIT_FOREVER_REL,
+  ic = GNUNET_PEERSTORE_iterate (h, ss, &p1, NULL, 
GNUNET_TIME_UNIT_FOREVER_REL,
                             iter2_cb, NULL);
-  return GNUNET_YES;
 }
 
 
@@ -114,7 +121,7 @@
   GNUNET_PEERSTORE_store (h, ss, &p2, k3, val, strlen (val) + 1,
                           GNUNET_TIME_UNIT_FOREVER_ABS,
                           GNUNET_PEERSTORE_STOREOPTION_REPLACE, NULL, NULL);
-  GNUNET_PEERSTORE_iterate (h, ss, &p1, k1, GNUNET_TIME_UNIT_FOREVER_REL,
+  ic = GNUNET_PEERSTORE_iterate (h, ss, &p1, k1, GNUNET_TIME_UNIT_FOREVER_REL,
                             iter1_cb, NULL);
 }
 

Modified: gnunet/src/peerstore/test_peerstore_api_sync.c
===================================================================
--- gnunet/src/peerstore/test_peerstore_api_sync.c      2016-06-18 21:20:00 UTC 
(rev 37283)
+++ gnunet/src/peerstore/test_peerstore_api_sync.c      2016-06-18 21:49:23 UTC 
(rev 37284)
@@ -79,7 +79,7 @@
  * @param emsg any error message
  * @return #GNUNET_YES (all good, continue)
  */
-static int
+static void
 iterate_cb (void *cls,
            const struct GNUNET_PEERSTORE_Record *record,
             const char *emsg)
@@ -92,12 +92,10 @@
     GNUNET_PEERSTORE_disconnect (h,
                                 GNUNET_NO);
     GNUNET_SCHEDULER_shutdown ();
-    return GNUNET_YES;
   }
   rec_val = record->value;
   GNUNET_break (0 == strcmp (rec_val, val));
   ok = 0;
-  return GNUNET_YES;
 }
 
 

Modified: gnunet/src/peerstore/test_peerstore_api_watch.c
===================================================================
--- gnunet/src/peerstore/test_peerstore_api_watch.c     2016-06-18 21:20:00 UTC 
(rev 37283)
+++ gnunet/src/peerstore/test_peerstore_api_watch.c     2016-06-18 21:49:23 UTC 
(rev 37284)
@@ -35,7 +35,7 @@
 static char *k = "test_peerstore_api_watch_key";
 static char *val = "test_peerstore_api_watch_val";
 
-static int
+static void
 watch_cb (void *cls, const struct GNUNET_PEERSTORE_Record *record,
           const char *emsg)
 {
@@ -44,7 +44,6 @@
   ok = 0;
   GNUNET_PEERSTORE_disconnect (h, GNUNET_NO);
   GNUNET_SCHEDULER_shutdown ();
-  return GNUNET_YES;
 }
 
 

Modified: gnunet/src/peerstore/test_plugin_peerstore.c
===================================================================
--- gnunet/src/peerstore/test_plugin_peerstore.c        2016-06-18 21:20:00 UTC 
(rev 37283)
+++ gnunet/src/peerstore/test_plugin_peerstore.c        2016-06-18 21:49:23 UTC 
(rev 37284)
@@ -79,7 +79,7 @@
 }
 
 
-static int
+static void
 test_record (void *cls,
                                                 const struct 
GNUNET_PEERSTORE_Record *record,
                                                 const char *error)
@@ -88,13 +88,12 @@
   char* testval = "test_val";
 
   if (NULL == record)
-    return GNUNET_NO;
+    return;
 
   GNUNET_assert (0 == memcmp (record->peer, id, sizeof (struct 
GNUNET_PeerIdentity)));
   GNUNET_assert (0 == strcmp ("subsys", record->sub_system));
   GNUNET_assert (0 == strcmp ("key", record->key));
   GNUNET_assert (0 == memcmp (testval, record->value, strlen (testval)));
-  return GNUNET_YES;
 }