xref: /csrg-svn/usr.bin/telnet/telnet.c (revision 36241)
133685Sbostic /*
233685Sbostic  * Copyright (c) 1988 Regents of the University of California.
333685Sbostic  * All rights reserved.
433685Sbostic  *
533685Sbostic  * Redistribution and use in source and binary forms are permitted
634898Sbostic  * provided that the above copyright notice and this paragraph are
734898Sbostic  * duplicated in all such forms and that any documentation,
834898Sbostic  * advertising materials, and other materials related to such
934898Sbostic  * distribution and use acknowledge that the software was developed
1034898Sbostic  * by the University of California, Berkeley.  The name of the
1134898Sbostic  * University may not be used to endorse or promote products derived
1234898Sbostic  * from this software without specific prior written permission.
1334898Sbostic  * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
1434898Sbostic  * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
1534898Sbostic  * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.
1633685Sbostic  */
1711758Ssam 
1821580Sdist #ifndef lint
1935518Sminshall static char sccsid[] = "@(#)telnet.c	5.33 (Berkeley) 6/29/88";
2033685Sbostic #endif /* not lint */
2121580Sdist 
229217Ssam #include <sys/types.h>
239217Ssam 
2432377Sminshall #if	defined(unix)
2533804Sminshall #include <signal.h>
2632377Sminshall /* By the way, we need to include curses.h before telnet.h since,
2732377Sminshall  * among other things, telnet.h #defines 'DO', which is a variable
2832377Sminshall  * declared in curses.h.
2932377Sminshall  */
3032377Sminshall #include <curses.h>
3132377Sminshall #endif	/* defined(unix) */
3232377Sminshall 
3312212Ssam #include <arpa/telnet.h>
3432377Sminshall 
3532377Sminshall #if	defined(unix)
3627186Sminshall #include <strings.h>
3732377Sminshall #else	/* defined(unix) */
3832377Sminshall #include <string.h>
3932377Sminshall #endif	/* defined(unix) */
409217Ssam 
4132381Sminshall #include "ring.h"
4232381Sminshall 
4332377Sminshall #include "defines.h"
4432377Sminshall #include "externs.h"
4532377Sminshall #include "types.h"
4632377Sminshall #include "general.h"
4727178Sminshall 
4827178Sminshall 
4927228Sminshall #define	strip(x)	((x)&0x7f)
506000Sroot 
5127088Sminshall 
5232377Sminshall static char	subbuffer[SUBBUFSIZE],
5332377Sminshall 		*subpointer, *subend;	 /* buffer for sub-options */
5427676Sminshall #define	SB_CLEAR()	subpointer = subbuffer;
5527676Sminshall #define	SB_TERM()	subend = subpointer;
5627676Sminshall #define	SB_ACCUM(c)	if (subpointer < (subbuffer+sizeof subbuffer)) { \
5727676Sminshall 				*subpointer++ = (c); \
5827676Sminshall 			}
5927676Sminshall 
606000Sroot char	hisopts[256];
616000Sroot char	myopts[256];
626000Sroot 
636000Sroot char	doopt[] = { IAC, DO, '%', 'c', 0 };
646000Sroot char	dont[] = { IAC, DONT, '%', 'c', 0 };
656000Sroot char	will[] = { IAC, WILL, '%', 'c', 0 };
666000Sroot char	wont[] = { IAC, WONT, '%', 'c', 0 };
676000Sroot 
6832377Sminshall int
6932377Sminshall 	connected,
7032377Sminshall 	showoptions,
7132377Sminshall 	In3270,		/* Are we in 3270 mode? */
7232377Sminshall 	ISend,		/* trying to send network data in */
7332377Sminshall 	debug = 0,
7432377Sminshall 	crmod,
7532377Sminshall 	netdata,	/* Print out network data flow */
7632377Sminshall 	crlf,		/* Should '\r' be mapped to <CR><LF> (or <CR><NUL>)? */
7734848Sminshall #if	defined(TN3270)
78*36241Sminshall 	noasynchtty = 0,/* User specified "-noasynch" on command line */
79*36241Sminshall 	noasynchnet = 0,/* User specified "-noasynch" on command line */
8032377Sminshall 	askedSGA = 0,	/* We have talked about suppress go ahead */
8134848Sminshall #endif	/* defined(TN3270) */
8233286Sminshall 	telnetport,
8332531Sminshall 	SYNCHing,	/* we are in TELNET SYNCH mode */
8432531Sminshall 	flushout,	/* flush output */
8532531Sminshall 	autoflush = 0,	/* flush output when interrupting? */
8632531Sminshall 	autosynch,	/* send interrupt characters with SYNCH? */
8732531Sminshall 	localchars,	/* we recognize interrupt/quit */
8832531Sminshall 	donelclchars,	/* the user has set "localchars" */
8932531Sminshall 	donebinarytoggle,	/* the user has put us in binary */
9032531Sminshall 	dontlecho,	/* do we suppress local echoing right now? */
9132531Sminshall 	globalmode;
9227088Sminshall 
9332377Sminshall #define	CONTROL(x)	((x)&0x1f)		/* CTRL(x) is not portable */
946000Sroot 
9532377Sminshall char
9632377Sminshall 	*prompt = 0,
9732377Sminshall 	escape,
9832377Sminshall 	echoc;
9927186Sminshall 
10027186Sminshall /*
1016000Sroot  * Telnet receiver states for fsm
1026000Sroot  */
1036000Sroot #define	TS_DATA		0
1046000Sroot #define	TS_IAC		1
1056000Sroot #define	TS_WILL		2
1066000Sroot #define	TS_WONT		3
1076000Sroot #define	TS_DO		4
1086000Sroot #define	TS_DONT		5
10927021Sminshall #define	TS_CR		6
11027676Sminshall #define	TS_SB		7		/* sub-option collection */
11127676Sminshall #define	TS_SE		8		/* looking for sub-option end */
1126000Sroot 
11332377Sminshall static int	telrcv_state;
1146000Sroot 
11532377Sminshall jmp_buf	toplevel = { 0 };
11632377Sminshall jmp_buf	peerdied;
1176000Sroot 
11832377Sminshall int	flushline;
11927021Sminshall 
12032377Sminshall /*
12132377Sminshall  * The following are some clocks used to decide how to interpret
12232377Sminshall  * the relationship between various variables.
12332377Sminshall  */
1246000Sroot 
12532377Sminshall Clocks clocks;
12632377Sminshall 
12732377Sminshall Modelist modelist[] = {
12832377Sminshall 	{ "telnet command mode", COMMAND_LINE },
12932377Sminshall 	{ "character-at-a-time mode", 0 },
13032377Sminshall 	{ "character-at-a-time mode (local echo)", LOCAL_ECHO|LOCAL_CHARS },
13132377Sminshall 	{ "line-by-line mode (remote echo)", LINE | LOCAL_CHARS },
13232377Sminshall 	{ "line-by-line mode", LINE | LOCAL_ECHO | LOCAL_CHARS },
13332377Sminshall 	{ "line-by-line mode (local echoing suppressed)", LINE | LOCAL_CHARS },
13432377Sminshall 	{ "3270 mode", 0 },
13532377Sminshall };
1366000Sroot 
13732377Sminshall 
13832377Sminshall /*
13932377Sminshall  * Initialize telnet environment.
14032377Sminshall  */
1416000Sroot 
14232377Sminshall init_telnet()
14332377Sminshall {
14432377Sminshall     SB_CLEAR();
14532377Sminshall     ClearArray(hisopts);
14632377Sminshall     ClearArray(myopts);
1476000Sroot 
14832554Sminshall     connected = In3270 = ISend = donebinarytoggle = 0;
1496000Sroot 
15032377Sminshall     SYNCHing = 0;
1516000Sroot 
15232377Sminshall     /* Don't change NetTrace */
1536000Sroot 
15432377Sminshall     escape = CONTROL(']');
15532377Sminshall     echoc = CONTROL('E');
1566000Sroot 
15732377Sminshall     flushline = 1;
15832377Sminshall     telrcv_state = TS_DATA;
15932377Sminshall }
16032554Sminshall 
1616000Sroot 
16232554Sminshall #include <varargs.h>
1636000Sroot 
16434848Sminshall /*VARARGS*/
16532554Sminshall static void
16632554Sminshall printring(va_alist)
16732554Sminshall va_dcl
16832554Sminshall {
16932554Sminshall     va_list ap;
17032554Sminshall     char buffer[100];		/* where things go */
17132554Sminshall     char *ptr;
17232554Sminshall     char *format;
17332554Sminshall     char *string;
17432554Sminshall     Ring *ring;
17532554Sminshall     int i;
17632554Sminshall 
17732554Sminshall     va_start(ap);
17832554Sminshall 
17932554Sminshall     ring = va_arg(ap, Ring *);
18032554Sminshall     format = va_arg(ap, char *);
18132554Sminshall     ptr = buffer;
18232554Sminshall 
18332554Sminshall     while ((i = *format++) != 0) {
18432554Sminshall 	if (i == '%') {
18532554Sminshall 	    i = *format++;
18632554Sminshall 	    switch (i) {
18732554Sminshall 	    case 'c':
18832554Sminshall 		*ptr++ = va_arg(ap, int);
18932554Sminshall 		break;
19032554Sminshall 	    case 's':
19132554Sminshall 		string = va_arg(ap, char *);
19232554Sminshall 		ring_supply_data(ring, buffer, ptr-buffer);
19332554Sminshall 		ring_supply_data(ring, string, strlen(string));
19432554Sminshall 		ptr = buffer;
19532554Sminshall 		break;
19632554Sminshall 	    case 0:
19732554Sminshall 		ExitString("printring: trailing %%.\n", 1);
19832554Sminshall 		/*NOTREACHED*/
19932554Sminshall 	    default:
20032554Sminshall 		ExitString("printring: unknown format character.\n", 1);
20132554Sminshall 		/*NOTREACHED*/
20232554Sminshall 	    }
20332554Sminshall 	} else {
20432554Sminshall 	    *ptr++ = i;
20532554Sminshall 	}
20632554Sminshall     }
20732554Sminshall     ring_supply_data(ring, buffer, ptr-buffer);
20832554Sminshall }
20932554Sminshall 
21032554Sminshall 
21132377Sminshall void
21227676Sminshall willoption(option, reply)
21327676Sminshall 	int option, reply;
2146000Sroot {
2156000Sroot 	char *fmt;
2166000Sroot 
2176000Sroot 	switch (option) {
2186000Sroot 
2196000Sroot 	case TELOPT_ECHO:
22032377Sminshall #	if defined(TN3270)
22132377Sminshall 	    /*
22232377Sminshall 	     * The following is a pain in the rear-end.
22332377Sminshall 	     * Various IBM servers (some versions of Wiscnet,
22432377Sminshall 	     * possibly Fibronics/Spartacus, and who knows who
22532377Sminshall 	     * else) will NOT allow us to send "DO SGA" too early
22632377Sminshall 	     * in the setup proceedings.  On the other hand,
22732377Sminshall 	     * 4.2 servers (telnetd) won't set SGA correctly.
22832377Sminshall 	     * So, we are stuck.  Empirically (but, based on
22932377Sminshall 	     * a VERY small sample), the IBM servers don't send
23032377Sminshall 	     * out anything about ECHO, so we postpone our sending
23132377Sminshall 	     * "DO SGA" until we see "WILL ECHO" (which 4.2 servers
23232377Sminshall 	     * DO send).
23332377Sminshall 	     */
23432377Sminshall 	    {
23532377Sminshall 		if (askedSGA == 0) {
23632377Sminshall 		    askedSGA = 1;
23732377Sminshall 		    if (!hisopts[TELOPT_SGA]) {
23832377Sminshall 			willoption(TELOPT_SGA, 0);
23932377Sminshall 		    }
24032377Sminshall 		}
24132377Sminshall 	    }
24232377Sminshall 		/* Fall through */
24332377Sminshall 	case TELOPT_EOR:
24432377Sminshall 	case TELOPT_BINARY:
24532377Sminshall #endif	/* defined(TN3270) */
2466000Sroot 	case TELOPT_SGA:
24727110Sminshall 		settimer(modenegotiated);
2486000Sroot 		hisopts[option] = 1;
2496000Sroot 		fmt = doopt;
25027110Sminshall 		setconnmode();		/* possibly set new tty mode */
2516000Sroot 		break;
2526000Sroot 
2536000Sroot 	case TELOPT_TM:
25427110Sminshall 		return;			/* Never reply to TM will's/wont's */
2556000Sroot 
2566000Sroot 	default:
2576000Sroot 		fmt = dont;
2586000Sroot 		break;
2596000Sroot 	}
26032554Sminshall 	printring(&netoring, fmt, option);
26127676Sminshall 	if (reply)
26232377Sminshall 		printoption(">SENT", fmt, option, reply);
26327676Sminshall 	else
26432377Sminshall 		printoption("<SENT", fmt, option, reply);
2656000Sroot }
2666000Sroot 
26732377Sminshall void
26827676Sminshall wontoption(option, reply)
26927676Sminshall 	int option, reply;
2706000Sroot {
2716000Sroot 	char *fmt;
2726000Sroot 
2736000Sroot 	switch (option) {
2746000Sroot 
2756000Sroot 	case TELOPT_ECHO:
2766000Sroot 	case TELOPT_SGA:
27727110Sminshall 		settimer(modenegotiated);
2786000Sroot 		hisopts[option] = 0;
2796000Sroot 		fmt = dont;
28027110Sminshall 		setconnmode();			/* Set new tty mode */
2816000Sroot 		break;
2826000Sroot 
28327110Sminshall 	case TELOPT_TM:
28427110Sminshall 		return;		/* Never reply to TM will's/wont's */
28527110Sminshall 
2866000Sroot 	default:
2876000Sroot 		fmt = dont;
2886000Sroot 	}
28932554Sminshall 	printring(&netoring, fmt, option);
29027676Sminshall 	if (reply)
29132377Sminshall 		printoption(">SENT", fmt, option, reply);
29227676Sminshall 	else
29332377Sminshall 		printoption("<SENT", fmt, option, reply);
2946000Sroot }
2956000Sroot 
29632377Sminshall static void
2976000Sroot dooption(option)
2986000Sroot 	int option;
2996000Sroot {
3006000Sroot 	char *fmt;
3016000Sroot 
3026000Sroot 	switch (option) {
3036000Sroot 
3046000Sroot 	case TELOPT_TM:
30513231Ssam 		fmt = will;
30613231Ssam 		break;
30713231Ssam 
30832377Sminshall #	if defined(TN3270)
30932377Sminshall 	case TELOPT_EOR:
31032377Sminshall 	case TELOPT_BINARY:
31132377Sminshall #	endif	/* defined(TN3270) */
31227676Sminshall 	case TELOPT_TTYPE:		/* terminal type option */
31327110Sminshall 	case TELOPT_SGA:		/* no big deal */
3146000Sroot 		fmt = will;
31527110Sminshall 		myopts[option] = 1;
3166000Sroot 		break;
3176000Sroot 
31827110Sminshall 	case TELOPT_ECHO:		/* We're never going to echo... */
3196000Sroot 	default:
3206000Sroot 		fmt = wont;
3216000Sroot 		break;
3226000Sroot 	}
32332554Sminshall 	printring(&netoring, fmt, option);
32432377Sminshall 	printoption(">SENT", fmt, option, 0);
3256000Sroot }
32627676Sminshall 
32727676Sminshall /*
32827676Sminshall  * suboption()
32927676Sminshall  *
33027676Sminshall  *	Look at the sub-option buffer, and try to be helpful to the other
33127676Sminshall  * side.
33227676Sminshall  *
33327676Sminshall  *	Currently we recognize:
33427676Sminshall  *
33527676Sminshall  *		Terminal type, send request.
33627676Sminshall  */
33727676Sminshall 
33832377Sminshall static void
33927676Sminshall suboption()
34027676Sminshall {
34132377Sminshall     printsub("<", subbuffer, subend-subbuffer+1);
34227676Sminshall     switch (subbuffer[0]&0xff) {
34327676Sminshall     case TELOPT_TTYPE:
34427676Sminshall 	if ((subbuffer[1]&0xff) != TELQUAL_SEND) {
34527676Sminshall 	    ;
34627676Sminshall 	} else {
34727676Sminshall 	    char *name;
34827676Sminshall 	    char namebuf[41];
34932377Sminshall 	    extern char *getenv();
35027676Sminshall 	    int len;
35127676Sminshall 
35232377Sminshall #if	defined(TN3270)
35332531Sminshall 	    if (tn3270_ttype()) {
35432377Sminshall 		return;
35532377Sminshall 	    }
35632377Sminshall #endif	/* defined(TN3270) */
35727676Sminshall 	    name = getenv("TERM");
35827676Sminshall 	    if ((name == 0) || ((len = strlen(name)) > 40)) {
35927676Sminshall 		name = "UNKNOWN";
36033492Sminshall 		len = strlen(name);
36127676Sminshall 	    }
36227676Sminshall 	    if ((len + 4+2) < NETROOM()) {
36327676Sminshall 		strcpy(namebuf, name);
36427676Sminshall 		upcase(namebuf);
36532554Sminshall 		printring(&netoring, "%c%c%c%c%s%c%c", IAC, SB, TELOPT_TTYPE,
36627676Sminshall 				    TELQUAL_IS, namebuf, IAC, SE);
36732381Sminshall 		/* XXX */
36832381Sminshall 		/* printsub(">", nfrontp+2, 4+strlen(namebuf)+2-2-2); */
36932377Sminshall 	    } else {
37032381Sminshall 		ExitString("No room in buffer for terminal type.\n",
37132377Sminshall 							1);
37232377Sminshall 		/*NOTREACHED*/
37327676Sminshall 	    }
37427676Sminshall 	}
37527676Sminshall 
37627676Sminshall     default:
37727676Sminshall 	break;
37827676Sminshall     }
37927676Sminshall }
38032377Sminshall 
38127088Sminshall 
38233804Sminshall int
38332377Sminshall telrcv()
38427110Sminshall {
38532377Sminshall     register int c;
38632385Sminshall     register int scc;
38732385Sminshall     register char *sbp;
38832385Sminshall     int count;
38932385Sminshall     int returnValue = 0;
39027088Sminshall 
39132385Sminshall     scc = 0;
39232385Sminshall     count = 0;
39332385Sminshall     while (TTYROOM() > 2) {
39432385Sminshall 	if (scc == 0) {
39532385Sminshall 	    if (count) {
39632528Sminshall 		ring_consumed(&netiring, count);
39732385Sminshall 		returnValue = 1;
39832385Sminshall 		count = 0;
39932385Sminshall 	    }
40032528Sminshall 	    sbp = netiring.consume;
40132528Sminshall 	    scc = ring_full_consecutive(&netiring);
40232385Sminshall 	    if (scc == 0) {
40332385Sminshall 		/* No more data coming in */
40432385Sminshall 		break;
40532385Sminshall 	    }
40632385Sminshall 	}
40732385Sminshall 
40832385Sminshall 	c = *sbp++ & 0xff, scc--; count++;
40932385Sminshall 
41032377Sminshall 	switch (telrcv_state) {
41127110Sminshall 
41232377Sminshall 	case TS_CR:
41332377Sminshall 	    telrcv_state = TS_DATA;
41435518Sminshall 	    if (c == '\0') {
41535518Sminshall 		break;	/* Ignore \0 after CR */
41635518Sminshall 	    } else if ((c == '\n') && (!hisopts[TELOPT_ECHO]) && !crmod) {
41735518Sminshall 		TTYADD(c);
41835518Sminshall 		break;
41932377Sminshall 	    }
42035518Sminshall 	    /* Else, fall through */
42127088Sminshall 
42232377Sminshall 	case TS_DATA:
42332377Sminshall 	    if (c == IAC) {
42432377Sminshall 		telrcv_state = TS_IAC;
42533804Sminshall 		break;
42632377Sminshall 	    }
42732377Sminshall #	    if defined(TN3270)
42832377Sminshall 	    if (In3270) {
42932377Sminshall 		*Ifrontp++ = c;
43032385Sminshall 		while (scc > 0) {
43132385Sminshall 		    c = *sbp++ & 0377, scc--; count++;
43232377Sminshall 		    if (c == IAC) {
43332377Sminshall 			telrcv_state = TS_IAC;
43434304Sminshall 			break;
43532377Sminshall 		    }
43632377Sminshall 		    *Ifrontp++ = c;
43732377Sminshall 		}
43832377Sminshall 	    } else
43932377Sminshall #	    endif /* defined(TN3270) */
44035518Sminshall 		    /*
44135518Sminshall 		     * The 'crmod' hack (see following) is needed
44235518Sminshall 		     * since we can't * set CRMOD on output only.
44335518Sminshall 		     * Machines like MULTICS like to send \r without
44435518Sminshall 		     * \n; since we must turn off CRMOD to get proper
44535518Sminshall 		     * input, the mapping is done here (sigh).
44635518Sminshall 		     */
44732377Sminshall 	    if ((c == '\r') && !hisopts[TELOPT_BINARY]) {
44835518Sminshall 		if (scc > 0) {
44935518Sminshall 		    c = *sbp&0xff;
45035518Sminshall 		    if (c == 0) {
45135518Sminshall 			sbp++, scc--; count++;
45235518Sminshall 			/* a "true" CR */
45332377Sminshall 			TTYADD('\r');
45435518Sminshall 		    } else if (!hisopts[TELOPT_ECHO] &&
45535518Sminshall 					(c == '\n')) {
45635518Sminshall 			sbp++, scc--; count++;
45732377Sminshall 			TTYADD('\n');
45835518Sminshall 		    } else {
45935518Sminshall 			TTYADD('\r');
46035518Sminshall 			if (crmod) {
46135518Sminshall 				TTYADD('\n');
46232377Sminshall 			}
46332377Sminshall 		    }
46435518Sminshall 		} else {
46535518Sminshall 		    telrcv_state = TS_CR;
46635518Sminshall 		    TTYADD('\r');
46735518Sminshall 		    if (crmod) {
46835518Sminshall 			    TTYADD('\n');
46935518Sminshall 		    }
47032377Sminshall 		}
47132377Sminshall 	    } else {
47232377Sminshall 		TTYADD(c);
47332377Sminshall 	    }
47432377Sminshall 	    continue;
47527088Sminshall 
47632377Sminshall 	case TS_IAC:
47732377Sminshall 	    switch (c) {
47832377Sminshall 
47932377Sminshall 	    case WILL:
48032377Sminshall 		telrcv_state = TS_WILL;
48132377Sminshall 		continue;
48227261Sminshall 
48332377Sminshall 	    case WONT:
48432377Sminshall 		telrcv_state = TS_WONT;
48532377Sminshall 		continue;
48627261Sminshall 
48732377Sminshall 	    case DO:
48832377Sminshall 		telrcv_state = TS_DO;
48932377Sminshall 		continue;
49027261Sminshall 
49132377Sminshall 	    case DONT:
49232377Sminshall 		telrcv_state = TS_DONT;
49332377Sminshall 		continue;
49427261Sminshall 
49532377Sminshall 	    case DM:
49632377Sminshall 		    /*
49732377Sminshall 		     * We may have missed an urgent notification,
49832377Sminshall 		     * so make sure we flush whatever is in the
49932377Sminshall 		     * buffer currently.
50032377Sminshall 		     */
50132377Sminshall 		SYNCHing = 1;
50232377Sminshall 		ttyflush(1);
50332554Sminshall 		SYNCHing = stilloob();
50432377Sminshall 		settimer(gotDM);
50532377Sminshall 		break;
50627088Sminshall 
50732377Sminshall 	    case NOP:
50832377Sminshall 	    case GA:
50932377Sminshall 		break;
51027088Sminshall 
51132377Sminshall 	    case SB:
51232377Sminshall 		SB_CLEAR();
51332377Sminshall 		telrcv_state = TS_SB;
51432377Sminshall 		continue;
51527261Sminshall 
51632377Sminshall #	    if defined(TN3270)
51732377Sminshall 	    case EOR:
51832377Sminshall 		if (In3270) {
51932377Sminshall 		    Ibackp += DataFromNetwork(Ibackp, Ifrontp-Ibackp, 1);
52032377Sminshall 		    if (Ibackp == Ifrontp) {
52132377Sminshall 			Ibackp = Ifrontp = Ibuf;
52232377Sminshall 			ISend = 0;	/* should have been! */
52332377Sminshall 		    } else {
52432377Sminshall 			ISend = 1;
52527088Sminshall 		    }
52627088Sminshall 		}
52727088Sminshall 		break;
52832377Sminshall #	    endif /* defined(TN3270) */
52932377Sminshall 
53032377Sminshall 	    case IAC:
53132377Sminshall #	    if !defined(TN3270)
53232377Sminshall 		TTYADD(IAC);
53332377Sminshall #	    else /* !defined(TN3270) */
53432377Sminshall 		if (In3270) {
53532377Sminshall 		    *Ifrontp++ = IAC;
53632377Sminshall 		} else {
53732377Sminshall 		    TTYADD(IAC);
53832377Sminshall 		}
53932377Sminshall #	    endif /* !defined(TN3270) */
54027088Sminshall 		break;
54132377Sminshall 
54227088Sminshall 	    default:
54327088Sminshall 		break;
54427088Sminshall 	    }
54532377Sminshall 	    telrcv_state = TS_DATA;
54632377Sminshall 	    continue;
54727088Sminshall 
54832377Sminshall 	case TS_WILL:
54932377Sminshall 	    printoption(">RCVD", will, c, !hisopts[c]);
55032377Sminshall 	    if (c == TELOPT_TM) {
55132377Sminshall 		if (flushout) {
55232377Sminshall 		    flushout = 0;
55332377Sminshall 		}
55432377Sminshall 	    } else if (!hisopts[c]) {
55532377Sminshall 		willoption(c, 1);
55632377Sminshall 	    }
55732377Sminshall 	    SetIn3270();
55832377Sminshall 	    telrcv_state = TS_DATA;
55932377Sminshall 	    continue;
56027110Sminshall 
56132377Sminshall 	case TS_WONT:
56232377Sminshall 	    printoption(">RCVD", wont, c, hisopts[c]);
56332377Sminshall 	    if (c == TELOPT_TM) {
56432377Sminshall 		if (flushout) {
56532377Sminshall 		    flushout = 0;
56632377Sminshall 		}
56732377Sminshall 	    } else if (hisopts[c]) {
56832377Sminshall 		wontoption(c, 1);
56932377Sminshall 	    }
57032377Sminshall 	    SetIn3270();
57132377Sminshall 	    telrcv_state = TS_DATA;
57232377Sminshall 	    continue;
57327088Sminshall 
57432377Sminshall 	case TS_DO:
57532377Sminshall 	    printoption(">RCVD", doopt, c, !myopts[c]);
57632377Sminshall 	    if (!myopts[c])
57732377Sminshall 		dooption(c);
57832377Sminshall 	    SetIn3270();
57932377Sminshall 	    telrcv_state = TS_DATA;
58032377Sminshall 	    continue;
58127088Sminshall 
58232377Sminshall 	case TS_DONT:
58332377Sminshall 	    printoption(">RCVD", dont, c, myopts[c]);
58432377Sminshall 	    if (myopts[c]) {
58532377Sminshall 		myopts[c] = 0;
58632554Sminshall 		printring(&netoring, wont, c);
58732377Sminshall 		flushline = 1;
58832377Sminshall 		setconnmode();	/* set new tty mode (maybe) */
58932377Sminshall 		printoption(">SENT", wont, c, 0);
59032377Sminshall 	    }
59132377Sminshall 	    SetIn3270();
59232377Sminshall 	    telrcv_state = TS_DATA;
59332377Sminshall 	    continue;
59427088Sminshall 
59532377Sminshall 	case TS_SB:
59632377Sminshall 	    if (c == IAC) {
59732377Sminshall 		telrcv_state = TS_SE;
59832377Sminshall 	    } else {
59932377Sminshall 		SB_ACCUM(c);
60032377Sminshall 	    }
60132377Sminshall 	    continue;
60227088Sminshall 
60332377Sminshall 	case TS_SE:
60432377Sminshall 	    if (c != SE) {
60532377Sminshall 		if (c != IAC) {
60632377Sminshall 		    SB_ACCUM(IAC);
60732377Sminshall 		}
60832377Sminshall 		SB_ACCUM(c);
60932377Sminshall 		telrcv_state = TS_SB;
61032377Sminshall 	    } else {
61132377Sminshall 		SB_TERM();
61232377Sminshall 		suboption();	/* handle sub-option */
61332377Sminshall 		SetIn3270();
61432377Sminshall 		telrcv_state = TS_DATA;
61532377Sminshall 	    }
61627088Sminshall 	}
61727088Sminshall     }
61832667Sminshall     if (count)
61932667Sminshall 	ring_consumed(&netiring, count);
62032385Sminshall     return returnValue||count;
62127088Sminshall }
62232385Sminshall 
62332385Sminshall static int
62432554Sminshall telsnd()
62532385Sminshall {
62632385Sminshall     int tcc;
62732385Sminshall     int count;
62832385Sminshall     int returnValue = 0;
62932385Sminshall     char *tbp;
63032385Sminshall 
63132385Sminshall     tcc = 0;
63232385Sminshall     count = 0;
63332385Sminshall     while (NETROOM() > 2) {
63432385Sminshall 	register int sc;
63532385Sminshall 	register int c;
63632385Sminshall 
63732385Sminshall 	if (tcc == 0) {
63832385Sminshall 	    if (count) {
63932528Sminshall 		ring_consumed(&ttyiring, count);
64032385Sminshall 		returnValue = 1;
64132385Sminshall 		count = 0;
64232385Sminshall 	    }
64332528Sminshall 	    tbp = ttyiring.consume;
64432528Sminshall 	    tcc = ring_full_consecutive(&ttyiring);
64532385Sminshall 	    if (tcc == 0) {
64632385Sminshall 		break;
64732385Sminshall 	    }
64832385Sminshall 	}
64932385Sminshall 	c = *tbp++ & 0xff, sc = strip(c), tcc--; count++;
65032385Sminshall 	if (sc == escape) {
65132385Sminshall 	    command(0);
65232385Sminshall 	    tcc = 0;
65332385Sminshall 	    flushline = 1;
65432385Sminshall 	    break;
65532385Sminshall 	} else if (MODE_LINE(globalmode) && (sc == echoc)) {
65632385Sminshall 	    if (tcc > 0 && strip(*tbp) == echoc) {
65732385Sminshall 		tcc--; tbp++; count++;
65832385Sminshall 	    } else {
65932385Sminshall 		dontlecho = !dontlecho;
66032385Sminshall 		settimer(echotoggle);
66132385Sminshall 		setconnmode();
66232385Sminshall 		flushline = 1;
66332385Sminshall 		break;
66432385Sminshall 	    }
66532385Sminshall 	}
66632385Sminshall 	if (localchars) {
66732385Sminshall 	    if (TerminalSpecialChars(sc) == 0) {
66832385Sminshall 		break;
66932385Sminshall 	    }
67032385Sminshall 	}
67132385Sminshall 	if (!myopts[TELOPT_BINARY]) {
67232385Sminshall 	    switch (c) {
67332385Sminshall 	    case '\n':
67432385Sminshall 		    /*
67532385Sminshall 		     * If we are in CRMOD mode (\r ==> \n)
67632385Sminshall 		     * on our local machine, then probably
67732385Sminshall 		     * a newline (unix) is CRLF (TELNET).
67832385Sminshall 		     */
67932385Sminshall 		if (MODE_LOCAL_CHARS(globalmode)) {
68032385Sminshall 		    NETADD('\r');
68132385Sminshall 		}
68232385Sminshall 		NETADD('\n');
68332385Sminshall 		flushline = 1;
68432385Sminshall 		break;
68532385Sminshall 	    case '\r':
68632385Sminshall 		if (!crlf) {
68732385Sminshall 		    NET2ADD('\r', '\0');
68832385Sminshall 		} else {
68932385Sminshall 		    NET2ADD('\r', '\n');
69032385Sminshall 		}
69132385Sminshall 		flushline = 1;
69232385Sminshall 		break;
69332385Sminshall 	    case IAC:
69432385Sminshall 		NET2ADD(IAC, IAC);
69532385Sminshall 		break;
69632385Sminshall 	    default:
69732385Sminshall 		NETADD(c);
69832385Sminshall 		break;
69932385Sminshall 	    }
70032385Sminshall 	} else if (c == IAC) {
70132385Sminshall 	    NET2ADD(IAC, IAC);
70232385Sminshall 	} else {
70332385Sminshall 	    NETADD(c);
70432385Sminshall 	}
70532385Sminshall     }
70632667Sminshall     if (count)
70732667Sminshall 	ring_consumed(&ttyiring, count);
70832385Sminshall     return returnValue||count;		/* Non-zero if we did anything */
70932385Sminshall }
71032377Sminshall 
71127088Sminshall /*
71232377Sminshall  * Scheduler()
71332377Sminshall  *
71432377Sminshall  * Try to do something.
71532377Sminshall  *
71632377Sminshall  * If we do something useful, return 1; else return 0.
71732377Sminshall  *
71827110Sminshall  */
71927110Sminshall 
72027110Sminshall 
72132377Sminshall int
72232377Sminshall Scheduler(block)
72332377Sminshall int	block;			/* should we block in the select ? */
72427110Sminshall {
72532377Sminshall 		/* One wants to be a bit careful about setting returnValue
72632377Sminshall 		 * to one, since a one implies we did some useful work,
72732377Sminshall 		 * and therefore probably won't be called to block next
72832377Sminshall 		 * time (TN3270 mode only).
72932377Sminshall 		 */
73032531Sminshall     int returnValue;
73132531Sminshall     int netin, netout, netex, ttyin, ttyout;
73227110Sminshall 
73332531Sminshall     /* Decide which rings should be processed */
73432531Sminshall 
73532531Sminshall     netout = ring_full_count(&netoring) &&
73632531Sminshall 	    (!MODE_LINE(globalmode) || flushline || myopts[TELOPT_BINARY]);
73732531Sminshall     ttyout = ring_full_count(&ttyoring);
73832531Sminshall 
73932377Sminshall #if	defined(TN3270)
74032531Sminshall     ttyin = ring_empty_count(&ttyiring) && (shell_active == 0);
74132377Sminshall #else	/* defined(TN3270) */
74232531Sminshall     ttyin = ring_empty_count(&ttyiring);
74332377Sminshall #endif	/* defined(TN3270) */
74432531Sminshall 
74532531Sminshall #if	defined(TN3270)
74632531Sminshall     netin = ring_empty_count(&netiring);
74732377Sminshall #   else /* !defined(TN3270) */
74832531Sminshall     netin = !ISend && ring_empty_count(&netiring);
74932377Sminshall #   endif /* !defined(TN3270) */
75032531Sminshall 
75132531Sminshall     netex = !SYNCHing;
75232531Sminshall 
75332531Sminshall     /* If we have seen a signal recently, reset things */
75432377Sminshall #   if defined(TN3270) && defined(unix)
75532377Sminshall     if (HaveInput) {
75632377Sminshall 	HaveInput = 0;
75732377Sminshall 	signal(SIGIO, inputAvailable);
75832377Sminshall     }
75932377Sminshall #endif	/* defined(TN3270) && defined(unix) */
76032377Sminshall 
76132531Sminshall     /* Call to system code to process rings */
76227178Sminshall 
76332531Sminshall     returnValue = process_rings(netin, netout, netex, ttyin, ttyout, !block);
76427178Sminshall 
76532531Sminshall     /* Now, look at the input rings, looking for work to do. */
76632377Sminshall 
76732531Sminshall     if (ring_full_count(&ttyiring)) {
76832377Sminshall #   if defined(TN3270)
76932377Sminshall 	if (In3270) {
77034848Sminshall 	    int c;
77134848Sminshall 
77233804Sminshall 	    c = DataFromTerminal(ttyiring.consume,
77332528Sminshall 					ring_full_consecutive(&ttyiring));
77432377Sminshall 	    if (c) {
77532377Sminshall 		returnValue = 1;
77632667Sminshall 	        ring_consumed(&ttyiring, c);
77732377Sminshall 	    }
77832377Sminshall 	} else {
77932377Sminshall #   endif /* defined(TN3270) */
78032554Sminshall 	    returnValue |= telsnd();
78132377Sminshall #   if defined(TN3270)
78227178Sminshall 	}
78332531Sminshall #   endif /* defined(TN3270) */
78427178Sminshall     }
78532377Sminshall 
78632528Sminshall     if (ring_full_count(&netiring)) {
78732377Sminshall #	if !defined(TN3270)
78832385Sminshall 	returnValue |= telrcv();
78932377Sminshall #	else /* !defined(TN3270) */
79032377Sminshall 	returnValue = Push3270();
79132377Sminshall #	endif /* !defined(TN3270) */
79232377Sminshall     }
79332377Sminshall     return returnValue;
79427178Sminshall }
79527178Sminshall 
79627178Sminshall /*
79732377Sminshall  * Select from tty and network...
79827088Sminshall  */
79932377Sminshall void
80032377Sminshall telnet()
80127088Sminshall {
80232531Sminshall     sys_telnet_init();
80327088Sminshall 
80432377Sminshall #   if !defined(TN3270)
80532377Sminshall     if (telnetport) {
80632377Sminshall 	if (!hisopts[TELOPT_SGA]) {
80732377Sminshall 	    willoption(TELOPT_SGA, 0);
80827110Sminshall 	}
80932377Sminshall 	if (!myopts[TELOPT_TTYPE]) {
81034848Sminshall 	    dooption(TELOPT_TTYPE);
81132377Sminshall 	}
81227178Sminshall     }
81332377Sminshall #   endif /* !defined(TN3270) */
81427088Sminshall 
81532377Sminshall #   if !defined(TN3270)
81632377Sminshall     for (;;) {
81732385Sminshall 	int schedValue;
81832385Sminshall 
81932385Sminshall 	while ((schedValue = Scheduler(0)) != 0) {
82032385Sminshall 	    if (schedValue == -1) {
82132385Sminshall 		setcommandmode();
82232385Sminshall 		return;
82332385Sminshall 	    }
82432385Sminshall 	}
82532385Sminshall 
82632531Sminshall 	if (Scheduler(1) == -1) {
82732377Sminshall 	    setcommandmode();
82832377Sminshall 	    return;
82932377Sminshall 	}
83032377Sminshall     }
83132377Sminshall #   else /* !defined(TN3270) */
83232377Sminshall     for (;;) {
83332377Sminshall 	int schedValue;
83427088Sminshall 
83532377Sminshall 	while (!In3270 && !shell_active) {
83632531Sminshall 	    if (Scheduler(1) == -1) {
83732377Sminshall 		setcommandmode();
83832377Sminshall 		return;
83932377Sminshall 	    }
84027088Sminshall 	}
84132377Sminshall 
84232377Sminshall 	while ((schedValue = Scheduler(0)) != 0) {
84332377Sminshall 	    if (schedValue == -1) {
84432377Sminshall 		setcommandmode();
84532377Sminshall 		return;
84632377Sminshall 	    }
84727088Sminshall 	}
84832377Sminshall 		/* If there is data waiting to go out to terminal, don't
84932377Sminshall 		 * schedule any more data for the terminal.
85032377Sminshall 		 */
85134304Sminshall 	if (ring_full_count(&ttyoring)) {
85232377Sminshall 	    schedValue = 1;
85327088Sminshall 	} else {
85432377Sminshall 	    if (shell_active) {
85532377Sminshall 		if (shell_continue() == 0) {
85632377Sminshall 		    ConnectScreen();
85727088Sminshall 		}
85832377Sminshall 	    } else if (In3270) {
85932377Sminshall 		schedValue = DoTerminalOutput();
86032377Sminshall 	    }
86127088Sminshall 	}
86232377Sminshall 	if (schedValue && (shell_active == 0)) {
86332531Sminshall 	    if (Scheduler(1) == -1) {
86432377Sminshall 		setcommandmode();
86532377Sminshall 		return;
86632377Sminshall 	    }
86727088Sminshall 	}
86832377Sminshall     }
86932377Sminshall #   endif /* !defined(TN3270) */
87027088Sminshall }
87132377Sminshall 
87234848Sminshall #if	0	/* XXX - this not being in is a bug */
87327088Sminshall /*
87432554Sminshall  * nextitem()
87532554Sminshall  *
87632554Sminshall  *	Return the address of the next "item" in the TELNET data
87732554Sminshall  * stream.  This will be the address of the next character if
87832554Sminshall  * the current address is a user data character, or it will
87932554Sminshall  * be the address of the character following the TELNET command
88032554Sminshall  * if the current address is a TELNET IAC ("I Am a Command")
88132554Sminshall  * character.
88232554Sminshall  */
88332554Sminshall 
88432554Sminshall static char *
88532554Sminshall nextitem(current)
88632554Sminshall char	*current;
88732554Sminshall {
88832554Sminshall     if ((*current&0xff) != IAC) {
88932554Sminshall 	return current+1;
89032554Sminshall     }
89132554Sminshall     switch (*(current+1)&0xff) {
89232554Sminshall     case DO:
89332554Sminshall     case DONT:
89432554Sminshall     case WILL:
89532554Sminshall     case WONT:
89632554Sminshall 	return current+3;
89732554Sminshall     case SB:		/* loop forever looking for the SE */
89832554Sminshall 	{
89932554Sminshall 	    register char *look = current+2;
90032554Sminshall 
90132554Sminshall 	    for (;;) {
90232554Sminshall 		if ((*look++&0xff) == IAC) {
90332554Sminshall 		    if ((*look++&0xff) == SE) {
90432554Sminshall 			return look;
90532554Sminshall 		    }
90632554Sminshall 		}
90732554Sminshall 	    }
90832554Sminshall 	}
90932554Sminshall     default:
91032554Sminshall 	return current+2;
91132554Sminshall     }
91232554Sminshall }
91334848Sminshall #endif	/* 0 */
91432554Sminshall 
91532554Sminshall /*
91632554Sminshall  * netclear()
91732554Sminshall  *
91832554Sminshall  *	We are about to do a TELNET SYNCH operation.  Clear
91932554Sminshall  * the path to the network.
92032554Sminshall  *
92132554Sminshall  *	Things are a bit tricky since we may have sent the first
92232554Sminshall  * byte or so of a previous TELNET command into the network.
92332554Sminshall  * So, we have to scan the network buffer from the beginning
92432554Sminshall  * until we are up to where we want to be.
92532554Sminshall  *
92632554Sminshall  *	A side effect of what we do, just to keep things
92732554Sminshall  * simple, is to clear the urgent data pointer.  The principal
92832554Sminshall  * caller should be setting the urgent data pointer AFTER calling
92932554Sminshall  * us in any case.
93032554Sminshall  */
93132554Sminshall 
93232554Sminshall static void
93332554Sminshall netclear()
93432554Sminshall {
93532554Sminshall #if	0	/* XXX */
93632554Sminshall     register char *thisitem, *next;
93732554Sminshall     char *good;
93832554Sminshall #define	wewant(p)	((nfrontp > p) && ((*p&0xff) == IAC) && \
93932554Sminshall 				((*(p+1)&0xff) != EC) && ((*(p+1)&0xff) != EL))
94032554Sminshall 
94132554Sminshall     thisitem = netobuf;
94232554Sminshall 
94332554Sminshall     while ((next = nextitem(thisitem)) <= netobuf.send) {
94432554Sminshall 	thisitem = next;
94532554Sminshall     }
94632554Sminshall 
94732554Sminshall     /* Now, thisitem is first before/at boundary. */
94832554Sminshall 
94932554Sminshall     good = netobuf;	/* where the good bytes go */
95032554Sminshall 
95132554Sminshall     while (netoring.add > thisitem) {
95232554Sminshall 	if (wewant(thisitem)) {
95332554Sminshall 	    int length;
95432554Sminshall 
95532554Sminshall 	    next = thisitem;
95632554Sminshall 	    do {
95732554Sminshall 		next = nextitem(next);
95832554Sminshall 	    } while (wewant(next) && (nfrontp > next));
95932554Sminshall 	    length = next-thisitem;
96032554Sminshall 	    memcpy(good, thisitem, length);
96132554Sminshall 	    good += length;
96232554Sminshall 	    thisitem = next;
96332554Sminshall 	} else {
96432554Sminshall 	    thisitem = nextitem(thisitem);
96532554Sminshall 	}
96632554Sminshall     }
96732554Sminshall 
96832554Sminshall #endif	/* 0 */
96932554Sminshall }
97032554Sminshall 
97132554Sminshall /*
97232377Sminshall  * These routines add various telnet commands to the data stream.
97327088Sminshall  */
97432377Sminshall 
97532554Sminshall static void
97632554Sminshall doflush()
97732554Sminshall {
97832554Sminshall     NET2ADD(IAC, DO);
97932554Sminshall     NETADD(TELOPT_TM);
98032554Sminshall     flushline = 1;
98132554Sminshall     flushout = 1;
98232554Sminshall     ttyflush(1);			/* Flush/drop output */
98332554Sminshall     /* do printoption AFTER flush, otherwise the output gets tossed... */
98432554Sminshall     printoption("<SENT", doopt, TELOPT_TM, 0);
98532554Sminshall }
98632554Sminshall 
98732377Sminshall void
98832377Sminshall xmitAO()
98927088Sminshall {
99032377Sminshall     NET2ADD(IAC, AO);
99132377Sminshall     if (autoflush) {
99232377Sminshall 	doflush();
99332377Sminshall     }
99432377Sminshall }
99527088Sminshall 
99632377Sminshall 
99732377Sminshall void
99832377Sminshall xmitEL()
99927088Sminshall {
100032377Sminshall     NET2ADD(IAC, EL);
100127088Sminshall }
100227088Sminshall 
100332377Sminshall void
100432377Sminshall xmitEC()
100527088Sminshall {
100632377Sminshall     NET2ADD(IAC, EC);
100727088Sminshall }
100827088Sminshall 
100932377Sminshall 
101032377Sminshall #if	defined(NOT43)
101132377Sminshall int
101232377Sminshall #else	/* defined(NOT43) */
101332377Sminshall void
101432377Sminshall #endif	/* defined(NOT43) */
101532377Sminshall dosynch()
101627088Sminshall {
101732377Sminshall     netclear();			/* clear the path to the network */
101833294Sminshall     NETADD(IAC);
101933294Sminshall     setneturg();
102033294Sminshall     NETADD(DM);
102127088Sminshall 
102232377Sminshall #if	defined(NOT43)
102332377Sminshall     return 0;
102432377Sminshall #endif	/* defined(NOT43) */
102527088Sminshall }
102627088Sminshall 
102732377Sminshall void
102832377Sminshall intp()
102927088Sminshall {
103032377Sminshall     NET2ADD(IAC, IP);
103132377Sminshall     flushline = 1;
103232377Sminshall     if (autoflush) {
103332377Sminshall 	doflush();
103432377Sminshall     }
103532377Sminshall     if (autosynch) {
103632377Sminshall 	dosynch();
103732377Sminshall     }
103827088Sminshall }
103927186Sminshall 
104032377Sminshall void
104132377Sminshall sendbrk()
104227186Sminshall {
104332377Sminshall     NET2ADD(IAC, BREAK);
104432377Sminshall     flushline = 1;
104532377Sminshall     if (autoflush) {
104632377Sminshall 	doflush();
104732377Sminshall     }
104832377Sminshall     if (autosynch) {
104932377Sminshall 	dosynch();
105032377Sminshall     }
105127186Sminshall }
1052