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