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