2
* Copyright (c) 1995 Danny Gasparovski.
4
* Please read the file COPYRIGHT for the
5
* terms and conditions of the copyright.
8
#define WANT_SYS_IOCTL_H
11
u_int curtime, time_fasttimo, last_slowtimo, detach_time;
12
u_int detach_wait = 600000; /* 10 minutes */
25
lprint("X Redir: X not being redirected.\r\n");
27
lprint("X Redir: In sh/bash/zsh/etc. type: DISPLAY=%s:%d.%d; export DISPLAY\r\n",
28
inet_ntoa(our_addr), x_port, x_screen);
29
lprint("X Redir: In csh/tcsh/etc. type: setenv DISPLAY %s:%d.%d\r\n",
30
inet_ntoa(our_addr), x_port, x_screen);
32
lprint("X Redir: Redirecting to display %d\r\n", x_display);
40
* XXX Allow more than one X redirection?
43
redir_x(inaddr, start_port, display, screen)
52
lprint("X Redir: X already being redirected.\r\n");
55
for (i = 6001 + (start_port-1); i <= 6100; i++) {
56
if (solisten(htons(i), inaddr, htons(6000 + display), 0)) {
65
lprint("X Redir: Error: Couldn't redirect a port for X. Weird.\r\n");
70
#ifndef HAVE_INET_ATON
76
u_int32_t addr = inet_addr(cp);
77
if (addr == 0xffffffff)
85
* Get our IP address and put it in our_addr
93
if (gethostname(buff,256) < 0)
96
if ((he = gethostbyname(buff)) == NULL)
99
our_addr = *(struct in_addr *)he->h_addr;
102
#if SIZEOF_CHAR_P == 8
114
register struct quehead_32 *element = (struct quehead_32 *) a;
115
register struct quehead_32 *head = (struct quehead_32 *) b;
116
element->qh_link = head->qh_link;
117
head->qh_link = (u_int32_t)element;
118
element->qh_rlink = (u_int32_t)head;
119
((struct quehead_32 *)(element->qh_link))->qh_rlink
120
= (u_int32_t)element;
127
register struct quehead_32 *element = (struct quehead_32 *) a;
128
((struct quehead_32 *)(element->qh_link))->qh_rlink = element->qh_rlink;
129
((struct quehead_32 *)(element->qh_rlink))->qh_link = element->qh_link;
130
element->qh_rlink = 0;
133
#endif /* SIZEOF_CHAR_P == 8 */
136
struct quehead *qh_link;
137
struct quehead *qh_rlink;
144
register struct quehead *element = (struct quehead *) a;
145
register struct quehead *head = (struct quehead *) b;
146
element->qh_link = head->qh_link;
147
head->qh_link = (struct quehead *)element;
148
element->qh_rlink = (struct quehead *)head;
149
((struct quehead *)(element->qh_link))->qh_rlink
150
= (struct quehead *)element;
157
register struct quehead *element = (struct quehead *) a;
158
((struct quehead *)(element->qh_link))->qh_rlink = element->qh_rlink;
159
((struct quehead *)(element->qh_rlink))->qh_link = element->qh_link;
160
element->qh_rlink = NULL;
161
/* element->qh_link = NULL; TCP FIN1 crashes if you do this. Why ? */
168
add_exec(ex_ptr, do_pty, exec, addr, port)
169
struct ex_list **ex_ptr;
175
struct ex_list *tmp_ptr;
177
/* First, check if the port is "bound" */
178
for (tmp_ptr = *ex_ptr; tmp_ptr; tmp_ptr = tmp_ptr->ex_next) {
179
if (port == tmp_ptr->ex_fport && addr == tmp_ptr->ex_addr)
184
*ex_ptr = (struct ex_list *)malloc(sizeof(struct ex_list));
185
(*ex_ptr)->ex_fport = port;
186
(*ex_ptr)->ex_addr = addr;
187
(*ex_ptr)->ex_pty = do_pty;
188
(*ex_ptr)->ex_exec = strdup(exec);
189
(*ex_ptr)->ex_next = tmp_ptr;
193
#ifndef HAVE_STRERROR
196
* For systems with no strerror
200
extern char *sys_errlist[];
206
if (error < sys_nerr)
207
return sys_errlist[error];
209
return "Unknown error.";
218
fork_exec(so, ex, do_pty)
223
/* not implemented */
230
slirp_openpty(amaster, aslave)
231
int *amaster, *aslave;
233
register int master, slave;
238
if ((master = open("/dev/ptmx", O_RDWR)) < 0 ||
239
grantpt(master) < 0 ||
240
unlockpt(master) < 0 ||
241
(ptr = ptsname(master)) == NULL) {
246
if ((slave = open(ptr, O_RDWR)) < 0 ||
247
ioctl(slave, I_PUSH, "ptem") < 0 ||
248
ioctl(slave, I_PUSH, "ldterm") < 0 ||
249
ioctl(slave, I_PUSH, "ttcompat") < 0) {
261
static char line[] = "/dev/ptyXX";
262
register const char *cp1, *cp2;
264
for (cp1 = "pqrsPQRS"; *cp1; cp1++) {
266
for (cp2 = "0123456789abcdefghijklmnopqrstuv"; *cp2; cp2++) {
268
if ((master = open(line, O_RDWR, 0)) == -1) {
270
return (-1); /* out of ptys */
273
/* These will fail */
274
(void) chown(line, getuid(), 0);
275
(void) chmod(line, S_IRUSR|S_IWUSR|S_IWGRP);
279
if ((slave = open(line, O_RDWR, 0)) != -1) {
284
(void) close(master);
289
errno = ENOENT; /* out of ptys */
296
* We create and bind a socket, then fork off to another
297
* process, which connects to this socket, after which we
298
* exec the wanted program. If something (strange) happens,
299
* the accept() call could block us forever.
301
* do_pty = 0 Fork/exec inetd style
302
* do_pty = 1 Fork/exec using slirp.telnetd
303
* do_ptr = 2 Fork/exec using pty
306
fork_exec(so, ex, do_pty)
312
struct sockaddr_in addr;
313
socklen_t addrlen = sizeof(addr);
320
/* don't want to clobber the original */
325
DEBUG_CALL("fork_exec");
326
DEBUG_ARG("so = %lx", (long)so);
327
DEBUG_ARG("ex = %lx", (long)ex);
328
DEBUG_ARG("do_pty = %lx", (long)do_pty);
331
if (slirp_openpty(&master, &s) == -1) {
332
lprint("Error: openpty failed: %s\n", strerror(errno));
336
addr.sin_family = AF_INET;
338
addr.sin_addr.s_addr = INADDR_ANY;
340
if ((s = socket(AF_INET, SOCK_STREAM, 0)) < 0 ||
341
bind(s, (struct sockaddr *)&addr, addrlen) < 0 ||
343
lprint("Error: inet socket: %s\n", strerror(errno));
352
lprint("Error: fork failed: %s\n", strerror(errno));
359
/* Set the DISPLAY */
361
(void) close(master);
362
#ifdef TIOCSCTTY /* XXXXX */
364
ioctl(s, TIOCSCTTY, (char *)NULL);
367
getsockname(s, (struct sockaddr *)&addr, &addrlen);
370
* Connect to the socket
371
* XXX If any of these fail, we're in trouble!
373
s = socket(AF_INET, SOCK_STREAM, 0);
374
addr.sin_addr = loopback_addr;
376
ret = connect(s, (struct sockaddr *)&addr, addrlen);
377
} while (ret < 0 && errno == EINTR);
383
sprintf(buff, "%s:%d.%d", inet_ntoa(our_addr), x_port, x_screen);
384
setenv("DISPLAY", buff, 1);
386
sprintf(buff, "DISPLAY=%s:%d.%d", inet_ntoa(our_addr), x_port, x_screen);
394
for (s = 3; s <= 255; s++)
398
bptr = strdup(ex); /* No need to free() this */
400
/* Setup "slirp.telnetd -x" */
401
argv[i++] = "slirp.telnetd";
406
/* Change the string into argv[] */
408
while (*bptr != ' ' && *bptr != (char)0)
412
argv[i++] = strdup(curarg);
416
execvp(argv[0], argv);
418
/* Ooops, failed, let's tell the user why */
422
sprintf(buff, "Error: execvp of %s failed: %s\n",
423
argv[0], strerror(errno));
424
write(2, buff, strlen(buff)+1);
426
close(0); close(1); close(2); /* XXX */
435
* XXX this could block us...
436
* XXX Should set a timer here, and if accept() doesn't
437
* return after X seconds, declare it a failure
438
* The only reason this will block forever is if socket()
439
* of connect() fail in the child process
442
so->s = accept(s, (struct sockaddr *)&addr, &addrlen);
443
} while (so->s < 0 && errno == EINTR);
446
setsockopt(so->s,SOL_SOCKET,SO_REUSEADDR,(char *)&opt,sizeof(int));
448
setsockopt(so->s,SOL_SOCKET,SO_OOBINLINE,(char *)&opt,sizeof(int));
452
/* Append the telnet options now */
453
if (so->so_m != 0 && do_pty == 1) {
454
sbappend(so, so->so_m);
470
bptr = (char *)malloc(strlen(str)+1);
483
#ifndef NO_UNIX_SOCKETS
484
struct sockaddr_un sock_un;
486
struct sockaddr_in sock_in;
490
if (slirp_socket_passwd) {
491
s = socket(AF_INET, SOCK_STREAM, 0);
494
sock_in.sin_family = AF_INET;
495
sock_in.sin_addr.s_addr = slirp_socket_addr;
496
sock_in.sin_port = htons(slirp_socket_port);
497
if (connect(s, (struct sockaddr *)&sock_in, sizeof(sock_in)) != 0)
498
slirp_exit(1); /* just exit...*/
499
sprintf(buff, "kill %s:%d", slirp_socket_passwd, slirp_socket_unit);
500
write(s, buff, strlen(buff)+1);
502
#ifndef NO_UNIX_SOCKETS
504
s = socket(AF_UNIX, SOCK_STREAM, 0);
507
sock_un.sun_family = AF_UNIX;
508
strcpy(sock_un.sun_path, socket_path);
509
if (connect(s, (struct sockaddr *)&sock_un,
510
sizeof(sock_un.sun_family) + sizeof(sock_un.sun_path)) != 0)
512
sprintf(buff, "kill none:%d", slirp_socket_unit);
513
write(s, buff, strlen(buff)+1);
526
/* Don't need our data anymore */
527
/* XXX This makes SunOS barf */
531
for (i = 255; i >= 0; i--)
534
signal(SIGQUIT, slirp_exit);
535
signal(SIGHUP, snooze_hup);
538
/* Wait for any signal */
541
/* Just in case ... */
554
/* Don't need our data anymore */
555
/* XXX This makes SunOS barf */
558
signal(SIGQUIT, slirp_exit);
559
signal(SIGHUP, slirp_exit);
560
signal(SIGINT, slirp_exit);
561
signal(SIGTERM, slirp_exit);
563
/* Fudge to get term_raw and term_restore to work */
564
if (NULL == (ttyp = tty_attach (0, slirp_tty))) {
565
lprint ("Error: tty_attach failed in misc.c:relay()\r\n");
569
ttyp->flags |= TTY_CTTY;
578
n = select(s+1, &readfds, (fd_set *)0, (fd_set *)0, (struct timeval *)0);
583
if (FD_ISSET(0, &readfds)) {
584
n = read(0, buf, 8192);
587
n = writen(s, buf, n);
592
if (FD_ISSET(s, &readfds)) {
593
n = read(s, buf, 8192);
596
n = writen(0, buf, n);
602
/* Just in case.... */
607
int (*lprint_print) _P((void *, const char *, va_list));
608
char *lprint_ptr, *lprint_ptr2, **lprint_arg;
612
lprint(const char *format, ...)
614
lprint(va_alist) va_dcl
620
va_start(args, format);
624
format = va_arg(args, char *);
627
/* If we're printing to an sbuf, make sure there's enough room */
630
if ((lprint_ptr - lprint_sb->sb_wptr) >=
631
(lprint_sb->sb_datalen - (strlen(format) + 100))) {
632
int deltaw = lprint_sb->sb_wptr - lprint_sb->sb_data;
633
int deltar = lprint_sb->sb_rptr - lprint_sb->sb_data;
634
int deltap = lprint_ptr - lprint_sb->sb_data;
636
lprint_sb->sb_data = (char *)realloc(lprint_sb->sb_data,
637
lprint_sb->sb_datalen + TCP_SNDSPACE);
639
/* Adjust all values */
640
lprint_sb->sb_wptr = lprint_sb->sb_data + deltaw;
641
lprint_sb->sb_rptr = lprint_sb->sb_data + deltar;
642
lprint_ptr = lprint_sb->sb_data + deltap;
644
lprint_sb->sb_datalen += TCP_SNDSPACE;
649
lprint_ptr += (*lprint_print)(*lprint_arg, format, args);
651
/* Check if they want output to be logged to file as well */
655
* otherwise you'll get ^M all over the file
657
int len = strlen(format);
660
bptr1 = bptr2 = strdup(format);
664
memcpy(bptr1, bptr1+1, len+1);
668
vfprintf(lfd, bptr2, args);
679
u_int8_t tos = 0, emu = 0;
680
char buff1[256], buff2[256], buff4[128];
685
if (sscanf(buff, "%256s %256s", buff2, buff1) != 2) {
686
lprint("Error: Bad arguments\r\n");
690
if (sscanf(buff1, "%d:%d", &lport, &fport) != 2) {
692
if (sscanf(buff1, "%d", &fport) != 1) {
693
lprint("Error: Bad first argument\r\n");
698
if (sscanf(buff2, "%128[^:]:%128s", buff1, buff3) != 2) {
700
if (sscanf(buff2, "%256s", buff1) != 1) {
701
lprint("Error: Bad second argument\r\n");
707
if (strcmp(buff3, "lowdelay") == 0)
708
tos = IPTOS_LOWDELAY;
709
else if (strcmp(buff3, "throughput") == 0)
710
tos = IPTOS_THROUGHPUT;
712
lprint("Error: Expecting \"lowdelay\"/\"throughput\"\r\n");
717
if (strcmp(buff1, "ftp") == 0)
719
else if (strcmp(buff1, "irc") == 0)
721
else if (strcmp(buff1, "none") == 0)
722
emu = EMU_NONE; /* ie: no emulation */
724
lprint("Error: Unknown service\r\n");
728
/* First, check that it isn't already emulated */
729
for (emup = tcpemu; emup; emup = emup->next) {
730
if (emup->lport == lport && emup->fport == fport) {
731
lprint("Error: port already emulated\r\n");
737
emup = (struct emu_t *)malloc(sizeof (struct emu_t));
738
emup->lport = (u_int16_t)lport;
739
emup->fport = (u_int16_t)fport;
745
/* And finally, mark all current sessions, if any, as being emulated */
746
for (so = tcb.so_next; so != &tcb; so = so->so_next) {
747
if ((lport && lport == ntohs(so->so_lport)) ||
748
(fport && fport == ntohs(so->so_fport))) {
756
lprint("Adding emulation for %s to port %d/%d\r\n", buff1, emup->lport, emup->fport);
765
* Some BSD-derived systems have a sprintf which returns char *
769
vsprintf_len(string, format, args)
774
vsprintf(string, format, args);
775
return strlen(string);
780
sprintf_len(char *string, const char *format, ...)
782
sprintf_len(va_alist) va_dcl
787
va_start(args, format);
792
string = va_arg(args, char *);
793
format = va_arg(args, char *);
795
vsprintf(string, format, args);
796
return strlen(string);
811
t.tv_usec = usec * 1000;
813
select(0, &fdset, &fdset, &fdset, &t);
817
* Set fd blocking and non-blocking
827
ioctlsocket(fd, FIONBIO, &opt);
831
opt = fcntl(fd, F_GETFL, 0);
833
fcntl(fd, F_SETFL, opt);
844
ioctlsocket(fd, FIONBIO, &opt);
848
opt = fcntl(fd, F_GETFL, 0);
850
fcntl(fd, F_SETFL, opt);
860
rsh_exec(so,ns, user, host, args)
872
DEBUG_CALL("rsh_exec");
873
DEBUG_ARG("so = %lx", (long)so);
876
lprint("Error: pipe failed: %s\n", strerror(errno));
879
/* #ifdef HAVE_SOCKETPAIR */
881
if (socketpair(PF_UNIX,SOCK_STREAM,0, fd0) == -1) {
884
lprint("Error: openpty failed: %s\n", strerror(errno));
888
if (slirp_openpty(&fd0[0], &fd0[1]) == -1) {
891
lprint("Error: openpty failed: %s\n", strerror(errno));
898
lprint("Error: fork failed: %s\n", strerror(errno));
909
/* Set the DISPLAY */
912
sprintf(buff, "%s:%d.%d", inet_ntoa(our_addr), x_port, x_screen);
913
setenv("DISPLAY", buff, 1);
915
sprintf(buff, "DISPLAY=%s:%d.%d", inet_ntoa(our_addr), x_port, x_screen);
923
for (s = 3; s <= 255; s++)
926
execlp("rsh","rsh","-l", user, host, args, NULL);
928
/* Ooops, failed, let's tell the user why */
930
sprintf(buff, "Error: execlp of %s failed: %s\n",
931
"rsh", strerror(errno));
932
write(2, buff, strlen(buff)+1);
933
close(0); close(1); close(2); /* XXX */