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
;
24 lprint("X Redir: X not being redirected.\r\n");
26 lprint("X Redir: In sh/bash/zsh/etc. type: DISPLAY=%s:%d.%d; export DISPLAY\r\n",
27 inet_ntoa(our_addr
), x_port
, x_screen
);
28 lprint("X Redir: In csh/tcsh/etc. type: setenv DISPLAY %s:%d.%d\r\n",
29 inet_ntoa(our_addr
), x_port
, x_screen
);
31 lprint("X Redir: Redirecting to display %d\r\n", x_display
);
39 * XXX Allow more than one X redirection?
42 redir_x(inaddr
, start_port
, display
, screen
)
51 lprint("X Redir: X already being redirected.\r\n");
54 for (i
= 6001 + (start_port
-1); i
<= 6100; i
++) {
55 if (solisten(htons(i
), inaddr
, htons(6000 + display
), 0)) {
64 lprint("X Redir: Error: Couldn't redirect a port for X. Weird.\r\n");
70 * Get our IP address and put it in our_addr
76 struct hostent
*he
= NULL
;
78 if (gethostname(buff
,256) == 0)
79 he
= gethostbyname(buff
);
81 our_addr
= *(struct in_addr
*)he
->h_addr
;
82 if (our_addr
.s_addr
== 0)
83 our_addr
.s_addr
= loopback_addr
.s_addr
;
86 #if SIZEOF_CHAR_P == 8
98 register struct quehead_32
*element
= (struct quehead_32
*) a
;
99 register struct quehead_32
*head
= (struct quehead_32
*) b
;
100 element
->qh_link
= head
->qh_link
;
101 head
->qh_link
= (u_int32_t
)element
;
102 element
->qh_rlink
= (u_int32_t
)head
;
103 ((struct quehead_32
*)(element
->qh_link
))->qh_rlink
104 = (u_int32_t
)element
;
111 register struct quehead_32
*element
= (struct quehead_32
*) a
;
112 ((struct quehead_32
*)(element
->qh_link
))->qh_rlink
= element
->qh_rlink
;
113 ((struct quehead_32
*)(element
->qh_rlink
))->qh_link
= element
->qh_link
;
114 element
->qh_rlink
= 0;
117 #endif /* SIZEOF_CHAR_P == 8 */
120 struct quehead
*qh_link
;
121 struct quehead
*qh_rlink
;
128 register struct quehead
*element
= (struct quehead
*) a
;
129 register struct quehead
*head
= (struct quehead
*) b
;
130 element
->qh_link
= head
->qh_link
;
131 head
->qh_link
= (struct quehead
*)element
;
132 element
->qh_rlink
= (struct quehead
*)head
;
133 ((struct quehead
*)(element
->qh_link
))->qh_rlink
134 = (struct quehead
*)element
;
141 register struct quehead
*element
= (struct quehead
*) a
;
142 ((struct quehead
*)(element
->qh_link
))->qh_rlink
= element
->qh_rlink
;
143 ((struct quehead
*)(element
->qh_rlink
))->qh_link
= element
->qh_link
;
144 element
->qh_rlink
= NULL
;
145 /* element->qh_link = NULL; TCP FIN1 crashes if you do this. Why ? */
152 add_exec(ex_ptr
, do_pty
, exec
, addr
, port
)
153 struct ex_list
**ex_ptr
;
159 struct ex_list
*tmp_ptr
;
161 /* First, check if the port is "bound" */
162 for (tmp_ptr
= *ex_ptr
; tmp_ptr
; tmp_ptr
= tmp_ptr
->ex_next
) {
163 if (port
== tmp_ptr
->ex_fport
&& addr
== tmp_ptr
->ex_addr
)
168 *ex_ptr
= (struct ex_list
*)malloc(sizeof(struct ex_list
));
169 (*ex_ptr
)->ex_fport
= port
;
170 (*ex_ptr
)->ex_addr
= addr
;
171 (*ex_ptr
)->ex_pty
= do_pty
;
172 (*ex_ptr
)->ex_exec
= strdup(exec
);
173 (*ex_ptr
)->ex_next
= tmp_ptr
;
177 #ifndef HAVE_STRERROR
180 * For systems with no strerror
184 extern char *sys_errlist
[];
190 if (error
< sys_nerr
)
191 return sys_errlist
[error
];
193 return "Unknown error.";
202 fork_exec(struct socket
*so
, const char *ex
, int do_pty
)
204 /* not implemented */
212 slirp_openpty(amaster
, aslave
)
213 int *amaster
, *aslave
;
215 register int master
, slave
;
220 if ((master
= open("/dev/ptmx", O_RDWR
)) < 0 ||
221 grantpt(master
) < 0 ||
222 unlockpt(master
) < 0 ||
223 (ptr
= ptsname(master
)) == NULL
) {
228 if ((slave
= open(ptr
, O_RDWR
)) < 0 ||
229 ioctl(slave
, I_PUSH
, "ptem") < 0 ||
230 ioctl(slave
, I_PUSH
, "ldterm") < 0 ||
231 ioctl(slave
, I_PUSH
, "ttcompat") < 0) {
243 static char line
[] = "/dev/ptyXX";
244 register const char *cp1
, *cp2
;
246 for (cp1
= "pqrsPQRS"; *cp1
; cp1
++) {
248 for (cp2
= "0123456789abcdefghijklmnopqrstuv"; *cp2
; cp2
++) {
250 if ((master
= open(line
, O_RDWR
, 0)) == -1) {
252 return (-1); /* out of ptys */
255 /* These will fail */
256 (void) chown(line
, getuid(), 0);
257 (void) chmod(line
, S_IRUSR
|S_IWUSR
|S_IWGRP
);
261 if ((slave
= open(line
, O_RDWR
, 0)) != -1) {
266 (void) close(master
);
271 errno
= ENOENT
; /* out of ptys */
279 * We create and bind a socket, then fork off to another
280 * process, which connects to this socket, after which we
281 * exec the wanted program. If something (strange) happens,
282 * the accept() call could block us forever.
284 * do_pty = 0 Fork/exec inetd style
285 * do_pty = 1 Fork/exec using slirp.telnetd
286 * do_ptr = 2 Fork/exec using pty
289 fork_exec(struct socket
*so
, const char *ex
, int do_pty
)
292 struct sockaddr_in addr
;
293 socklen_t addrlen
= sizeof(addr
);
296 const char *argv
[256];
300 /* don't want to clobber the original */
305 DEBUG_CALL("fork_exec");
306 DEBUG_ARG("so = %lx", (long)so
);
307 DEBUG_ARG("ex = %lx", (long)ex
);
308 DEBUG_ARG("do_pty = %lx", (long)do_pty
);
312 if (slirp_openpty(&master
, &s
) == -1) {
313 lprint("Error: openpty failed: %s\n", strerror(errno
));
320 addr
.sin_family
= AF_INET
;
322 addr
.sin_addr
.s_addr
= INADDR_ANY
;
324 if ((s
= socket(AF_INET
, SOCK_STREAM
, 0)) < 0 ||
325 bind(s
, (struct sockaddr
*)&addr
, addrlen
) < 0 ||
327 lprint("Error: inet socket: %s\n", strerror(errno
));
336 lprint("Error: fork failed: %s\n", strerror(errno
));
343 /* Set the DISPLAY */
345 (void) close(master
);
346 #ifdef TIOCSCTTY /* XXXXX */
348 ioctl(s
, TIOCSCTTY
, (char *)NULL
);
351 getsockname(s
, (struct sockaddr
*)&addr
, &addrlen
);
354 * Connect to the socket
355 * XXX If any of these fail, we're in trouble!
357 s
= socket(AF_INET
, SOCK_STREAM
, 0);
358 addr
.sin_addr
= loopback_addr
;
360 ret
= connect(s
, (struct sockaddr
*)&addr
, addrlen
);
361 } while (ret
< 0 && errno
== EINTR
);
367 sprintf(buff
, "%s:%d.%d", inet_ntoa(our_addr
), x_port
, x_screen
);
368 setenv("DISPLAY", buff
, 1);
370 sprintf(buff
, "DISPLAY=%s:%d.%d", inet_ntoa(our_addr
), x_port
, x_screen
);
378 for (s
= getdtablesize() - 1; s
>= 3; s
--)
382 bptr
= strdup(ex
); /* No need to free() this */
384 /* Setup "slirp.telnetd -x" */
385 argv
[i
++] = "slirp.telnetd";
390 /* Change the string into argv[] */
392 while (*bptr
!= ' ' && *bptr
!= (char)0)
396 argv
[i
++] = strdup(curarg
);
400 execvp(argv
[0], (char **)argv
);
402 /* Ooops, failed, let's tell the user why */
406 snprintf(buff
, sizeof(buff
),
407 "Error: execvp of %s failed: %s\n",
408 argv
[0], strerror(errno
));
409 write(2, buff
, strlen(buff
)+1);
411 close(0); close(1); close(2); /* XXX */
420 * XXX this could block us...
421 * XXX Should set a timer here, and if accept() doesn't
422 * return after X seconds, declare it a failure
423 * The only reason this will block forever is if socket()
424 * of connect() fail in the child process
427 so
->s
= accept(s
, (struct sockaddr
*)&addr
, &addrlen
);
428 } while (so
->s
< 0 && errno
== EINTR
);
431 setsockopt(so
->s
,SOL_SOCKET
,SO_REUSEADDR
,(char *)&opt
,sizeof(int));
433 setsockopt(so
->s
,SOL_SOCKET
,SO_OOBINLINE
,(char *)&opt
,sizeof(int));
437 /* Append the telnet options now */
438 if (so
->so_m
!= 0 && do_pty
== 1) {
439 sbappend(so
, so
->so_m
);
455 bptr
= (char *)malloc(strlen(str
)+1);
468 #ifndef NO_UNIX_SOCKETS
469 struct sockaddr_un sock_un
;
471 struct sockaddr_in sock_in
;
475 if (slirp_socket_passwd
) {
476 s
= socket(AF_INET
, SOCK_STREAM
, 0);
479 sock_in
.sin_family
= AF_INET
;
480 sock_in
.sin_addr
.s_addr
= slirp_socket_addr
;
481 sock_in
.sin_port
= htons(slirp_socket_port
);
482 if (connect(s
, (struct sockaddr
*)&sock_in
, sizeof(sock_in
)) != 0)
483 slirp_exit(1); /* just exit...*/
484 sprintf(buff
, "kill %s:%d", slirp_socket_passwd
, slirp_socket_unit
);
485 write(s
, buff
, strlen(buff
)+1);
487 #ifndef NO_UNIX_SOCKETS
489 s
= socket(AF_UNIX
, SOCK_STREAM
, 0);
492 sock_un
.sun_family
= AF_UNIX
;
493 strcpy(sock_un
.sun_path
, socket_path
);
494 if (connect(s
, (struct sockaddr
*)&sock_un
,
495 sizeof(sock_un
.sun_family
) + sizeof(sock_un
.sun_path
)) != 0)
497 sprintf(buff
, "kill none:%d", slirp_socket_unit
);
498 write(s
, buff
, strlen(buff
)+1);
511 /* Don't need our data anymore */
512 /* XXX This makes SunOS barf */
516 for (i
= 255; i
>= 0; i
--)
519 signal(SIGQUIT
, slirp_exit
);
520 signal(SIGHUP
, snooze_hup
);
523 /* Wait for any signal */
526 /* Just in case ... */
539 /* Don't need our data anymore */
540 /* XXX This makes SunOS barf */
543 signal(SIGQUIT
, slirp_exit
);
544 signal(SIGHUP
, slirp_exit
);
545 signal(SIGINT
, slirp_exit
);
546 signal(SIGTERM
, slirp_exit
);
548 /* Fudge to get term_raw and term_restore to work */
549 if (NULL
== (ttyp
= tty_attach (0, slirp_tty
))) {
550 lprint ("Error: tty_attach failed in misc.c:relay()\r\n");
554 ttyp
->flags
|= TTY_CTTY
;
563 n
= select(s
+1, &readfds
, (fd_set
*)0, (fd_set
*)0, (struct timeval
*)0);
568 if (FD_ISSET(0, &readfds
)) {
569 n
= read(0, buf
, 8192);
572 n
= writen(s
, buf
, n
);
577 if (FD_ISSET(s
, &readfds
)) {
578 n
= read(s
, buf
, 8192);
581 n
= writen(0, buf
, n
);
587 /* Just in case.... */
593 extern void term_vprintf(const char *fmt
, va_list ap
);
595 void lprint(const char *format
, ...)
599 va_start(args
, format
);
600 term_vprintf(format
, args
);
604 int (*lprint_print
) _P((void *, const char *, va_list));
605 char *lprint_ptr
, *lprint_ptr2
, **lprint_arg
;
609 lprint(const char *format
, ...)
611 lprint(va_alist
) va_dcl
617 va_start(args
, format
);
621 format
= va_arg(args
, char *);
624 /* If we're printing to an sbuf, make sure there's enough room */
627 if ((lprint_ptr
- lprint_sb
->sb_wptr
) >=
628 (lprint_sb
->sb_datalen
- (strlen(format
) + 100))) {
629 int deltaw
= lprint_sb
->sb_wptr
- lprint_sb
->sb_data
;
630 int deltar
= lprint_sb
->sb_rptr
- lprint_sb
->sb_data
;
631 int deltap
= lprint_ptr
- lprint_sb
->sb_data
;
633 lprint_sb
->sb_data
= (char *)realloc(lprint_sb
->sb_data
,
634 lprint_sb
->sb_datalen
+ TCP_SNDSPACE
);
636 /* Adjust all values */
637 lprint_sb
->sb_wptr
= lprint_sb
->sb_data
+ deltaw
;
638 lprint_sb
->sb_rptr
= lprint_sb
->sb_data
+ deltar
;
639 lprint_ptr
= lprint_sb
->sb_data
+ deltap
;
641 lprint_sb
->sb_datalen
+= TCP_SNDSPACE
;
646 lprint_ptr
+= (*lprint_print
)(*lprint_arg
, format
, args
);
648 /* Check if they want output to be logged to file as well */
652 * otherwise you'll get ^M all over the file
654 int len
= strlen(format
);
657 bptr1
= bptr2
= strdup(format
);
661 memcpy(bptr1
, bptr1
+1, len
+1);
665 vfprintf(lfd
, bptr2
, args
);
676 u_int8_t tos
= 0, emu
= 0;
677 char buff1
[256], buff2
[256], buff4
[128];
682 if (sscanf(buff
, "%256s %256s", buff2
, buff1
) != 2) {
683 lprint("Error: Bad arguments\r\n");
687 if (sscanf(buff1
, "%d:%d", &lport
, &fport
) != 2) {
689 if (sscanf(buff1
, "%d", &fport
) != 1) {
690 lprint("Error: Bad first argument\r\n");
695 if (sscanf(buff2
, "%128[^:]:%128s", buff1
, buff3
) != 2) {
697 if (sscanf(buff2
, "%256s", buff1
) != 1) {
698 lprint("Error: Bad second argument\r\n");
704 if (strcmp(buff3
, "lowdelay") == 0)
705 tos
= IPTOS_LOWDELAY
;
706 else if (strcmp(buff3
, "throughput") == 0)
707 tos
= IPTOS_THROUGHPUT
;
709 lprint("Error: Expecting \"lowdelay\"/\"throughput\"\r\n");
714 if (strcmp(buff1
, "ftp") == 0)
716 else if (strcmp(buff1
, "irc") == 0)
718 else if (strcmp(buff1
, "none") == 0)
719 emu
= EMU_NONE
; /* ie: no emulation */
721 lprint("Error: Unknown service\r\n");
725 /* First, check that it isn't already emulated */
726 for (emup
= tcpemu
; emup
; emup
= emup
->next
) {
727 if (emup
->lport
== lport
&& emup
->fport
== fport
) {
728 lprint("Error: port already emulated\r\n");
734 emup
= (struct emu_t
*)malloc(sizeof (struct emu_t
));
735 emup
->lport
= (u_int16_t
)lport
;
736 emup
->fport
= (u_int16_t
)fport
;
742 /* And finally, mark all current sessions, if any, as being emulated */
743 for (so
= tcb
.so_next
; so
!= &tcb
; so
= so
->so_next
) {
744 if ((lport
&& lport
== ntohs(so
->so_lport
)) ||
745 (fport
&& fport
== ntohs(so
->so_fport
))) {
753 lprint("Adding emulation for %s to port %d/%d\r\n", buff1
, emup
->lport
, emup
->fport
);
763 * Some BSD-derived systems have a sprintf which returns char *
767 vsprintf_len(string
, format
, args
)
772 vsprintf(string
, format
, args
);
773 return strlen(string
);
778 sprintf_len(char *string
, const char *format
, ...)
780 sprintf_len(va_alist
) va_dcl
785 va_start(args
, format
);
790 string
= va_arg(args
, char *);
791 format
= va_arg(args
, char *);
793 vsprintf(string
, format
, args
);
794 return strlen(string
);
809 t
.tv_usec
= usec
* 1000;
811 select(0, &fdset
, &fdset
, &fdset
, &t
);
815 * Set fd blocking and non-blocking
825 ioctlsocket(fd
, FIONBIO
, &opt
);
829 opt
= fcntl(fd
, F_GETFL
, 0);
831 fcntl(fd
, F_SETFL
, opt
);
842 ioctlsocket(fd
, FIONBIO
, &opt
);
846 opt
= fcntl(fd
, F_GETFL
, 0);
848 fcntl(fd
, F_SETFL
, opt
);
858 rsh_exec(so
,ns
, user
, host
, args
)
870 DEBUG_CALL("rsh_exec");
871 DEBUG_ARG("so = %lx", (long)so
);
874 lprint("Error: pipe failed: %s\n", strerror(errno
));
877 /* #ifdef HAVE_SOCKETPAIR */
879 if (socketpair(PF_UNIX
,SOCK_STREAM
,0, fd0
) == -1) {
882 lprint("Error: openpty failed: %s\n", strerror(errno
));
886 if (slirp_openpty(&fd0
[0], &fd0
[1]) == -1) {
889 lprint("Error: openpty failed: %s\n", strerror(errno
));
896 lprint("Error: fork failed: %s\n", strerror(errno
));
907 /* Set the DISPLAY */
910 sprintf(buff
, "%s:%d.%d", inet_ntoa(our_addr
), x_port
, x_screen
);
911 setenv("DISPLAY", buff
, 1);
913 sprintf(buff
, "DISPLAY=%s:%d.%d", inet_ntoa(our_addr
), x_port
, x_screen
);
921 for (s
= 3; s
<= 255; s
++)
924 execlp("rsh","rsh","-l", user
, host
, args
, NULL
);
926 /* Ooops, failed, let's tell the user why */
928 sprintf(buff
, "Error: execlp of %s failed: %s\n",
929 "rsh", strerror(errno
));
930 write(2, buff
, strlen(buff
)+1);
931 close(0); close(1); close(2); /* XXX */