[moira.git] / clients / moira / dcmmaint.c

/* $Header$
 *
 * Copyright 1987, 1988 by the Massachusetts Institute of Technology.
 * For copying and distribution information, please see the file
 * <mit-copyright.h>.
 */

#include <stdio.h>
#include <strings.h>
#include <ctype.h>
#include <moira.h>
#include <moira_site.h>
#include <menu.h>

#include "mit-copyright.h"
#include "defs.h"
#include "f_defs.h"
#include "globals.h"

extern char *whoami;
static char buf[BUFSIZ];
char *unparse_interval(), *canonicalize_hostname();
char *atot();

#define DCM_ENABLE_FLAG 0

genable(argc, argv, info)
int argc;
char **argv;
char **info;
{
    info[1] = strsave(argv[0]);
    return(MR_CONT);
}

EnableDcm(argc, argv)
int argc;
char **argv;
{
    int status;
    char *info[3];

    info[0] = "dcm_enable";
    if (status = do_mr_query("get_value", 1, info, genable, info))
      com_err(whoami, status, " while getting value of dcm_enable");
    GetValueFromUser("Enable value", &info[1]);
    if (status = do_mr_query("update_value", 2, info, Scream, NULL))
      com_err(whoami, status, " while updating value of dcm_enable");
    FreeAndClear(&info[0], FALSE);
    FreeAndClear(&info[1], TRUE);
    return(DM_NORMAL);
}


int shserv(argc, argv)
int argc;
char **argv;
{
    char tmp[64], *dfgen;

    Put_message("Name       Type     Owner       Modified");
    sprintf(tmp, "%s:%s", argv[SVC_ACE_TYPE], argv[SVC_ACE_NAME]);
    sprintf(buf, "%-10s %-8s %-11s by %s on %s with %s", argv[SVC_SERVICE],
	    argv[SVC_TYPE], tmp, argv[SVC_MODBY], argv[SVC_MODTIME],
	    argv[SVC_MODWITH]);
    Put_message(buf);
    sprintf(buf, "  Interval %s, Target:%s, Script:%s",
	    unparse_interval(atoi(argv[SVC_INTERVAL])), argv[SVC_TARGET],
	    argv[SVC_SCRIPT]);
    Put_message(buf);
    if (atoi(argv[SVC_HARDERROR]))
      sprintf(tmp, "Error %d: %s", atoi(argv[SVC_HARDERROR]), argv[SVC_ERRMSG]);
    else
      strcpy(tmp, "No error");
    dfgen = strsave(atot(argv[SVC_DFGEN]));
    sprintf(buf, "  Generated %s; Last Checked %s", dfgen,
	    atot(argv[SVC_DFCHECK]));
    free(dfgen);
    Put_message(buf);
    sprintf(buf, "  %s/%s/%s", atoi(argv[SVC_ENABLE]) ? "Enabled" : "Disabled",
	    atoi(argv[SVC_INPROGRESS]) ? "InProgress" : "Idle", tmp);
    Put_message(buf);
    Put_message("");
    return(MR_CONT);
}


showserv(argc, argv)
int argc;
char **argv;
{
    char *qargv[1];
    int status;	
 
    qargv[0] = argv[1];
    if (status = do_mr_query("get_server_info", 1, qargv, shserv, NULL))
      com_err(whoami, status, " while getting server info");
    return(DM_NORMAL);
}


char *unparse_interval(i)
int i;
{
    static char uibuf[10];

    sprintf(uibuf, "%02d:%02d:00", i / 60, i % 60);
    return(uibuf);
}

addserv(argc, argv)
int argc;
char **argv;
{
    int status;
    char *info[8];

    initserv(argv[1], info);
    askserv(info);
    if (status = do_mr_query("add_server_info", 8, info, Scream, NULL))
      com_err(whoami, status, " while updating server info");
    FreeInfo(info);
    return(DM_NORMAL);
}

askserv(info)
char **info;
{
    GetValueFromUser("Interval", &info[SC_INTERVAL]);
    GetValueFromUser("Target", &info[SC_TARGET]);
    GetValueFromUser("Script", &info[SC_SCRIPT]);
    GetTypeFromUser("Service type", "service", &info[SC_TYPE]);
    GetValueFromUser("Enable", &info[SC_ENABLE]);
    GetTypeFromUser("ACE type", "ace_type", &info[SC_ACE_TYPE]);
    if (strcasecmp("none", info[SC_ACE_TYPE]))
      GetValueFromUser("Ace name", &info[SC_ACE_NAME]);
}


gserv(argc, argv, cargv)
int argc;
char **argv;
char **cargv;
{
    cargv[SC_SERVICE] = strsave(argv[SVC_SERVICE]);
    cargv[SC_INTERVAL] = strsave(argv[SVC_INTERVAL]);
    cargv[SC_TARGET] = strsave(argv[SVC_TARGET]);
    cargv[SC_SCRIPT] = strsave(argv[SVC_SCRIPT]);
    cargv[SC_TYPE] = strsave(argv[SVC_TYPE]);
    cargv[SC_ENABLE] = strsave(argv[SVC_ENABLE]);
    cargv[SC_ACE_TYPE] = strsave(argv[SVC_ACE_TYPE]);
    cargv[SC_ACE_NAME] = strsave(argv[SVC_ACE_NAME]);
    cargv[SC_END] = NULL;
    return(MR_CONT);
}

initserv(name, argv)
char *name;
char **argv;
{
    char tmp[BUFSIZ];

    argv[SC_SERVICE] = strsave(name);
    argv[SC_INTERVAL] = strsave("1440");
    sprintf(tmp, "/tmp/%s.out", name);
    argv[SC_TARGET] = strsave(tmp);
    sprintf(tmp, "/u1/mr/bin/%s.sh", name);
    argv[SC_SCRIPT] = strsave(tmp);
    argv[SC_TYPE] = strsave("UNIQUE");
    argv[SC_ENABLE] = strsave("1");
    argv[SC_ACE_TYPE] = strsave("LIST");
    argv[SC_ACE_NAME] = strsave("dbadmin");
    argv[SC_END] = NULL;
}


updateserv(argc, argv)
int argc;
char **argv;
{
    char *qargv[9];
    int status;

    qargv[0] = (char *)argv[1];
    if (status = do_mr_query("get_server_info", 1,
			      qargv, gserv, (char *)qargv)) {
	com_err(whoami, status, " while getting server info");
	return(DM_NORMAL);
    }
    askserv(qargv);
    if (status = do_mr_query("update_server_info", 8, qargv, Scream, NULL))
      com_err(whoami, status, " while updating server info");
    return(DM_NORMAL);
}


int shhost(argc, argv)
int argc;
char **argv;
{
    char tmp[64], *ltt;

    sprintf(buf, "%s:%s  mod by %s on %s with %s", argv[SH_MACHINE],
	    argv[SH_SERVICE], argv[SH_MODBY], argv[SH_MODTIME],
	    argv[SH_MODWITH]);
    Put_message(buf);
    if (atoi(argv[SH_HOSTERROR]))
      sprintf(tmp, "Error %d: %s", atoi(argv[SH_HOSTERROR]), argv[SH_ERRMSG]);
    else
      strcpy(tmp, "No error");
    sprintf(buf, "  %s/%s/%s/%s/%s",
	    atoi(argv[SH_ENABLE]) ? "Enabled" : "Disabled",
	    atoi(argv[SH_SUCCESS]) ? "Success" : "Failure",
	    atoi(argv[SH_INPROGRESS]) ? "InProgress" : "Idle",
	    atoi(argv[SH_OVERRIDE]) ? "Override" : "Normal", tmp);
    Put_message(buf);
    Put_message("  Last Try             Last Success         Value1    Value2    Value3");
    ltt = strsave(atot(argv[SH_LASTTRY]));
    sprintf(buf, "  %-20s %-20s %-9d %-9d %s", ltt, atot(argv[SH_LASTSUCCESS]),
	    atoi(argv[SH_VALUE1]), atoi(argv[SH_VALUE2]), argv[SH_VALUE3]);
    free(ltt);
    Put_message(buf);
    Put_message("");
    return(MR_CONT);
}


showhost(argc, argv)
int argc;
char **argv;
{
    char *qargv[2];
    int status;

    qargv[SHI_SERVICE] = argv[1];
    qargv[SHI_MACHINE] = canonicalize_hostname(argv[2]);
    if (status = do_mr_query("get_server_host_info", 2, qargv, shhost, NULL))
      com_err(whoami, status, " getting server/host info");
    return(DM_NORMAL);
}


resetsrverr(argc, argv)
int argc;
char  **argv;
{
    int status;
    if (status = do_mr_query("reset_server_error", 1, &argv[1], Scream, NULL))
      com_err(whoami, status, " while resetting server error");
    return(DM_NORMAL);
}


resetsrvc(argc, argv)
int argc;
char **argv;
{
    int status;
    char *qargv[5], buf[BUFSIZ];

    sprintf(buf, "Reset state for service %s (Y/N)", argv[1]);
    if (!Confirm(buf))
      return(DM_NORMAL);
    qargv[0] = argv[1];
    qargv[1] = "0";
    qargv[2] = "0";
    qargv[3] = "0";
    qargv[4] = "0";
    qargv[5] = "";
    if (status = do_mr_query("set_server_internal_flags", 6, qargv,
			      Scream, NULL))
      com_err(whoami, status, " while resetting server error");
    return(DM_NORMAL);
}


resethosterr(argc, argv)
int argc;
char  **argv;
{
    int status;

    argv[2] = canonicalize_hostname(argv[2]);
    if (status = do_mr_query("reset_server_host_error", 2, &argv[1],
			      Scream, NULL))
      com_err(whoami, status, " while resetting server/host error");
    return(DM_NORMAL);
}


resethost(argc, argv)
int argc;
char **argv;
{
    int status;
    char *qargv[9], buf[BUFSIZ];

    sprintf(buf, "Reset state for service %s on host %s (Y/N)", argv[1],
	    canonicalize_hostname(argv[2]));
    if (!Confirm(buf))
      return(DM_NORMAL);
    qargv[0] = argv[1];
    qargv[1] = canonicalize_hostname(argv[2]);
    qargv[2] = "0";
    qargv[3] = "0";
    qargv[4] = "0";
    qargv[5] = "0";
    qargv[6] = "";
    qargv[7] = "0";
    qargv[8] = "0";
    if (status = do_mr_query("set_server_host_internal", 9, qargv,
			      Scream, NULL))
      com_err(whoami, status, " while resetting server/host error");
    return(DM_NORMAL);
}


sethostor(argc, argv)
int argc;
char  **argv;
{
    int status;

    argv[2] = canonicalize_hostname(argv[2]);
    if (status = do_mr_query("set_server_host_override", 2, &argv[1],
			      Scream, NULL))
      com_err(whoami, status, " while setting server/host override");
    return(DM_NORMAL);
}


ghost(argc, argv, cargv)
int argc;
char **argv;
char **cargv;
{
    cargv[SHI_SERVICE] = strsave(argv[SH_SERVICE]);
    cargv[SHI_MACHINE] = strsave(argv[SH_MACHINE]);
    cargv[SHI_ENABLE] = strsave(argv[SH_ENABLE]);
    cargv[SHI_VALUE1] = strsave(argv[SH_VALUE1]);
    cargv[SHI_VALUE2] = strsave(argv[SH_VALUE2]);
    cargv[SHI_VALUE3] = strsave(argv[SH_VALUE3]);
    cargv[SHI_END] = NULL;
    return(MR_CONT);
}


inithost(info)
char **info;
{
    info[SHI_MACHINE] = strsave(canonicalize_hostname(info[SH_MACHINE]));
    info[SHI_ENABLE] = strsave("1");
    info[SHI_VALUE1] = strsave("0");
    info[SHI_VALUE2] = strsave("0");
    info[SHI_VALUE3] = strsave("");
    info[SHI_END] = NULL;
}


askhost(info)
char **info;
{
    GetValueFromUser("Enable", &info[SHI_ENABLE]);
    GetValueFromUser("Value 1", &info[SHI_VALUE1]);
    GetValueFromUser("Value 2", &info[SHI_VALUE2]);
    GetValueFromUser("Value 3", &info[SHI_VALUE3]);
}


updatehost(argc, argv)
int argc;
char **argv;
{
    char *info[SHI_END+1];
    int status;

    info[SHI_SERVICE] = strsave(argv[1]);
    info[SHI_MACHINE] = strsave(canonicalize_hostname(argv[2]));
    if (status = do_mr_query("get_server_host_info", 2, info, ghost, 
			      (char *)info)) {
	com_err(whoami, status, " while getting server/host info");
	return(DM_NORMAL);
    }
    askhost(info);
    if (status = do_mr_query("update_server_host_info", SHI_END, info,
			      Scream, NULL))
      com_err(whoami, status, " while updating server/host info");
    FreeInfo(info);
    return(DM_NORMAL);
}


addhost(argc, argv)
int argc;
char **argv;
{
    char *info[SHI_END+1];
    int status;

    info[SHI_SERVICE] = strsave(argv[1]);
    info[SHI_MACHINE] = strsave(canonicalize_hostname(argv[2]));
    inithost(info);
    askhost(info);
    if (status = do_mr_query("add_server_host_info", 6, info, Scream, NULL))
      com_err(whoami, status, " while adding server/host info");
    FreeInfo(info);
    return(DM_NORMAL);
}


delserv(argc, argv)
int argc;
char **argv;
{
    int status;

    if (status = do_mr_query("delete_server_info", 1, &argv[1], Scream, NULL))
      com_err(whoami, status, " while deleting server info");
    return(DM_NORMAL);
}


delhost(argc, argv)
int argc;
char **argv;
{
    int status;

    argv[2] = canonicalize_hostname(argv[2]);
    if (status = do_mr_query("delete_server_host_info", 2, &argv[1],
			      Scream, NULL))
      com_err(whoami, status, " while deleting server/host info");
    return(DM_NORMAL);
}


pserv(argc, argv, count)
int argc;
char **argv;
int *count;
{
    sprintf(buf, "Service %s", argv[0]);
    Put_message(buf);
    (*count)++;
    return(MR_CONT);
}

phost(argc, argv, count)
int argc;
char **argv;
int *count;
{
    sprintf(buf, "Host %s:%s", argv[0], argv[1]);
    Put_message(buf);
    (*count)++;
    return(MR_CONT);
}


InProgress()
{
    char *argv[6];
    int status, count = 0;

    argv[0] = argv[2] = "DONTCARE";
    argv[1] = "TRUE";
    if ((status = do_mr_query("qualified_get_server", 3, argv, pserv, 
			       (char *)&count)) &&
	status != MR_NO_MATCH)
      com_err(whoami, status, " while getting servers");
    argv[0] = "*";
    argv[1] = argv[2] = argv[3] = argv[5] = "DONTCARE";
    argv[4] = "TRUE";
    if ((status = do_mr_query("qualified_get_server_host",6,argv,phost,
			       (char *)&count)) &&
	status != MR_NO_MATCH)
      com_err(whoami, status, " while getting server/hosts");
    if (!count)
      strcpy(buf, "Nothing is in progress at this time");
    else
      sprintf(buf, "%d update%s in progress at this time", count,
	      count == 1 ? "" : "s");
    Put_message(buf);
    return(DM_NORMAL);
}

DcmFailed()
{
    char *argv[6];
    int status, count = 0;

    argv[0] = argv[1] = "DONTCARE";
    argv[2] = "TRUE";
    if ((status = do_mr_query("qualified_get_server", 3, argv, pserv, 
			       (char *)&count)) &&
	status != MR_NO_MATCH)
      com_err(whoami, status, " while getting servers");
    argv[0] = "*";
    argv[1] = argv[2] = argv[3] = argv[4] = "DONTCARE";
    argv[5] = "TRUE";
    if ((status = do_mr_query("qualified_get_server_host",6,argv,phost,
			       (char *)&count)) &&
	status != MR_NO_MATCH)
      com_err(whoami, status, " while getting server/hosts");
    if (!count)
      strcpy(buf, "Nothing has failed at this time");
    else
      sprintf(buf, "%d thing%s ha%s failed at this time", count,
	      count == 1 ? "" : "s", count == 1 ? "s" : "ve");
    Put_message(buf);
    return(DM_NORMAL);
}


Dcm()
{
    int status;
    if (status = mr_do_update())
      com_err(whoami, status, " while triggering update");
    return(DM_NORMAL);
}


char *atot(itime)
char *itime;
{
    int time;
    char *ct, *ctime();

    time = atoi(itime);
    ct = ctime(&time);
    ct[24] = 0;
    return(&ct[4]);
}
Commit	Line	Data
cc5b487a	1	/* $Header$
44d40e72	2	*
	3	* Copyright 1987, 1988 by the Massachusetts Institute of Technology.
	4	* For copying and distribution information, please see the file
	5	* <mit-copyright.h>.
cc5b487a	6	*/
	7
	8	#include <stdio.h>
	9	#include <strings.h>
	10	#include <ctype.h>
8defc06b	11	#include <moira.h>
8defc06b	12	#include <moira_site.h>
cc5b487a	13	#include <menu.h>
	14
	15	#include "mit-copyright.h"
	16	#include "defs.h"
	17	#include "f_defs.h"
	18	#include "globals.h"
cc5b487a	19
3ed06d63	20	extern char *whoami;
cc5b487a	21	static char buf[BUFSIZ];
44d40e72	22	char unparse_interval(), canonicalize_hostname();
cc5b487a	23	char *atot();
	24
	25	#define DCM_ENABLE_FLAG 0
	26
44d40e72	27	genable(argc, argv, info)
cc5b487a	28	int argc;
cc5b487a	29	char **argv;
44d40e72	30	char **info;
cc5b487a	31	{
44d40e72	32	info[1] = strsave(argv[0]);
8defc06b	33	return(MR_CONT);
cc5b487a	34	}
cc5b487a	35
3ed06d63	36	EnableDcm(argc, argv)
cc5b487a	37	int argc;
	38	char **argv;
	39	{
44d40e72	40	int status;
44d40e72	41	char *info[3];
cc5b487a	42
44d40e72	43	info[0] = "dcm_enable";
8defc06b	44	if (status = do_mr_query("get_value", 1, info, genable, info))
cc5b487a	45	com_err(whoami, status, " while getting value of dcm_enable");
44d40e72	46	GetValueFromUser("Enable value", &info[1]);
8defc06b	47	if (status = do_mr_query("update_value", 2, info, Scream, NULL))
cc5b487a	48	com_err(whoami, status, " while updating value of dcm_enable");
44d40e72	49	FreeAndClear(&info[0], FALSE);
44d40e72	50	FreeAndClear(&info[1], TRUE);
cc5b487a	51	return(DM_NORMAL);
	52	}
	53
	54
	55	int shserv(argc, argv)
	56	int argc;
	57	char **argv;
	58	{
	59	char tmp[64], *dfgen;
	60
44d40e72	61	Put_message("Name Type Owner Modified");
	62	sprintf(tmp, "%s:%s", argv[SVC_ACE_TYPE], argv[SVC_ACE_NAME]);
	63	sprintf(buf, "%-10s %-8s %-11s by %s on %s with %s", argv[SVC_SERVICE],
	64	argv[SVC_TYPE], tmp, argv[SVC_MODBY], argv[SVC_MODTIME],
	65	argv[SVC_MODWITH]);
cc5b487a	66	Put_message(buf);
cc5b487a	67	sprintf(buf, " Interval %s, Target:%s, Script:%s",
44d40e72	68	unparse_interval(atoi(argv[SVC_INTERVAL])), argv[SVC_TARGET],
44d40e72	69	argv[SVC_SCRIPT]);
cc5b487a	70	Put_message(buf);
44d40e72	71	if (atoi(argv[SVC_HARDERROR]))
44d40e72	72	sprintf(tmp, "Error %d: %s", atoi(argv[SVC_HARDERROR]), argv[SVC_ERRMSG]);
cc5b487a	73	else
cc5b487a	74	strcpy(tmp, "No error");
44d40e72	75	dfgen = strsave(atot(argv[SVC_DFGEN]));
	76	sprintf(buf, " Generated %s; Last Checked %s", dfgen,
	77	atot(argv[SVC_DFCHECK]));
cc5b487a	78	free(dfgen);
cc5b487a	79	Put_message(buf);
44d40e72	80	sprintf(buf, " %s/%s/%s", atoi(argv[SVC_ENABLE]) ? "Enabled" : "Disabled",
44d40e72	81	atoi(argv[SVC_INPROGRESS]) ? "InProgress" : "Idle", tmp);
cc5b487a	82	Put_message(buf);
cc5b487a	83	Put_message("");
8defc06b	84	return(MR_CONT);
cc5b487a	85	}
	86
	87
	88	showserv(argc, argv)
	89	int argc;
	90	char **argv;
	91	{
	92	char *qargv[1];
	93	int status;
	94
	95	qargv[0] = argv[1];
8defc06b	96	if (status = do_mr_query("get_server_info", 1, qargv, shserv, NULL))
cc5b487a	97	com_err(whoami, status, " while getting server info");
	98	return(DM_NORMAL);
	99	}
	100
	101
	102	char *unparse_interval(i)
	103	int i;
	104	{
	105	static char uibuf[10];
	106
	107	sprintf(uibuf, "%02d:%02d:00", i / 60, i % 60);
	108	return(uibuf);
	109	}
	110
	111	addserv(argc, argv)
	112	int argc;
	113	char **argv;
	114	{
cc5b487a	115	int status;
44d40e72	116	char *info[8];
cc5b487a	117
44d40e72	118	initserv(argv[1], info);
44d40e72	119	askserv(info);
8defc06b	120	if (status = do_mr_query("add_server_info", 8, info, Scream, NULL))
cc5b487a	121	com_err(whoami, status, " while updating server info");
44d40e72	122	FreeInfo(info);
cc5b487a	123	return(DM_NORMAL);
	124	}
	125
44d40e72	126	askserv(info)
	127	char **info;
	128	{
	129	GetValueFromUser("Interval", &info[SC_INTERVAL]);
	130	GetValueFromUser("Target", &info[SC_TARGET]);
	131	GetValueFromUser("Script", &info[SC_SCRIPT]);
	132	GetTypeFromUser("Service type", "service", &info[SC_TYPE]);
	133	GetValueFromUser("Enable", &info[SC_ENABLE]);
	134	GetTypeFromUser("ACE type", "ace_type", &info[SC_ACE_TYPE]);
	135	if (strcasecmp("none", info[SC_ACE_TYPE]))
	136	GetValueFromUser("Ace name", &info[SC_ACE_NAME]);
	137	}
	138
cc5b487a	139
	140	gserv(argc, argv, cargv)
	141	int argc;
	142	char **argv;
	143	char **cargv;
	144	{
44d40e72	145	cargv[SC_SERVICE] = strsave(argv[SVC_SERVICE]);
	146	cargv[SC_INTERVAL] = strsave(argv[SVC_INTERVAL]);
	147	cargv[SC_TARGET] = strsave(argv[SVC_TARGET]);
	148	cargv[SC_SCRIPT] = strsave(argv[SVC_SCRIPT]);
	149	cargv[SC_TYPE] = strsave(argv[SVC_TYPE]);
	150	cargv[SC_ENABLE] = strsave(argv[SVC_ENABLE]);
	151	cargv[SC_ACE_TYPE] = strsave(argv[SVC_ACE_TYPE]);
	152	cargv[SC_ACE_NAME] = strsave(argv[SVC_ACE_NAME]);
	153	cargv[SC_END] = NULL;
8defc06b	154	return(MR_CONT);
cc5b487a	155	}
cc5b487a	156
44d40e72	157	initserv(name, argv)
	158	char *name;
	159	char **argv;
cc5b487a	160	{
44d40e72	161	char tmp[BUFSIZ];
	162
	163	argv[SC_SERVICE] = strsave(name);
	164	argv[SC_INTERVAL] = strsave("1440");
	165	sprintf(tmp, "/tmp/%s.out", name);
	166	argv[SC_TARGET] = strsave(tmp);
8defc06b	167	sprintf(tmp, "/u1/mr/bin/%s.sh", name);
44d40e72	168	argv[SC_SCRIPT] = strsave(tmp);
	169	argv[SC_TYPE] = strsave("UNIQUE");
	170	argv[SC_ENABLE] = strsave("1");
	171	argv[SC_ACE_TYPE] = strsave("LIST");
	172	argv[SC_ACE_NAME] = strsave("dbadmin");
	173	argv[SC_END] = NULL;
cc5b487a	174	}
	175
	176
	177	updateserv(argc, argv)
	178	int argc;
	179	char **argv;
	180	{
44d40e72	181	char *qargv[9];
cc5b487a	182	int status;
	183
	184	qargv[0] = (char *)argv[1];
8defc06b	185	if (status = do_mr_query("get_server_info", 1,
44d40e72	186	qargv, gserv, (char *)qargv)) {
cc5b487a	187	com_err(whoami, status, " while getting server info");
	188	return(DM_NORMAL);
	189	}
44d40e72	190	askserv(qargv);
8defc06b	191	if (status = do_mr_query("update_server_info", 8, qargv, Scream, NULL))
cc5b487a	192	com_err(whoami, status, " while updating server info");
	193	return(DM_NORMAL);
	194	}
	195
	196
	197	int shhost(argc, argv)
	198	int argc;
	199	char **argv;
	200	{
	201	char tmp[64], *ltt;
	202
44d40e72	203	sprintf(buf, "%s:%s mod by %s on %s with %s", argv[SH_MACHINE],
	204	argv[SH_SERVICE], argv[SH_MODBY], argv[SH_MODTIME],
	205	argv[SH_MODWITH]);
cc5b487a	206	Put_message(buf);
44d40e72	207	if (atoi(argv[SH_HOSTERROR]))
44d40e72	208	sprintf(tmp, "Error %d: %s", atoi(argv[SH_HOSTERROR]), argv[SH_ERRMSG]);
cc5b487a	209	else
	210	strcpy(tmp, "No error");
	211	sprintf(buf, " %s/%s/%s/%s/%s",
44d40e72	212	atoi(argv[SH_ENABLE]) ? "Enabled" : "Disabled",
	213	atoi(argv[SH_SUCCESS]) ? "Success" : "Failure",
	214	atoi(argv[SH_INPROGRESS]) ? "InProgress" : "Idle",
	215	atoi(argv[SH_OVERRIDE]) ? "Override" : "Normal", tmp);
cc5b487a	216	Put_message(buf);
cc5b487a	217	Put_message(" Last Try Last Success Value1 Value2 Value3");
44d40e72	218	ltt = strsave(atot(argv[SH_LASTTRY]));
	219	sprintf(buf, " %-20s %-20s %-9d %-9d %s", ltt, atot(argv[SH_LASTSUCCESS]),
	220	atoi(argv[SH_VALUE1]), atoi(argv[SH_VALUE2]), argv[SH_VALUE3]);
cc5b487a	221	free(ltt);
	222	Put_message(buf);
	223	Put_message("");
8defc06b	224	return(MR_CONT);
cc5b487a	225	}
	226
	227
	228	showhost(argc, argv)
	229	int argc;
	230	char **argv;
	231	{
44d40e72	232	char *qargv[2];
cc5b487a	233	int status;
cc5b487a	234
44d40e72	235	qargv[SHI_SERVICE] = argv[1];
44d40e72	236	qargv[SHI_MACHINE] = canonicalize_hostname(argv[2]);
8defc06b	237	if (status = do_mr_query("get_server_host_info", 2, qargv, shhost, NULL))
cc5b487a	238	com_err(whoami, status, " getting server/host info");
	239	return(DM_NORMAL);
	240	}
	241
	242
	243	resetsrverr(argc, argv)
	244	int argc;
	245	char **argv;
	246	{
	247	int status;
8defc06b	248	if (status = do_mr_query("reset_server_error", 1, &argv[1], Scream, NULL))
cc5b487a	249	com_err(whoami, status, " while resetting server error");
	250	return(DM_NORMAL);
	251	}
	252
	253
	254	resetsrvc(argc, argv)
	255	int argc;
	256	char **argv;
	257	{
	258	int status;
cf09387e	259	char *qargv[5], buf[BUFSIZ];
cc5b487a	260
cf09387e	261	sprintf(buf, "Reset state for service %s (Y/N)", argv[1]);
	262	if (!Confirm(buf))
	263	return(DM_NORMAL);
cc5b487a	264	qargv[0] = argv[1];
	265	qargv[1] = "0";
	266	qargv[2] = "0";
	267	qargv[3] = "0";
	268	qargv[4] = "0";
	269	qargv[5] = "";
8defc06b	270	if (status = do_mr_query("set_server_internal_flags", 6, qargv,
44d40e72	271	Scream, NULL))
cc5b487a	272	com_err(whoami, status, " while resetting server error");
	273	return(DM_NORMAL);
	274	}
	275
	276
	277	resethosterr(argc, argv)
	278	int argc;
	279	char **argv;
	280	{
	281	int status;
	282
	283	argv[2] = canonicalize_hostname(argv[2]);
8defc06b	284	if (status = do_mr_query("reset_server_host_error", 2, &argv[1],
44d40e72	285	Scream, NULL))
cc5b487a	286	com_err(whoami, status, " while resetting server/host error");
	287	return(DM_NORMAL);
	288	}
	289
	290
	291	resethost(argc, argv)
	292	int argc;
	293	char **argv;
	294	{
	295	int status;
cf09387e	296	char *qargv[9], buf[BUFSIZ];
cc5b487a	297
cf09387e	298	sprintf(buf, "Reset state for service %s on host %s (Y/N)", argv[1],
	299	canonicalize_hostname(argv[2]));
	300	if (!Confirm(buf))
	301	return(DM_NORMAL);
cc5b487a	302	qargv[0] = argv[1];
	303	qargv[1] = canonicalize_hostname(argv[2]);
	304	qargv[2] = "0";
	305	qargv[3] = "0";
	306	qargv[4] = "0";
	307	qargv[5] = "0";
	308	qargv[6] = "";
	309	qargv[7] = "0";
	310	qargv[8] = "0";
8defc06b	311	if (status = do_mr_query("set_server_host_internal", 9, qargv,
44d40e72	312	Scream, NULL))
cc5b487a	313	com_err(whoami, status, " while resetting server/host error");
	314	return(DM_NORMAL);
	315	}
	316
	317
	318	sethostor(argc, argv)
	319	int argc;
	320	char **argv;
	321	{
	322	int status;
	323
	324	argv[2] = canonicalize_hostname(argv[2]);
8defc06b	325	if (status = do_mr_query("set_server_host_override", 2, &argv[1],
44d40e72	326	Scream, NULL))
cc5b487a	327	com_err(whoami, status, " while setting server/host override");
	328	return(DM_NORMAL);
	329	}
	330
	331
	332	ghost(argc, argv, cargv)
	333	int argc;
	334	char **argv;
	335	char **cargv;
	336	{
44d40e72	337	cargv[SHI_SERVICE] = strsave(argv[SH_SERVICE]);
	338	cargv[SHI_MACHINE] = strsave(argv[SH_MACHINE]);
	339	cargv[SHI_ENABLE] = strsave(argv[SH_ENABLE]);
	340	cargv[SHI_VALUE1] = strsave(argv[SH_VALUE1]);
	341	cargv[SHI_VALUE2] = strsave(argv[SH_VALUE2]);
	342	cargv[SHI_VALUE3] = strsave(argv[SH_VALUE3]);
	343	cargv[SHI_END] = NULL;
8defc06b	344	return(MR_CONT);
cc5b487a	345	}
	346
	347
44d40e72	348	inithost(info)
	349	char **info;
	350	{
	351	info[SHI_MACHINE] = strsave(canonicalize_hostname(info[SH_MACHINE]));
	352	info[SHI_ENABLE] = strsave("1");
	353	info[SHI_VALUE1] = strsave("0");
	354	info[SHI_VALUE2] = strsave("0");
	355	info[SHI_VALUE3] = strsave("");
	356	info[SHI_END] = NULL;
	357	}
	358
	359
	360	askhost(info)
	361	char **info;
	362	{
	363	GetValueFromUser("Enable", &info[SHI_ENABLE]);
	364	GetValueFromUser("Value 1", &info[SHI_VALUE1]);
	365	GetValueFromUser("Value 2", &info[SHI_VALUE2]);
	366	GetValueFromUser("Value 3", &info[SHI_VALUE3]);
	367	}
	368
	369
cc5b487a	370	updatehost(argc, argv)
	371	int argc;
	372	char **argv;
	373	{
44d40e72	374	char *info[SHI_END+1];
cc5b487a	375	int status;
cc5b487a	376
44d40e72	377	info[SHI_SERVICE] = strsave(argv[1]);
44d40e72	378	info[SHI_MACHINE] = strsave(canonicalize_hostname(argv[2]));
8defc06b	379	if (status = do_mr_query("get_server_host_info", 2, info, ghost,
44d40e72	380	(char *)info)) {
cc5b487a	381	com_err(whoami, status, " while getting server/host info");
	382	return(DM_NORMAL);
	383	}
44d40e72	384	askhost(info);
8defc06b	385	if (status = do_mr_query("update_server_host_info", SHI_END, info,
44d40e72	386	Scream, NULL))
cc5b487a	387	com_err(whoami, status, " while updating server/host info");
44d40e72	388	FreeInfo(info);
cc5b487a	389	return(DM_NORMAL);
	390	}
	391
	392
	393	addhost(argc, argv)
	394	int argc;
	395	char **argv;
	396	{
44d40e72	397	char *info[SHI_END+1];
cc5b487a	398	int status;
cc5b487a	399
44d40e72	400	info[SHI_SERVICE] = strsave(argv[1]);
	401	info[SHI_MACHINE] = strsave(canonicalize_hostname(argv[2]));
	402	inithost(info);
	403	askhost(info);
8defc06b	404	if (status = do_mr_query("add_server_host_info", 6, info, Scream, NULL))
cc5b487a	405	com_err(whoami, status, " while adding server/host info");
44d40e72	406	FreeInfo(info);
cc5b487a	407	return(DM_NORMAL);
	408	}
	409
	410
	411	delserv(argc, argv)
	412	int argc;
	413	char **argv;
	414	{
	415	int status;
	416
8defc06b	417	if (status = do_mr_query("delete_server_info", 1, &argv[1], Scream, NULL))
cc5b487a	418	com_err(whoami, status, " while deleting server info");
	419	return(DM_NORMAL);
	420	}
	421
	422
	423	delhost(argc, argv)
	424	int argc;
	425	char **argv;
	426	{
	427	int status;
	428
	429	argv[2] = canonicalize_hostname(argv[2]);
8defc06b	430	if (status = do_mr_query("delete_server_host_info", 2, &argv[1],
44d40e72	431	Scream, NULL))
cc5b487a	432	com_err(whoami, status, " while deleting server/host info");
	433	return(DM_NORMAL);
	434	}
	435
	436
	437	pserv(argc, argv, count)
	438	int argc;
	439	char **argv;
	440	int *count;
	441	{
	442	sprintf(buf, "Service %s", argv[0]);
	443	Put_message(buf);
	444	(*count)++;
8defc06b	445	return(MR_CONT);
cc5b487a	446	}
	447
	448	phost(argc, argv, count)
	449	int argc;
	450	char **argv;
	451	int *count;
	452	{
	453	sprintf(buf, "Host %s:%s", argv[0], argv[1]);
	454	Put_message(buf);
	455	(*count)++;
8defc06b	456	return(MR_CONT);
cc5b487a	457	}
	458
	459
3ed06d63	460	InProgress()
cc5b487a	461	{
	462	char *argv[6];
	463	int status, count = 0;
	464
	465	argv[0] = argv[2] = "DONTCARE";
	466	argv[1] = "TRUE";
8defc06b	467	if ((status = do_mr_query("qualified_get_server", 3, argv, pserv,
44d40e72	468	(char *)&count)) &&
8defc06b	469	status != MR_NO_MATCH)
cc5b487a	470	com_err(whoami, status, " while getting servers");
	471	argv[0] = "*";
	472	argv[1] = argv[2] = argv[3] = argv[5] = "DONTCARE";
	473	argv[4] = "TRUE";
8defc06b	474	if ((status = do_mr_query("qualified_get_server_host",6,argv,phost,
44d40e72	475	(char *)&count)) &&
8defc06b	476	status != MR_NO_MATCH)
cc5b487a	477	com_err(whoami, status, " while getting server/hosts");
	478	if (!count)
	479	strcpy(buf, "Nothing is in progress at this time");
	480	else
	481	sprintf(buf, "%d update%s in progress at this time", count,
	482	count == 1 ? "" : "s");
	483	Put_message(buf);
	484	return(DM_NORMAL);
	485	}
	486
3ed06d63	487	DcmFailed()
cc5b487a	488	{
	489	char *argv[6];
	490	int status, count = 0;
	491
	492	argv[0] = argv[1] = "DONTCARE";
	493	argv[2] = "TRUE";
8defc06b	494	if ((status = do_mr_query("qualified_get_server", 3, argv, pserv,
44d40e72	495	(char *)&count)) &&
8defc06b	496	status != MR_NO_MATCH)
cc5b487a	497	com_err(whoami, status, " while getting servers");
	498	argv[0] = "*";
	499	argv[1] = argv[2] = argv[3] = argv[4] = "DONTCARE";
	500	argv[5] = "TRUE";
8defc06b	501	if ((status = do_mr_query("qualified_get_server_host",6,argv,phost,
44d40e72	502	(char *)&count)) &&
8defc06b	503	status != MR_NO_MATCH)
cc5b487a	504	com_err(whoami, status, " while getting server/hosts");
	505	if (!count)
	506	strcpy(buf, "Nothing has failed at this time");
	507	else
	508	sprintf(buf, "%d thing%s ha%s failed at this time", count,
	509	count == 1 ? "" : "s", count == 1 ? "s" : "ve");
	510	Put_message(buf);
	511	return(DM_NORMAL);
	512	}
	513
	514
3ed06d63	515	Dcm()
cc5b487a	516	{
cc5b487a	517	int status;
8defc06b	518	if (status = mr_do_update())
cc5b487a	519	com_err(whoami, status, " while triggering update");
	520	return(DM_NORMAL);
	521	}
	522
	523
	524	char *atot(itime)
	525	char *itime;
	526	{
	527	int time;
	528	char ct, ctime();
	529
	530	time = atoi(itime);
	531	ct = ctime(&time);
	532	ct[24] = 0;
	533	return(&ct[4]);
	534	}