From 1c1d28d3f5746fac496b517d0b3b78ca1726f01f Mon Sep 17 00:00:00 2001
From: Christian Grothoff <christian@grothoff.org>
Date: Fri, 3 Sep 2021 21:30:14 +0200
Subject: first draft for an aggregator benchmark, plus fixing
 inclusive/exclusive sharding range issues

---
 src/exchange-tools/taler-exchange-dbinit.c | 31 +++++++++++++++++++++---------
 1 file changed, 22 insertions(+), 9 deletions(-)

(limited to 'src/exchange-tools/taler-exchange-dbinit.c')

diff --git a/src/exchange-tools/taler-exchange-dbinit.c b/src/exchange-tools/taler-exchange-dbinit.c
index 5e18549e7..b187cff33 100644
--- a/src/exchange-tools/taler-exchange-dbinit.c
+++ b/src/exchange-tools/taler-exchange-dbinit.c
@@ -89,20 +89,33 @@ run (void *cls,
     global_ret = EXIT_NOPERMISSION;
     return;
   }
-  if (clear_shards)
+  if (gc_db || clear_shards)
   {
-    if (0 < plugin->delete_revolving_shards (plugin->cls))
+    if (GNUNET_OK !=
+        plugin->preflight (plugin->cls))
     {
       fprintf (stderr,
-               "Clearing revolving shards failed!\n");
+               "Failed to prepare database.\n");
+      TALER_EXCHANGEDB_plugin_unload (plugin);
+      global_ret = EXIT_NOPERMISSION;
+      return;
     }
-  }
-  if (gc_db)
-  {
-    if (GNUNET_SYSERR == plugin->gc (plugin->cls))
+    if (clear_shards)
     {
-      fprintf (stderr,
-               "Garbage collection failed!\n");
+      if (0 >
+          plugin->delete_revolving_shards (plugin->cls))
+      {
+        fprintf (stderr,
+                 "Clearing revolving shards failed!\n");
+      }
+    }
+    if (gc_db)
+    {
+      if (GNUNET_SYSERR == plugin->gc (plugin->cls))
+      {
+        fprintf (stderr,
+                 "Garbage collection failed!\n");
+      }
     }
   }
   TALER_EXCHANGEDB_plugin_unload (plugin);
-- 
cgit v1.2.3