/*
* Verify that all MOIRA updates are successful
*
- * Copyright 1988 by the Massachusetts Institute of Technology. For copying
- * and distribution information, see the file "mit-copyright.h".
+ * Copyright 1988, 1991 by the Massachusetts Institute of Technology.
+ * For copying and distribution information, see the file "mit-copyright.h".
*
- * $Source$
* $Header$
* $Author$
*/
#include <moira.h>
#include <moira_site.h>
#include "mit-copyright.h"
+#include <sys/time.h>
+#include <strings.h>
-char *malloc(), *rindex(), *strsave();
+char *malloc();
-static int status;
+static int count = 0;
static char *whoami;
+static struct timeval now;
+struct service {
+ char name[17];
+ char update_int[10];
+};
+
+
+/* turn an ascii string containing the number of seconds sinc the epoch
+ * into an ascii string containing the corresponding time & date
+ */
+
char *atot(itime)
char *itime;
{
return(&ct[4]);
}
-gserv(argc, argv, sq)
+
+/* Decide if the server has an error or not. Also, save the name and
+ * interval for later use.
+ */
+
+process_server(argc, argv, sq)
int argc;
char **argv;
struct save_queue *sq;
{
- char *tmp;
+ struct service *s;
- tmp = strsave(atot(argv[4]));
- printf("Service %s, error %s: %s\n\tlast success %s, last try %s\n",
- argv[0], argv[9], argv[10], tmp, atot(argv[5]));
- free(tmp);
+ if (atoi(argv[SVC_ENABLE])) {
+ s = (struct service *)malloc(sizeof(struct service));
+ strcpy(s->name, argv[SVC_SERVICE]);
+ strcpy(s->update_int, argv[SVC_INTERVAL]);
+ sq_save_data(sq, s);
+ }
+
+ if (atoi(argv[SVC_HARDERROR]) && atoi(argv[SVC_ENABLE])) {
+ disp_svc(argv, "Error needs to be reset\n");
+ } else if (atoi(argv[SVC_HARDERROR]) ||
+ (!atoi(argv[SVC_ENABLE]) && atoi(argv[SVC_DFCHECK]))) {
+ disp_svc(argv, "Should this be enabled?\n");
+ } else if (atoi(argv[SVC_ENABLE]) &&
+ 60 * atoi(argv[SVC_INTERVAL]) + 86400 + atoi(argv[SVC_DFCHECK])
+ < now.tv_sec) {
+ disp_svc(argv, "Service has not been updated\n");
+ }
return(MR_CONT);
}
-ghost(argc, argv, sq)
-int argc;
+
+/* Format the information about a service. */
+
+disp_svc(argv, msg)
char **argv;
-struct save_queue *sq;
+char *msg;
{
- char *tmp;
-
- tmp = strsave(atot(argv[9]));
- printf("Host %s:%s, error %s: %s\n\tlast success %s, last try %s\n",
- argv[0], argv[1], argv[6], argv[7], tmp, atot(argv[8]));
+ char *tmp = strsave(atot(argv[SVC_DFGEN]));
+
+ printf("Service %s Interval %s %s/%s/%s %s\n",
+ argv[SVC_SERVICE], argv[SVC_INTERVAL],
+ atoi(argv[SVC_ENABLE]) ? "Enabled" : "Disabled",
+ atoi(argv[SVC_INPROGRESS]) ? "InProgress" : "Idle",
+ atoi(argv[SVC_HARDERROR]) ? "Error" : "NoError",
+ atoi(argv[SVC_HARDERROR]) ? argv[SVC_ERRMSG] : "");
+ printf(" Generated %s; Last checked %s\n", tmp, atot(argv[SVC_DFCHECK]));
+ printf(" Last modified by %s at %s with %s\n",
+ argv[SVC_MODBY], argv[SVC_MODTIME], argv[SVC_MODWITH]);
+ printf(" * %s\n", msg);
+ count++;
free(tmp);
- return(MR_CONT);
}
-save_args(argc, argv, sq)
+
+/* Decide if the host has an error or not.
+ */
+
+process_host(argc, argv, sq)
int argc;
char **argv;
struct save_queue *sq;
{
- sq_save_args(argc, argv, sq);
+ struct service *s = NULL;
+ struct save_queue *sq1;
+ char *update_int = NULL;
+
+ for (sq1 = sq->q_next; sq1 != sq; sq1 = sq1->q_next)
+ if ((s = (struct service *)sq1->q_data) &&
+ !strcmp(s->name, argv[SH_SERVICE]))
+ break;
+ if (s && !strcmp(s->name, argv[SH_SERVICE]))
+ update_int = s->update_int;
+
+ if (atoi(argv[SH_HOSTERROR]) && atoi(argv[SH_ENABLE])) {
+ disp_sh(argv, "Error needs to be reset\n");
+ } else if (atoi(argv[SH_HOSTERROR]) ||
+ (!atoi(argv[SH_ENABLE]) && atoi(argv[SH_LASTTRY]))) {
+ disp_sh(argv, "Should this be enabled?\n");
+ } else if (atoi(argv[SH_ENABLE]) && update_int &&
+ 60 * atoi(update_int) + 86400 + atoi(argv[SH_LASTSUCCESS])
+ < now.tv_sec) {
+ disp_sh(argv, "Host has not been updated\n");
+ }
return(MR_CONT);
}
-main(argc, argv)
- char *argv[];
+/* Format the information about a host. */
+
+disp_sh(argv, msg)
+char **argv;
+char *msg;
+{
+ char *tmp = strsave(atot(argv[SH_LASTTRY]));
+
+ printf("Host %s:%s %s/%s/%s/%s/%s %s\n",
+ argv[SH_SERVICE], argv[SH_MACHINE],
+ atoi(argv[SH_ENABLE]) ? "Enabled" : "Disabled",
+ atoi(argv[SH_SUCCESS]) ? "Success" : "Failure",
+ atoi(argv[SH_INPROGRESS]) ? "InProgress" : "Idle",
+ atoi(argv[SH_OVERRIDE]) ? "Override" : "Normal",
+ atoi(argv[SH_HOSTERROR]) ? "Error" : "NoError",
+ atoi(argv[SH_HOSTERROR]) ? argv[SH_ERRMSG] : "");
+ printf(" Last try %s; Last success %s\n", tmp, atot(argv[SH_LASTSUCCESS]));
+ printf(" Last modified by %s at %s with %s\n",
+ argv[SH_MODBY], argv[SH_MODTIME], argv[SH_MODWITH]);
+ printf(" * %s\n", msg);
+ count++;
+ free(tmp);
+}
+
+
+
+
+main(argc, argv)
+int argc;
+char *argv[];
{
- char *args[6], buf[BUFSIZ], **service, **host, *motd;
- struct save_queue *services, *hosts;
- int count = 0, scream();
+ char *args[2], buf[BUFSIZ], *motd;
+ struct save_queue *sq;
+ int status;
+ int scream();
if ((whoami = rindex(argv[0], '/')) == NULL)
whoami = argv[0];
exit(2);
}
if (motd) {
- fprintf(stderr, "The Moira server is currently unavailable:\n%s\n", motd);
+ fprintf(stderr, "The Moira server is currently unavailable:\n%s\n",
+ motd);
mr_disconnect();
exit(2);
}
goto punt;
}
- services = sq_create();
- args[0] = args[2] = "TRUE";
- args[1] = "DONTCARE";
- if ((status = mr_query("qualified_get_server", 3, args, save_args,
- (char *)services)) &&
- status != MR_NO_MATCH)
- com_err(whoami, status, " while getting servers");
+ gettimeofday(&now, 0);
+ sq = sq_create();
- hosts = sq_create();
+ /* Check services first */
args[0] = "*";
- args[1] = args[5] = "TRUE";
- args[2] = args[3] = args[4] = "DONTCARE";
- if ((status = mr_query("qualified_get_server_host", 6, args, save_args,
- (char *)hosts)) &&
+ if ((status = mr_query("get_server_info", 1, args,
+ process_server, (char *)sq)) &&
status != MR_NO_MATCH)
- com_err(whoami, status, " while getting server/hosts");
-
- while (sq_get_data(services, &service)) {
- count++;
- if (status = mr_query("get_server_info", 1, service, gserv, NULL))
- com_err(whoami, status, " while getting info about service %s",
- service[0]);
- }
+ com_err(whoami, status, " while getting servers");
- while (sq_get_data(hosts, &host)) {
- count++;
- if (status = mr_query("get_server_host_info", 2, host, ghost, NULL))
- com_err(whoami, status, " while getting info about host %s:%s",
- host[0], host[1]);
- }
+ args[1] = "*";
+ if ((status = mr_query("get_server_host_info", 2, args,
+ process_host, (char *)sq)) &&
+ status != MR_NO_MATCH)
+ com_err(whoami, status, " while getting servers");
if (!count)
- strcpy(buf, "Nothing has failed at this time");
+ printf("Nothing has failed at this time\n");
else
- sprintf(buf, "%d thing%s ha%s failed at this time", count,
- count == 1 ? "" : "s", count == 1 ? "s" : "ve");
- puts(buf);
+ printf("%d thing%s ha%s failed at this time\n", count,
+ count == 1 ? "" : "s", count == 1 ? "s" : "ve");
mr_disconnect();
exit(0);
scream()
{
- com_err(whoami, status, "Update to Moira returned a value -- \
-programmer botch.\n");
+ com_err(whoami, 0,
+ "Update to Moira returned a value -- programmer botch.\n");
mr_disconnect();
exit(1);
}
andersk / moira.git / commitdiff
