Add -R option to kproplog to force full resyncs

ticket: 7375

1 files changed, 25 insertions, 4 deletions

diff --git a/src/slave/kproplog.c b/src/slave/kproplog.c
index e58ca20783..c6f244bbb3 100644
--- a/src/slave/kproplog.c
+++ b/src/slave/kproplog.c
@@ -30,8 +30,8 @@ static char     *progname;
 static void
 usage()
 {
-    (void) fprintf(stderr, _("\nUsage: %s [-h] [-v] [-v] [-e num]\n\n"),
-                   progname);
+    fprintf(stderr, _("\nUsage: %s [-h] [-v] [-v] [-e num]\n\t%s -R\n\n"),
+            progname, progname);
     exit(1);
 }
 
@@ -489,6 +489,7 @@ main(int argc, char **argv)
     int                 c;
     unsigned int        verbose = 0;
     bool_t              headeronly = FALSE;
+    bool_t              reset = FALSE;
     uint32_t            entry = 0;
     krb5_context        context;
     kadm5_config_params params;
@@ -506,7 +507,7 @@ main(int argc, char **argv)
 
     progname = argv[0];
 
-    while ((c = getopt(argc, argv, "vhe:")) != -1) {
+    while ((c = getopt(argc, argv, "Rvhe:")) != -1) {
         switch (c) {
         case 'h':
             headeronly = TRUE;
@@ -514,6 +515,9 @@ main(int argc, char **argv)
         case 'e':
             entry = atoi(optarg);
             break;
+        case 'R':
+            reset = TRUE;
+            break;
         case 'v':
             verbose++;
             break;
@@ -539,7 +543,8 @@ main(int argc, char **argv)
     (void) printf(_("\nKerberos update log (%s)\n"),
                   params.iprop_logfile);
 
-    if (ulog_map(context, params.iprop_logfile, 0, FKPROPLOG, db_args)) {
+    if (ulog_map(context, params.iprop_logfile, 0,
+                 reset ? FKADMIND : FKPROPLOG, db_args)) {
         (void) fprintf(stderr, _("Unable to map log file %s\n\n"),
                        params.iprop_logfile);
         exit(1);
@@ -560,6 +565,22 @@ main(int argc, char **argv)
         exit(1);
     }
 
+    if (reset) {
+        ulog->kdb_hmagic = KDB_ULOG_HDR_MAGIC;
+        ulog->db_version_num = KDB_VERSION;
+        ulog->kdb_state = KDB_STABLE;
+        ulog->kdb_block = ULOG_BLOCK;
+        ulog->kdb_first_sno = 0;
+        ulog->kdb_first_time.seconds = 0;
+        ulog->kdb_first_time.useconds = 0;
+        ulog->kdb_last_sno = 0;
+        ulog->kdb_last_time.seconds = 0;
+        ulog->kdb_last_time.useconds = 0;
+        ulog_sync_header(ulog);
+        printf(_("Reinitialized the ulog.\n"));
+        exit(0);
+    }
+
     (void) printf(_("Update log dump :\n"));
     (void) printf(_("\tLog version # : %u\n"), ulog->db_version_num);
     (void) printf(_("\tLog state : "));