2.9BSD/usr/net/src/netser/rlogin/rlogind.c
#ifndef lint
static char sccsid[] = "@(#)rlogind.c 4.2 82/10/07";
#endif
#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/socket.h>
#include <net/in.h>
#include <errno.h>
#include <pwd.h>
#include <wait.h>
#include <signal.h>
#include <sgtty.h>
#include <stdio.h>
#include <netdb.h>
#define wait3(a,b,c) wait2(&a,b)
extern errno;
struct passwd *getpwnam();
char *crypt(), *rindex(), *index(), *malloc();
int options = SO_ACCEPTCONN|SO_KEEPALIVE;
struct sockaddr_in sin = { AF_INET };
/*
* remote login server:
* remuser\0
* locuser\0
* terminal type\0
* data
*/
main(argc, argv)
int argc;
char **argv;
{
union wait status;
int f, debug = 0;
struct sockaddr_in from;
struct servent *sp;
sp = getservbyname("login", "tcp");
if (sp == 0) {
fprintf(stderr, "rlogind: tcp/rlogin: unknown service\n");
exit(1);
}
#ifndef DEBUG
if (fork())
exit(0);
for (f = 0; f < 10; f++)
(void) close(f);
(void) open("/", 0);
(void) dup2(0, 1);
(void) dup2(0, 2);
{ int tt = open("/dev/tty", 2);
if (tt > 0) {
ioctl(tt, TIOCNOTTY, 0);
close(tt);
}
}
#endif
sin.sin_port = htons(sp->s_port);
argc--, argv++;
if (argc > 0 && !strcmp(argv[0], "-d"))
options |= SO_DEBUG, argv++, argc--;
if (argc > 0) {
int port = atoi(argv[0]);
if (port < 0) {
fprintf(stderr, "%s: bad port #\n", argv[0]);
exit(1);
}
sin.sin_port = htons(port);
argv++, argc--;
}
for (;;) {
f = socket(SOCK_STREAM, 0, &sin, options);
if (f < 0) {
perror("socket");
sleep(5);
continue;
}
if (accept(f, &from) < 0) {
perror("accept");
close(f);
sleep(1);
continue;
}
if (fork() == 0)
doit(f, &from);
close(f);
while (wait3(status, WNOHANG, 0) > 0)
continue;
}
}
char locuser[32], remuser[32];
char buf[BUFSIZ];
int child;
int cleanup();
int netf;
extern errno;
char *line;
doit(f, fromp)
int f;
struct sockaddr_in *fromp;
{
char c;
int i, p, cc, t;
int stop = TIOCPKT_DOSTOP;
register struct hostent *hp;
alarm(60);
read(f, &c, 1);
if (c != 0)
exit(1);
alarm(0);
fromp->sin_port = htons(fromp->sin_port);
hp = gethostbyaddr(&fromp->sin_addr, sizeof (struct in_addr),
fromp->sin_family);
if (fromp->sin_family != AF_INET ||
fromp->sin_port >= IPPORT_RESERVED ||
hp == 0) {
write(f, "\01Permission denied.\n", 20);
exit(1);
}
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;
}
}
dup2(f, 1);
printf("All network ports in use.\r\n");
exit(1);
gotpty:
dup2(f, 0);
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) {
dup2(f, 2);
perror(line);
exit(1);
}
{ struct sgttyb b;
gtty(t, &b); b.sg_flags = RAW|ANYP; stty(t, &b);
}
if (fork()) {
char pibuf[1024], fibuf[1024], *pbp, *fbp;
int pcc = 0, fcc = 0, on = 1;
/* FILE *console = fopen("/dev/console", "w"); */
/* setbuf(console, 0); */
/* fprintf(console, "f %d p %d\r\n", f, p); */
ioctl(f, FIONBIO, &on);
ioctl(p, FIONBIO, &on);
ioctl(p, TIOCPKT, &on);
signal(SIGTSTP, SIG_IGN);
sigset(SIGCHLD, cleanup);
for (;;) {
long 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 (fcc < 0 && pcc < 0) break;
/* fprintf(console, "ibits from %d obits from %d\r\n", ibits, obits); */
select(32, &ibits, &obits, (long)10000000);
/* fprintf(console, "ibits %d obits %d\r\n", ibits, obits); */
if (ibits == 0 && obits == 0) {
sleep(5);
continue;
}
if (ibits & (1<<f)) {
fcc = read(f, fibuf, sizeof (fibuf));
/* fprintf(console, "%d from f\r\n", fcc); */
if (fcc < 0 && errno == EWOULDBLOCK)
fcc = 0;
else {
if (fcc <= 0)
break;
fbp = fibuf;
}
}
if (ibits & (1<<p)) {
pcc = read(p, pibuf, sizeof (pibuf));
/* fprintf(console, "%d from p, buf[0] %x, errno %d\r\n", pcc, buf[0], errno); */
pbp = pibuf;
if (pcc < 0 && errno == EWOULDBLOCK)
pcc = 0;
else if (pcc <= 0)
pcc = -1;
else if (pibuf[0] == 0)
pbp++, pcc--;
else {
if (pibuf[0]&(TIOCPKT_FLUSHWRITE|
TIOCPKT_NOSTOP|
TIOCPKT_DOSTOP)) {
int nstop = pibuf[0] &
(TIOCPKT_NOSTOP|
TIOCPKT_DOSTOP);
if (nstop)
stop = nstop;
pibuf[0] |= nstop;
ioctl(f,SIOCSENDOOB,&pibuf[0]);
}
pcc = 0;
}
}
if ((obits & (1<<f)) && pcc > 0) {
cc = write(f, pbp, pcc);
/* fprintf(console, "%d of %d to f\r\n", cc, pcc); */
if (cc > 0) {
pcc -= cc;
pbp += cc;
}
}
if ((obits & (1<<p)) && fcc > 0) {
cc = write(p, fbp, fcc);
/* fprintf(console, "%d of %d to p\r\n", cc, fcc); */
if (cc > 0) {
fcc -= cc;
fbp += cc;
}
}
}
cleanup();
}
close(f);
close(p);
dup2(t, 0);
dup2(t, 1);
dup2(t, 2);
close(t);
#if !pdp11
execl("/bin/login", "login", "-r", hp->h_name, 0);
#else
execl("/etc/getty", "-", line, 0);
#endif
perror("/bin/login");
exit(1);
}
cleanup()
{
int how = 2;
rmut();
ioctl(netf, SIOCDONE, &how);
kill(0, SIGKILL);
exit(1);
}
#include <utmp.h>
struct utmp wtmp;
char wtmpf[] = "/usr/adm/wtmp";
char utmp[] = "/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;
f = open(utmp, 2);
if (f >= 0) {
while(read(f, (char *)&wtmp, sizeof(wtmp)) == sizeof(wtmp)) {
if (SCMPN(wtmp.ut_line, line+5) || wtmp.ut_name[0]==0)
continue;
lseek(f, -(long)sizeof(wtmp), 1);
SCPYN(wtmp.ut_name, "");
time(&wtmp.ut_time);
write(f, (char *)&wtmp, sizeof(wtmp));
found++;
}
close(f);
}
if (found) {
f = open(wtmpf, 1);
if (f >= 0) {
SCPYN(wtmp.ut_line, line+5);
SCPYN(wtmp.ut_name, "");
time(&wtmp.ut_time);
lseek(f, (long)0, 2);
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);
}