[moira.git] / incremental / afs.c

/* $Header$
 *
 * Do AFS incremental updates
 *
 * Copyright (C) 1989,1992 by the Massachusetts Institute of Technology
 * for copying and distribution information, please see the file
 * <mit-copyright.h>.
 */

#include <sys/types.h>
#include <sys/file.h>
#include <strings.h>

#include <moira.h>
#include <moira_site.h>

#include <afs/param.h>
#include <afs/cellconfig.h>
#include <afs/venus.h>
#include <afs/ptclient.h>
#include <afs/pterror.h>

#define file_exists(file) (access((file), F_OK) == 0)

char *whoami;
char *cellname = "ATHENA.MIT.EDU";

main(argc, argv)
char **argv;
int argc;
{
    int beforec, afterc, i;
    char *table, **before, **after;
#ifdef DEBUG
    char buf[1024];
#endif

    for (i = getdtablesize() - 1; i > 2; i--)
      close(i);

    table = argv[1];
    beforec = atoi(argv[2]);
    before = &argv[4];
    afterc = atoi(argv[3]);
    after = &argv[4 + beforec];
    whoami = argv[0];

#ifdef DEBUG
    sprintf(buf, "%s (", table);
    for (i = 0; i < beforec; i++) {
	if (i > 0)
	  strcat(buf, ",");
	strcat(buf, before[i]);
    }
    strcat(buf, ")->(");
    for (i = 0; i < afterc; i++) {
	if (i > 0)
	  strcat(buf, ",");
	strcat(buf, after[i]);
    }
    strcat(buf, ")\n");
    write(1,buf,strlen(buf));
#endif

    initialize_sms_error_table();
    initialize_krb_error_table();

    if (!strcmp(table, "users")) {
	do_user(before, beforec, after, afterc);
    } else if (!strcmp(table, "list")) {
	do_list(before, beforec, after, afterc);
    } else if (!strcmp(table, "members")) {
	do_member(before, beforec, after, afterc);
    } else if (!strcmp(table, "filesys")) {
	do_filesys(before, beforec, after, afterc);
    } else if (!strcmp(table, "quota")) {
	do_quota(before, beforec, after, afterc);
    }
    exit(0);
}


do_cmd(cmd)
char *cmd;
{
    int success = 0, tries = 0;

    while (success == 0 && tries < 1) {
	if (tries++)
	    sleep(5*60);
	com_err(whoami, 0, "Executing command: %s", cmd);
	if (system(cmd) == 0)
	    success++;
    }
    if (!success)
	critical_alert("incremental", "failed command: %s", cmd);
}


do_user(before, beforec, after, afterc)
char **before;
int beforec;
char **after;
int afterc;
{
    int astate, bstate, auid, buid, code;

    auid = buid = astate = bstate = 0;
    if (afterc > U_STATE) astate = atoi(after[U_STATE]);
    if (beforec > U_STATE) bstate = atoi(before[U_STATE]);
    if (afterc > U_UID) auid = atoi(after[U_UID]);
    if (beforec > U_UID) buid = atoi(before[U_UID]);

    /* We consider "half-registered" users to be active */
    if (astate == 2) astate = 1;
    if (bstate == 2) bstate = 1;

    if (astate != 1 && bstate != 1)		/* inactive user */
	return;

    if (astate == bstate && auid == buid && 
	!strcmp(before[U_NAME], after[U_NAME]))
	/* No AFS related attributes have changed */
	return;

    code=pr_Initialize(1, AFSCONF_CLIENTNAME, 0);
    if (code) {
	critical_alert("incremental", "Couldn't initialize libprot: %s",
		       error_message(code));
	return;
    }
    
    if (astate == bstate) {
	/* Only a modify has to be done */
	code = pr_ChangeEntry(before[U_NAME], after[U_NAME],
			      (auid==buid) ? 0 : auid, "");
	if (code) {
	    critical_alert("incremental",
			   "Couldn't change user %s (id %d) to %s (id %d): %s",
			   before[U_NAME], buid, after[U_NAME], auid,
			   error_message(code));
	}
	return;
    }
    if (bstate == 1) {
	code = pr_DeleteByID(buid);
	if (code && code != PRNOENT) {
	    critical_alert("incremental",
			   "Couldn't delete user %s (id %d): %s",
			   before[U_NAME], buid, error_message(code));
	}
	return;
    }
    if (astate == 1) {
	code = pr_CreateUser(after[U_NAME], &auid);
	if (code) {
	    critical_alert("incremental",
			   "Couldn't create user %s (id %d): %s",
			   after[U_NAME], auid, error_message(code));
	}
	return;
    }
}


do_list(before, beforec, after, afterc)
char **before;
int beforec;
char **after;
int afterc;
{
    int agid, bgid;
    long code, id;
    char hostname[64];
    char g1[PR_MAXNAMELEN], g2[PR_MAXNAMELEN];
    char *av[2];

    agid = bgid = 0;
    if (beforec > L_GID && atoi(before[L_ACTIVE]) && atoi(before[L_GROUP]))
	bgid = atoi(before[L_GID]);
    if (afterc > L_GID && atoi(after[L_ACTIVE]) && atoi(after[L_GROUP]))
	agid = atoi(after[L_GID]);

    if (agid == 0 && bgid == 0)			/* Not active groups */
	return;
    if (agid == bgid && !strcmp(after[L_NAME], before[L_NAME]))
	return;					/* No change */

    code=pr_Initialize(1, AFSCONF_CLIENTNAME, 0);
    if (code) {
	critical_alert("incremental", "Couldn't initialize libprot: %s",
		       error_message(code));
	return;
    }

    if (agid && bgid) {
	/* Only a modify is required */
	strcpy(g1, "system:");
	strcpy(g2, "system:");
	strcat(g1, before[L_NAME]);
	strcat(g2, after[L_NAME]);
	code = pr_ChangeEntry(g1, g2, (agid==bgid) ? 0 : -agid, "");
	if (code) {
	    critical_alert("incremental",
			   "Couldn't change group %s (id %d) to %s (id %d): %s",
			   before[L_NAME], -bgid, after[L_NAME], -agid,
			   error_message(code));
	}
	return;
    }
    if (bgid) {
	code = pr_DeleteByID(-bgid);
	if (code && code != PRNOENT) {
	    critical_alert("incremental",
			   "Couldn't delete group %s (id %d): %s",
			   before[L_NAME], -bgid, error_message(code));
	}
	return;
    }
    if (agid) {
	strcpy(g1, "system:");
	strcat(g1, after[L_NAME]);
	strcpy(g2, "system:administrators");
	id = -agid;
	code = pr_CreateGroup(g1, g2, &id);
	if (code) {
	    critical_alert("incremental",
			   "Couldn't create group %s (id %d): %s",
			   after[L_NAME], id, error_message(code));
	    return;
	}

	/* We need to make sure the group is properly populated */
	if (beforec < L_ACTIVE || atoi(before[L_ACTIVE]) == 0) return;

	gethostname(hostname, sizeof(hostname));
	code = mr_connect(hostname);
	if (!code) code = mr_auth("afs.incr");
	if (code) {
	    critical_alert("incremental",
			   "Error contacting Moira server to resolve %s: %s",
			   after[L_NAME], error_message(code));
	    return;
	}
	av[0] = "LIST";
	av[1] = after[L_NAME];
	get_members(2, av, after[L_NAME]);

	mr_disconnect();
	return;
    }
}


do_member(before, beforec, after, afterc)
char **before;
int beforec;
char **after;
int afterc;
{
    int code;
    char *p;
    
    if ((beforec < 4 || !atoi(before[LM_END])) &&
	(afterc < 4 || !atoi(after[LM_END])))
	return;

    code=pr_Initialize(1, AFSCONF_CLIENTNAME, 0);
    if (code) {
	critical_alert("incremental", "Couldn't initialize libprot: %s",
		       error_message(code));
	return;
    }

    if (afterc) 
	edit_group(1, after[LM_LIST], after[LM_TYPE], after[LM_MEMBER]);
    if (beforec)
	edit_group(0, after[LM_LIST], after[LM_TYPE], after[LM_MEMBER]);
}


get_members(ac, av, group)
    int ac;
    char *av[];
    char *group;
{
    int code=0;

    if (strcmp(av[0], "LIST")) {
	sleep(1);				/* give the ptserver room */
	edit_group(1, group, av[0], av[1]);
    } else {
	code = mr_query("get_members_of_list", 1, &av[1], get_members, group);
	if (code)
	    critical_alert("incremental",
			   "Couldn't retrieve full membership of %s: %s",
			   group, error_message(code));
    }
    return code;
}


edit_group(op, group, type, member)
    int op;
    char *group;
    char *type;
    char *member;
{
    char *p = 0;
    char buf[PR_MAXNAMELEN];
    int (*fn)();
    int code;
    extern long pr_AddToGroup(), pr_RemoveUserFromGroup();

    fn = op ? pr_AddToGroup : pr_RemoveUserFromGroup;
    
    /* The following KERBEROS code allows for the use of entities
     * user@foreign_cell.
     */
    if (!strcmp(type, "KERBEROS")) {
	p = index(member, '@');
	if (p && !strcasecmp(p+1, cellname))
	    *p = 0;
    } else if (strcmp(type, "USER"))
	return;					/* invalid type */

    strcpy(buf, "system:");
    strcat(buf, group);
    code = (*fn)(member, buf);
    if (code) {
	if (op==0 && code == PRNOENT) return;
	if (op==1 && code == PRIDEXIST) return;
	if (strcmp(type, "KERBEROS") || code != PRNOENT) {
	    critical_alert("incremental",
			   "Couldn't %s %s %s %s: %s",
			   op ? "add" : "remove", member,
			   op ? "to" : "from", buf,
			   error_message(code));
	}
    }
    if (p) *p = '@';
}


do_filesys(before, beforec, after, afterc)
char **before;
int beforec;
char **after;
int afterc;
{
    char cmd[1024];
    
    if (beforec < FS_CREATE) {
	if (afterc < FS_CREATE || atoi(after[FS_CREATE])==0 ||
	    strcmp(after[FS_TYPE], "AFS"))
	    return;

	/* new locker creation */
	sprintf(cmd, "%s/perl -I%s %s/afs_create.pl %s %s %s %s %s %s",
		BIN_DIR, BIN_DIR, BIN_DIR,
		after[FS_NAME], after[FS_L_TYPE], after[FS_MACHINE],
		after[FS_PACK], after[FS_OWNER], after[FS_OWNERS]);
	do_cmd(cmd);
	return;
    }

    /* What do we do?  When do we use FS_CREATE?
     * 
     * TYPE change:  AFS->ERR, ERR->AFS: rename/unmount/remount
     * LOCKERTYPE change: rename/remount
     * PACK change: remount
     * LABEL change: rename/remount
     * Deletion: rename/unmount
     */
}


do_quota(before, beforec, after, afterc)
char **before;
int beforec;
char **after;
int afterc;
{
    char cmd[1024];

    if (afterc < Q_DIRECTORY || strcmp("ANY", after[Q_TYPE]) ||
	strncmp("/afs/", after[Q_DIRECTORY], 5))
	return;

    sprintf(cmd, "%s/perl -I%s %s/afs_quota.pl %s %s",
	    BIN_DIR, BIN_DIR, BIN_DIR,
	    after[Q_DIRECTORY], after[Q_QUOTA]);
    do_cmd(cmd);
    return;
}
Commit	Line	Data
fb8809f4	1	/* $Header$
	2	*
	3	* Do AFS incremental updates
	4	*
60c22e5f	5	* Copyright (C) 1989,1992 by the Massachusetts Institute of Technology
fb8809f4	6	* for copying and distribution information, please see the file
	7	* <mit-copyright.h>.
	8	*/
	9
60c22e5f	10	#include <sys/types.h>
	11	#include <sys/file.h>
	12	#include <strings.h>
	13
2ce085d2	14	#include <moira.h>
2ce085d2	15	#include <moira_site.h>
f633445d	16
60c22e5f	17	#include <afs/param.h>
	18	#include <afs/cellconfig.h>
	19	#include <afs/venus.h>
	20	#include <afs/ptclient.h>
	21	#include <afs/pterror.h>
fb8809f4	22
60c22e5f	23	#define file_exists(file) (access((file), F_OK) == 0)
fb8809f4	24
fb8809f4	25	char *whoami;
60c22e5f	26	char *cellname = "ATHENA.MIT.EDU";
fb8809f4	27
	28	main(argc, argv)
	29	char **argv;
	30	int argc;
	31	{
a7fdf2de	32	int beforec, afterc, i;
fb8809f4	33	char table, before, *after;
810d12a7	34	#ifdef DEBUG
810d12a7	35	char buf[1024];
810d12a7	36	#endif
fb8809f4	37
a7fdf2de	38	for (i = getdtablesize() - 1; i > 2; i--)
	39	close(i);
	40
fb8809f4	41	table = argv[1];
	42	beforec = atoi(argv[2]);
	43	before = &argv[4];
	44	afterc = atoi(argv[3]);
	45	after = &argv[4 + beforec];
	46	whoami = argv[0];
	47
810d12a7	48	#ifdef DEBUG
	49	sprintf(buf, "%s (", table);
	50	for (i = 0; i < beforec; i++) {
	51	if (i > 0)
	52	strcat(buf, ",");
	53	strcat(buf, before[i]);
	54	}
	55	strcat(buf, ")->(");
	56	for (i = 0; i < afterc; i++) {
	57	if (i > 0)
	58	strcat(buf, ",");
	59	strcat(buf, after[i]);
	60	}
	61	strcat(buf, ")\n");
	62	write(1,buf,strlen(buf));
	63	#endif
	64
fb8809f4	65	initialize_sms_error_table();
	66	initialize_krb_error_table();
	67
	68	if (!strcmp(table, "users")) {
	69	do_user(before, beforec, after, afterc);
	70	} else if (!strcmp(table, "list")) {
	71	do_list(before, beforec, after, afterc);
	72	} else if (!strcmp(table, "members")) {
	73	do_member(before, beforec, after, afterc);
	74	} else if (!strcmp(table, "filesys")) {
	75	do_filesys(before, beforec, after, afterc);
1f377b55	76	} else if (!strcmp(table, "quota")) {
fb8809f4	77	do_quota(before, beforec, after, afterc);
fb8809f4	78	}
fb8809f4	79	exit(0);
	80	}
	81
	82
	83	do_cmd(cmd)
	84	char *cmd;
	85	{
a7fdf2de	86	int success = 0, tries = 0;
fb8809f4	87
60c22e5f	88	while (success == 0 && tries < 1) {
	89	if (tries++)
	90	sleep(5*60);
a7fdf2de	91	com_err(whoami, 0, "Executing command: %s", cmd);
a7fdf2de	92	if (system(cmd) == 0)
60c22e5f	93	success++;
fb8809f4	94	}
fb8809f4	95	if (!success)
60c22e5f	96	critical_alert("incremental", "failed command: %s", cmd);
fb8809f4	97	}
	98
	99
	100	do_user(before, beforec, after, afterc)
	101	char **before;
	102	int beforec;
	103	char **after;
	104	int afterc;
	105	{
60c22e5f	106	int astate, bstate, auid, buid, code;
	107
	108	auid = buid = astate = bstate = 0;
	109	if (afterc > U_STATE) astate = atoi(after[U_STATE]);
	110	if (beforec > U_STATE) bstate = atoi(before[U_STATE]);
	111	if (afterc > U_UID) auid = atoi(after[U_UID]);
	112	if (beforec > U_UID) buid = atoi(before[U_UID]);
	113
	114	/* We consider "half-registered" users to be active */
810d12a7	115	if (astate == 2) astate = 1;
810d12a7	116	if (bstate == 2) bstate = 1;
fb8809f4	117
60c22e5f	118	if (astate != 1 && bstate != 1) /* inactive user */
fb8809f4	119	return;
60c22e5f	120
	121	if (astate == bstate && auid == buid &&
	122	!strcmp(before[U_NAME], after[U_NAME]))
	123	/* No AFS related attributes have changed */
fb8809f4	124	return;
fb8809f4	125
60c22e5f	126	code=pr_Initialize(1, AFSCONF_CLIENTNAME, 0);
	127	if (code) {
	128	critical_alert("incremental", "Couldn't initialize libprot: %s",
	129	error_message(code));
	130	return;
fb8809f4	131	}
60c22e5f	132
	133	if (astate == bstate) {
	134	/* Only a modify has to be done */
58283442	135	code = pr_ChangeEntry(before[U_NAME], after[U_NAME],
58283442	136	(auid==buid) ? 0 : auid, "");
60c22e5f	137	if (code) {
	138	critical_alert("incremental",
	139	"Couldn't change user %s (id %d) to %s (id %d): %s",
	140	before[U_NAME], buid, after[U_NAME], auid,
	141	error_message(code));
	142	}
	143	return;
	144	}
	145	if (bstate == 1) {
	146	code = pr_DeleteByID(buid);
	147	if (code && code != PRNOENT) {
	148	critical_alert("incremental",
	149	"Couldn't delete user %s (id %d): %s",
	150	before[U_NAME], buid, error_message(code));
	151	}
	152	return;
	153	}
	154	if (astate == 1) {
	155	code = pr_CreateUser(after[U_NAME], &auid);
	156	if (code) {
	157	critical_alert("incremental",
	158	"Couldn't create user %s (id %d): %s",
	159	after[U_NAME], auid, error_message(code));
	160	}
	161	return;
fb8809f4	162	}
	163	}
	164
	165
	166
	167	do_list(before, beforec, after, afterc)
	168	char **before;
	169	int beforec;
	170	char **after;
	171	int afterc;
	172	{
fb8809f4	173	int agid, bgid;
60c22e5f	174	long code, id;
ed9a5300	175	char hostname[64];
60c22e5f	176	char g1[PR_MAXNAMELEN], g2[PR_MAXNAMELEN];
ed9a5300	177	char *av[2];
fb8809f4	178
60c22e5f	179	agid = bgid = 0;
fb8809f4	180	if (beforec > L_GID && atoi(before[L_ACTIVE]) && atoi(before[L_GROUP]))
60c22e5f	181	bgid = atoi(before[L_GID]);
fb8809f4	182	if (afterc > L_GID && atoi(after[L_ACTIVE]) && atoi(after[L_GROUP]))
60c22e5f	183	agid = atoi(after[L_GID]);
fb8809f4	184
60c22e5f	185	if (agid == 0 && bgid == 0) /* Not active groups */
	186	return;
	187	if (agid == bgid && !strcmp(after[L_NAME], before[L_NAME]))
	188	return; /* No change */
	189
	190	code=pr_Initialize(1, AFSCONF_CLIENTNAME, 0);
	191	if (code) {
	192	critical_alert("incremental", "Couldn't initialize libprot: %s",
	193	error_message(code));
fb8809f4	194	return;
fb8809f4	195	}
60c22e5f	196
	197	if (agid && bgid) {
	198	/* Only a modify is required */
	199	strcpy(g1, "system:");
	200	strcpy(g2, "system:");
	201	strcat(g1, before[L_NAME]);
	202	strcat(g2, after[L_NAME]);
58283442	203	code = pr_ChangeEntry(g1, g2, (agid==bgid) ? 0 : -agid, "");
60c22e5f	204	if (code) {
	205	critical_alert("incremental",
	206	"Couldn't change group %s (id %d) to %s (id %d): %s",
	207	before[L_NAME], -bgid, after[L_NAME], -agid,
	208	error_message(code));
	209	}
fb8809f4	210	return;
fb8809f4	211	}
60c22e5f	212	if (bgid) {
	213	code = pr_DeleteByID(-bgid);
	214	if (code && code != PRNOENT) {
	215	critical_alert("incremental",
	216	"Couldn't delete group %s (id %d): %s",
	217	before[L_NAME], -bgid, error_message(code));
	218	}
fb8809f4	219	return;
fb8809f4	220	}
60c22e5f	221	if (agid) {
	222	strcpy(g1, "system:");
	223	strcat(g1, after[L_NAME]);
	224	strcpy(g2, "system:administrators");
	225	id = -agid;
	226	code = pr_CreateGroup(g1, g2, &id);
	227	if (code) {
	228	critical_alert("incremental",
	229	"Couldn't create group %s (id %d): %s",
ed9a5300	230	after[L_NAME], id, error_message(code));
60c22e5f	231	return;
	232	}
	233
	234	/* We need to make sure the group is properly populated */
	235	if (beforec < L_ACTIVE \|\| atoi(before[L_ACTIVE]) == 0) return;
	236
ed9a5300	237	gethostname(hostname, sizeof(hostname));
	238	code = mr_connect(hostname);
	239	if (!code) code = mr_auth("afs.incr");
	240	if (code) {
	241	critical_alert("incremental",
	242	"Error contacting Moira server to resolve %s: %s",
	243	after[L_NAME], error_message(code));
	244	return;
	245	}
	246	av[0] = "LIST";
	247	av[1] = after[L_NAME];
	248	get_members(2, av, after[L_NAME]);
	249
	250	mr_disconnect();
	251	return;
60c22e5f	252	}
fb8809f4	253	}
	254
	255
	256	do_member(before, beforec, after, afterc)
	257	char **before;
	258	int beforec;
	259	char **after;
	260	int afterc;
	261	{
60c22e5f	262	int code;
	263	char *p;
	264
bd70a79d	265	if ((beforec < 4 \|\| !atoi(before[LM_END])) &&
bd70a79d	266	(afterc < 4 \|\| !atoi(after[LM_END])))
fb8809f4	267	return;
60c22e5f	268
	269	code=pr_Initialize(1, AFSCONF_CLIENTNAME, 0);
	270	if (code) {
	271	critical_alert("incremental", "Couldn't initialize libprot: %s",
	272	error_message(code));
fb8809f4	273	return;
fb8809f4	274	}
60c22e5f	275
ed9a5300	276	if (afterc)
	277	edit_group(1, after[LM_LIST], after[LM_TYPE], after[LM_MEMBER]);
	278	if (beforec)
	279	edit_group(0, after[LM_LIST], after[LM_TYPE], after[LM_MEMBER]);
	280	}
	281
	282
	283	get_members(ac, av, group)
	284	int ac;
	285	char *av[];
	286	char *group;
	287	{
	288	int code=0;
	289
	290	if (strcmp(av[0], "LIST")) {
	291	sleep(1); /* give the ptserver room */
	292	edit_group(1, group, av[0], av[1]);
	293	} else {
	294	code = mr_query("get_members_of_list", 1, &av[1], get_members, group);
	295	if (code)
	296	critical_alert("incremental",
	297	"Couldn't retrieve full membership of %s: %s",
	298	group, error_message(code));
	299	}
	300	return code;
	301	}
	302
	303
	304	edit_group(op, group, type, member)
	305	int op;
	306	char *group;
	307	char *type;
	308	char *member;
	309	{
	310	char *p = 0;
	311	char buf[PR_MAXNAMELEN];
	312	int (*fn)();
	313	int code;
	314	extern long pr_AddToGroup(), pr_RemoveUserFromGroup();
	315
	316	fn = op ? pr_AddToGroup : pr_RemoveUserFromGroup;
	317
60c22e5f	318	/* The following KERBEROS code allows for the use of entities
	319	* user@foreign_cell.
	320	*/
ed9a5300	321	if (!strcmp(type, "KERBEROS")) {
ed9a5300	322	p = index(member, '@');
60c22e5f	323	if (p && !strcasecmp(p+1, cellname))
60c22e5f	324	*p = 0;
ed9a5300	325	} else if (strcmp(type, "USER"))
ed9a5300	326	return; /* invalid type */
60c22e5f	327
ed9a5300	328	strcpy(buf, "system:");
	329	strcat(buf, group);
	330	code = (*fn)(member, buf);
	331	if (code) {
	332	if (op==0 && code == PRNOENT) return;
	333	if (op==1 && code == PRIDEXIST) return;
	334	if (strcmp(type, "KERBEROS") \|\| code != PRNOENT) {
60c22e5f	335	critical_alert("incremental",
ed9a5300	336	"Couldn't %s %s %s %s: %s",
	337	op ? "add" : "remove", member,
	338	op ? "to" : "from", buf,
60c22e5f	339	error_message(code));
60c22e5f	340	}
57bc9f26	341	}
ed9a5300	342	if (p) *p = '@';
fb8809f4	343	}
	344
	345
	346	do_filesys(before, beforec, after, afterc)
	347	char **before;
	348	int beforec;
	349	char **after;
	350	int afterc;
	351	{
60c22e5f	352	char cmd[1024];
60c22e5f	353
d43ba793	354	if (beforec < FS_CREATE) {
60c22e5f	355	if (afterc < FS_CREATE \|\| atoi(after[FS_CREATE])==0 \|\|
	356	strcmp(after[FS_TYPE], "AFS"))
	357	return;
	358
d43ba793	359	/* new locker creation */
60c22e5f	360	sprintf(cmd, "%s/perl -I%s %s/afs_create.pl %s %s %s %s %s %s",
	361	BIN_DIR, BIN_DIR, BIN_DIR,
	362	after[FS_NAME], after[FS_L_TYPE], after[FS_MACHINE],
	363	after[FS_PACK], after[FS_OWNER], after[FS_OWNERS]);
d43ba793	364	do_cmd(cmd);
d43ba793	365	return;
f633445d	366	}
60c22e5f	367
	368	/* What do we do? When do we use FS_CREATE?
	369	*
	370	* TYPE change: AFS->ERR, ERR->AFS: rename/unmount/remount
	371	* LOCKERTYPE change: rename/remount
	372	* PACK change: remount
	373	* LABEL change: rename/remount
	374	* Deletion: rename/unmount
	375	*/
fb8809f4	376	}
	377
	378
	379	do_quota(before, beforec, after, afterc)
	380	char **before;
	381	int beforec;
	382	char **after;
	383	int afterc;
	384	{
60c22e5f	385	char cmd[1024];
fb8809f4	386
1f377b55	387	if (afterc < Q_DIRECTORY \|\| strcmp("ANY", after[Q_TYPE]) \|\|
60c22e5f	388	strncmp("/afs/", after[Q_DIRECTORY], 5))
60c22e5f	389	return;
1f377b55	390
60c22e5f	391	sprintf(cmd, "%s/perl -I%s %s/afs_quota.pl %s %s",
60c22e5f	392	BIN_DIR, BIN_DIR, BIN_DIR,
1f377b55	393	after[Q_DIRECTORY], after[Q_QUOTA]);
	394	do_cmd(cmd);
	395	return;
fb8809f4	396	}