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
91 struct hostent *he = NULL;
93 if (gethostname(buff,256) == 0)
94 he = gethostbyname(buff);
96 our_addr = *(struct in_addr *)he->h_addr;
97 /* If the host doesn't have a useful IP address then use the
98 guest side address. */
99 if (our_addr.s_addr == 0 || our_addr.s_addr == loopback_addr.s_addr)
100 our_addr.s_addr = special_addr.s_addr | htonl(CTL_ALIAS);
103 #if SIZEOF_CHAR_P == 8
115 register struct quehead_32 *element = (struct quehead_32 *) a;
116 register struct quehead_32 *head = (struct quehead_32 *) b;
117 element->qh_link = head->qh_link;
118 head->qh_link = (u_int32_t)element;
119 element->qh_rlink = (u_int32_t)head;
120 ((struct quehead_32 *)(element->qh_link))->qh_rlink
121 = (u_int32_t)element;
128 register struct quehead_32 *element = (struct quehead_32 *) a;
129 ((struct quehead_32 *)(element->qh_link))->qh_rlink = element->qh_rlink;
130 ((struct quehead_32 *)(element->qh_rlink))->qh_link = element->qh_link;
131 element->qh_rlink = 0;
134 #endif /* SIZEOF_CHAR_P == 8 */
137 struct quehead *qh_link;
138 struct quehead *qh_rlink;
145 register struct quehead *element = (struct quehead *) a;
146 register struct quehead *head = (struct quehead *) b;
147 element->qh_link = head->qh_link;
148 head->qh_link = (struct quehead *)element;
149 element->qh_rlink = (struct quehead *)head;
150 ((struct quehead *)(element->qh_link))->qh_rlink
151 = (struct quehead *)element;
158 register struct quehead *element = (struct quehead *) a;
159 ((struct quehead *)(element->qh_link))->qh_rlink = element->qh_rlink;
160 ((struct quehead *)(element->qh_rlink))->qh_link = element->qh_link;
161 element->qh_rlink = NULL;
162 /* element->qh_link = NULL; TCP FIN1 crashes if you do this. Why ? */
169 add_exec(ex_ptr, do_pty, exec, addr, port)
170 struct ex_list **ex_ptr;
176 struct ex_list *tmp_ptr;
178 /* First, check if the port is "bound" */
179 for (tmp_ptr = *ex_ptr; tmp_ptr; tmp_ptr = tmp_ptr->ex_next) {
180 if (port == tmp_ptr->ex_fport && addr == tmp_ptr->ex_addr)
185 *ex_ptr = (struct ex_list *)malloc(sizeof(struct ex_list));
186 (*ex_ptr)->ex_fport = port;
187 (*ex_ptr)->ex_addr = addr;
188 (*ex_ptr)->ex_pty = do_pty;
189 (*ex_ptr)->ex_exec = strdup(exec);
190 (*ex_ptr)->ex_next = tmp_ptr;
194 #ifndef HAVE_STRERROR
197 * For systems with no strerror
201 extern char *sys_errlist[];
207 if (error < sys_nerr)
208 return sys_errlist[error];
210 return "Unknown error.";
219 fork_exec(so, ex, do_pty)
224 /* not implemented */
231 slirp_openpty(amaster, aslave)
232 int *amaster, *aslave;
234 register int master, slave;
239 if ((master = open("/dev/ptmx", O_RDWR)) < 0 ||
240 grantpt(master) < 0 ||
241 unlockpt(master) < 0 ||
242 (ptr = ptsname(master)) == NULL) {
247 if ((slave = open(ptr, O_RDWR)) < 0 ||
248 ioctl(slave, I_PUSH, "ptem") < 0 ||
249 ioctl(slave, I_PUSH, "ldterm") < 0 ||
250 ioctl(slave, I_PUSH, "ttcompat") < 0) {
262 static char line[] = "/dev/ptyXX";
263 register const char *cp1, *cp2;
265 for (cp1 = "pqrsPQRS"; *cp1; cp1++) {
267 for (cp2 = "0123456789abcdefghijklmnopqrstuv"; *cp2; cp2++) {
269 if ((master = open(line, O_RDWR, 0)) == -1) {
271 return (-1); /* out of ptys */
274 /* These will fail */
275 (void) chown(line, getuid(), 0);
276 (void) chmod(line, S_IRUSR|S_IWUSR|S_IWGRP);
280 if ((slave = open(line, O_RDWR, 0)) != -1) {
285 (void) close(master);
290 errno = ENOENT; /* out of ptys */
297 * We create and bind a socket, then fork off to another
298 * process, which connects to this socket, after which we
299 * exec the wanted program. If something (strange) happens,
300 * the accept() call could block us forever.
302 * do_pty = 0 Fork/exec inetd style
303 * do_pty = 1 Fork/exec using slirp.telnetd
304 * do_ptr = 2 Fork/exec using pty
307 fork_exec(so, ex, do_pty)
313 struct sockaddr_in addr;
314 int addrlen = sizeof(addr);
321 /* don't want to clobber the original */
326 DEBUG_CALL("fork_exec");
327 DEBUG_ARG("so = %lx", (long)so);
328 DEBUG_ARG("ex = %lx", (long)ex);
329 DEBUG_ARG("do_pty = %lx", (long)do_pty);
332 if (slirp_openpty(&master, &s) == -1) {
333 lprint("Error: openpty failed: %s\n", strerror(errno));
337 addr.sin_family = AF_INET;
339 addr.sin_addr.s_addr = INADDR_ANY;
341 if ((s = socket(AF_INET, SOCK_STREAM, 0)) < 0 ||
342 bind(s, (struct sockaddr *)&addr, addrlen) < 0 ||
344 lprint("Error: inet socket: %s\n", strerror(errno));
353 lprint("Error: fork failed: %s\n", strerror(errno));
360 /* Set the DISPLAY */
362 (void) close(master);
363 #ifdef TIOCSCTTY /* XXXXX */
365 ioctl(s, TIOCSCTTY, (char *)NULL);
368 getsockname(s, (struct sockaddr *)&addr, &addrlen);
371 * Connect to the socket
372 * XXX If any of these fail, we're in trouble!
374 s = socket(AF_INET, SOCK_STREAM, 0);
375 addr.sin_addr = loopback_addr;
377 ret = connect(s, (struct sockaddr *)&addr, addrlen);
378 } while (ret < 0 && errno == EINTR);
384 sprintf(buff, "%s:%d.%d", inet_ntoa(our_addr), x_port, x_screen);
385 setenv("DISPLAY", buff, 1);
387 sprintf(buff, "DISPLAY=%s:%d.%d", inet_ntoa(our_addr), x_port, x_screen);
395 for (s = 3; s <= 255; s++)
399 bptr = strdup(ex); /* No need to free() this */
401 /* Setup "slirp.telnetd -x" */
402 argv[i++] = "slirp.telnetd";
407 /* Change the string into argv[] */
409 while (*bptr != ' ' && *bptr != (char)0)
413 argv[i++] = strdup(curarg);
417 execvp(argv[0], argv);
419 /* Ooops, failed, let's tell the user why */
423 sprintf(buff, "Error: execvp of %s failed: %s\n",
424 argv[0], strerror(errno));
425 write(2, buff, strlen(buff)+1);
427 close(0); close(1); close(2); /* XXX */
436 * XXX this could block us...
437 * XXX Should set a timer here, and if accept() doesn't
438 * return after X seconds, declare it a failure
439 * The only reason this will block forever is if socket()
440 * of connect() fail in the child process
443 so->s = accept(s, (struct sockaddr *)&addr, &addrlen);
444 } while (so->s < 0 && errno == EINTR);
447 setsockopt(so->s,SOL_SOCKET,SO_REUSEADDR,(char *)&opt,sizeof(int));
449 setsockopt(so->s,SOL_SOCKET,SO_OOBINLINE,(char *)&opt,sizeof(int));
453 /* Append the telnet options now */
454 if (so->so_m != 0 && do_pty == 1) {
455 sbappend(so, so->so_m);
471 bptr = (char *)malloc(strlen(str)+1);
484 #ifndef NO_UNIX_SOCKETS
485 struct sockaddr_un sock_un;
487 struct sockaddr_in sock_in;
491 if (slirp_socket_passwd) {
492 s = socket(AF_INET, SOCK_STREAM, 0);
495 sock_in.sin_family = AF_INET;
496 sock_in.sin_addr.s_addr = slirp_socket_addr;
497 sock_in.sin_port = htons(slirp_socket_port);
498 if (connect(s, (struct sockaddr *)&sock_in, sizeof(sock_in)) != 0)
499 slirp_exit(1); /* just exit...*/
500 sprintf(buff, "kill %s:%d", slirp_socket_passwd, slirp_socket_unit);
501 write(s, buff, strlen(buff)+1);
503 #ifndef NO_UNIX_SOCKETS
505 s = socket(AF_UNIX, SOCK_STREAM, 0);
508 sock_un.sun_family = AF_UNIX;
509 strcpy(sock_un.sun_path, socket_path);
510 if (connect(s, (struct sockaddr *)&sock_un,
511 sizeof(sock_un.sun_family) + sizeof(sock_un.sun_path)) != 0)
513 sprintf(buff, "kill none:%d", slirp_socket_unit);
514 write(s, buff, strlen(buff)+1);
527 /* Don't need our data anymore */
528 /* XXX This makes SunOS barf */
532 for (i = 255; i >= 0; i--)
535 signal(SIGQUIT, slirp_exit);
536 signal(SIGHUP, snooze_hup);
539 /* Wait for any signal */
542 /* Just in case ... */
555 /* Don't need our data anymore */
556 /* XXX This makes SunOS barf */
559 signal(SIGQUIT, slirp_exit);
560 signal(SIGHUP, slirp_exit);
561 signal(SIGINT, slirp_exit);
562 signal(SIGTERM, slirp_exit);
564 /* Fudge to get term_raw and term_restore to work */
565 if (NULL == (ttyp = tty_attach (0, slirp_tty))) {
566 lprint ("Error: tty_attach failed in misc.c:relay()\r\n");
570 ttyp->flags |= TTY_CTTY;
579 n = select(s+1, &readfds, (fd_set *)0, (fd_set *)0, (struct timeval *)0);
584 if (FD_ISSET(0, &readfds)) {
585 n = read(0, buf, 8192);
588 n = writen(s, buf, n);
593 if (FD_ISSET(s, &readfds)) {
594 n = read(s, buf, 8192);
597 n = writen(0, buf, n);
603 /* Just in case.... */
608 int (*lprint_print) _P((void *, const char *, va_list));
609 char *lprint_ptr, *lprint_ptr2, **lprint_arg;
613 lprint(const char *format, ...)
615 lprint(va_alist) va_dcl
621 va_start(args, format);
625 format = va_arg(args, char *);
628 /* If we're printing to an sbuf, make sure there's enough room */
631 if ((lprint_ptr - lprint_sb->sb_wptr) >=
632 (lprint_sb->sb_datalen - (strlen(format) + 100))) {
633 int deltaw = lprint_sb->sb_wptr - lprint_sb->sb_data;
634 int deltar = lprint_sb->sb_rptr - lprint_sb->sb_data;
635 int deltap = lprint_ptr - lprint_sb->sb_data;
637 lprint_sb->sb_data = (char *)realloc(lprint_sb->sb_data,
638 lprint_sb->sb_datalen + TCP_SNDSPACE);
640 /* Adjust all values */
641 lprint_sb->sb_wptr = lprint_sb->sb_data + deltaw;
642 lprint_sb->sb_rptr = lprint_sb->sb_data + deltar;
643 lprint_ptr = lprint_sb->sb_data + deltap;
645 lprint_sb->sb_datalen += TCP_SNDSPACE;
650 lprint_ptr += (*lprint_print)(*lprint_arg, format, args);
652 /* Check if they want output to be logged to file as well */
656 * otherwise you'll get ^M all over the file
658 int len = strlen(format);
661 bptr1 = bptr2 = strdup(format);
665 memcpy(bptr1, bptr1+1, len+1);
669 vfprintf(lfd, bptr2, args);
680 u_int8_t tos = 0, emu = 0;
681 char buff1[256], buff2[256], buff4[128];
686 if (sscanf(buff, "%256s %256s", buff2, buff1) != 2) {
687 lprint("Error: Bad arguments\r\n");
691 if (sscanf(buff1, "%d:%d", &lport, &fport) != 2) {
693 if (sscanf(buff1, "%d", &fport) != 1) {
694 lprint("Error: Bad first argument\r\n");
699 if (sscanf(buff2, "%128[^:]:%128s", buff1, buff3) != 2) {
701 if (sscanf(buff2, "%256s", buff1) != 1) {
702 lprint("Error: Bad second argument\r\n");
708 if (strcmp(buff3, "lowdelay") == 0)
709 tos = IPTOS_LOWDELAY;
710 else if (strcmp(buff3, "throughput") == 0)
711 tos = IPTOS_THROUGHPUT;
713 lprint("Error: Expecting \"lowdelay\"/\"throughput\"\r\n");
718 if (strcmp(buff1, "ftp") == 0)
720 else if (strcmp(buff1, "irc") == 0)
722 else if (strcmp(buff1, "none") == 0)
723 emu = EMU_NONE; /* ie: no emulation */
725 lprint("Error: Unknown service\r\n");
729 /* First, check that it isn't already emulated */
730 for (emup = tcpemu; emup; emup = emup->next) {
731 if (emup->lport == lport && emup->fport == fport) {
732 lprint("Error: port already emulated\r\n");
738 emup = (struct emu_t *)malloc(sizeof (struct emu_t));
739 emup->lport = (u_int16_t)lport;
740 emup->fport = (u_int16_t)fport;
746 /* And finally, mark all current sessions, if any, as being emulated */
747 for (so = tcb.so_next; so != &tcb; so = so->so_next) {
748 if ((lport && lport == ntohs(so->so_lport)) ||
749 (fport && fport == ntohs(so->so_fport))) {
757 lprint("Adding emulation for %s to port %d/%d\r\n", buff1, emup->lport, emup->fport);
766 * Some BSD-derived systems have a sprintf which returns char *
770 vsprintf_len(string, format, args)
775 vsprintf(string, format, args);
776 return strlen(string);
781 sprintf_len(char *string, const char *format, ...)
783 sprintf_len(va_alist) va_dcl
788 va_start(args, format);
793 string = va_arg(args, char *);
794 format = va_arg(args, char *);
796 vsprintf(string, format, args);
797 return strlen(string);
812 t.tv_usec = usec * 1000;
814 select(0, &fdset, &fdset, &fdset, &t);
818 * Set fd blocking and non-blocking
828 ioctlsocket(fd, FIONBIO, &opt);
832 opt = fcntl(fd, F_GETFL, 0);
834 fcntl(fd, F_SETFL, opt);
845 ioctlsocket(fd, FIONBIO, &opt);
849 opt = fcntl(fd, F_GETFL, 0);
851 fcntl(fd, F_SETFL, opt);
861 rsh_exec(so,ns, user, host, args)
873 DEBUG_CALL("rsh_exec");
874 DEBUG_ARG("so = %lx", (long)so);
877 lprint("Error: pipe failed: %s\n", strerror(errno));
880 /* #ifdef HAVE_SOCKETPAIR */
882 if (socketpair(PF_UNIX,SOCK_STREAM,0, fd0) == -1) {
885 lprint("Error: openpty failed: %s\n", strerror(errno));
889 if (slirp_openpty(&fd0[0], &fd0[1]) == -1) {
892 lprint("Error: openpty failed: %s\n", strerror(errno));
899 lprint("Error: fork failed: %s\n", strerror(errno));
910 /* Set the DISPLAY */
913 sprintf(buff, "%s:%d.%d", inet_ntoa(our_addr), x_port, x_screen);
914 setenv("DISPLAY", buff, 1);
916 sprintf(buff, "DISPLAY=%s:%d.%d", inet_ntoa(our_addr), x_port, x_screen);
924 for (s = 3; s <= 255; s++)
927 execlp("rsh","rsh","-l", user, host, args, NULL);
929 /* Ooops, failed, let's tell the user why */
931 sprintf(buff, "Error: execlp of %s failed: %s\n",
932 "rsh", strerror(errno));
933 write(2, buff, strlen(buff)+1);
934 close(0); close(1); close(2); /* XXX */