xref: /csrg-svn/usr.bin/telnet/telnet.c (revision 32667)
111758Ssam #ifndef lint
232377Sminshall static char copyright[] =
332377Sminshall "@(#) Copyright (c) 1984-1987 Regents of the University of California.\n\
421580Sdist  All rights reserved.\n";
532377Sminshall #endif	/* not lint */
611758Ssam 
721580Sdist #ifndef lint
832377Sminshall static char sccsid[] = "@(#)telnet.c	1.2 (Berkeley) 9/25/87";
932377Sminshall #endif	/* not lint */
1021580Sdist 
119217Ssam #include <sys/types.h>
129217Ssam 
1332377Sminshall #if	defined(unix)
1432377Sminshall /* By the way, we need to include curses.h before telnet.h since,
1532377Sminshall  * among other things, telnet.h #defines 'DO', which is a variable
1632377Sminshall  * declared in curses.h.
1732377Sminshall  */
1832377Sminshall #include <curses.h>
1932377Sminshall #endif	/* defined(unix) */
2032377Sminshall 
2112212Ssam #include <arpa/telnet.h>
2232377Sminshall 
2332377Sminshall #if	defined(unix)
2427186Sminshall #include <strings.h>
2532377Sminshall #else	/* defined(unix) */
2632377Sminshall #include <string.h>
2732377Sminshall #endif	/* defined(unix) */
289217Ssam 
2932381Sminshall #include "ring.h"
3032381Sminshall 
3132377Sminshall #include "defines.h"
3232377Sminshall #include "externs.h"
3332377Sminshall #include "types.h"
3432377Sminshall #include "general.h"
3527178Sminshall 
3627178Sminshall 
3727228Sminshall #define	strip(x)	((x)&0x7f)
386000Sroot 
3927088Sminshall 
4032377Sminshall static char	subbuffer[SUBBUFSIZE],
4132377Sminshall 		*subpointer, *subend;	 /* buffer for sub-options */
4227676Sminshall #define	SB_CLEAR()	subpointer = subbuffer;
4327676Sminshall #define	SB_TERM()	subend = subpointer;
4427676Sminshall #define	SB_ACCUM(c)	if (subpointer < (subbuffer+sizeof subbuffer)) { \
4527676Sminshall 				*subpointer++ = (c); \
4627676Sminshall 			}
4727676Sminshall 
486000Sroot char	hisopts[256];
496000Sroot char	myopts[256];
506000Sroot 
516000Sroot char	doopt[] = { IAC, DO, '%', 'c', 0 };
526000Sroot char	dont[] = { IAC, DONT, '%', 'c', 0 };
536000Sroot char	will[] = { IAC, WILL, '%', 'c', 0 };
546000Sroot char	wont[] = { IAC, WONT, '%', 'c', 0 };
556000Sroot 
5632377Sminshall int
5732377Sminshall 	connected,
5832377Sminshall 	showoptions,
5932377Sminshall 	In3270,		/* Are we in 3270 mode? */
6032377Sminshall 	ISend,		/* trying to send network data in */
6132377Sminshall 	debug = 0,
6232377Sminshall 	crmod,
6332377Sminshall 	netdata,	/* Print out network data flow */
6432377Sminshall 	crlf,		/* Should '\r' be mapped to <CR><LF> (or <CR><NUL>)? */
6532377Sminshall 	noasynch = 0,	/* User specified "-noasynch" on command line */
6632377Sminshall 	askedSGA = 0,	/* We have talked about suppress go ahead */
6732531Sminshall 	telnetport = 1,
6832531Sminshall 	SYNCHing,	/* we are in TELNET SYNCH mode */
6932531Sminshall 	flushout,	/* flush output */
7032531Sminshall 	autoflush = 0,	/* flush output when interrupting? */
7132531Sminshall 	autosynch,	/* send interrupt characters with SYNCH? */
7232531Sminshall 	localchars,	/* we recognize interrupt/quit */
7332531Sminshall 	donelclchars,	/* the user has set "localchars" */
7432531Sminshall 	donebinarytoggle,	/* the user has put us in binary */
7532531Sminshall 	dontlecho,	/* do we suppress local echoing right now? */
7632531Sminshall 	globalmode;
7727088Sminshall 
7832377Sminshall #define	CONTROL(x)	((x)&0x1f)		/* CTRL(x) is not portable */
796000Sroot 
8032377Sminshall char
8132377Sminshall 	*prompt = 0,
8232377Sminshall 	escape,
8332377Sminshall 	echoc;
8427186Sminshall 
8527186Sminshall /*
866000Sroot  * Telnet receiver states for fsm
876000Sroot  */
886000Sroot #define	TS_DATA		0
896000Sroot #define	TS_IAC		1
906000Sroot #define	TS_WILL		2
916000Sroot #define	TS_WONT		3
926000Sroot #define	TS_DO		4
936000Sroot #define	TS_DONT		5
9427021Sminshall #define	TS_CR		6
9527676Sminshall #define	TS_SB		7		/* sub-option collection */
9627676Sminshall #define	TS_SE		8		/* looking for sub-option end */
976000Sroot 
9832377Sminshall static int	telrcv_state;
996000Sroot 
10032377Sminshall jmp_buf	toplevel = { 0 };
10132377Sminshall jmp_buf	peerdied;
1026000Sroot 
10332377Sminshall int	flushline;
10427021Sminshall 
10532377Sminshall /*
10632377Sminshall  * The following are some clocks used to decide how to interpret
10732377Sminshall  * the relationship between various variables.
10832377Sminshall  */
1096000Sroot 
11032377Sminshall Clocks clocks;
11132377Sminshall 
11232377Sminshall Modelist modelist[] = {
11332377Sminshall 	{ "telnet command mode", COMMAND_LINE },
11432377Sminshall 	{ "character-at-a-time mode", 0 },
11532377Sminshall 	{ "character-at-a-time mode (local echo)", LOCAL_ECHO|LOCAL_CHARS },
11632377Sminshall 	{ "line-by-line mode (remote echo)", LINE | LOCAL_CHARS },
11732377Sminshall 	{ "line-by-line mode", LINE | LOCAL_ECHO | LOCAL_CHARS },
11832377Sminshall 	{ "line-by-line mode (local echoing suppressed)", LINE | LOCAL_CHARS },
11932377Sminshall 	{ "3270 mode", 0 },
12032377Sminshall };
1216000Sroot 
12232377Sminshall 
12332377Sminshall /*
12432377Sminshall  * Initialize telnet environment.
12532377Sminshall  */
1266000Sroot 
12732377Sminshall init_telnet()
12832377Sminshall {
12932377Sminshall     /* Don't change telnetport */
13032377Sminshall     SB_CLEAR();
13132377Sminshall     ClearArray(hisopts);
13232377Sminshall     ClearArray(myopts);
1336000Sroot 
13432554Sminshall     connected = In3270 = ISend = donebinarytoggle = 0;
13532377Sminshall     telnetport = 0;
1366000Sroot 
13732377Sminshall #if	defined(unix) && defined(TN3270)
13832377Sminshall     HaveInput = 0;
13932377Sminshall #endif	/* defined(unix) && defined(TN3270) */
1406000Sroot 
14132377Sminshall     SYNCHing = 0;
1426000Sroot 
14332377Sminshall     /* Don't change NetTrace */
1446000Sroot 
14532377Sminshall     escape = CONTROL(']');
14632377Sminshall     echoc = CONTROL('E');
1476000Sroot 
14832377Sminshall     flushline = 1;
14932377Sminshall     telrcv_state = TS_DATA;
15032377Sminshall }
15132554Sminshall 
1526000Sroot 
15332554Sminshall #include <varargs.h>
1546000Sroot 
15532554Sminshall static void
15632554Sminshall printring(va_alist)
15732554Sminshall va_dcl
15832554Sminshall {
15932554Sminshall     va_list ap;
16032554Sminshall     char buffer[100];		/* where things go */
16132554Sminshall     char *ptr;
16232554Sminshall     char *format;
16332554Sminshall     char *string;
16432554Sminshall     Ring *ring;
16532554Sminshall     int i;
16632554Sminshall 
16732554Sminshall     va_start(ap);
16832554Sminshall 
16932554Sminshall     ring = va_arg(ap, Ring *);
17032554Sminshall     format = va_arg(ap, char *);
17132554Sminshall     ptr = buffer;
17232554Sminshall 
17332554Sminshall     while ((i = *format++) != 0) {
17432554Sminshall 	if (i == '%') {
17532554Sminshall 	    i = *format++;
17632554Sminshall 	    switch (i) {
17732554Sminshall 	    case 'c':
17832554Sminshall 		*ptr++ = va_arg(ap, int);
17932554Sminshall 		break;
18032554Sminshall 	    case 's':
18132554Sminshall 		string = va_arg(ap, char *);
18232554Sminshall 		ring_supply_data(ring, buffer, ptr-buffer);
18332554Sminshall 		ring_supply_data(ring, string, strlen(string));
18432554Sminshall 		ptr = buffer;
18532554Sminshall 		break;
18632554Sminshall 	    case 0:
18732554Sminshall 		ExitString("printring: trailing %%.\n", 1);
18832554Sminshall 		/*NOTREACHED*/
18932554Sminshall 	    default:
19032554Sminshall 		ExitString("printring: unknown format character.\n", 1);
19132554Sminshall 		/*NOTREACHED*/
19232554Sminshall 	    }
19332554Sminshall 	} else {
19432554Sminshall 	    *ptr++ = i;
19532554Sminshall 	}
19632554Sminshall     }
19732554Sminshall     ring_supply_data(ring, buffer, ptr-buffer);
19832554Sminshall }
19932554Sminshall 
20032554Sminshall 
20132377Sminshall void
20227676Sminshall willoption(option, reply)
20327676Sminshall 	int option, reply;
2046000Sroot {
2056000Sroot 	char *fmt;
2066000Sroot 
2076000Sroot 	switch (option) {
2086000Sroot 
2096000Sroot 	case TELOPT_ECHO:
21032377Sminshall #	if defined(TN3270)
21132377Sminshall 	    /*
21232377Sminshall 	     * The following is a pain in the rear-end.
21332377Sminshall 	     * Various IBM servers (some versions of Wiscnet,
21432377Sminshall 	     * possibly Fibronics/Spartacus, and who knows who
21532377Sminshall 	     * else) will NOT allow us to send "DO SGA" too early
21632377Sminshall 	     * in the setup proceedings.  On the other hand,
21732377Sminshall 	     * 4.2 servers (telnetd) won't set SGA correctly.
21832377Sminshall 	     * So, we are stuck.  Empirically (but, based on
21932377Sminshall 	     * a VERY small sample), the IBM servers don't send
22032377Sminshall 	     * out anything about ECHO, so we postpone our sending
22132377Sminshall 	     * "DO SGA" until we see "WILL ECHO" (which 4.2 servers
22232377Sminshall 	     * DO send).
22332377Sminshall 	     */
22432377Sminshall 	    {
22532377Sminshall 		if (askedSGA == 0) {
22632377Sminshall 		    askedSGA = 1;
22732377Sminshall 		    if (!hisopts[TELOPT_SGA]) {
22832377Sminshall 			willoption(TELOPT_SGA, 0);
22932377Sminshall 		    }
23032377Sminshall 		}
23132377Sminshall 	    }
23232377Sminshall 		/* Fall through */
23332377Sminshall 	case TELOPT_EOR:
23432377Sminshall 	case TELOPT_BINARY:
23532377Sminshall #endif	/* defined(TN3270) */
2366000Sroot 	case TELOPT_SGA:
23727110Sminshall 		settimer(modenegotiated);
2386000Sroot 		hisopts[option] = 1;
2396000Sroot 		fmt = doopt;
24027110Sminshall 		setconnmode();		/* possibly set new tty mode */
2416000Sroot 		break;
2426000Sroot 
2436000Sroot 	case TELOPT_TM:
24427110Sminshall 		return;			/* Never reply to TM will's/wont's */
2456000Sroot 
2466000Sroot 	default:
2476000Sroot 		fmt = dont;
2486000Sroot 		break;
2496000Sroot 	}
25032554Sminshall 	printring(&netoring, fmt, option);
25127676Sminshall 	if (reply)
25232377Sminshall 		printoption(">SENT", fmt, option, reply);
25327676Sminshall 	else
25432377Sminshall 		printoption("<SENT", fmt, option, reply);
2556000Sroot }
2566000Sroot 
25732377Sminshall void
25827676Sminshall wontoption(option, reply)
25927676Sminshall 	int option, reply;
2606000Sroot {
2616000Sroot 	char *fmt;
2626000Sroot 
2636000Sroot 	switch (option) {
2646000Sroot 
2656000Sroot 	case TELOPT_ECHO:
2666000Sroot 	case TELOPT_SGA:
26727110Sminshall 		settimer(modenegotiated);
2686000Sroot 		hisopts[option] = 0;
2696000Sroot 		fmt = dont;
27027110Sminshall 		setconnmode();			/* Set new tty mode */
2716000Sroot 		break;
2726000Sroot 
27327110Sminshall 	case TELOPT_TM:
27427110Sminshall 		return;		/* Never reply to TM will's/wont's */
27527110Sminshall 
2766000Sroot 	default:
2776000Sroot 		fmt = dont;
2786000Sroot 	}
27932554Sminshall 	printring(&netoring, fmt, option);
28027676Sminshall 	if (reply)
28132377Sminshall 		printoption(">SENT", fmt, option, reply);
28227676Sminshall 	else
28332377Sminshall 		printoption("<SENT", fmt, option, reply);
2846000Sroot }
2856000Sroot 
28632377Sminshall static void
2876000Sroot dooption(option)
2886000Sroot 	int option;
2896000Sroot {
2906000Sroot 	char *fmt;
2916000Sroot 
2926000Sroot 	switch (option) {
2936000Sroot 
2946000Sroot 	case TELOPT_TM:
29513231Ssam 		fmt = will;
29613231Ssam 		break;
29713231Ssam 
29832377Sminshall #	if defined(TN3270)
29932377Sminshall 	case TELOPT_EOR:
30032377Sminshall 	case TELOPT_BINARY:
30132377Sminshall #	endif	/* defined(TN3270) */
30227676Sminshall 	case TELOPT_TTYPE:		/* terminal type option */
30327110Sminshall 	case TELOPT_SGA:		/* no big deal */
3046000Sroot 		fmt = will;
30527110Sminshall 		myopts[option] = 1;
3066000Sroot 		break;
3076000Sroot 
30827110Sminshall 	case TELOPT_ECHO:		/* We're never going to echo... */
3096000Sroot 	default:
3106000Sroot 		fmt = wont;
3116000Sroot 		break;
3126000Sroot 	}
31332554Sminshall 	printring(&netoring, fmt, option);
31432377Sminshall 	printoption(">SENT", fmt, option, 0);
3156000Sroot }
31627676Sminshall 
31727676Sminshall /*
31827676Sminshall  * suboption()
31927676Sminshall  *
32027676Sminshall  *	Look at the sub-option buffer, and try to be helpful to the other
32127676Sminshall  * side.
32227676Sminshall  *
32327676Sminshall  *	Currently we recognize:
32427676Sminshall  *
32527676Sminshall  *		Terminal type, send request.
32627676Sminshall  */
32727676Sminshall 
32832377Sminshall static void
32927676Sminshall suboption()
33027676Sminshall {
33132377Sminshall     printsub("<", subbuffer, subend-subbuffer+1);
33227676Sminshall     switch (subbuffer[0]&0xff) {
33327676Sminshall     case TELOPT_TTYPE:
33427676Sminshall 	if ((subbuffer[1]&0xff) != TELQUAL_SEND) {
33527676Sminshall 	    ;
33627676Sminshall 	} else {
33727676Sminshall 	    char *name;
33827676Sminshall 	    char namebuf[41];
33932377Sminshall 	    extern char *getenv();
34027676Sminshall 	    int len;
34127676Sminshall 
34232377Sminshall #if	defined(TN3270)
34332531Sminshall 	    if (tn3270_ttype()) {
34432377Sminshall 		return;
34532377Sminshall 	    }
34632377Sminshall #endif	/* defined(TN3270) */
34727676Sminshall 	    name = getenv("TERM");
34827676Sminshall 	    if ((name == 0) || ((len = strlen(name)) > 40)) {
34927676Sminshall 		name = "UNKNOWN";
35027676Sminshall 	    }
35127676Sminshall 	    if ((len + 4+2) < NETROOM()) {
35227676Sminshall 		strcpy(namebuf, name);
35327676Sminshall 		upcase(namebuf);
35432554Sminshall 		printring(&netoring, "%c%c%c%c%s%c%c", IAC, SB, TELOPT_TTYPE,
35527676Sminshall 				    TELQUAL_IS, namebuf, IAC, SE);
35632381Sminshall 		/* XXX */
35732381Sminshall 		/* printsub(">", nfrontp+2, 4+strlen(namebuf)+2-2-2); */
35832377Sminshall 	    } else {
35932381Sminshall 		ExitString("No room in buffer for terminal type.\n",
36032377Sminshall 							1);
36132377Sminshall 		/*NOTREACHED*/
36227676Sminshall 	    }
36327676Sminshall 	}
36427676Sminshall 
36527676Sminshall     default:
36627676Sminshall 	break;
36727676Sminshall     }
36827676Sminshall }
36932377Sminshall 
37027088Sminshall 
37132385Sminshall static int
37232377Sminshall telrcv()
37327110Sminshall {
37432377Sminshall     register int c;
37532385Sminshall     register int scc;
37632385Sminshall     register char *sbp;
37732385Sminshall     int count;
37832385Sminshall     int returnValue = 0;
37927088Sminshall 
38032385Sminshall     scc = 0;
38132385Sminshall     count = 0;
38232385Sminshall     while (TTYROOM() > 2) {
38332385Sminshall 	if (scc == 0) {
38432385Sminshall 	    if (count) {
38532528Sminshall 		ring_consumed(&netiring, count);
38632385Sminshall 		returnValue = 1;
38732385Sminshall 		count = 0;
38832385Sminshall 	    }
38932528Sminshall 	    sbp = netiring.consume;
39032528Sminshall 	    scc = ring_full_consecutive(&netiring);
39132385Sminshall 	    if (scc == 0) {
39232385Sminshall 		/* No more data coming in */
39332385Sminshall 		break;
39432385Sminshall 	    }
39532385Sminshall 	}
39632385Sminshall 
39732385Sminshall 	c = *sbp++ & 0xff, scc--; count++;
39832385Sminshall 
39932377Sminshall 	switch (telrcv_state) {
40027110Sminshall 
40132377Sminshall 	case TS_CR:
40232377Sminshall 	    telrcv_state = TS_DATA;
40332377Sminshall 	    if (c == '\0') {
40432377Sminshall 		break;	/* Ignore \0 after CR */
40532377Sminshall 	    } else if (c == '\n') {
40632657Sminshall 		if ((!hisopts[TELOPT_ECHO]) && !crmod) {
40732377Sminshall 		    TTYADD(c);
40832377Sminshall 		}
40932377Sminshall 		break;
41032377Sminshall 	    }
41132377Sminshall 	    /* Else, fall through */
41227088Sminshall 
41332377Sminshall 	case TS_DATA:
41432377Sminshall 	    if (c == IAC) {
41532377Sminshall 		telrcv_state = TS_IAC;
41632377Sminshall 		continue;
41732377Sminshall 	    }
41832377Sminshall #	    if defined(TN3270)
41932377Sminshall 	    if (In3270) {
42032377Sminshall 		*Ifrontp++ = c;
42132385Sminshall 		while (scc > 0) {
42232385Sminshall 		    c = *sbp++ & 0377, scc--; count++;
42332377Sminshall 		    if (c == IAC) {
42432377Sminshall 			telrcv_state = TS_IAC;
42532377Sminshall 			break;
42632377Sminshall 		    }
42732377Sminshall 		    *Ifrontp++ = c;
42832377Sminshall 		}
42932377Sminshall 	    } else
43032377Sminshall #	    endif /* defined(TN3270) */
43132377Sminshall 		    /*
43232377Sminshall 		     * The 'crmod' hack (see following) is needed
43332377Sminshall 		     * since we can't * set CRMOD on output only.
43432377Sminshall 		     * Machines like MULTICS like to send \r without
43532377Sminshall 		     * \n; since we must turn off CRMOD to get proper
43632377Sminshall 		     * input, the mapping is done here (sigh).
43732377Sminshall 		     */
43832377Sminshall 	    if ((c == '\r') && !hisopts[TELOPT_BINARY]) {
43932377Sminshall 		if (scc > 0) {
44032377Sminshall 		    c = *sbp&0xff;
44132377Sminshall 		    if (c == 0) {
44232385Sminshall 			sbp++, scc--; count++;
44332377Sminshall 			/* a "true" CR */
44432377Sminshall 			TTYADD('\r');
44532377Sminshall 		    } else if (!hisopts[TELOPT_ECHO] &&
44632377Sminshall 					(c == '\n')) {
44732385Sminshall 			sbp++, scc--; count++;
44832377Sminshall 			TTYADD('\n');
44932377Sminshall 		    } else {
45032377Sminshall 			TTYADD('\r');
45132377Sminshall 			if (crmod) {
45232377Sminshall 				TTYADD('\n');
45332377Sminshall 			}
45432377Sminshall 		    }
45532377Sminshall 		} else {
45632377Sminshall 		    telrcv_state = TS_CR;
45732377Sminshall 		    TTYADD('\r');
45832377Sminshall 		    if (crmod) {
45932377Sminshall 			    TTYADD('\n');
46032377Sminshall 		    }
46132377Sminshall 		}
46232377Sminshall 	    } else {
46332377Sminshall 		TTYADD(c);
46432377Sminshall 	    }
46532377Sminshall 	    continue;
46627088Sminshall 
46732377Sminshall 	case TS_IAC:
46832377Sminshall 	    switch (c) {
46932377Sminshall 
47032377Sminshall 	    case WILL:
47132377Sminshall 		telrcv_state = TS_WILL;
47232377Sminshall 		continue;
47327261Sminshall 
47432377Sminshall 	    case WONT:
47532377Sminshall 		telrcv_state = TS_WONT;
47632377Sminshall 		continue;
47727261Sminshall 
47832377Sminshall 	    case DO:
47932377Sminshall 		telrcv_state = TS_DO;
48032377Sminshall 		continue;
48127261Sminshall 
48232377Sminshall 	    case DONT:
48332377Sminshall 		telrcv_state = TS_DONT;
48432377Sminshall 		continue;
48527261Sminshall 
48632377Sminshall 	    case DM:
48732377Sminshall 		    /*
48832377Sminshall 		     * We may have missed an urgent notification,
48932377Sminshall 		     * so make sure we flush whatever is in the
49032377Sminshall 		     * buffer currently.
49132377Sminshall 		     */
49232377Sminshall 		SYNCHing = 1;
49332377Sminshall 		ttyflush(1);
49432554Sminshall 		SYNCHing = stilloob();
49532377Sminshall 		settimer(gotDM);
49632377Sminshall 		break;
49727088Sminshall 
49832377Sminshall 	    case NOP:
49932377Sminshall 	    case GA:
50032377Sminshall 		break;
50127088Sminshall 
50232377Sminshall 	    case SB:
50332377Sminshall 		SB_CLEAR();
50432377Sminshall 		telrcv_state = TS_SB;
50532377Sminshall 		continue;
50627261Sminshall 
50732377Sminshall #	    if defined(TN3270)
50832377Sminshall 	    case EOR:
50932377Sminshall 		if (In3270) {
51032377Sminshall 		    Ibackp += DataFromNetwork(Ibackp, Ifrontp-Ibackp, 1);
51132377Sminshall 		    if (Ibackp == Ifrontp) {
51232377Sminshall 			Ibackp = Ifrontp = Ibuf;
51332377Sminshall 			ISend = 0;	/* should have been! */
51432377Sminshall 		    } else {
51532377Sminshall 			ISend = 1;
51627088Sminshall 		    }
51727088Sminshall 		}
51827088Sminshall 		break;
51932377Sminshall #	    endif /* defined(TN3270) */
52032377Sminshall 
52132377Sminshall 	    case IAC:
52232377Sminshall #	    if !defined(TN3270)
52332377Sminshall 		TTYADD(IAC);
52432377Sminshall #	    else /* !defined(TN3270) */
52532377Sminshall 		if (In3270) {
52632377Sminshall 		    *Ifrontp++ = IAC;
52732377Sminshall 		} else {
52832377Sminshall 		    TTYADD(IAC);
52932377Sminshall 		}
53032377Sminshall #	    endif /* !defined(TN3270) */
53127088Sminshall 		break;
53232377Sminshall 
53327088Sminshall 	    default:
53427088Sminshall 		break;
53527088Sminshall 	    }
53632377Sminshall 	    telrcv_state = TS_DATA;
53732377Sminshall 	    continue;
53827088Sminshall 
53932377Sminshall 	case TS_WILL:
54032377Sminshall 	    printoption(">RCVD", will, c, !hisopts[c]);
54132377Sminshall 	    if (c == TELOPT_TM) {
54232377Sminshall 		if (flushout) {
54332377Sminshall 		    flushout = 0;
54432377Sminshall 		}
54532377Sminshall 	    } else if (!hisopts[c]) {
54632377Sminshall 		willoption(c, 1);
54732377Sminshall 	    }
54832377Sminshall 	    SetIn3270();
54932377Sminshall 	    telrcv_state = TS_DATA;
55032377Sminshall 	    continue;
55127110Sminshall 
55232377Sminshall 	case TS_WONT:
55332377Sminshall 	    printoption(">RCVD", wont, c, hisopts[c]);
55432377Sminshall 	    if (c == TELOPT_TM) {
55532377Sminshall 		if (flushout) {
55632377Sminshall 		    flushout = 0;
55732377Sminshall 		}
55832377Sminshall 	    } else if (hisopts[c]) {
55932377Sminshall 		wontoption(c, 1);
56032377Sminshall 	    }
56132377Sminshall 	    SetIn3270();
56232377Sminshall 	    telrcv_state = TS_DATA;
56332377Sminshall 	    continue;
56427088Sminshall 
56532377Sminshall 	case TS_DO:
56632377Sminshall 	    printoption(">RCVD", doopt, c, !myopts[c]);
56732377Sminshall 	    if (!myopts[c])
56832377Sminshall 		dooption(c);
56932377Sminshall 	    SetIn3270();
57032377Sminshall 	    telrcv_state = TS_DATA;
57132377Sminshall 	    continue;
57227088Sminshall 
57332377Sminshall 	case TS_DONT:
57432377Sminshall 	    printoption(">RCVD", dont, c, myopts[c]);
57532377Sminshall 	    if (myopts[c]) {
57632377Sminshall 		myopts[c] = 0;
57732554Sminshall 		printring(&netoring, wont, c);
57832377Sminshall 		flushline = 1;
57932377Sminshall 		setconnmode();	/* set new tty mode (maybe) */
58032377Sminshall 		printoption(">SENT", wont, c, 0);
58132377Sminshall 	    }
58232377Sminshall 	    SetIn3270();
58332377Sminshall 	    telrcv_state = TS_DATA;
58432377Sminshall 	    continue;
58527088Sminshall 
58632377Sminshall 	case TS_SB:
58732377Sminshall 	    if (c == IAC) {
58832377Sminshall 		telrcv_state = TS_SE;
58932377Sminshall 	    } else {
59032377Sminshall 		SB_ACCUM(c);
59132377Sminshall 	    }
59232377Sminshall 	    continue;
59327088Sminshall 
59432377Sminshall 	case TS_SE:
59532377Sminshall 	    if (c != SE) {
59632377Sminshall 		if (c != IAC) {
59732377Sminshall 		    SB_ACCUM(IAC);
59832377Sminshall 		}
59932377Sminshall 		SB_ACCUM(c);
60032377Sminshall 		telrcv_state = TS_SB;
60132377Sminshall 	    } else {
60232377Sminshall 		SB_TERM();
60332377Sminshall 		suboption();	/* handle sub-option */
60432377Sminshall 		SetIn3270();
60532377Sminshall 		telrcv_state = TS_DATA;
60632377Sminshall 	    }
60727088Sminshall 	}
60827088Sminshall     }
609*32667Sminshall     if (count)
610*32667Sminshall 	ring_consumed(&netiring, count);
61132385Sminshall     return returnValue||count;
61227088Sminshall }
61332385Sminshall 
61432385Sminshall static int
61532554Sminshall telsnd()
61632385Sminshall {
61732385Sminshall     int tcc;
61832385Sminshall     int count;
61932385Sminshall     int returnValue = 0;
62032385Sminshall     char *tbp;
62132385Sminshall 
62232385Sminshall     tcc = 0;
62332385Sminshall     count = 0;
62432385Sminshall     while (NETROOM() > 2) {
62532385Sminshall 	register int sc;
62632385Sminshall 	register int c;
62732385Sminshall 
62832385Sminshall 	if (tcc == 0) {
62932385Sminshall 	    if (count) {
63032528Sminshall 		ring_consumed(&ttyiring, count);
63132385Sminshall 		returnValue = 1;
63232385Sminshall 		count = 0;
63332385Sminshall 	    }
63432528Sminshall 	    tbp = ttyiring.consume;
63532528Sminshall 	    tcc = ring_full_consecutive(&ttyiring);
63632385Sminshall 	    if (tcc == 0) {
63732385Sminshall 		break;
63832385Sminshall 	    }
63932385Sminshall 	}
64032385Sminshall 	c = *tbp++ & 0xff, sc = strip(c), tcc--; count++;
64132385Sminshall 	if (sc == escape) {
64232385Sminshall 	    command(0);
64332385Sminshall 	    tcc = 0;
64432385Sminshall 	    flushline = 1;
64532385Sminshall 	    break;
64632385Sminshall 	} else if (MODE_LINE(globalmode) && (sc == echoc)) {
64732385Sminshall 	    if (tcc > 0 && strip(*tbp) == echoc) {
64832385Sminshall 		tcc--; tbp++; count++;
64932385Sminshall 	    } else {
65032385Sminshall 		dontlecho = !dontlecho;
65132385Sminshall 		settimer(echotoggle);
65232385Sminshall 		setconnmode();
65332385Sminshall 		flushline = 1;
65432385Sminshall 		break;
65532385Sminshall 	    }
65632385Sminshall 	}
65732385Sminshall 	if (localchars) {
65832385Sminshall 	    if (TerminalSpecialChars(sc) == 0) {
65932385Sminshall 		break;
66032385Sminshall 	    }
66132385Sminshall 	}
66232385Sminshall 	if (!myopts[TELOPT_BINARY]) {
66332385Sminshall 	    switch (c) {
66432385Sminshall 	    case '\n':
66532385Sminshall 		    /*
66632385Sminshall 		     * If we are in CRMOD mode (\r ==> \n)
66732385Sminshall 		     * on our local machine, then probably
66832385Sminshall 		     * a newline (unix) is CRLF (TELNET).
66932385Sminshall 		     */
67032385Sminshall 		if (MODE_LOCAL_CHARS(globalmode)) {
67132385Sminshall 		    NETADD('\r');
67232385Sminshall 		}
67332385Sminshall 		NETADD('\n');
67432385Sminshall 		flushline = 1;
67532385Sminshall 		break;
67632385Sminshall 	    case '\r':
67732385Sminshall 		if (!crlf) {
67832385Sminshall 		    NET2ADD('\r', '\0');
67932385Sminshall 		} else {
68032385Sminshall 		    NET2ADD('\r', '\n');
68132385Sminshall 		}
68232385Sminshall 		flushline = 1;
68332385Sminshall 		break;
68432385Sminshall 	    case IAC:
68532385Sminshall 		NET2ADD(IAC, IAC);
68632385Sminshall 		break;
68732385Sminshall 	    default:
68832385Sminshall 		NETADD(c);
68932385Sminshall 		break;
69032385Sminshall 	    }
69132385Sminshall 	} else if (c == IAC) {
69232385Sminshall 	    NET2ADD(IAC, IAC);
69332385Sminshall 	} else {
69432385Sminshall 	    NETADD(c);
69532385Sminshall 	}
69632385Sminshall     }
697*32667Sminshall     if (count)
698*32667Sminshall 	ring_consumed(&ttyiring, count);
69932385Sminshall     return returnValue||count;		/* Non-zero if we did anything */
70032385Sminshall }
70132377Sminshall 
70227088Sminshall /*
70332377Sminshall  * Scheduler()
70432377Sminshall  *
70532377Sminshall  * Try to do something.
70632377Sminshall  *
70732377Sminshall  * If we do something useful, return 1; else return 0.
70832377Sminshall  *
70927110Sminshall  */
71027110Sminshall 
71127110Sminshall 
71232377Sminshall int
71332377Sminshall Scheduler(block)
71432377Sminshall int	block;			/* should we block in the select ? */
71527110Sminshall {
71632377Sminshall     register int c;
71732377Sminshall 		/* One wants to be a bit careful about setting returnValue
71832377Sminshall 		 * to one, since a one implies we did some useful work,
71932377Sminshall 		 * and therefore probably won't be called to block next
72032377Sminshall 		 * time (TN3270 mode only).
72132377Sminshall 		 */
72232531Sminshall     int returnValue;
72332531Sminshall     int netin, netout, netex, ttyin, ttyout;
72427110Sminshall 
72532531Sminshall     /* Decide which rings should be processed */
72632531Sminshall 
72732531Sminshall     netout = ring_full_count(&netoring) &&
72832531Sminshall 	    (!MODE_LINE(globalmode) || flushline || myopts[TELOPT_BINARY]);
72932531Sminshall     ttyout = ring_full_count(&ttyoring);
73032531Sminshall 
73132377Sminshall #if	defined(TN3270)
73232531Sminshall     ttyin = ring_empty_count(&ttyiring) && (shell_active == 0);
73332377Sminshall #else	/* defined(TN3270) */
73432531Sminshall     ttyin = ring_empty_count(&ttyiring);
73532377Sminshall #endif	/* defined(TN3270) */
73632531Sminshall 
73732531Sminshall #if	defined(TN3270)
73832531Sminshall     netin = ring_empty_count(&netiring);
73932377Sminshall #   else /* !defined(TN3270) */
74032531Sminshall     netin = !ISend && ring_empty_count(&netiring);
74132377Sminshall #   endif /* !defined(TN3270) */
74232531Sminshall 
74332531Sminshall     netex = !SYNCHing;
74432531Sminshall 
74532531Sminshall     /* If we have seen a signal recently, reset things */
74632377Sminshall #   if defined(TN3270) && defined(unix)
74732377Sminshall     if (HaveInput) {
74832377Sminshall 	HaveInput = 0;
74932377Sminshall 	signal(SIGIO, inputAvailable);
75032377Sminshall     }
75132377Sminshall #endif	/* defined(TN3270) && defined(unix) */
75232377Sminshall 
75332531Sminshall     /* Call to system code to process rings */
75427178Sminshall 
75532531Sminshall     returnValue = process_rings(netin, netout, netex, ttyin, ttyout, !block);
75627178Sminshall 
75732531Sminshall     /* Now, look at the input rings, looking for work to do. */
75832377Sminshall 
75932531Sminshall     if (ring_full_count(&ttyiring)) {
76032377Sminshall #   if defined(TN3270)
76132377Sminshall 	if (In3270) {
76232385Sminshall 	    c = DataFromTerminal(ttyiring.send,
76332528Sminshall 					ring_full_consecutive(&ttyiring));
76432377Sminshall 	    if (c) {
76532377Sminshall 		returnValue = 1;
766*32667Sminshall 	        ring_consumed(&ttyiring, c);
76732377Sminshall 	    }
76832377Sminshall 	} else {
76932377Sminshall #   endif /* defined(TN3270) */
77032554Sminshall 	    returnValue |= telsnd();
77132377Sminshall #   if defined(TN3270)
77227178Sminshall 	}
77332531Sminshall #   endif /* defined(TN3270) */
77427178Sminshall     }
77532377Sminshall 
77632528Sminshall     if (ring_full_count(&netiring)) {
77732377Sminshall #	if !defined(TN3270)
77832385Sminshall 	returnValue |= telrcv();
77932377Sminshall #	else /* !defined(TN3270) */
78032377Sminshall 	returnValue = Push3270();
78132377Sminshall #	endif /* !defined(TN3270) */
78232377Sminshall     }
78332377Sminshall     return returnValue;
78427178Sminshall }
78527178Sminshall 
78627178Sminshall /*
78732377Sminshall  * Select from tty and network...
78827088Sminshall  */
78932377Sminshall void
79032377Sminshall telnet()
79127088Sminshall {
79232531Sminshall     sys_telnet_init();
79327088Sminshall 
79432377Sminshall #   if !defined(TN3270)
79532377Sminshall     if (telnetport) {
79632377Sminshall 	if (!hisopts[TELOPT_SGA]) {
79732377Sminshall 	    willoption(TELOPT_SGA, 0);
79827110Sminshall 	}
79932377Sminshall 	if (!myopts[TELOPT_TTYPE]) {
80032377Sminshall 	    dooption(TELOPT_TTYPE, 0);
80132377Sminshall 	}
80227178Sminshall     }
80332377Sminshall #   endif /* !defined(TN3270) */
80427088Sminshall 
80532377Sminshall #   if !defined(TN3270)
80632377Sminshall     for (;;) {
80732385Sminshall 	int schedValue;
80832385Sminshall 
80932385Sminshall 	while ((schedValue = Scheduler(0)) != 0) {
81032385Sminshall 	    if (schedValue == -1) {
81132385Sminshall 		setcommandmode();
81232385Sminshall 		return;
81332385Sminshall 	    }
81432385Sminshall 	}
81532385Sminshall 
81632531Sminshall 	if (Scheduler(1) == -1) {
81732377Sminshall 	    setcommandmode();
81832377Sminshall 	    return;
81932377Sminshall 	}
82032377Sminshall     }
82132377Sminshall #   else /* !defined(TN3270) */
82232377Sminshall     for (;;) {
82332377Sminshall 	int schedValue;
82427088Sminshall 
82532377Sminshall 	while (!In3270 && !shell_active) {
82632531Sminshall 	    if (Scheduler(1) == -1) {
82732377Sminshall 		setcommandmode();
82832377Sminshall 		return;
82932377Sminshall 	    }
83027088Sminshall 	}
83132377Sminshall 
83232377Sminshall 	while ((schedValue = Scheduler(0)) != 0) {
83332377Sminshall 	    if (schedValue == -1) {
83432377Sminshall 		setcommandmode();
83532377Sminshall 		return;
83632377Sminshall 	    }
83727088Sminshall 	}
83832377Sminshall 		/* If there is data waiting to go out to terminal, don't
83932377Sminshall 		 * schedule any more data for the terminal.
84032377Sminshall 		 */
84132377Sminshall 	if (tfrontp-tbackp) {
84232377Sminshall 	    schedValue = 1;
84327088Sminshall 	} else {
84432377Sminshall 	    if (shell_active) {
84532377Sminshall 		if (shell_continue() == 0) {
84632377Sminshall 		    ConnectScreen();
84727088Sminshall 		}
84832377Sminshall 	    } else if (In3270) {
84932377Sminshall 		schedValue = DoTerminalOutput();
85032377Sminshall 	    }
85127088Sminshall 	}
85232377Sminshall 	if (schedValue && (shell_active == 0)) {
85332531Sminshall 	    if (Scheduler(1) == -1) {
85432377Sminshall 		setcommandmode();
85532377Sminshall 		return;
85632377Sminshall 	    }
85727088Sminshall 	}
85832377Sminshall     }
85932377Sminshall #   endif /* !defined(TN3270) */
86027088Sminshall }
86132377Sminshall 
86227088Sminshall /*
86332554Sminshall  * nextitem()
86432554Sminshall  *
86532554Sminshall  *	Return the address of the next "item" in the TELNET data
86632554Sminshall  * stream.  This will be the address of the next character if
86732554Sminshall  * the current address is a user data character, or it will
86832554Sminshall  * be the address of the character following the TELNET command
86932554Sminshall  * if the current address is a TELNET IAC ("I Am a Command")
87032554Sminshall  * character.
87132554Sminshall  */
87232554Sminshall 
87332554Sminshall static char *
87432554Sminshall nextitem(current)
87532554Sminshall char	*current;
87632554Sminshall {
87732554Sminshall     if ((*current&0xff) != IAC) {
87832554Sminshall 	return current+1;
87932554Sminshall     }
88032554Sminshall     switch (*(current+1)&0xff) {
88132554Sminshall     case DO:
88232554Sminshall     case DONT:
88332554Sminshall     case WILL:
88432554Sminshall     case WONT:
88532554Sminshall 	return current+3;
88632554Sminshall     case SB:		/* loop forever looking for the SE */
88732554Sminshall 	{
88832554Sminshall 	    register char *look = current+2;
88932554Sminshall 
89032554Sminshall 	    for (;;) {
89132554Sminshall 		if ((*look++&0xff) == IAC) {
89232554Sminshall 		    if ((*look++&0xff) == SE) {
89332554Sminshall 			return look;
89432554Sminshall 		    }
89532554Sminshall 		}
89632554Sminshall 	    }
89732554Sminshall 	}
89832554Sminshall     default:
89932554Sminshall 	return current+2;
90032554Sminshall     }
90132554Sminshall }
90232554Sminshall 
90332554Sminshall /*
90432554Sminshall  * netclear()
90532554Sminshall  *
90632554Sminshall  *	We are about to do a TELNET SYNCH operation.  Clear
90732554Sminshall  * the path to the network.
90832554Sminshall  *
90932554Sminshall  *	Things are a bit tricky since we may have sent the first
91032554Sminshall  * byte or so of a previous TELNET command into the network.
91132554Sminshall  * So, we have to scan the network buffer from the beginning
91232554Sminshall  * until we are up to where we want to be.
91332554Sminshall  *
91432554Sminshall  *	A side effect of what we do, just to keep things
91532554Sminshall  * simple, is to clear the urgent data pointer.  The principal
91632554Sminshall  * caller should be setting the urgent data pointer AFTER calling
91732554Sminshall  * us in any case.
91832554Sminshall  */
91932554Sminshall 
92032554Sminshall static void
92132554Sminshall netclear()
92232554Sminshall {
92332554Sminshall #if	0	/* XXX */
92432554Sminshall     register char *thisitem, *next;
92532554Sminshall     char *good;
92632554Sminshall #define	wewant(p)	((nfrontp > p) && ((*p&0xff) == IAC) && \
92732554Sminshall 				((*(p+1)&0xff) != EC) && ((*(p+1)&0xff) != EL))
92832554Sminshall 
92932554Sminshall     thisitem = netobuf;
93032554Sminshall 
93132554Sminshall     while ((next = nextitem(thisitem)) <= netobuf.send) {
93232554Sminshall 	thisitem = next;
93332554Sminshall     }
93432554Sminshall 
93532554Sminshall     /* Now, thisitem is first before/at boundary. */
93632554Sminshall 
93732554Sminshall     good = netobuf;	/* where the good bytes go */
93832554Sminshall 
93932554Sminshall     while (netoring.add > thisitem) {
94032554Sminshall 	if (wewant(thisitem)) {
94132554Sminshall 	    int length;
94232554Sminshall 
94332554Sminshall 	    next = thisitem;
94432554Sminshall 	    do {
94532554Sminshall 		next = nextitem(next);
94632554Sminshall 	    } while (wewant(next) && (nfrontp > next));
94732554Sminshall 	    length = next-thisitem;
94832554Sminshall 	    memcpy(good, thisitem, length);
94932554Sminshall 	    good += length;
95032554Sminshall 	    thisitem = next;
95132554Sminshall 	} else {
95232554Sminshall 	    thisitem = nextitem(thisitem);
95332554Sminshall 	}
95432554Sminshall     }
95532554Sminshall 
95632554Sminshall #endif	/* 0 */
95732554Sminshall }
95832554Sminshall 
95932554Sminshall /*
96032377Sminshall  * These routines add various telnet commands to the data stream.
96127088Sminshall  */
96232377Sminshall 
96332554Sminshall static void
96432554Sminshall doflush()
96532554Sminshall {
96632554Sminshall     NET2ADD(IAC, DO);
96732554Sminshall     NETADD(TELOPT_TM);
96832554Sminshall     flushline = 1;
96932554Sminshall     flushout = 1;
97032554Sminshall     ttyflush(1);			/* Flush/drop output */
97132554Sminshall     /* do printoption AFTER flush, otherwise the output gets tossed... */
97232554Sminshall     printoption("<SENT", doopt, TELOPT_TM, 0);
97332554Sminshall }
97432554Sminshall 
97532377Sminshall void
97632377Sminshall xmitAO()
97727088Sminshall {
97832377Sminshall     NET2ADD(IAC, AO);
97932377Sminshall     if (autoflush) {
98032377Sminshall 	doflush();
98132377Sminshall     }
98232377Sminshall }
98327088Sminshall 
98432377Sminshall 
98532377Sminshall void
98632377Sminshall xmitEL()
98727088Sminshall {
98832377Sminshall     NET2ADD(IAC, EL);
98927088Sminshall }
99027088Sminshall 
99132377Sminshall void
99232377Sminshall xmitEC()
99327088Sminshall {
99432377Sminshall     NET2ADD(IAC, EC);
99527088Sminshall }
99627088Sminshall 
99732377Sminshall 
99832377Sminshall #if	defined(NOT43)
99932377Sminshall int
100032377Sminshall #else	/* defined(NOT43) */
100132377Sminshall void
100232377Sminshall #endif	/* defined(NOT43) */
100332377Sminshall dosynch()
100427088Sminshall {
100532377Sminshall     netclear();			/* clear the path to the network */
100632377Sminshall     NET2ADD(IAC, DM);
100727088Sminshall 
100832377Sminshall #if	defined(NOT43)
100932377Sminshall     return 0;
101032377Sminshall #endif	/* defined(NOT43) */
101127088Sminshall }
101227088Sminshall 
101332377Sminshall void
101432377Sminshall intp()
101527088Sminshall {
101632377Sminshall     NET2ADD(IAC, IP);
101732377Sminshall     flushline = 1;
101832377Sminshall     if (autoflush) {
101932377Sminshall 	doflush();
102032377Sminshall     }
102132377Sminshall     if (autosynch) {
102232377Sminshall 	dosynch();
102332377Sminshall     }
102427088Sminshall }
102527186Sminshall 
102632377Sminshall void
102732377Sminshall sendbrk()
102827186Sminshall {
102932377Sminshall     NET2ADD(IAC, BREAK);
103032377Sminshall     flushline = 1;
103132377Sminshall     if (autoflush) {
103232377Sminshall 	doflush();
103332377Sminshall     }
103432377Sminshall     if (autosynch) {
103532377Sminshall 	dosynch();
103632377Sminshall     }
103727186Sminshall }
1038