[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, "");
	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, "");
	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 */
	135	code = pr_ChangeEntry(before[U_NAME], after[U_NAME], auid, "");
	136	if (code) {
	137	critical_alert("incremental",
	138	"Couldn't change user %s (id %d) to %s (id %d): %s",
	139	before[U_NAME], buid, after[U_NAME], auid,
	140	error_message(code));
	141	}
	142	return;
	143	}
	144	if (bstate == 1) {
	145	code = pr_DeleteByID(buid);
	146	if (code && code != PRNOENT) {
	147	critical_alert("incremental",
	148	"Couldn't delete user %s (id %d): %s",
	149	before[U_NAME], buid, error_message(code));
	150	}
	151	return;
	152	}
	153	if (astate == 1) {
	154	code = pr_CreateUser(after[U_NAME], &auid);
	155	if (code) {
	156	critical_alert("incremental",
	157	"Couldn't create user %s (id %d): %s",
	158	after[U_NAME], auid, error_message(code));
	159	}
	160	return;
fb8809f4	161	}
	162	}
	163
	164
	165
	166	do_list(before, beforec, after, afterc)
	167	char **before;
	168	int beforec;
	169	char **after;
	170	int afterc;
	171	{
fb8809f4	172	int agid, bgid;
60c22e5f	173	long code, id;
ed9a5300	174	char hostname[64];
60c22e5f	175	char g1[PR_MAXNAMELEN], g2[PR_MAXNAMELEN];
ed9a5300	176	char *av[2];
fb8809f4	177
60c22e5f	178	agid = bgid = 0;
fb8809f4	179	if (beforec > L_GID && atoi(before[L_ACTIVE]) && atoi(before[L_GROUP]))
60c22e5f	180	bgid = atoi(before[L_GID]);
fb8809f4	181	if (afterc > L_GID && atoi(after[L_ACTIVE]) && atoi(after[L_GROUP]))
60c22e5f	182	agid = atoi(after[L_GID]);
fb8809f4	183
60c22e5f	184	if (agid == 0 && bgid == 0) /* Not active groups */
	185	return;
	186	if (agid == bgid && !strcmp(after[L_NAME], before[L_NAME]))
	187	return; /* No change */
	188
	189	code=pr_Initialize(1, AFSCONF_CLIENTNAME, 0);
	190	if (code) {
	191	critical_alert("incremental", "Couldn't initialize libprot: %s",
	192	error_message(code));
fb8809f4	193	return;
fb8809f4	194	}
60c22e5f	195
	196	if (agid && bgid) {
	197	/* Only a modify is required */
	198	strcpy(g1, "system:");
	199	strcpy(g2, "system:");
	200	strcat(g1, before[L_NAME]);
	201	strcat(g2, after[L_NAME]);
	202	code = pr_ChangeEntry(g1, g2, -agid, "");
	203	if (code) {
	204	critical_alert("incremental",
	205	"Couldn't change group %s (id %d) to %s (id %d): %s",
	206	before[L_NAME], -bgid, after[L_NAME], -agid,
	207	error_message(code));
	208	}
fb8809f4	209	return;
fb8809f4	210	}
60c22e5f	211	if (bgid) {
	212	code = pr_DeleteByID(-bgid);
	213	if (code && code != PRNOENT) {
	214	critical_alert("incremental",
	215	"Couldn't delete group %s (id %d): %s",
	216	before[L_NAME], -bgid, error_message(code));
	217	}
fb8809f4	218	return;
fb8809f4	219	}
60c22e5f	220	if (agid) {
	221	strcpy(g1, "system:");
	222	strcat(g1, after[L_NAME]);
	223	strcpy(g2, "system:administrators");
	224	id = -agid;
	225	code = pr_CreateGroup(g1, g2, &id);
	226	if (code) {
	227	critical_alert("incremental",
	228	"Couldn't create group %s (id %d): %s",
ed9a5300	229	after[L_NAME], id, error_message(code));
60c22e5f	230	return;
	231	}
	232
	233	/* We need to make sure the group is properly populated */
	234	if (beforec < L_ACTIVE \|\| atoi(before[L_ACTIVE]) == 0) return;
	235
ed9a5300	236	gethostname(hostname, sizeof(hostname));
	237	code = mr_connect(hostname);
	238	if (!code) code = mr_auth("afs.incr");
	239	if (code) {
	240	critical_alert("incremental",
	241	"Error contacting Moira server to resolve %s: %s",
	242	after[L_NAME], error_message(code));
	243	return;
	244	}
	245	av[0] = "LIST";
	246	av[1] = after[L_NAME];
	247	get_members(2, av, after[L_NAME]);
	248
	249	mr_disconnect();
	250	return;
60c22e5f	251	}
fb8809f4	252	}
	253
	254
	255	do_member(before, beforec, after, afterc)
	256	char **before;
	257	int beforec;
	258	char **after;
	259	int afterc;
	260	{
60c22e5f	261	int code;
	262	char *p;
	263
bd70a79d	264	if ((beforec < 4 \|\| !atoi(before[LM_END])) &&
bd70a79d	265	(afterc < 4 \|\| !atoi(after[LM_END])))
fb8809f4	266	return;
60c22e5f	267
	268	code=pr_Initialize(1, AFSCONF_CLIENTNAME, 0);
	269	if (code) {
	270	critical_alert("incremental", "Couldn't initialize libprot: %s",
	271	error_message(code));
fb8809f4	272	return;
fb8809f4	273	}
60c22e5f	274
ed9a5300	275	if (afterc)
	276	edit_group(1, after[LM_LIST], after[LM_TYPE], after[LM_MEMBER]);
	277	if (beforec)
	278	edit_group(0, after[LM_LIST], after[LM_TYPE], after[LM_MEMBER]);
	279	}
	280
	281
	282	get_members(ac, av, group)
	283	int ac;
	284	char *av[];
	285	char *group;
	286	{
	287	int code=0;
	288
	289	if (strcmp(av[0], "LIST")) {
	290	sleep(1); /* give the ptserver room */
	291	edit_group(1, group, av[0], av[1]);
	292	} else {
	293	code = mr_query("get_members_of_list", 1, &av[1], get_members, group);
	294	if (code)
	295	critical_alert("incremental",
	296	"Couldn't retrieve full membership of %s: %s",
	297	group, error_message(code));
	298	}
	299	return code;
	300	}
	301
	302
	303	edit_group(op, group, type, member)
	304	int op;
	305	char *group;
	306	char *type;
	307	char *member;
	308	{
	309	char *p = 0;
	310	char buf[PR_MAXNAMELEN];
	311	int (*fn)();
	312	int code;
	313	extern long pr_AddToGroup(), pr_RemoveUserFromGroup();
	314
	315	fn = op ? pr_AddToGroup : pr_RemoveUserFromGroup;
	316
60c22e5f	317	/* The following KERBEROS code allows for the use of entities
	318	* user@foreign_cell.
	319	*/
ed9a5300	320	if (!strcmp(type, "KERBEROS")) {
ed9a5300	321	p = index(member, '@');
60c22e5f	322	if (p && !strcasecmp(p+1, cellname))
60c22e5f	323	*p = 0;
ed9a5300	324	} else if (strcmp(type, "USER"))
ed9a5300	325	return; /* invalid type */
60c22e5f	326
ed9a5300	327	strcpy(buf, "system:");
	328	strcat(buf, group);
	329	code = (*fn)(member, buf);
	330	if (code) {
	331	if (op==0 && code == PRNOENT) return;
	332	if (op==1 && code == PRIDEXIST) return;
	333	if (strcmp(type, "KERBEROS") \|\| code != PRNOENT) {
60c22e5f	334	critical_alert("incremental",
ed9a5300	335	"Couldn't %s %s %s %s: %s",
	336	op ? "add" : "remove", member,
	337	op ? "to" : "from", buf,
60c22e5f	338	error_message(code));
60c22e5f	339	}
57bc9f26	340	}
ed9a5300	341	if (p) *p = '@';
fb8809f4	342	}
	343
	344
	345	do_filesys(before, beforec, after, afterc)
	346	char **before;
	347	int beforec;
	348	char **after;
	349	int afterc;
	350	{
60c22e5f	351	char cmd[1024];
60c22e5f	352
d43ba793	353	if (beforec < FS_CREATE) {
60c22e5f	354	if (afterc < FS_CREATE \|\| atoi(after[FS_CREATE])==0 \|\|
	355	strcmp(after[FS_TYPE], "AFS"))
	356	return;
	357
d43ba793	358	/* new locker creation */
60c22e5f	359	sprintf(cmd, "%s/perl -I%s %s/afs_create.pl %s %s %s %s %s %s",
	360	BIN_DIR, BIN_DIR, BIN_DIR,
	361	after[FS_NAME], after[FS_L_TYPE], after[FS_MACHINE],
	362	after[FS_PACK], after[FS_OWNER], after[FS_OWNERS]);
d43ba793	363	do_cmd(cmd);
d43ba793	364	return;
f633445d	365	}
60c22e5f	366
	367	/* What do we do? When do we use FS_CREATE?
	368	*
	369	* TYPE change: AFS->ERR, ERR->AFS: rename/unmount/remount
	370	* LOCKERTYPE change: rename/remount
	371	* PACK change: remount
	372	* LABEL change: rename/remount
	373	* Deletion: rename/unmount
	374	*/
fb8809f4	375	}
	376
	377
	378	do_quota(before, beforec, after, afterc)
	379	char **before;
	380	int beforec;
	381	char **after;
	382	int afterc;
	383	{
60c22e5f	384	char cmd[1024];
fb8809f4	385
1f377b55	386	if (afterc < Q_DIRECTORY \|\| strcmp("ANY", after[Q_TYPE]) \|\|
60c22e5f	387	strncmp("/afs/", after[Q_DIRECTORY], 5))
60c22e5f	388	return;
1f377b55	389
60c22e5f	390	sprintf(cmd, "%s/perl -I%s %s/afs_quota.pl %s %s",
60c22e5f	391	BIN_DIR, BIN_DIR, BIN_DIR,
1f377b55	392	after[Q_DIRECTORY], after[Q_QUOTA]);
	393	do_cmd(cmd);
	394	return;
fb8809f4	395	}