GBP plugin

[vpp.git] / src / vppinfra / test_maplog.c

diff --git a/src/vppinfra/test_maplog.c b/src/vppinfra/test_maplog.c
index fb9fb0c..edb61bd 100644 (file)
--- a/src/vppinfra/test_maplog.c
+++ b/src/vppinfra/test_maplog.c
@@ -23,15 +23,59 @@ typedef struct
   u64 junk[7];
 } test_entry_t;
 
+static void
+process_maplog_records (clib_maplog_header_t * h,
+                       test_entry_t * e, u64 records_this_file)
+{
+  static int print_header;
+  int i = 0;
+
+  if (print_header == 0)
+    {
+      print_header = 1;
+      fformat (stdout, "%U", format_maplog_header, h, 1 /* verbose */ );
+    }
+
+  while (records_this_file--)
+    {
+      /* Padding at the end of a damaged log? */
+      if (e->serial_number == 0ULL)
+       break;
+      fformat (stdout, "%4lld ", e->serial_number);
+      if (++i == 8)
+       {
+         fformat (stdout, "\n");
+         i = 0;
+       }
+      e++;
+    }
+  fformat (stdout, "--------------\n");
+}
+
 int
 test_maplog_main (unformat_input_t * input)
 {
   clib_maplog_main_t *mm = &maplog_main;
+  clib_maplog_init_args_t _a, *a = &_a;
   int rv;
   int i;
   test_entry_t *t;
+  int noclose = 0;
 
-  rv = clib_maplog_init (mm, "/tmp/maplog_test", 4096, sizeof (test_entry_t));
+  if (unformat (input, "noclose"))
+    noclose = 1;
+
+  memset (a, 0, sizeof (*a));
+  a->mm = mm;
+  a->file_basename = "/tmp/maplog_test";
+  a->file_size_in_bytes = 4096;
+  a->record_size_in_bytes = sizeof (test_entry_t);
+  a->application_id = 1;
+  a->application_major_version = 1;
+  a->application_minor_version = 0;
+  a->application_patch_version = 0;
+
+  rv = clib_maplog_init (a);
 
   if (rv)
     {
@@ -42,10 +86,15 @@ test_maplog_main (unformat_input_t * input)
   for (i = 0; i < 64 * 5; i++)
     {
       t = clib_maplog_get_entry (mm);
-      t->serial_number = i;
+      t->serial_number = i + 1;
     }
 
-  clib_maplog_close (mm);
+  if (noclose)
+    memset (mm, 0, sizeof (*mm));
+  else
+    clib_maplog_close (mm);
+
+  clib_maplog_process ("/tmp/maplog_test", process_maplog_records);
 
   return 0;
 }