[unix-history] / usr / src / ucb / berknet / netq.c

static char sccsid[] = "@(#)netq.c	4.2	(Berkeley)	9/12/82";

/* netq - print the netq send queue */
/* netq [-] [mach] */
/* must be setuid root */

/* sccs id variable */
static char *netq_sid = "@(#)netq.c	1.5";

# include "defs.h"
/* this is an internal table size -- only STSIZE entries will 
	be sorted correctly */
# define STSIZE 150

static DIR *df;
static char jname[16], printlong;
static struct table {
	char name[16];
	long filesize;
	} stack[STSIZE], temp;
static int stptr = 0;
static char mach,visit[MAXINX];
static char netcmd1[] =	NETCMD1;
static int hisuid,sumj,nsumj;
static long sumb, nsumb;
static struct stat statbuf;

char _sobuf[BUFSIZ];
main(argc,argv)
  char **argv; {
	int i;
	setbuf(stdout,_sobuf);
	hisuid = getuid();
	hisuid = uidmask(hisuid);
	if(stat(netcmd,&statbuf) >= 0)
		if((statbuf.st_mode & 07) == 0){
			printf("Network is down\n");
			exit(EX_UNAVAILABLE);
			}
	else if(stat(netcmd1,&statbuf) >= 0)
		if((statbuf.st_mode & 07) == 0){
			printf("Network is down\n");
			exit(EX_UNAVAILABLE);
			}
	while(argc > 1){
		switch(argv[1][0]){
		case '-': printlong++; break;
		default: mach = lookup(argv[1]);
			if(mach > 0 && machtype[chtoinx(mach)] == 0)mach = 0;
			break;
		}
		argc--, argv++;
		}
	if(mach){
		mach = gothru(local,mach); /* list to directly conn. machine */
		if(mach == 0){
			fprintf(stderr,"That machine not directly connected.\n");
			exit(EX_USAGE);
		}
		senddir[strlen(senddir)-1] = mach;
		if(chdir(senddir) < 0){
			perror(senddir);
			exit(EX_OSFILE);
		}
		pdir(senddir);
	}
	else for(i = 0; i < MAXINX; i++)
		if((mach = gothru(local,inxtoch(i))) && !visit[chtoinx(mach)]){
			visit[chtoinx(mach)] = 1;
			senddir[strlen(senddir)-1] = mach;
			if(chdir(senddir) < 0)continue;
			pdir(senddir);
			printf("---\n");
			}
	fflush(stdout);
	}
static pdir(str)
  char *str; {
	int i;
	char more = 0, *cp;
	char listrest = 0;
	int (*compar)();
	char printhead = 0;
	register struct direct *dp;
	df = opendir(str);
	if(df == NULL){
		perror(str);
		exit(EX_OSFILE);
		}
	stptr = 0;
	while((dp = readdir(df)) != NULL){
		if(dp->d_name[0] != 'c'
		|| dp->d_name[1] != 'f'
		|| stat(dp->d_name,&statbuf) < 0)
			continue;
		if(mach != dp->d_name[2])continue;
		dp->d_name[0] = 'd';
		if(stat(dp->d_name,&statbuf) < 0)continue;
#ifdef MAXSENDQ
		if( stptr >= MAXSENDQ ) {
			listrest++;
			break;
		}
#endif

		if(!insert(dp->d_name,getsize(&statbuf))){
			more++;
			break;
			}
		}
	if(stptr == 0){
		printf("Network queue to/thru %s is empty.\n",longname(mach));
		closedir(df);
		return;
		}
	cp = (char *)&(stack[0].name[0]);
	sort(cp,stptr,sizeof temp,compar);
	printf("Network queue to/thru %s:\n",longname(mach));
	for(i = 0; i < stptr; i++){ /* screen size */
		strcpy(jname,stack[i].name);
		jname[0] = 'd';
		if(stat(jname,&statbuf) < 0)
			continue;
		if(printlong || guid(statbuf.st_uid,statbuf.st_gid) == hisuid){
			if(!printhead){
				printhead = 1;
				printf( "From       To           Len  Code   Time          Command\n");
				};
			process();
			}
		else summarize( stack[i].filesize );
		}
# ifdef MAXSENDQ
	if( listrest )
		listem(dp);
# endif
	closedir(df);
	printsum();
	if(more)printf("   ... more ...\n");
	}
summarize( size )
long size;
	{
#ifndef DONTHOLDBIG
	if( size > MAXDAYFILE ) {
		nsumj++;
		nsumb += size;
	}
	else {
		sumj++;
		sumb += size;
	}
#else
	sumb += size;
	sumj++;
#endif
	}
printsum(){
#ifndef DONTHOLDBIG
	if( sumj != 0 || nsumj != 0 ){
		printf("day jobs: %d request%s (%ld bytes)",
			sumj, (sumj > 1 ? "s" : ""), sumb);
		if(nsumj > 0)
			printf("; night jobs: %d request%s (%ld bytes)", 
				nsumj, ( nsumj > 1 ? "s" : ""), nsumb );
		putchar('\n');
		nsumb = 0l;
		nsumj = 0;
	}
#else
	if(sumj != 0){
		printf("%d request%s, %ld bytes\n",
			sumj,(sumj > 1 ? "s" : ""),sumb);
		}
#endif
	sumj = 0;
	sumb = 0l;
	}
process(){
	static struct header hd;
	static char nightheader = 0;
	FILE *look;
	char *cp;
	long size;

	printsum();
	look = fopen(jname,"r");
	if(look == NULL)
		return;
	readhdfd(&hd,look);
	fclose(look);
	if(hd.hd_snfrom[0] == 0)strcat(hd.hd_addrfrom,"Internal");
	expandcc(hd.hd_sttyname);
	cp = ctime(&statbuf.st_mtime);
	cp[strlen(cp)-9] = 0;
	jname[3] = jname[2];
	size = getsize(&statbuf);
	if(size >= MAXDAYFILE && ! nightheader){
		printf("(> %ld bytes, will only transfer between Midnight and 6AM.)\n", MAXDAYFILE);
		nightheader = 1;
		};
	printf("%-10s %-10s %6ld %s %s  %-.27s\n",
		hd.hd_addrfrom,hd.hd_addrto,size,jname+3,cp+4,hd.hd_scmdvirt);
	}
readhdfd(phd,fd)
register struct header *phd;
FILE *fd;
{
	char sbuf[BUFSIZ], parmlist[PARMLIST];
	char *s, cflag;
	int c, i;
	phd->hd_code = phd->hd_mchto = phd->hd_snto[0] = phd->hd_sinfile[0] = 0;
	phd->hd_soutfile[0] = phd->hd_srespfile[0] = phd->hd_snfrom[0] = 0;
	phd->hd_scmdact[0] = 0;
	for(i=0;i<20;i++)phd->hd_sttyname[i] = 0;

	phd->hd_code = ngetc(fd);
	if(phd->hd_code == 0)return;
	phd->hd_mchto = ngetc(fd);
	phd->hd_mchfrom = ngetc(fd);	/* from machine */
	phd->hd_vmajor = ngetc(fd);
	phd->hd_vminor = ngetc(fd);
	ngets(phd->hd_snto,NS,fd);
	ngets(phd->hd_spasswd,20,fd);			/* passwd */
	ngets(phd->hd_sinfile,FNS,fd);
	ngets(phd->hd_soutfile,FNS,fd);
	ngets(phd->hd_srespfile,FNS,fd);
	ngets(phd->hd_snfrom,NS,fd);
	ngets(phd->hd_sttyname,20,fd);
	cflag = ngetc(fd);		
	ngets(sbuf,BUFSIZ,fd);				/* lttytime */
	ngets(parmlist,PARMLIST,fd);			/* jobno */
	parseparmlist(parmlist);
	ngets(sbuf,BUFSIZ,fd);				/* timesent */
	s = phd->hd_scmdact;
	while((c = getc(fd)) != EOF && c != '\n'){
		if(c == '\\')c = getc(fd);
		*s++ = c;
		}
	*s = 0;
	s = phd->hd_scmdvirt;
	while((c = getc(fd)) != EOF && c != '\n'){
		if(c == '\\')c = getc(fd);
		*s++ = c;
		}
	*s = 0;
	if(phd->hd_scmdvirt[0] == 0)strcpy(phd->hd_scmdvirt,phd->hd_scmdact);
	sprintf(phd->hd_addrfrom,"%c:%s",phd->hd_mchfrom,phd->hd_snfrom);
	sprintf(phd->hd_addrto  ,"%c:%s",phd->hd_mchto  ,phd->hd_snto  );
}
ngetc(fd)
FILE *fd;
{
	char b[3];
	if(feof(fd))return(0);
	if(fread(b,1,3,fd) != 3) return(0);
	return(b[0]);
	}
/* read a string s of max length maxlen out of queue file */
ngets(s,maxlen,fd)
int maxlen;
char *s;
FILE *fd;
{
	int i;
	if(feof(fd))return;
	for(;;){
		i = getc(fd);
		if(i == EOF){
			*s = 0;
			return;
			}
		*s = i;
		if(*s == '\\')*s = getc(fd);
		if(*s == ' ')break;
		if(maxlen-- > 0)s++;
		}
	*s = 0;
	getc(fd);
	}
insert(f,t)
  char *f;
  long t; {
	strcpy(stack[stptr].name,f);
	stack[stptr++].filesize = t;
	return(stptr <= STSIZE);
	}
compar(a,b)
  register struct table *a,*b; {
	if(a->filesize < b->filesize)return(-1);
	if(a->filesize > b->filesize)return(1);
	return(0);
	}
sort(){		/* use this cause qsort doesn't work */
	register int i,j;
	for(i=0; i< stptr-1; i++)
		for(j=i+1;j<stptr;j++)
			if(compar(&stack[i],&stack[j]) > 0)
				swap(&stack[i],&stack[j]);
	}
swap(a,b)
  register struct table *a, *b; {
	char str[16];
	long t;
	strcpy(str,a->name);
	t = a->filesize;
	strcpy(a->name,b->name);
	a->filesize = b->filesize;
	strcpy(b->name,str);
	b->filesize = t;
	}
# ifdef MAXSENDQ
listem(dp)
register struct direct *dp; {
	
	do {
		if(dp->d_name[0] != 'c'
		|| dp->d_name[1] != 'f'
		|| stat( dp->d_name, &statbuf ) < 0 )
			continue;
		if( mach != dp->d_name[2] )
			continue;
		dp->d_name[0] = 'd';
		if( stat( dp->d_name, &statbuf ) < 0 )
			continue;
		if( printlong || guid( statbuf.st_uid, statbuf.st_gid) == hisuid )
			process();
		else
			summarize( getsize( &statbuf ) );
	} while((dp = readdir(df)) != NULL);

	return;
}
# endif MAXSENDQ
Commit	Line	Data
e804469b	1	static char sccsid[] = "@(#)netq.c 4.2 (Berkeley) 9/12/82";
4c12ba52 KM	2
	3	/* netq - print the netq send queue */
	4	/* netq [-] [mach] */
	5	/* must be setuid root */
	6
	7	/* sccs id variable */
	8	static char *netq_sid = "@(#)netq.c 1.5";
	9
	10	# include "defs.h"
	11	/* this is an internal table size -- only STSIZE entries will
	12	be sorted correctly */
	13	# define STSIZE 150
	14
23f1e696	15	static DIR *df;
4c12ba52 KM	16	static char jname[16], printlong;
	17	static struct table {
	18	char name[16];
	19	long filesize;
	20	} stack[STSIZE], temp;
	21	static int stptr = 0;
	22	static char mach,visit[MAXINX];
	23	static char netcmd1[] = NETCMD1;
	24	static int hisuid,sumj,nsumj;
	25	static long sumb, nsumb;
	26	static struct stat statbuf;
4c12ba52 KM	27
	28	char _sobuf[BUFSIZ];
	29	main(argc,argv)
	30	char **argv; {
	31	int i;
	32	setbuf(stdout,_sobuf);
	33	hisuid = getuid();
	34	hisuid = uidmask(hisuid);
	35	if(stat(netcmd,&statbuf) >= 0)
	36	if((statbuf.st_mode & 07) == 0){
	37	printf("Network is down\n");
	38	exit(EX_UNAVAILABLE);
	39	}
	40	else if(stat(netcmd1,&statbuf) >= 0)
	41	if((statbuf.st_mode & 07) == 0){
	42	printf("Network is down\n");
	43	exit(EX_UNAVAILABLE);
	44	}
	45	while(argc > 1){
	46	switch(argv[1][0]){
	47	case '-': printlong++; break;
	48	default: mach = lookup(argv[1]);
	49	if(mach > 0 && machtype[chtoinx(mach)] == 0)mach = 0;
	50	break;
	51	}
	52	argc--, argv++;
	53	}
	54	if(mach){
	55	mach = gothru(local,mach); /* list to directly conn. machine */
	56	if(mach == 0){
	57	fprintf(stderr,"That machine not directly connected.\n");
	58	exit(EX_USAGE);
	59	}
	60	senddir[strlen(senddir)-1] = mach;
	61	if(chdir(senddir) < 0){
	62	perror(senddir);
	63	exit(EX_OSFILE);
	64	}
	65	pdir(senddir);
	66	}
	67	else for(i = 0; i < MAXINX; i++)
	68	if((mach = gothru(local,inxtoch(i))) && !visit[chtoinx(mach)]){
	69	visit[chtoinx(mach)] = 1;
	70	senddir[strlen(senddir)-1] = mach;
	71	if(chdir(senddir) < 0)continue;
	72	pdir(senddir);
	73	printf("---\n");
	74	}
	75	fflush(stdout);
	76	}
	77	static pdir(str)
	78	char *str; {
	79	int i;
	80	char more = 0, *cp;
	81	char listrest = 0;
	82	int (*compar)();
	83	char printhead = 0;
23f1e696 KM	84	register struct direct *dp;
23f1e696 KM	85	df = opendir(str);
4c12ba52 KM	86	if(df == NULL){
	87	perror(str);
	88	exit(EX_OSFILE);
	89	}
	90	stptr = 0;
23f1e696 KM	91	while((dp = readdir(df)) != NULL){
	92	if(dp->d_name[0] != 'c'
	93	\|\| dp->d_name[1] != 'f'
	94	\|\| stat(dp->d_name,&statbuf) < 0)
4c12ba52	95	continue;
23f1e696 KM	96	if(mach != dp->d_name[2])continue;
	97	dp->d_name[0] = 'd';
	98	if(stat(dp->d_name,&statbuf) < 0)continue;
4c12ba52 KM	99	#ifdef MAXSENDQ
	100	if( stptr >= MAXSENDQ ) {
	101	listrest++;
	102	break;
	103	}
	104	#endif
	105
23f1e696	106	if(!insert(dp->d_name,getsize(&statbuf))){
4c12ba52 KM	107	more++;
	108	break;
	109	}
	110	}
	111	if(stptr == 0){
	112	printf("Network queue to/thru %s is empty.\n",longname(mach));
23f1e696	113	closedir(df);
4c12ba52 KM	114	return;
	115	}
	116	cp = (char *)&(stack[0].name[0]);
	117	sort(cp,stptr,sizeof temp,compar);
	118	printf("Network queue to/thru %s:\n",longname(mach));
	119	for(i = 0; i < stptr; i++){ /* screen size */
	120	strcpy(jname,stack[i].name);
	121	jname[0] = 'd';
	122	if(stat(jname,&statbuf) < 0)
	123	continue;
	124	if(printlong \|\| guid(statbuf.st_uid,statbuf.st_gid) == hisuid){
	125	if(!printhead){
	126	printhead = 1;
	127	printf( "From To Len Code Time Command\n");
	128	};
	129	process();
	130	}
	131	else summarize( stack[i].filesize );
	132	}
	133	# ifdef MAXSENDQ
	134	if( listrest )
23f1e696	135	listem(dp);
4c12ba52	136	# endif
23f1e696	137	closedir(df);
4c12ba52 KM	138	printsum();
	139	if(more)printf(" ... more ...\n");
	140	}
	141	summarize( size )
	142	long size;
	143	{
	144	#ifndef DONTHOLDBIG
	145	if( size > MAXDAYFILE ) {
	146	nsumj++;
	147	nsumb += size;
	148	}
	149	else {
	150	sumj++;
	151	sumb += size;
	152	}
	153	#else
	154	sumb += size;
	155	sumj++;
	156	#endif
	157	}
	158	printsum(){
	159	#ifndef DONTHOLDBIG
	160	if( sumj != 0 \|\| nsumj != 0 ){
	161	printf("day jobs: %d request%s (%ld bytes)",
	162	sumj, (sumj > 1 ? "s" : ""), sumb);
	163	if(nsumj > 0)
	164	printf("; night jobs: %d request%s (%ld bytes)",
	165	nsumj, ( nsumj > 1 ? "s" : ""), nsumb );
	166	putchar('\n');
	167	nsumb = 0l;
	168	nsumj = 0;
	169	}
	170	#else
	171	if(sumj != 0){
	172	printf("%d request%s, %ld bytes\n",
	173	sumj,(sumj > 1 ? "s" : ""),sumb);
	174	}
	175	#endif
	176	sumj = 0;
	177	sumb = 0l;
	178	}
	179	process(){
	180	static struct header hd;
	181	static char nightheader = 0;
	182	FILE *look;
	183	char *cp;
	184	long size;
	185
	186	printsum();
	187	look = fopen(jname,"r");
	188	if(look == NULL)
	189	return;
	190	readhdfd(&hd,look);
	191	fclose(look);
	192	if(hd.hd_snfrom[0] == 0)strcat(hd.hd_addrfrom,"Internal");
	193	expandcc(hd.hd_sttyname);
	194	cp = ctime(&statbuf.st_mtime);
	195	cp[strlen(cp)-9] = 0;
	196	jname[3] = jname[2];
	197	size = getsize(&statbuf);
	198	if(size >= MAXDAYFILE && ! nightheader){
	199	printf("(> %ld bytes, will only transfer between Midnight and 6AM.)\n", MAXDAYFILE);
	200	nightheader = 1;
	201	};
202	printf("%-10s %-10s %6ld %s %s %-.27s\n",
203	hd.hd_addrfrom,hd.hd_addrto,size,jname+3,cp+4,hd.hd_scmdvirt);
204	}
205	readhdfd(phd,fd)
206	register struct header *phd;
207	FILE *fd;
208	{
209	char sbuf[BUFSIZ], parmlist[PARMLIST];
210	char *s, cflag;
211	int c, i;
212	phd->hd_code = phd->hd_mchto = phd->hd_snto[0] = phd->hd_sinfile[0] = 0;
213	phd->hd_soutfile[0] = phd->hd_srespfile[0] = phd->hd_snfrom[0] = 0;
214	phd->hd_scmdact[0] = 0;
215	for(i=0;i<20;i++)phd->hd_sttyname[i] = 0;
216
217	phd->hd_code = ngetc(fd);
218	if(phd->hd_code == 0)return;
219	phd->hd_mchto = ngetc(fd);
220	phd->hd_mchfrom = ngetc(fd); /* from machine */
221	phd->hd_vmajor = ngetc(fd);
222	phd->hd_vminor = ngetc(fd);
223	ngets(phd->hd_snto,NS,fd);
224	ngets(phd->hd_spasswd,20,fd); /* passwd */
225	ngets(phd->hd_sinfile,FNS,fd);
226	ngets(phd->hd_soutfile,FNS,fd);
227	ngets(phd->hd_srespfile,FNS,fd);
228	ngets(phd->hd_snfrom,NS,fd);
229	ngets(phd->hd_sttyname,20,fd);
230	cflag = ngetc(fd);
231	ngets(sbuf,BUFSIZ,fd); /* lttytime */
232	ngets(parmlist,PARMLIST,fd); /* jobno */
233	parseparmlist(parmlist);
234	ngets(sbuf,BUFSIZ,fd); /* timesent */
235	s = phd->hd_scmdact;
236	while((c = getc(fd)) != EOF && c != '\n'){
237	if(c == '\\')c = getc(fd);
238	*s++ = c;
239	}
240	*s = 0;
241	s = phd->hd_scmdvirt;
242	while((c = getc(fd)) != EOF && c != '\n'){
243	if(c == '\\')c = getc(fd);
244	*s++ = c;
245	}
246	*s = 0;
247	if(phd->hd_scmdvirt[0] == 0)strcpy(phd->hd_scmdvirt,phd->hd_scmdact);
248	sprintf(phd->hd_addrfrom,"%c:%s",phd->hd_mchfrom,phd->hd_snfrom);
249	sprintf(phd->hd_addrto ,"%c:%s",phd->hd_mchto ,phd->hd_snto );
250	}
251	ngetc(fd)
252	FILE *fd;
253	{
254	char b[3];
255	if(feof(fd))return(0);
256	if(fread(b,1,3,fd) != 3) return(0);
257	return(b[0]);
258	}
259	/* read a string s of max length maxlen out of queue file */
260	ngets(s,maxlen,fd)
261	int maxlen;
262	char *s;
263	FILE *fd;
264	{
265	int i;
266	if(feof(fd))return;
267	for(;;){
268	i = getc(fd);
269	if(i == EOF){
270	*s = 0;
271	return;
272	}
273	*s = i;
274	if(s == '\\')s = getc(fd);
275	if(*s == ' ')break;
276	if(maxlen-- > 0)s++;
277	}
278	*s = 0;
279	getc(fd);
280	}
281	insert(f,t)
282	char *f;
283	long t; {
284	strcpy(stack[stptr].name,f);
285	stack[stptr++].filesize = t;
286	return(stptr <= STSIZE);
287	}
288	compar(a,b)
289	register struct table a,b; {
290	if(a->filesize < b->filesize)return(-1);
291	if(a->filesize > b->filesize)return(1);
292	return(0);
293	}
294	sort(){ /* use this cause qsort doesn't work */
295	register int i,j;
296	for(i=0; i< stptr-1; i++)
297	for(j=i+1;j<stptr;j++)
298	if(compar(&stack[i],&stack[j]) > 0)
299	swap(&stack[i],&stack[j]);
300	}
301	swap(a,b)
302	register struct table a, b; {
303	char str[16];
304	long t;
305	strcpy(str,a->name);
306	t = a->filesize;
307	strcpy(a->name,b->name);
308	a->filesize = b->filesize;
309	strcpy(b->name,str);
310	b->filesize = t;
311	}
312	# ifdef MAXSENDQ
23f1e696 KM	313	listem(dp)
23f1e696 KM	314	register struct direct *dp; {
4c12ba52	315
23f1e696 KM	316	do {
	317	if(dp->d_name[0] != 'c'
	318	\|\| dp->d_name[1] != 'f'
	319	\|\| stat( dp->d_name, &statbuf ) < 0 )
4c12ba52	320	continue;
23f1e696	321	if( mach != dp->d_name[2] )
4c12ba52	322	continue;
23f1e696 KM	323	dp->d_name[0] = 'd';
23f1e696 KM	324	if( stat( dp->d_name, &statbuf ) < 0 )
4c12ba52 KM	325	continue;
	326	if( printlong \|\| guid( statbuf.st_uid, statbuf.st_gid) == hisuid )
	327	process();
	328	else
	329	summarize( getsize( &statbuf ) );
23f1e696	330	} while((dp = readdir(df)) != NULL);
4c12ba52 KM	331
	332	return;
	333	}
	334	# endif MAXSENDQ