[unix-history] / usr / src / libexec / rlogind / rlogind.c

/*
 * Copyright (c) 1983 Regents of the University of California.
 * All rights reserved.  The Berkeley software License Agreement
 * specifies the terms and conditions for redistribution.
 */

#ifndef lint
char copyright[] =
"@(#) Copyright (c) 1983 Regents of the University of California.\n\
 All rights reserved.\n";
#endif not lint

#ifndef lint
static char sccsid[] = "@(#)rlogind.c	5.8 (Berkeley) %G%";
#endif not lint

/*
 * remote login server:
 *	remuser\0
 *	locuser\0
 *	terminal info\0
 *	data
 */

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/socket.h>
#include <sys/wait.h>
#include <sys/file.h>

#include <netinet/in.h>

#include <errno.h>
#include <pwd.h>
#include <signal.h>
#include <sgtty.h>
#include <stdio.h>
#include <netdb.h>
#include <syslog.h>
#include <strings.h>

# ifndef TIOCPKT_WINDOW
# define TIOCPKT_WINDOW 0x80
# endif TIOCPKT_WINDOW

extern	errno;
int	reapchild();
struct	passwd *getpwnam();
char	*malloc();

main(argc, argv)
	int argc;
	char **argv;
{
	int on = 1, options = 0, fromlen;
	struct sockaddr_in from;

	openlog("rlogind", LOG_PID | LOG_AUTH, LOG_AUTH);
	fromlen = sizeof (from);
	if (getpeername(0, &from, &fromlen) < 0) {
		fprintf(stderr, "%s: ", argv[0]);
		perror("getpeername");
		_exit(1);
	}
	if (setsockopt(0, SOL_SOCKET, SO_KEEPALIVE, &on, sizeof (on)) < 0) {
		syslog(LOG_WARNING, "setsockopt (SO_KEEPALIVE): %m");
	}
	doit(0, &from);
}

int	child;
int	cleanup();
int	netf;
extern	errno;
char	*line;
extern	char	*inet_ntoa();

struct winsize win = { 0, 0, 0, 0 };


doit(f, fromp)
	int f;
	struct sockaddr_in *fromp;
{
	int i, p, t, pid, on = 1;
	register struct hostent *hp;
	struct hostent hostent;
	char c;

	alarm(60);
	read(f, &c, 1);
	if (c != 0)
		exit(1);
	alarm(0);
	fromp->sin_port = ntohs((u_short)fromp->sin_port);
	hp = gethostbyaddr(&fromp->sin_addr, sizeof (struct in_addr),
		fromp->sin_family);
	if (hp == 0) {
		/*
		 * Only the name is used below.
		 */
		hp = &hostent;
		hp->h_name = inet_ntoa(fromp->sin_addr);
	}
	if (fromp->sin_family != AF_INET ||
	    fromp->sin_port >= IPPORT_RESERVED)
		fatal(f, "Permission denied");
	write(f, "", 1);
	for (c = 'p'; c <= 's'; c++) {
		struct stat stb;
		line = "/dev/ptyXX";
		line[strlen("/dev/pty")] = c;
		line[strlen("/dev/ptyp")] = '0';
		if (stat(line, &stb) < 0)
			break;
		for (i = 0; i < 16; i++) {
			line[strlen("/dev/ptyp")] = "0123456789abcdef"[i];
			p = open(line, 2);
			if (p > 0)
				goto gotpty;
		}
	}
	fatal(f, "Out of ptys");
	/*NOTREACHED*/
gotpty:
	(void) ioctl(p, TIOCSWINSZ, &win);
	netf = f;
	line[strlen("/dev/")] = 't';
#ifdef DEBUG
	{ int tt = open("/dev/tty", 2);
	  if (tt > 0) {
		ioctl(tt, TIOCNOTTY, 0);
		close(tt);
	  }
	}
#endif
	t = open(line, 2);
	if (t < 0)
		fatalperror(f, line, errno);
	{ struct sgttyb b;
	  gtty(t, &b); b.sg_flags = RAW|ANYP; stty(t, &b);
	}
	pid = fork();
	if (pid < 0)
		fatalperror(f, "", errno);
	if (pid == 0) {
		close(f), close(p);
		dup2(t, 0), dup2(t, 1), dup2(t, 2);
		close(t);
		execl("/bin/login", "login", "-r", hp->h_name, 0);
		fatalperror(2, "/bin/login", errno);
		/*NOTREACHED*/
	}
	close(t);
	ioctl(f, FIONBIO, &on);
	ioctl(p, FIONBIO, &on);
	ioctl(p, TIOCPKT, &on);
	signal(SIGTSTP, SIG_IGN);
	signal(SIGCHLD, cleanup);
	setpgrp(0, 0);
	protocol(f, p);
	cleanup();
}

char	magic[2] = { 0377, 0377 };

/*
 * Handle a "control" request (signaled by magic being present)
 * in the data stream.  For now, we are only willing to handle
 * window size changes.
 */
control(pty, cp, n)
	int pty;
	char *cp;
	int n;
{
	struct winsize *wp;

	if (n < 4+sizeof (*wp) || cp[2] != 's' || cp[3] != 's')
		return (0);
	wp = (struct winsize *)(cp+4);
	wp->ws_row = ntohs(wp->ws_row);
	wp->ws_col = ntohs(wp->ws_col);
	wp->ws_xpixel = ntohs(wp->ws_xpixel);
	wp->ws_ypixel = ntohs(wp->ws_ypixel);
	(void)ioctl(pty, TIOCSWINSZ, wp);
	return (4+sizeof (*wp));
}

/*
 * rlogin "protocol" machine.
 */
protocol(f, p)
	int f, p;
{
	char pibuf[1024], fibuf[1024], *pbp, *fbp;
	register pcc = 0, fcc = 0;
	int cc, stop = TIOCPKT_DOSTOP, wsize;
	static char oob[] = {TIOCPKT_WINDOW};

	/*
	 * Must ignore SIGTTOU, otherwise we'll stop
	 * when we try and set slave pty's window shape
	 * (our pgrp is that of the master pty).
	 */
	(void) signal(SIGTTOU, SIG_IGN);
	send(f, oob, 1, MSG_OOB);	/* indicate new rlogin */
	for (;;) {
		int ibits = 0, obits = 0;

		if (fcc)
			obits |= (1<<p);
		else
			ibits |= (1<<f);
		if (pcc >= 0)
			if (pcc)
				obits |= (1<<f);
			else
				ibits |= (1<<p);
		if (select(16, &ibits, &obits, 0, 0) < 0) {
			if (errno == EINTR)
				continue;
			fatalperror(f, "select", errno);
		}
		if (ibits == 0 && obits == 0) {
			/* shouldn't happen... */
			sleep(5);
			continue;
		}
		if (ibits & (1<<f)) {
			fcc = read(f, fibuf, sizeof (fibuf));
			if (fcc < 0 && errno == EWOULDBLOCK)
				fcc = 0;
			else {
				register char *cp;
				int left, n;

				if (fcc <= 0)
					break;
				fbp = fibuf;

			top:
				for (cp = fibuf; cp < fibuf+fcc; cp++)
					if (cp[0] == magic[0] &&
					    cp[1] == magic[1]) {
						left = fcc - (cp-fibuf);
						n = control(p, cp, left);
						if (n) {
							left -= n;
							if (left > 0)
								bcopy(cp, cp+n, left);
							fcc -= n;
							goto top; /* n^2 */
						} /* if (n) */
					} /* for (cp = ) */
				} /* else */
		} /* if (ibits & (1<<f)) */

		if ((obits & (1<<p)) && fcc > 0) {
			wsize = fcc;
			do {
				cc = write(p, fbp, wsize);
				wsize /= 2;
			} while (cc<0 && errno==EWOULDBLOCK && wsize);
			if (cc > 0) {
				fcc -= cc;
				fbp += cc;
			}
		}

		if (ibits & (1<<p)) {
			pcc = read(p, pibuf, sizeof (pibuf));
			pbp = pibuf;
			if (pcc < 0 && errno == EWOULDBLOCK)
				pcc = 0;
			else if (pcc <= 0)
				break;
			else if (pibuf[0] == 0)
				pbp++, pcc--;
			else {
#define	pkcontrol(c)	((c)&(TIOCPKT_FLUSHWRITE|TIOCPKT_NOSTOP|TIOCPKT_DOSTOP))
				int out = FREAD;

				if (pkcontrol(pibuf[0])) {
				/* The following 3 lines do nothing. */
					int nstop = pibuf[0] &
					    (TIOCPKT_NOSTOP|TIOCPKT_DOSTOP);

					if (nstop)
						stop = nstop;
					pibuf[0] |= nstop | oob[0];
					send(f, &pibuf[0], 1, MSG_OOB);
					if (pibuf[0] & TIOCPKT_FLUSHWRITE)
					  ioctl(p, TIOCFLUSH, (char *)&out);

				}
				pcc = 0;
			}
		}
		if ((obits & (1<<f)) && pcc > 0) {
			wsize = pcc;
			do {
				cc = write(f, pbp, wsize);
				wsize /= 2;
			} while (cc<0 && errno==EWOULDBLOCK && wsize);
			if (cc > 0) {
				pcc -= cc;
				pbp += cc;
			}
		}
	}
}

cleanup()
{

	rmut();
	vhangup();		/* XXX */
	shutdown(netf, 2);
	exit(1);
}

fatal(f, msg)
	int f;
	char *msg;
{
	char buf[BUFSIZ];

	buf[0] = '\01';		/* error indicator */
	(void) sprintf(buf + 1, "rlogind: %s.\r\n", msg);
	(void) write(f, buf, strlen(buf));
	exit(1);
}

fatalperror(f, msg, errno)
	int f;
	char *msg;
	int errno;
{
	char buf[BUFSIZ];
	extern int sys_nerr;
	extern char *sys_errlist[];

	if ((unsigned)errno < sys_nerr)
		(void) sprintf(buf, "%s: %s", msg, sys_errlist[errno]);
	else
		(void) sprintf(buf, "%s: Error %d", msg, errno);
	fatal(f, buf);
}

#include <utmp.h>

struct	utmp wtmp;
char	wtmpf[]	= "/usr/adm/wtmp";
char	utmpf[] = "/etc/utmp";
#define SCPYN(a, b)	strncpy(a, b, sizeof(a))
#define SCMPN(a, b)	strncmp(a, b, sizeof(a))

rmut()
{
	register f;
	int found = 0;
	struct utmp *u, *utmp;
	int nutmp;
	struct stat statbf;

	f = open(utmpf, O_RDWR);
	if (f >= 0) {
		fstat(f, &statbf);
		utmp = (struct utmp *)malloc(statbf.st_size);
		if (!utmp)
			syslog(LOG_ERR, "utmp malloc failed");
		if (statbf.st_size && utmp) {
			nutmp = read(f, utmp, statbf.st_size);
			nutmp /= sizeof(struct utmp);
		
			for (u = utmp ; u < &utmp[nutmp] ; u++) {
				if (SCMPN(u->ut_line, line+5) ||
				    u->ut_name[0]==0)
					continue;
				lseek(f, ((long)u)-((long)utmp), L_SET);
				SCPYN(u->ut_name, "");
				SCPYN(u->ut_host, "");
				time(&u->ut_time);
				write(f, (char *)u, sizeof(wtmp));
				found++;
			}
		}
		close(f);
	}
	if (found) {
		f = open(wtmpf, O_WRONLY|O_APPEND);
		if (f >= 0) {
			SCPYN(wtmp.ut_line, line+5);
			SCPYN(wtmp.ut_name, "");
			SCPYN(wtmp.ut_host, "");
			time(&wtmp.ut_time);
			write(f, (char *)&wtmp, sizeof(wtmp));
			close(f);
		}
	}
	chmod(line, 0666);
	chown(line, 0, 0);
	line[strlen("/dev/")] = 'p';
	chmod(line, 0666);
	chown(line, 0, 0);
}
Commit	Line	Data
8c5eec2f DF	1	/*
	2	* Copyright (c) 1983 Regents of the University of California.
	3	* All rights reserved. The Berkeley software License Agreement
	4	* specifies the terms and conditions for redistribution.
	5	*/
	6
	7	#ifndef lint
	8	char copyright[] =
	9	"@(#) Copyright (c) 1983 Regents of the University of California.\n\
	10	All rights reserved.\n";
	11	#endif not lint
	12
a10a364d	13	#ifndef lint
d9b06a2d	14	static char sccsid[] = "@(#)rlogind.c 5.8 (Berkeley) %G%";
8c5eec2f	15	#endif not lint
a10a364d	16
bb933cc2 MK	17	/*
	18	* remote login server:
	19	* remuser\0
	20	* locuser\0
6632767b	21	* terminal info\0
bb933cc2 MK	22	* data
	23	*/
	24
a10a364d BJ	25	#include <stdio.h>
	26	#include <sys/types.h>
	27	#include <sys/stat.h>
	28	#include <sys/socket.h>
560a8855	29	#include <sys/wait.h>
6632767b	30	#include <sys/file.h>
c6c678f1 SL	31
	32	#include <netinet/in.h>
	33
a10a364d BJ	34	#include <errno.h>
a10a364d BJ	35	#include <pwd.h>
a10a364d BJ	36	#include <signal.h>
	37	#include <sgtty.h>
	38	#include <stdio.h>
3f5b52bc	39	#include <netdb.h>
3f99c0f7	40	#include <syslog.h>
6632767b	41	#include <strings.h>
a10a364d	42
66feb14c KM	43	# ifndef TIOCPKT_WINDOW
	44	# define TIOCPKT_WINDOW 0x80
	45	# endif TIOCPKT_WINDOW
	46
a10a364d	47	extern errno;
92e31018	48	int reapchild();
a10a364d	49	struct passwd *getpwnam();
66feb14c	50	char *malloc();
bb933cc2	51
a10a364d BJ	52	main(argc, argv)
	53	int argc;
	54	char **argv;
	55	{
bcb894cb	56	int on = 1, options = 0, fromlen;
a10a364d BJ	57	struct sockaddr_in from;
a10a364d BJ	58
076ae92c	59	openlog("rlogind", LOG_PID \| LOG_AUTH, LOG_AUTH);
bb933cc2 MK	60	fromlen = sizeof (from);
	61	if (getpeername(0, &from, &fromlen) < 0) {
	62	fprintf(stderr, "%s: ", argv[0]);
	63	perror("getpeername");
	64	_exit(1);
92e31018	65	}
bcb894cb	66	if (setsockopt(0, SOL_SOCKET, SO_KEEPALIVE, &on, sizeof (on)) < 0) {
3f99c0f7	67	syslog(LOG_WARNING, "setsockopt (SO_KEEPALIVE): %m");
c6c678f1	68	}
bb933cc2	69	doit(0, &from);
92e31018 SL	70	}
92e31018 SL	71
a10a364d BJ	72	int child;
	73	int cleanup();
	74	int netf;
	75	extern errno;
	76	char *line;
43368533	77	extern char *inet_ntoa();
a10a364d	78
8210fa73 KM	79	struct winsize win = { 0, 0, 0, 0 };
8210fa73 KM	80
66feb14c	81
a10a364d BJ	82	doit(f, fromp)
	83	int f;
	84	struct sockaddr_in *fromp;
	85	{
6632767b	86	int i, p, t, pid, on = 1;
3f5b52bc	87	register struct hostent *hp;
43368533	88	struct hostent hostent;
6632767b	89	char c;
a10a364d BJ	90
	91	alarm(60);
	92	read(f, &c, 1);
	93	if (c != 0)
	94	exit(1);
	95	alarm(0);
1227078b	96	fromp->sin_port = ntohs((u_short)fromp->sin_port);
3f5b52bc SL	97	hp = gethostbyaddr(&fromp->sin_addr, sizeof (struct in_addr),
3f5b52bc SL	98	fromp->sin_family);
8de87e4f	99	if (hp == 0) {
43368533 KM	100	/*
	101	* Only the name is used below.
	102	*/
	103	hp = &hostent;
	104	hp->h_name = inet_ntoa(fromp->sin_addr);
8de87e4f	105	}
a10a364d	106	if (fromp->sin_family != AF_INET \|\|
1227078b	107	fromp->sin_port >= IPPORT_RESERVED)
82c973f2	108	fatal(f, "Permission denied");
a10a364d BJ	109	write(f, "", 1);
	110	for (c = 'p'; c <= 's'; c++) {
	111	struct stat stb;
	112	line = "/dev/ptyXX";
	113	line[strlen("/dev/pty")] = c;
	114	line[strlen("/dev/ptyp")] = '0';
	115	if (stat(line, &stb) < 0)
	116	break;
	117	for (i = 0; i < 16; i++) {
	118	line[strlen("/dev/ptyp")] = "0123456789abcdef"[i];
	119	p = open(line, 2);
	120	if (p > 0)
	121	goto gotpty;
	122	}
	123	}
66feb14c	124	fatal(f, "Out of ptys");
82c973f2	125	/NOTREACHED/
a10a364d	126	gotpty:
8210fa73	127	(void) ioctl(p, TIOCSWINSZ, &win);
1227078b	128	netf = f;
a10a364d BJ	129	line[strlen("/dev/")] = 't';
	130	#ifdef DEBUG
	131	{ int tt = open("/dev/tty", 2);
	132	if (tt > 0) {
	133	ioctl(tt, TIOCNOTTY, 0);
	134	close(tt);
	135	}
	136	}
	137	#endif
	138	t = open(line, 2);
82c973f2 SL	139	if (t < 0)
82c973f2 SL	140	fatalperror(f, line, errno);
a10a364d BJ	141	{ struct sgttyb b;
	142	gtty(t, &b); b.sg_flags = RAW\|ANYP; stty(t, &b);
	143	}
82c973f2 SL	144	pid = fork();
	145	if (pid < 0)
	146	fatalperror(f, "", errno);
6632767b SL	147	if (pid == 0) {
	148	close(f), close(p);
	149	dup2(t, 0), dup2(t, 1), dup2(t, 2);
1227078b	150	close(t);
6632767b SL	151	execl("/bin/login", "login", "-r", hp->h_name, 0);
	152	fatalperror(2, "/bin/login", errno);
	153	/NOTREACHED/
	154	}
	155	close(t);
	156	ioctl(f, FIONBIO, &on);
	157	ioctl(p, FIONBIO, &on);
	158	ioctl(p, TIOCPKT, &on);
	159	signal(SIGTSTP, SIG_IGN);
	160	signal(SIGCHLD, cleanup);
ad5d2c7f	161	setpgrp(0, 0);
6632767b SL	162	protocol(f, p);
	163	cleanup();
	164	}
82c973f2	165
6632767b SL	166	char magic[2] = { 0377, 0377 };
	167
	168	/*
	169	* Handle a "control" request (signaled by magic being present)
	170	* in the data stream. For now, we are only willing to handle
	171	* window size changes.
	172	*/
	173	control(pty, cp, n)
	174	int pty;
	175	char *cp;
	176	int n;
	177	{
	178	struct winsize *wp;
	179
	180	if (n < 4+sizeof (*wp) \|\| cp[2] != 's' \|\| cp[3] != 's')
	181	return (0);
	182	wp = (struct winsize *)(cp+4);
	183	wp->ws_row = ntohs(wp->ws_row);
	184	wp->ws_col = ntohs(wp->ws_col);
	185	wp->ws_xpixel = ntohs(wp->ws_xpixel);
	186	wp->ws_ypixel = ntohs(wp->ws_ypixel);
	187	(void)ioctl(pty, TIOCSWINSZ, wp);
	188	return (4+sizeof (*wp));
	189	}
	190
	191	/*
	192	* rlogin "protocol" machine.
	193	*/
	194	protocol(f, p)
	195	int f, p;
	196	{
	197	char pibuf[1024], fibuf[1024], pbp, fbp;
	198	register pcc = 0, fcc = 0;
66feb14c KM	199	int cc, stop = TIOCPKT_DOSTOP, wsize;
66feb14c KM	200	static char oob[] = {TIOCPKT_WINDOW};
6632767b	201
ffaf1c0b	202	/*
9ee4d121 SL	203	* Must ignore SIGTTOU, otherwise we'll stop
	204	* when we try and set slave pty's window shape
	205	* (our pgrp is that of the master pty).
ffaf1c0b	206	*/
9ee4d121	207	(void) signal(SIGTTOU, SIG_IGN);
66feb14c	208	send(f, oob, 1, MSG_OOB); /* indicate new rlogin */
6632767b SL	209	for (;;) {
	210	int ibits = 0, obits = 0;
	211
	212	if (fcc)
	213	obits \|= (1<<p);
	214	else
	215	ibits \|= (1<<f);
	216	if (pcc >= 0)
	217	if (pcc)
	218	obits \|= (1<<f);
82c973f2	219	else
6632767b SL	220	ibits \|= (1<<p);
	221	if (select(16, &ibits, &obits, 0, 0) < 0) {
	222	if (errno == EINTR)
a10a364d	223	continue;
6632767b SL	224	fatalperror(f, "select", errno);
	225	}
	226	if (ibits == 0 && obits == 0) {
	227	/* shouldn't happen... */
	228	sleep(5);
	229	continue;
	230	}
	231	if (ibits & (1<<f)) {
	232	fcc = read(f, fibuf, sizeof (fibuf));
	233	if (fcc < 0 && errno == EWOULDBLOCK)
	234	fcc = 0;
	235	else {
	236	register char *cp;
	237	int left, n;
	238
	239	if (fcc <= 0)
1227078b	240	break;
6632767b	241	fbp = fibuf;
66feb14c	242
6632767b SL	243	top:
	244	for (cp = fibuf; cp < fibuf+fcc; cp++)
	245	if (cp[0] == magic[0] &&
	246	cp[1] == magic[1]) {
	247	left = fcc - (cp-fibuf);
	248	n = control(p, cp, left);
	249	if (n) {
	250	left -= n;
	251	if (left > 0)
	252	bcopy(cp, cp+n, left);
	253	fcc -= n;
	254	goto top; /* n^2 */
66feb14c KM	255	} /* if (n) */
	256	} /* for (cp = ) */
	257	} /* else */
	258	} /* if (ibits & (1<<f)) */
	259
	260	if ((obits & (1<<p)) && fcc > 0) {
	261	wsize = fcc;
	262	do {
	263	cc = write(p, fbp, wsize);
	264	wsize /= 2;
	265	} while (cc<0 && errno==EWOULDBLOCK && wsize);
	266	if (cc > 0) {
	267	fcc -= cc;
	268	fbp += cc;
a10a364d	269	}
6632767b	270	}
66feb14c	271
6632767b SL	272	if (ibits & (1<<p)) {
	273	pcc = read(p, pibuf, sizeof (pibuf));
	274	pbp = pibuf;
	275	if (pcc < 0 && errno == EWOULDBLOCK)
	276	pcc = 0;
	277	else if (pcc <= 0)
	278	break;
	279	else if (pibuf[0] == 0)
	280	pbp++, pcc--;
	281	else {
	282	#define pkcontrol(c) ((c)&(TIOCPKT_FLUSHWRITE\|TIOCPKT_NOSTOP\|TIOCPKT_DOSTOP))
66feb14c KM	283	int out = FREAD;
66feb14c KM	284
6632767b SL	285	if (pkcontrol(pibuf[0])) {
	286	/* The following 3 lines do nothing. */
	287	int nstop = pibuf[0] &
	288	(TIOCPKT_NOSTOP\|TIOCPKT_DOSTOP);
	289
	290	if (nstop)
	291	stop = nstop;
8210fa73	292	pibuf[0] \|= nstop \| oob[0];
6632767b	293	send(f, &pibuf[0], 1, MSG_OOB);
66feb14c KM	294	if (pibuf[0] & TIOCPKT_FLUSHWRITE)
	295	ioctl(p, TIOCFLUSH, (char *)&out);
	296
a10a364d	297	}
6632767b	298	pcc = 0;
a10a364d	299	}
6632767b SL	300	}
6632767b SL	301	if ((obits & (1<<f)) && pcc > 0) {
66feb14c KM	302	wsize = pcc;
	303	do {
	304	cc = write(f, pbp, wsize);
	305	wsize /= 2;
	306	} while (cc<0 && errno==EWOULDBLOCK && wsize);
6632767b SL	307	if (cc > 0) {
	308	pcc -= cc;
	309	pbp += cc;
	310	}
	311	}
a10a364d	312	}
a10a364d BJ	313	}
	314
	315	cleanup()
	316	{
a10a364d BJ	317
a10a364d BJ	318	rmut();
dd83e8ac	319	vhangup(); /* XXX */
ff24c640	320	shutdown(netf, 2);
a10a364d BJ	321	exit(1);
	322	}
	323
82c973f2 SL	324	fatal(f, msg)
	325	int f;
	326	char *msg;
	327	{
	328	char buf[BUFSIZ];
	329
	330	buf[0] = '\01'; /* error indicator */
560a8855	331	(void) sprintf(buf + 1, "rlogind: %s.\r\n", msg);
82c973f2 SL	332	(void) write(f, buf, strlen(buf));
	333	exit(1);
	334	}
	335
	336	fatalperror(f, msg, errno)
	337	int f;
	338	char *msg;
	339	int errno;
	340	{
	341	char buf[BUFSIZ];
1227078b	342	extern int sys_nerr;
82c973f2 SL	343	extern char *sys_errlist[];
82c973f2 SL	344
6632767b	345	if ((unsigned)errno < sys_nerr)
1227078b MK	346	(void) sprintf(buf, "%s: %s", msg, sys_errlist[errno]);
	347	else
	348	(void) sprintf(buf, "%s: Error %d", msg, errno);
82c973f2 SL	349	fatal(f, buf);
	350	}
	351
a10a364d BJ	352	#include <utmp.h>
	353
	354	struct utmp wtmp;
	355	char wtmpf[] = "/usr/adm/wtmp";
0675fdb1	356	char utmpf[] = "/etc/utmp";
a10a364d BJ	357	#define SCPYN(a, b) strncpy(a, b, sizeof(a))
	358	#define SCMPN(a, b) strncmp(a, b, sizeof(a))
	359
	360	rmut()
	361	{
	362	register f;
	363	int found = 0;
0675fdb1 JB	364	struct utmp u, utmp;
	365	int nutmp;
	366	struct stat statbf;
a10a364d	367
0675fdb1	368	f = open(utmpf, O_RDWR);
a10a364d	369	if (f >= 0) {
0675fdb1 JB	370	fstat(f, &statbf);
	371	utmp = (struct utmp *)malloc(statbf.st_size);
	372	if (!utmp)
	373	syslog(LOG_ERR, "utmp malloc failed");
	374	if (statbf.st_size && utmp) {
	375	nutmp = read(f, utmp, statbf.st_size);
	376	nutmp /= sizeof(struct utmp);
	377
	378	for (u = utmp ; u < &utmp[nutmp] ; u++) {
	379	if (SCMPN(u->ut_line, line+5) \|\|
	380	u->ut_name[0]==0)
	381	continue;
	382	lseek(f, ((long)u)-((long)utmp), L_SET);
	383	SCPYN(u->ut_name, "");
	384	SCPYN(u->ut_host, "");
	385	time(&u->ut_time);
	386	write(f, (char *)u, sizeof(wtmp));
	387	found++;
	388	}
a10a364d BJ	389	}
	390	close(f);
	391	}
	392	if (found) {
0675fdb1	393	f = open(wtmpf, O_WRONLY\|O_APPEND);
a10a364d BJ	394	if (f >= 0) {
	395	SCPYN(wtmp.ut_line, line+5);
	396	SCPYN(wtmp.ut_name, "");
9b3ee53c	397	SCPYN(wtmp.ut_host, "");
a10a364d	398	time(&wtmp.ut_time);
a10a364d BJ	399	write(f, (char *)&wtmp, sizeof(wtmp));
	400	close(f);
	401	}
	402	}
	403	chmod(line, 0666);
	404	chown(line, 0, 0);
	405	line[strlen("/dev/")] = 'p';
	406	chmod(line, 0666);
	407	chown(line, 0, 0);
	408	}