summaryrefslogtreecommitdiff
path: root/src/pmloglabel/pmloglabel.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/pmloglabel/pmloglabel.c')
-rw-r--r--src/pmloglabel/pmloglabel.c422
1 files changed, 422 insertions, 0 deletions
diff --git a/src/pmloglabel/pmloglabel.c b/src/pmloglabel/pmloglabel.c
new file mode 100644
index 0000000..ce7ae57
--- /dev/null
+++ b/src/pmloglabel/pmloglabel.c
@@ -0,0 +1,422 @@
+/*
+ * Copyright (c) 2014 Red Hat.
+ * Copyright (c) 2008 Aconex. All Rights Reserved.
+ *
+ * This program is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU General Public License as published by the
+ * Free Software Foundation; either version 2 of the License, or (at your
+ * option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
+ * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
+ * for more details.
+ */
+
+#include "pmapi.h"
+#include "impl.h"
+
+static int gold; /* boolean flag - do we have a golden label yet? */
+static char *goldfile;
+static __pmLogLabel golden;
+static __pmLogCtl logctl;
+static int status;
+
+/*
+ * Basic log control label sanity testing, with prefix/suffix len
+ * checks too (these are stored as int's around the actual label).
+ */
+int
+verify_label(FILE *f, const char *file)
+{
+ int version, magic;
+ int n, len, xpectlen = sizeof(__pmLogLabel) + 2 * sizeof(len);
+
+ /* check the prefix integer */
+ fseek(f, (long)0, SEEK_SET);
+ n = (int)fread(&len, 1, sizeof(len), f);
+ len = ntohl(len);
+ if (n != sizeof(len)) {
+ if (feof(f)) {
+ fprintf(stderr, "Bad prefix sentinel read for %s: file too short\n",
+ file);
+ status = 2;
+ }
+ else if (ferror(f)) {
+ fprintf(stderr, "Prefix sentinel read error for %s: %s\n",
+ file, osstrerror());
+ status = 2;
+ }
+ else {
+ fprintf(stderr, "Prefix sentinel read error for %s: read only %d\n",
+ file, n);
+ status = 2;
+ }
+ }
+ if (len != xpectlen) {
+ fprintf(stderr, "Bad prefix sentinel value for %s: %d (%d expected)\n",
+ file, len, xpectlen);
+ status = 2;
+ }
+
+ /* check the suffix integer */
+ fseek(f, (long)(xpectlen - sizeof(len)), SEEK_SET);
+ n = (int)fread(&len, 1, sizeof(len), f);
+ len = ntohl(len);
+ if (n != sizeof(len)) {
+ if (feof(f)) {
+ fprintf(stderr, "Bad suffix sentinel read for %s: file too short\n",
+ file);
+ status = 2;
+ }
+ else if (ferror(f)) {
+ fprintf(stderr, "Suffix sentinel read error for %s: %s\n",
+ file, osstrerror());
+ status = 2;
+ }
+ else {
+ fprintf(stderr, "Suffix sentinel read error for %s: read only %d\n",
+ file, n);
+ status = 2;
+ }
+ }
+ if (len != xpectlen) {
+ fprintf(stderr, "Bad suffix sentinel value for %s: %d (%d expected)\n",
+ file, len, xpectlen);
+ status = 2;
+ }
+
+ /* check the label itself */
+ magic = logctl.l_label.ill_magic & 0xffffff00;
+ version = logctl.l_label.ill_magic & 0xff;
+ if (magic != PM_LOG_MAGIC) {
+ fprintf(stderr, "Bad magic (%x) in %s\n", magic, file);
+ status = 2;
+ }
+ if (version != PM_LOG_VERS02) {
+ fprintf(stderr, "Bad version (%x) in %s\n", version, file);
+ status = 2;
+ }
+
+ return version;
+}
+
+/*
+ * Check log control label with the known good "golden" label, if
+ * we have it yet. Passed in status is __pmLogChkLabel result, &
+ * we only use that to determine if this is good as a gold label.
+ */
+void
+compare_golden(FILE *f, const char *file, int sts, int warnings)
+{
+ __pmLogLabel *label = &logctl.l_label;
+
+ if (!gold) {
+ memcpy(&golden, label, sizeof(golden));
+ if ((gold = (sts >= 0)) != 0)
+ goldfile = strdup(file);
+ }
+ else if (warnings) {
+ int version = verify_label(f, file);
+
+ if (version != (golden.ill_magic & 0xff)) {
+ fprintf(stderr, "Mismatched version (%x/%x) between %s and %s\n",
+ version, golden.ill_magic & 0xff, file, goldfile);
+ status = 2;
+ }
+ if (label->ill_pid != golden.ill_pid) {
+ fprintf(stderr, "Mismatched PID (%d/%d) between %s and %s\n",
+ label->ill_pid, golden.ill_pid, file, goldfile);
+ status = 2;
+ }
+ if (strncmp(label->ill_hostname, golden.ill_hostname,
+ PM_LOG_MAXHOSTLEN) != 0) {
+ fprintf(stderr, "Mismatched hostname (%s/%s) between %s and %s\n",
+ label->ill_hostname, golden.ill_hostname, file, goldfile);
+ status = 2;
+ }
+ if (strncmp(label->ill_tz, golden.ill_tz, PM_TZ_MAXLEN) != 0) {
+ fprintf(stderr, "Mismatched timezone (%s/%s) between %s and %s\n",
+ label->ill_tz, golden.ill_tz, file, goldfile);
+ status = 2;
+ }
+ }
+}
+
+static pmLongOptions longopts[] = {
+ PMAPI_OPTIONS_HEADER("Options"),
+ { "host", 1, 'h', "HOSTNAME", "set the hostname for all files in archive" },
+ { "label", 0, 'l', 0, "dump the archive label" },
+ { "", 0, 'L', 0, "more verbose form of label dump" },
+ { "pid", 1, 'p', "PID", "set the logger process ID field for all files in archive" },
+ { "", 0, 's', 0, "write the label sentinel values for all files in archive" },
+ { "verbose", 0, 'v', 0, "run in verbose mode, reporting on each stage of checking" },
+ { "version", 1, 'V', "NUM", "write magic and version numbers for all files in archive" },
+ { "timezone", 1, 'Z', "TZ", "set the timezone for all files in archive" },
+ PMAPI_OPTIONS_END
+};
+
+static pmOptions opts = {
+ .short_options = "D:h:lLp:svV:Z:?",
+ .long_options = longopts,
+ .short_usage = "[options] archive",
+};
+
+int
+main(int argc, char *argv[])
+{
+ int c;
+ int sts;
+ int lflag = 0;
+ int Lflag = 0;
+ int verbose = 0;
+ int version = 0;
+ int readonly = 1;
+ int warnings = 1;
+ int pid = 0;
+ char *archive;
+ char *tz = NULL;
+ char *host = NULL;
+ char buffer[MAXPATHLEN];
+
+ while ((c = pmgetopt_r(argc, argv, &opts)) != EOF) {
+ switch (c) {
+ case 'D': /* debug flag */
+ sts = __pmParseDebug(opts.optarg);
+ if (sts < 0) {
+ pmprintf("%s: unrecognized debug flag specification (%s)\n",
+ pmProgname, opts.optarg);
+ opts.errors++;
+ }
+ else
+ pmDebug |= sts;
+ break;
+
+ case 'h': /* rewrite hostname */
+ host = opts.optarg;
+ readonly = 0;
+ break;
+
+ case 'l': /* dump label */
+ lflag = 1;
+ break;
+
+ case 'L': /* dump label (verbose) */
+ Lflag = 1;
+ break;
+
+ case 'p': /* rewrite pid */
+ pid = atoi(opts.optarg);
+ readonly = 0;
+ break;
+
+ case 's': /* rewrite sentinels */
+ readonly = 0;
+ break;
+
+ case 'v': /* verbose */
+ verbose = 1;
+ break;
+
+ case 'V': /* reset magic and version numbers */
+ version = atoi(opts.optarg);
+ if (version != PM_LOG_VERS02) {
+ fprintf(stderr, "%s: unknown version number (%s)\n",
+ pmProgname, opts.optarg);
+ opts.errors++;
+ }
+ readonly = 0;
+ break;
+
+ case 'Z': /* $TZ timezone */
+ tz = opts.optarg;
+ readonly = 0;
+ break;
+
+ case '?':
+ default:
+ opts.errors++;
+ break;
+ }
+ }
+
+ if (opts.optind != argc - 1) {
+ pmprintf("%s: insufficient arguments\n", pmProgname);
+ opts.errors++;
+ }
+
+ if (opts.errors) {
+ pmUsageMessage(&opts);
+ exit(1);
+ }
+
+ archive = argv[opts.optind];
+ warnings = (readonly || verbose);
+
+ if (verbose)
+ printf("Scanning for components of archive \"%s\"\n", archive);
+ if ((sts = __pmLogLoadLabel(&logctl, archive)) < 0) {
+ fprintf(stderr, "%s: Cannot open archive \"%s\": %s\n",
+ pmProgname, archive, pmErrStr(sts));
+ exit(1);
+ }
+
+ logctl.l_curvol = -1;
+ logctl.l_physend = -1;
+
+ /*
+ * Read the label from each data volume, check, and report status
+ */
+ for (c = logctl.l_minvol; c <= logctl.l_maxvol; c++) {
+ if (verbose)
+ printf("Checking label on data volume %d\n", c);
+ if ((sts = __pmLogChangeVol(&logctl, c)) < 0 && warnings) {
+ fprintf(stderr, "Bad data volume %d label: %s\n", c, pmErrStr(sts));
+ status = 2;
+ }
+ snprintf(buffer, sizeof(buffer), "data volume %d", c);
+ compare_golden(logctl.l_mfp, buffer, sts, warnings);
+ }
+
+ if (logctl.l_tifp) {
+ if (verbose)
+ printf("Checking label on temporal index\n");
+ if ((sts = __pmLogChkLabel(&logctl, logctl.l_tifp, &logctl.l_label,
+ PM_LOG_VOL_TI)) < 0 && warnings) {
+ fprintf(stderr, "Bad temporal index label: %s\n", pmErrStr(sts));
+ status = 2;
+ }
+ compare_golden(logctl.l_tifp, "temporal index", sts, warnings);
+ }
+ else if (verbose) {
+ printf("No temporal index found\n");
+ }
+
+ if (verbose)
+ printf("Checking label on metadata volume\n");
+ if ((sts = __pmLogChkLabel(&logctl, logctl.l_mdfp, &logctl.l_label,
+ PM_LOG_VOL_META)) < 0 && warnings) {
+ fprintf(stderr, "Bad metadata volume label: %s\n", pmErrStr(sts));
+ status = 2;
+ }
+ compare_golden(logctl.l_mdfp, "metadata volume", sts, warnings);
+
+ /*
+ * Now, make any modifications requested
+ */
+ if (!readonly) {
+ if (version)
+ golden.ill_magic = PM_LOG_MAGIC | version;
+ if (pid)
+ golden.ill_pid = pid;
+ if (host) {
+ memset(golden.ill_hostname, 0, sizeof(golden.ill_hostname));
+ strncpy(golden.ill_hostname, host, PM_LOG_MAXHOSTLEN-1);
+ golden.ill_hostname[PM_LOG_MAXHOSTLEN-1] = '\0';
+ }
+ if (tz) {
+ memset(golden.ill_tz, 0, sizeof(golden.ill_tz));
+ strncpy(golden.ill_tz, tz, PM_TZ_MAXLEN-1);
+ golden.ill_tz[PM_TZ_MAXLEN-1] = '\0';
+ }
+
+ if (logctl.l_mfp)
+ fclose(logctl.l_mfp);
+ for (c = logctl.l_minvol; c <= logctl.l_maxvol; c++) {
+ if (verbose)
+ printf("Writing label on data volume %d\n", c);
+ golden.ill_vol = c;
+ snprintf(buffer, sizeof(buffer), "%s.%d", logctl.l_name, c);
+ if ((logctl.l_mfp = fopen(buffer, "r+")) == NULL) {
+ fprintf(stderr, "Failed data volume %d open: %s\n",
+ c, osstrerror());
+ status = 3;
+ }
+ else if ((sts = __pmLogWriteLabel(logctl.l_mfp, &golden)) < 0) {
+ fprintf(stderr, "Failed data volume %d label write: %s\n",
+ c, pmErrStr(sts));
+ status = 3;
+ }
+ if (logctl.l_mfp)
+ fclose(logctl.l_mfp);
+ }
+ /* Need to reset the data volume, for subsequent label read */
+ logctl.l_mfp = NULL;
+ logctl.l_curvol = -1;
+ __pmLogChangeVol(&logctl, logctl.l_minvol);
+
+ if (logctl.l_tifp) {
+ fclose(logctl.l_tifp);
+ if (verbose)
+ printf("Writing label on temporal index\n");
+ golden.ill_vol = PM_LOG_VOL_TI;
+ snprintf(buffer, sizeof(buffer), "%s.index", logctl.l_name);
+ if ((logctl.l_tifp = fopen(buffer, "r+")) == NULL) {
+ fprintf(stderr, "Failed temporal index open: %s\n",
+ osstrerror());
+ status = 3;
+ }
+ else if ((sts = __pmLogWriteLabel(logctl.l_tifp, &golden)) < 0) {
+ fprintf(stderr, "Failed temporal index label write: %s\n",
+ pmErrStr(sts));
+ status = 3;
+ }
+ }
+
+ fclose(logctl.l_mdfp);
+ if (verbose)
+ printf("Writing label on metadata volume\n");
+ golden.ill_vol = PM_LOG_VOL_META;
+ snprintf(buffer, sizeof(buffer), "%s.meta", logctl.l_name);
+ if ((logctl.l_mdfp = fopen(buffer, "r+")) == NULL) {
+ fprintf(stderr, "Failed metadata volume open: %s\n",
+ osstrerror());
+ status = 3;
+ }
+ else if ((sts = __pmLogWriteLabel(logctl.l_mdfp, &golden)) < 0) {
+ fprintf(stderr, "Failed metadata volume label write: %s\n",
+ pmErrStr(sts));
+ status = 3;
+ }
+ }
+
+ /*
+ * Finally, dump out the label if requested
+ */
+ if (lflag || Lflag) {
+ char *ddmm;
+ char *yr;
+ struct timeval tv;
+ time_t t = golden.ill_start.tv_sec;
+
+ printf("Log Label (Log Format Version %d)\n", golden.ill_magic & 0xff);
+ printf("Performance metrics from host %s\n", golden.ill_hostname);
+
+ ddmm = pmCtime(&t, buffer);
+ ddmm[10] = '\0';
+ yr = &ddmm[20];
+ printf(" commencing %s ", ddmm);
+ tv.tv_sec = golden.ill_start.tv_sec;
+ tv.tv_usec = golden.ill_start.tv_usec;
+ __pmPrintStamp(stdout, &tv);
+ printf(" %4.4s\n", yr);
+ if (__pmLogChangeVol(&logctl, 0) < 0)
+ printf(" ending UNKNOWN\n");
+ else if (__pmGetArchiveEnd(&logctl, &tv) < 0)
+ printf(" ending UNKNOWN\n");
+ else {
+ ddmm = pmCtime(&tv.tv_sec, buffer);
+ ddmm[10] = '\0';
+ yr = &ddmm[20];
+ printf(" ending %s ", ddmm);
+ __pmPrintStamp(stdout, &tv);
+ printf(" %4.4s\n", yr);
+ }
+ if (Lflag) {
+ printf("Archive timezone: %s\n", golden.ill_tz);
+ printf("PID for pmlogger: %d\n", golden.ill_pid);
+ }
+ }
+
+ exit(status);
+}
generated by cgit v1.2.3 (git 2.39.1) at 2024-06-10 05:49:13 +0000