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 */