开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 通讯/手机编程 > 查看源码
ckucns.c
资源名称：cku197.tar.Z　[点击查看]
上传用户：dufan58
上传日期：2007-01-05
资源大小：3407k
文件大小：66k
源码类别：

通讯/手机编程

开发平台：

Windows_Unix

ckucns.c：源码内容
  1. #include "ckcsym.h"
  2. #ifdef NOLOCAL
  3. char *connv = "";
  4. #else
  5. char *connv = "CONNECT Command for UNIX:select(), 7.0.110, 30 Dec 1999";
  7. /*  C K U C N S  --  Terminal connection to remote system, for UNIX  */
  8. /*
  9.   Author: Frank da Cruz <fdc@columbia.edu>,
  10.   Columbia University Academic Information Systems, New York City.
  12.   Copyright (C) 1985, 2000,
  13.     Trustees of Columbia University in the City of New York.
  14.     All rights reserved.  See the C-Kermit COPYING.TXT file or the
  15.     copyright text in the ckcmai.c module for disclaimer and permissions.
  16. */
  18. /*
  19.   This version of the UNIX CONNECT module uses select(), which is required for
  20.   Kerberos encryption.  Thus it can be used only on UNIX systems that support
  21.   select() on both TCP/IP and serial connections.  A separate module that uses
  22.   a completely portable fork() structure can be used on systems where select()
  23.   is not available or does not work as required.
  24. */
  26. #include "ckcdeb.h" /* Common things first */
  28. #ifdef OSF13
  29. #ifdef CK_ANSIC
  30. #ifdef _NO_PROTO
  31. #undef _NO_PROTO
  32. #endif /* _NO_PROTO */
  33. #endif /* CK_ANSIC */
  34. #endif /* OSF13 */
  36. #include <errno.h> /* Error numbers */
  37. #ifdef __linux__
  38. #include <sys/time.h> /* For FD_blah */
  39. #endif /* __linux__ */
  41. /* Kermit-specific includes */
  43. #include "ckcasc.h" /* ASCII characters */
  44. #include "ckcker.h" /* Kermit things */
  45. #include "ckucmd.h" /* For xxesc() prototype */
  46. #include "ckcnet.h" /* Network symbols */
  47. #ifndef NOCSETS
  48. #include "ckcxla.h" /* Character set translation */
  49. #endif /* NOCSETS */
  51. #ifdef BEBOX
  52. #include <kernel/OS.h>
  53. #include <socket.h>
  54. #include <stdio.h>
  55. #endif /* BEBOX */
  57. #include <signal.h>
  59. #ifndef SCO_OSR504
  60. #ifdef SELECT_H
  61. #include <sys/select.h>
  62. #endif /* SELECT_H */
  63. #endif /* SCO_OSR504 */
  65. /* Internal function prototypes */
  67. _PROTOTYP( VOID ttflux, (void) );
  68. _PROTOTYP( VOID doesc, (char) );
  69. _PROTOTYP( int hconne, (void) );
  70. #ifndef NOSHOW
  71. _PROTOTYP( VOID shomdm, (void) );
  72. #endif /* NOSHOW */
  73. _PROTOTYP( static int kbget, (void) );
  74. _PROTOTYP( static int ckcputf, (void) );
  76. /* External variables */
  78. extern struct ck_p ptab[];
  80. extern int local, escape, duplex, parity, flow, seslog, sessft, debses,
  81.  mdmtyp, ttnproto, cmask, cmdmsk, network, nettype, sosi, tnlm,
  82.  xitsta, what, ttyfd, ttpipe, quiet, backgrd, pflag, tt_crd, tn_nlm, ttfdflg,
  83.  tt_escape, justone, carrier, ttpty;
  85. extern long speed;
  86. extern char ttname[], sesfil[], myhost[], *ccntab[];
  87. #ifdef TNCODE
  88. extern int tn_b_nlm, tn_rem_echo;
  89. #endif /* TNCODE */
  91. #ifdef CK_TRIGGER
  92. extern char * tt_trigger[], * triggerval;
  93. #endif /* CK_TRIGGER */
  95. extern int nopush;
  97. #ifdef CK_APC
  98. extern int apcactive; /* Application Program Command (APC) */
  99. extern int apcstatus; /* items ... */
  100. static int apclength = 0;
  101. #ifdef DCMDBUF
  102. extern char *apcbuf;
  103. #else
  104. extern char apcbuf[];
  105. #endif /* DCMDBUF */
  106. static int apcbuflen = APCBUFLEN - 2;
  107. extern int protocol;
  108. #endif /* CK_APC */
  109. #ifndef NOXFER
  110. extern int autodl; /* Auto download */
  111. #endif /* NOXFER */
  113. #ifdef CK_AUTODL
  114. extern CHAR ksbuf[];
  115. #endif /* CK_AUTODL */
  117. #ifdef CK_ENCRYPTION
  118. extern int me_auth;
  119. #endif /* CK_ENCRYPTION */
  121. #ifdef CK_XYZ
  122. #ifdef XYZ_INTERNAL
  123. static int zmdlok = 1; /* Zmodem autodownloads available */
  124. #else
  125. static int zmdlok = 0; /* Depends on external protocol def */
  126. #endif /* XYZ_INTERNAL */
  127. #else
  128. static int zmdlok = 0; /* Not available at all */
  129. #endif /* CK_XYZ */
  131. #ifndef NOSETKEY /* Keyboard mapping */
  132. extern KEY *keymap; /* Single-character key map */
  133. extern MACRO *macrotab; /* Key macro pointer table */
  134. static MACRO kmptr = NULL; /* Pointer to current key macro */
  135. #endif /* NOSETKEY */
  137. /* Global variables local to this module */
  139. static int
  140.   active = 0,
  141.   quitnow = 0, /* <esc-char>Q was typed */
  142.   dohangup = 0, /* <esc-char>H was typed */
  143.   inshift = 0, /* SO/SI shift states */
  144.   outshift = 0;
  146. static char ecbuf[10], *ecbp; /* Escape char buffer & pointer */
  148. #ifdef CK_SMALL
  149. #define IBUFL 1536 /* Input buffer length */
  150. #else
  151. #define IBUFL 4096
  152. #endif /* CK_SMALL */
  154. static int obc = 0; /* Output buffer count */
  156. #ifndef OXOS
  157. #define OBUFL 1024 /* Output buffer length */
  158. #else
  159. #define OBUFL IBUFL
  160. #endif /* OXOS */
  162. #ifdef BIGBUFOK
  163. #define TMPLEN 4096 /* Temporary message buffer length */
  164. #else
  165. #define TMPLEN 200
  166. #endif /* BIGBUFOK */
  168. #ifdef DYNAMIC
  169. static char *ibuf = NULL, *obuf = NULL, *temp = NULL; /* Buffers */
  170. #else
  171. static char ibuf[IBUFL], obuf[OBUFL], temp[TMPLEN];
  172. #endif /* DYNAMIC */
  174. #ifdef DYNAMIC
  175. static char *ibp; /* Input buffer pointer */
  176. #else
  177. static char *ibp = ibuf; /* Input buffer pointer */
  178. #endif /*DYNAMIC */
  179. static int ibc = 0; /* Input buffer count */
  181. #ifdef DYNAMIC
  182. static char *obp; /* Output buffer pointer */
  183. #else
  184. static char *obp = obuf; /* Output buffer pointer */
  185. #endif /* DYNAMIC */
  187. /* Character-set items */
  189. static int unicode = 0;
  191. #ifndef NOCSETS
  192. #ifdef CK_ANSIC /* ANSI C prototypes... */
  193. extern CHAR (*xls[MAXTCSETS+1][MAXFCSETS+1])(CHAR); /* Character set */
  194. extern CHAR (*xlr[MAXTCSETS+1][MAXFCSETS+1])(CHAR); /* translation functions */
  195. static CHAR (*sxo)(CHAR); /* Local translation functions */
  196. static CHAR (*rxo)(CHAR); /* for output (sending) terminal chars */
  197. static CHAR (*sxi)(CHAR); /* and for input (receiving) terminal chars. */
  198. static CHAR (*rxi)(CHAR);
  199. #else /* Not ANSI C... */
  200. extern CHAR (*xls[MAXTCSETS+1][MAXFCSETS+1])(); /* Character set */
  201. extern CHAR (*xlr[MAXTCSETS+1][MAXFCSETS+1])(); /* translation functions. */
  202. static CHAR (*sxo)(); /* Local translation functions */
  203. static CHAR (*rxo)(); /* for output (sending) terminal chars */
  204. static CHAR (*sxi)(); /* and for input (receiving) terminal chars. */
  205. static CHAR (*rxi)();
  206. #endif /* CK_ANSIC */
  207. extern int language; /* Current language. */
  208. static int langsv; /* For remembering language setting. */
  209. extern struct csinfo fcsinfo[]; /* File character set info. */
  210. extern int tcsr, tcsl; /* Terminal character sets, remote & local. */
  211. static int tcs; /* Intermediate ("transfer") character set. */
  212. static int tcssize = 0; /* Size of tcs */
  213. #ifdef UNICODE /* UTF-8 support */
  214. #ifdef CK_ANSIC
  215. extern int (*xl_ufc[MAXFCSETS+1])(USHORT);  /* Unicode to FCS */
  216. extern USHORT (*xl_fcu[MAXFCSETS+1])(CHAR); /* FCS to Unicode */
  217. extern int (*xuf)(USHORT); /* Translation function UCS to FCS */
  218. extern USHORT (*xfu)(CHAR); /* Translation function FCS to UCS */
  219. #else
  220. extern int (*xl_ufc[MAXFCSETS+1])();
  221. extern USHORT (*xl_fcu[MAXFCSETS+1])();
  222. extern int (*xuf)();
  223. extern USHORT (*xfu)();
  224. #endif /* CK_ANSIC */
  225. #endif /* UNICODE */
  226. #endif /* NOCSETS */
  228. static int printing = 0;
  230. /*
  231.   We do not need to parse and recognize escape sequences if we are being built
  232.   without character-set support AND without APC support.
  233. */
  234. #ifdef NOESCSEQ
  235. #ifdef XPRINT
  236. #undef XPRINT
  237. #endif /* XPRINT */
  239. #else  /* NOESCSEQ not defined from outside */
  241. #ifdef NOCSETS /* No character sets */
  242. #ifndef CK_APC /* No APC */
  243. #ifndef XPRINT /* No transparent printing */
  244. #define NOESCSEQ /* So no escape sequence recognizer */
  245. #endif /* XPRINT */
  246. #endif /* CK_APC */
  247. #endif /* NOCSETS */
  248. #endif /* NOESCSEQ */
  250. static int escseq = 0; /* 1 = Recognizer is active */
  251. static int inesc[2] = { 0, 0 }; /* State of sequence recognizer */
  252. static int oldesc[2] = { -1, -1 }; /* Previous state of recognizer */
  254. #ifdef NOESCSEQ
  255. #define chkaes(x,y) 0
  256. #else
  257. /*
  258.   As of edit 178, the CONNECT command skips past ANSI escape sequences to
  259.   avoid translating the characters within them.  This allows the CONNECT
  260.   command to work correctly with a host that uses a 7-bit ISO 646 national
  261.   character set, in which characters like '[' would normally be translated
  262.   into accented characters, ruining the terminal's interpretation (and
  263.   generation) of escape sequences.
  265.   As of edit 190, the CONNECT command responds to APC escape sequences
  266.   (ESC _ text ESC ) if the user SETs TERMINAL APC ON or UNCHECKED, and the
  267.   program was built with CK_APC defined.
  269.   Non-ANSI/ISO-compliant escape sequences are not handled.
  270. */
  272. /* States for the escape-sequence recognizer. */
  274. #define ES_NORMAL 0 /* Normal, not in an escape sequence */
  275. #define ES_GOTESC 1 /* Current character is ESC */
  276. #define ES_ESCSEQ 2 /* Inside an escape sequence */
  277. #define ES_GOTCSI 3 /* Inside a control sequence */
  278. #define ES_STRING 4 /* Inside DCS,OSC,PM, or APC string */
  279. #define ES_TERMIN 5 /* 1st char of string terminator */
  281. /*
  282.   ANSI escape sequence handling.  Only the 7-bit form is treated, because
  283.   translation is not a problem in the 8-bit environment, in which all GL
  284.   characters are ASCII and no translation takes place.  So we don't check
  285.   for the 8-bit single-character versions of CSI, DCS, OSC, APC, or ST.
  286.   Here is the ANSI sequence recognizer state table, followed by the code
  287.   that implements it.
  289.   Definitions:
  290.     CAN = Cancel                       01/08         Ctrl-X
  291.     SUB = Substitute                   01/10         Ctrl-Z
  292.     DCS = Device Control Sequence      01/11 05/00   ESC P
  293.     CSI = Control Sequence Introducer  01/11 05/11   ESC [
  294.     ST  = String Terminator            01/11 05/12   ESC 
  295.     OSC = Operating System Command     01/11 05/13   ESC ]
  296.     PM  = Privacy Message              01/11 05/14   ESC ^
  297.     APC = Application Program Command  01/11 05/15   ESC _
  299.   ANSI escape sequence recognizer:
  301.     State    Input  New State  ; Commentary
  303.     NORMAL   (start)           ; Start in NORMAL state
  305.     (any)    CAN    NORMAL     ; ^X cancels
  306.     (any)    SUB    NORMAL     ; ^Z cancels
  308.     NORMAL   ESC    GOTESC     ; Begin escape sequence
  309.     NORMAL   other             ; NORMAL control or graphic character
  311.     GOTESC   ESC               ; Start again
  312.     GOTESC   [      GOTCSI     ; CSI
  313.     GOTESC   P      STRING     ; DCS introducer, consume through ST
  314.     GOTESC   ]      STRING     ; OSC introducer, consume through ST
  315.     GOTESC   ^      STRING     ; PM  introducer, consume through ST
  316.     GOTESC   _      STRING     ; APC introducer, consume through ST
  317.     GOTESC   0..~   NORMAL     ; 03/00 through 17/14 = Final character
  318.     GOTESC   other  ESCSEQ     ; Intermediate or ignored control character
  320.     ESCSEQ   ESC    GOTESC     ; Start again
  321.     ESCSEQ   0..~   NORMAL     ; 03/00 through 17/14 = Final character
  322.     ESCSEQ   other             ; Intermediate or ignored control character
  324.     GOTCSI   ESC    GOTESC     ; Start again
  325.     GOTCSI   @..~   NORMAL     ; 04/00 through 17/14 = Final character
  326.     GOTCSI   other             ; Intermediate char or ignored control char
  328.     STRING   ESC    TERMIN     ; Maybe have ST
  329.     STRING   other             ; Consume all else
  331.     TERMIN         NORMAL     ; End of string
  332.     TERMIN   other  STRING     ; Still in string
  333. */
  335. #ifdef XPRINT /* Transparent print support */
  336. /*
  337.   We can't just print each byte as it comes in because then the printer-off
  338.   sequence would be sent to the printer.  Thus we have to buffer up escape
  339.   sequences and print them only when they are complete AND we know they are
  340.   not the printer-off sequence.  All printing is done via zsoutx(ZMFILE,s,n).
  341.   This allows for strings that contain NULs.  Don't mix calls to zsoutx() with
  342.   calls to zchout(), or the output will be scrambled.  Also note that when
  343.   printing a saved-up escape sequence, we never print its final character
  344.   because that will be printed in the mainline code, upon return from
  345.   chkaes().  Note that the printer-on sequence is passed to the screen; this
  346.   is unavoidable, since we don't know what it is until after we get to the
  347.   end, and for screen display purposes we can't buffer up escape sequences
  348.   for numerous reasons.  Therefore we also must output the printer-off
  349.   sequence, otherwise a real terminal or emulator will be stuck in print mode.
  350. */
  351. extern int tt_print;
  352. #define ESCBUFLEN 63
  353. static char escbuf[ESCBUFLEN+1] = { NUL, NUL };
  354. static int escbufc = 0;
  356. VOID
  357. printon() { /* Turn printing on */
  358.     int x, pp;
  359.     char * p;
  360.     extern int printpipe, noprinter;
  361.     extern char * printername;
  363.     if (noprinter) {
  364. debug(F110,"PRINTER ON NOPRINTER","",0);
  365. return;
  366.     }
  367.     p = printername;
  368.     pp = printpipe;
  369.     if (!p) p = "";
  370.     if (!*p) {
  371. #ifdef ANYBSD
  372. p = "lpr";
  373. #else
  374. p = "lp";
  375. #endif /* ANYBSD */
  376. pp = 1;
  377. debug(F110,"PRINTER DEFAULT",p,0);
  378.     }
  379.     debug(F111,"PRINTER ON",p,pp);
  380.     if (pp) { /* Printing to pipe */
  381. x = zxcmd(ZMFILE,p);
  382.     } else { /* Append to file */
  383. struct filinfo xx;
  384. xx.bs = 0; xx.cs = 0; xx.rl = 0; xx.org = 0; xx.cc = 0;
  385. xx.typ = 0; xx.dsp = XYFZ_A; xx.os_specific = NUL;
  386. xx.lblopts = 0;
  387. x = zopeno(ZMFILE,p,NULL,&xx);
  388.     }
  389.     debug(F101,"PRINTER OPEN","",x);
  390.     printing = 1;
  391. }
  393. VOID
  394. printoff() { /* Turn printing off */
  395.     int x;
  396.     extern int noprinter;
  397.     printing = 0;
  398.     if (noprinter) {
  399. debug(F110,"PRINTER OFF NOPRINTER","",0);
  400. return;
  401.     }
  402.     debug(F100,"PRINTER OFF","",0);
  403.     if (printing) {
  404. x = zclose(ZMFILE);
  405. debug(F101,"PRINTER CLOSE","",x);
  406.     }
  407. }
  408. #endif /* XPRINT */
  410. /*
  411.   C H K A E S  --  Check ANSI Escape Sequence.
  413.   Call with EACH character in input stream.
  414.   src = 0 means c is incoming from remote; 1 = char from keyboard.
  415.   Sets global inesc[src] variable according to escape sequence state.
  416.   Returns 0 normally, 1 if an APC sequence is to be executed.
  417.   Handles transparent printing internally.
  418. */
  419. int
  420. #ifdef CK_ANSIC
  421. chkaes(char c, int src)
  422. #else
  423. chkaes(c,src) char c; int src;
  424. #endif /* CK_ANSIC */
  425. /* chkaes */ {
  427.     debug(F111,"chkaes entry inesc",ckitoa(src),inesc[src]);
  428.     debug(F101,"chkaes c","",c);
  430.     if (src < 0 || src > 1) /* Don't allow bad args. */
  431.       return(0);
  433.     oldesc[src] = inesc[src]; /* Remember previous state */
  435. #ifdef XPRINT
  436.     if (inesc[src] && !src) { /* Save up escape seq for printing  */
  437. if (!c) return(0); /* Ignore NULs */
  438. if (escbufc < ESCBUFLEN) {
  439.     escbuf[escbufc++] = c;
  440.     escbuf[escbufc] = NUL;
  441.     debug(F111,"ESCBUF 1",escbuf,escbufc);
  442. } else { /* Buffer overrun */
  443.     if (printing && escbufc) /* Print what's there so far */
  444.       zsoutx(ZMFILE,escbuf,escbufc);
  445.     escbufc = 1; /* clear it out */
  446.     escbuf[0] = c; /* and start off fresh buffer */
  447.     escbuf[1] = NUL; /* with this character. */
  448. }
  449.     }
  450. #endif /* XPRINT */
  452.     if (c == CAN || c == SUB) { /* CAN and SUB cancel any sequence */
  453. #ifdef XPRINT
  454. if (!src) {
  455.     if (printing && escbufc > 1)
  456.       zsoutx(ZMFILE,escbuf,escbufc-1);
  457.     escbufc = 0; /* Clear buffer */
  458.     escbuf[0] = NUL;
  459. }
  460. #endif /* XPRINT */
  461. inesc[src] = ES_NORMAL;
  462.     } else /* Otherwise */
  464.       switch (inesc[src]) { /* enter state switcher */
  465. case ES_NORMAL: /* NORMAL state */
  466.   if (c == ESC) { /* Got an ESC */
  467.       inesc[src] = ES_GOTESC; /* Change state to GOTESC */
  468. #ifdef XPRINT
  469.       if (!src) {
  470.   escbufc = 1; /* Clear escape sequence buffer */
  471.   escbuf[0] = c; /* and deposit the ESC */
  472.   escbuf[1] = NUL;
  473.   debug(F111,"ESCBUF 2",escbuf,escbufc);
  474.       }
  475. #endif /* XPRINT */
  476.   }
  477.   break; /* Otherwise stay in NORMAL state */
  479. case ES_GOTESC: /* GOTESC state - prev char was ESC*/
  480.   if (c == '[') { /* Left bracket after ESC is CSI */
  481.       inesc[src] = ES_GOTCSI; /* Change to GOTCSI state */
  482.   } else if (c == 'P' || (c > 0134 && c < 0140)) { /* P, ], ^, or _ */
  483.       inesc[src] = ES_STRING; /* Switch to STRING-absorption state */
  484. #ifdef XPRINT
  485.       debug(F111,"ESCBUF STRING",escbuf,escbufc);
  486. #endif /* XPRINT */
  487. #ifdef CK_APC
  488.       /* If APC not disabled */
  489.       if (!src && c == '_' && apcstatus != APC_OFF) {
  490.   debug(F100,"CONNECT APC begin","",0);
  491.   apcactive = APC_REMOTE; /* Set APC-Active flag */
  492.   apclength = 0; /* and reset APC buffer pointer */
  493.       }
  494. #endif /* CK_APC */
  495.   } else if (c > 057 && c < 0177) { /* Final character '0' thru '~' */
  496.       inesc[src] = ES_NORMAL; /* Back to normal */
  497. #ifdef XPRINT
  498.       if (!src) {
  499.   if (printing & escbufc > 1) {
  500.       /* Dump esc seq buf to printer */
  501.       zsoutx(ZMFILE,escbuf,escbufc-1);
  502.       debug(F111,"ESCBUF PRINT 1",escbuf,escbufc);
  503.   }
  505.   escbufc = 0; /* Clear parameter buffer */
  506.   escbuf[0] = NUL;
  507.       }
  508. #endif /* XPRINT */
  509.   } else if (c != ESC) { /* ESC in an escape sequence... */
  510.       inesc[src] = ES_ESCSEQ; /* starts a new escape sequence */
  511.   }
  512.   break; /* Intermediate or ignored ctrl char */
  514. case ES_ESCSEQ: /* ESCSEQ -- in an escape sequence */
  515.   if (c > 057 && c < 0177) { /* Final character '0' thru '~' */
  516.       inesc[src] = ES_NORMAL; /* Return to NORMAL state. */
  517. #ifdef XPRINT
  518.       if (!src) {
  519.   if (printing && escbufc > 1) {
  520.       zsoutx(ZMFILE,escbuf,escbufc-1);
  521.       debug(F111,"ESCBUF PRINT 2",escbuf,escbufc);
  522.   }
  523.   escbufc = 0; /* Clear escseq buffer */
  524.   escbuf[0] = NUL;
  525.       }
  526. #endif /* XPRINT */
  527.   } else if (c == ESC) { /* ESC ... */
  528.       inesc[src] = ES_GOTESC; /* starts a new escape sequence */
  529.   }
  530.   break; /* Intermediate or ignored ctrl char */
  532. case ES_GOTCSI: /* GOTCSI -- In a control sequence */
  533.   if (c > 077 && c < 0177) { /* Final character '@' thru '~' */
  534. #ifdef XPRINT
  535.       if (!src && tt_print) { /* Printer enabled? */
  536.   if (c == 'i') { /* Final char is "i"? */
  537.       char * p = (char *) (escbuf + escbufc - 4);
  538.       if (!strncmp(p, "33[5i", 4)) /* Yes, turn printer on */
  539. printon();
  540.       else if (!strncmp(p, "33[4i", 4)) { /* Or off... */
  541.   printoff(); /* Turn off printer. */
  542.   conxo(escbufc,escbuf); /* Display this sequence. */
  543.       } else if (printing && escbufc > 1) {
  544.   zsoutx(ZMFILE,escbuf,escbufc-1);
  545.   debug(F111,"ESCBUF PRINT 3",escbuf,escbufc);
  546.       }
  547.   } else if (printing && escbufc > 1) {
  548.       zsoutx(ZMFILE,escbuf,escbufc-1);
  549.       debug(F111,"ESCBUF PRINT 4",escbuf,escbufc);
  550.   }
  551.       }
  552.       if (!src) {
  553.   escbufc = 0; /* Clear esc sequence buffer */
  554.   escbuf[0] = NUL;
  555.       }
  556. #endif /* XPRINT */
  557.       inesc[src] = ES_NORMAL; /* Return to NORMAL. */
  558.   } else if (c == ESC) { /* ESC ... */
  559.       inesc[src] = ES_GOTESC; /* starts over. */
  560.   }
  561.   break;
  563. case ES_STRING: /* Inside a string */
  564.   if (c == ESC) /* ESC may be 1st char of terminator */
  565.     inesc[src] = ES_TERMIN; /* Go see. */
  566. #ifdef CK_APC
  567.   else if (apcactive) { /* If in APC */
  568.       if (apclength < apcbuflen) { /* and there is room... */
  569.   apcbuf[apclength++] = c; /* deposit this character. */
  570.       } else { /* Buffer overrun */
  571.   apcactive = 0; /* Discard what we got */
  572.   apclength = 0; /* and go back to normal */
  573.   apcbuf[0] = 0; /* Not pretty, but what else */
  574.   inesc[src] = ES_NORMAL; /* can we do?  (ST might not come) */
  575.       }
  576.   }
  577. #endif /* CK_APC */
  578.   break; /* Absorb all other characters. */
  580. case ES_TERMIN: /* Maybe a string terminator */
  581.   if (c == '\') { /* which must be backslash */
  582.       inesc[src] = ES_NORMAL; /* If so, back to NORMAL */
  583. #ifdef XPRINT
  584.       if (!src) {
  585.   if (printing && escbufc > 1) { /* If printing... */
  586.       /* Print esc seq buffer */
  587.       zsoutx(ZMFILE,escbuf,escbufc-1);
  588.       debug(F111,"ESCBUF PRINT 5",escbuf,escbufc);
  589.   }
  590.   escbufc = 0; /* Clear escseq buffer */
  591.   escbuf[0] = NUL;
  592.       }
  593. #endif /* XPRINT */
  594. #ifdef CK_APC
  595.       if (!src && apcactive) { /* If it was an APC string, */
  596.   debug(F101,"CONNECT APC terminated","",c);
  597.   apcbuf[apclength] = NUL; /* terminate it and then ... */
  598.   return(1);
  599.       }
  600. #endif /* CK_APC */
  601.   } else { /* It's not a backslash so... */
  602.       inesc[src] = ES_STRING; /* back to string absorption. */
  603. #ifdef CK_APC
  604.       if (apcactive) { /* In APC string */
  605.   if (apclength+1 < apcbuflen) { /* If enough room */
  606.       apcbuf[apclength++] = ESC; /* deposit the Esc */
  607.       apcbuf[apclength++] = c;   /* and this character too. */
  608.   } else { /* Buffer overrun */
  609.       apcactive = 0;
  610.       apclength = 0;
  611.       apcbuf[0] = 0;
  612.       inesc[src] = ES_NORMAL;
  613.   }
  614.       }
  615. #endif /* CK_APC */
  616.   }
  617.       } /* switch() */
  618.     debug(F111,"chkaes exit inesc",ckitoa(src),inesc[src]);
  619.     return(0);
  620. }
  621. #endif /* NOESCSEQ */
  623. /*  C K C P U T C  --  C-Kermit CONNECT Put Character to Screen  */
  624. /*
  625.   Output is buffered to avoid slow screen writes on fast connections.
  626. */
  627. static int
  628. ckcputf() { /* Dump the output buffer */
  629.     int x = 0;
  630.     if (obc > 0) /* If we have any characters, */
  631.       x = conxo(obc,obuf); /* dump them, */
  632.     obp = obuf; /* reset the pointer */
  633.     obc = 0; /* and the counter. */
  634.     return(x); /* Return conxo's return code */
  635. }
  637. /*
  638.   NOTE: This is probably the right place for character-set translation,
  639.   rather than down below in the mainline code.  ckcputc() would act like
  640.   xpnbyte() in ckcfns.c, and ckcgetc() would act like xgnbyte().  This
  641.   would shield the rest of the code from all the complexities of many-to-one
  642.   and one-to-many conversions, and would allow handling of Kanji and other
  643.   CJK sets along with UTF-8 and the rest.
  644. */
  645. int
  646. ckcputc(c) int c; {
  647.     int x;
  649.     *obp++ = c & 0xff; /* Deposit the character */
  650.     obc++; /* Count it */
  651.     if (ibc == 0 || /* If input buffer about empty */
  652. obc == OBUFL) { /* or output buffer full */
  653. debug(F101,"CONNECT CKCPUTC obc","",obc);
  654. x = conxo(obc,obuf); /* dump the buffer, */
  655. obp = obuf; /* reset the pointer */
  656. obc = 0; /* and the counter. */
  657. return(x); /* Return conxo's return code */
  658.     } else return(0);
  659. }
  661. /*  C K C G E T C  --  C-Kermit CONNECT Get Character  */
  662. /*
  663.   Buffered read from communication device.
  664.   Returns the next character, refilling the buffer if necessary.
  665.   On error, returns ttinc's return code (see ttinc() description).
  666.   Dummy argument for compatible calling conventions with ttinc()
  667.   so a pointer to this function can be passed to tn_doop().
  668. */
  669. int
  670. ckcgetc(dummy) int dummy; {
  671.     int c, n;
  672. #ifdef CK_SSL
  673.     extern int ssl_active_flag, tls_active_flag;
  674. #endif /* CK_SSL */
  676. #ifdef CK_ENCRYPTION
  677.     /* No buffering for possibly encrypted connections */
  678.     if (network && ttnproto == NP_TELNET && TELOPT_ME(TELOPT_AUTHENTICATION))
  679.       return(ttinc(0));
  680. #endif /* CK_ENCRYPTION */
  681. #ifdef CK_SSL
  682.     if (ssl_active_flag || tls_active_flag)
  683.         return(ttinc(0));
  684. #endif /* CK_SSL */
  686.     if (ibc < 1) { /* Need to refill buffer? */
  687. ibc = 0; /* Yes, reset count */
  688. ibp = ibuf; /* and buffer pointer */
  689. c = ttinc(0); /* Read one character, blocking */
  690. if (c < 0) { /* If error, return error code */
  691.     return(c);
  692. } else { /* Otherwise, got one character */
  693.     *ibp++ = c; /* Advance buffer pointer */
  694.     ibc++; /* and count. */
  695. }
  696. if ((n = ttchk()) > 0) { /* Any more waiting? */
  697.     if (n > (IBUFL - ibc)) /* Get them all at once. */
  698.       n = IBUFL - ibc; /* Don't overflow buffer */
  699.       if ((n = ttxin(n,(CHAR *)ibp)) > 0) {
  700. #ifdef CK_ENCRYPTION
  701.   if (TELOPT_U(TELOPT_ENCRYPTION))
  702.                     ck_tn_decrypt(ibp,n);
  703. #endif /* CK_ENCRYPTION */
  704.   ibc += n; /* Advance counter */
  705.               }
  706. } else if (n < 0) { /* Error? */
  707.     return(n); /* Return the error code */
  708. }
  709. ibp = ibuf; /* Point to beginning of buffer */
  710.     }
  711.     c = *ibp++ & 0xff; /* Get next character from buffer */
  712.     ibc--; /* Reduce buffer count */
  713.     /* debug(F000,"CKCGETC","",c); */
  714.     return(c); /* Return the character */
  715. }
  717. /*
  718.    Keyboard handling, buffered for speed, which is needed when C-Kermit is
  719.    in CONNECT mode between two other computers that are transferring data.
  720. */
  721. static char *kbp; /* Keyboard input buffer pointer */
  722. static int kbc; /* Keyboard input buffer count */
  724. #ifdef CK_SMALL /* Keyboard input buffer length */
  725. #define KBUFL 32 /* Small for PDP-11 UNIX */
  726. #else
  727. #define KBUFL 257 /* Regular kernel size for others */
  728. #endif /* CK_SMALL */
  730. #ifdef DYNAMIC
  731. static char *kbuf = NULL;
  732. #else
  733. static char kbuf[KBUFL];
  734. #endif /* DYNAMIC */
  736. /* Macro for reading keystrokes. */
  738. #define CONGKS() (((--kbc)>=0) ? ((int)(*kbp++) & 0377) : kbget())
  740. /*
  741.   Note that we call read() directly here, normally a no-no, but in this case
  742.   we know it's UNIX and we're only doing what coninc(0) would have done,
  743.   except we're reading a block of characters rather than just one.  There is,
  744.   at present, no conxin() analog to ttxin() for chunk reads, and instituting
  745.   one would only add function-call overhead as it would only be a wrapper for
  746.   a read() call anyway.
  748.   Another note: We stick in this read() till the user types something.
  749.   But we know they already did, since select() said so.  Therefore something
  750.   would need to be mighty wrong before we get in trouble here.
  751. */
  752. static int /* Keyboard buffer filler */
  753. kbget() {
  754. #ifdef EINTR
  755.     int tries = 10; /* If read() is interrupted, */
  756.     int ok = 0;
  757.     while (tries-- > 0) { /* try a few times... */
  758. #endif /* EINTR */
  759. kbc = conchk(); /* How many chars waiting? */
  760. debug(F101,"kbget kbc","",kbc);
  761. if (kbc < 1)
  762.   kbc = 1; /* If none or dunno, wait for one. */
  763. else if (kbc > KBUFL) /* If too many, */
  764.   kbc = KBUFL; /* only read this many. */
  765. if ((kbc = read(0, kbuf, kbc)) < 1) { /* Now read it/them. */
  766.     debug(F101,"CONNECT kbget errno","",errno); /* Got an error. */
  767. #ifdef EINTR
  768.     if (errno == EINTR) /* Interrupted system call. */
  769.       continue; /* Try again, up to limit. */
  770.     else /* Something else. */
  771. #endif /* EINTR */
  772.       return(-1); /* Pass along read() error. */
  773. }
  774. #ifdef EINTR
  775. else { ok = 1; break; }
  776.     }
  777.     if (!ok) return(-1);
  778. #endif /* EINTR */
  779.     kbp = kbuf; /* Adjust buffer pointer, */
  780.     kbc--; /* count, */
  781.     return((int)(*kbp++) & 0377); /* and return first character. */
  782. }
  784. #ifdef BEBOX
  785. /*
  786.  * CreateSocketPair --
  787.  *
  788.  * This procedure creates a connected socket pair
  789.  *
  790.  * Results:
  791.  * 0 if OK, the error if not OK.
  792.  *
  793.  * Side effects:
  794.  * None
  795.  */
  796. int
  797. socketpair(int *pair) {
  798.     int servsock;
  799.     int val;
  800.     struct sockaddr_in serv_addr, cli_addr;
  801.     extern char myipaddr[];
  803.     debug(F110,"socketpair",myipaddr,0);
  805.     if (myipaddr[0] == 0)
  806.       getlocalipaddr();
  808.     servsock = socket(AF_INET, SOCK_STREAM, 0);
  809.     if (servsock == 0) {
  810. return h_errno;
  811.     }
  812.     debug(F111,"socketpair","socket",servsock);
  814.     memset(&serv_addr, 0, sizeof(serv_addr));
  815.     serv_addr.sin_family = AF_INET;
  816.     serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
  817.     serv_addr.sin_port = htons(0);
  819.     val = sizeof(serv_addr);
  820.     if (bind(servsock, (struct sockaddr *) &serv_addr, val) < 0) {
  821. closesocket(servsock);
  822. return h_errno;
  823.     }
  824.     debug(F111,"socketpair","bind",0);
  826.     listen(servsock, 1);
  827.     debug(F111,"socketpair","listen",0);
  829.     if (getsockname(servsock, (struct sockaddr *) &serv_addr, &val) < 0) {
  830. closesocket(servsock);
  831. return h_errno;
  832.     }
  833.     debug(F111,"socketpair","getsockname",0);
  835.     pair[0] = socket(AF_INET, SOCK_STREAM, 0);
  836.     if (pair[0] == 0) {
  837. closesocket(servsock);
  838. return h_errno;
  839.     }
  840.     debug(F111,"socketpair","socket",pair[0]);
  842.     memset(&cli_addr, 0, sizeof(cli_addr));
  843.     cli_addr.sin_family = AF_INET;
  844.     cli_addr.sin_addr.s_addr = inet_addr(myipaddr[0]?myipaddr:"127.0.0.1");
  845.     cli_addr.sin_port = serv_addr.sin_port;
  847.     if (connect(pair[0],(struct sockaddr *) &cli_addr, sizeof(cli_addr)) < 0) {
  848. closesocket(pair[0]);
  849. closesocket(servsock);
  850. return h_errno;
  851.     }
  852.     debug(F111,"socketpair","connect",0);
  854.     pair[1] = accept(servsock, (struct sockaddr *) &serv_addr, &val);
  855.     if (pair[1] == 0) {
  856. closesocket(pair[0]);
  857. closesocket(servsock);
  858. return h_errno;
  859.     }
  860.     debug(F111,"socketpair","accept",pair[1]);
  862.     closesocket(servsock);
  863.     debug(F111,"socketpair","closesocket",0);
  864.     return 0;
  865. }
  867. long
  868. kbdread(void * param) {
  869.     int sock = (int) param;
  870.     char ch;
  871.     int rc = 0;
  873.     debug(F111,"kbdread","sock",sock);
  875.     while (rc >= 0) {
  876. rc = read(fileno(stdin), &ch, 1); /* Read a character. */
  877. if (rc > 0) {
  878.     rc = send(sock,&ch,1,0);
  879.     /* debug(F000,"kbdread","send()",ch); */
  880.     printf("rngot: %c rc = %drn",ch,rc);
  881. } else
  882.   msleep(100);
  883.     }
  884.     debug(F110,"kbdread","terminating",0);
  885.     return(rc);
  886. }
  887. #endif /* BEBOX */
  889. static int printbar = 0;
  891. #define OUTXBUFSIZ 15
  892. static CHAR inxbuf[OUTXBUFSIZ+1]; /* Host-to-screen expansion buffer */
  893. static int inxcount = 0; /* and count */
  894. static CHAR outxbuf[OUTXBUFSIZ+1]; /* Keyboard-to-host expansion buf */
  895. static int outxcount = 0; /* and count */
  897. int
  898. conect() {
  899.     int rc = 0; /* Return code: 0 = fail, 1 = OK */
  900.     int i, x = 0;
  901.     register int c, c2, csave; /* Characters */
  902. #ifdef TNCODE
  903.     int tx; /* For Telnet negotiations */
  904. #endif /* TNCODE */
  905.     int apcrc = 0; /* For APC and transparent print */
  906.     int n, kbin, scrnout; /* select() items... */
  907.     fd_set in, out, err; /* File descriptor sets */
  908.     int gotnet = 0; /* Flag for net ready to read */
  909.     int gotkbd = 0; /* Flag for keyboard ready to read */
  910.     int oldprt = 0; /* Used with printing */
  911.     int msgflg = 0;
  912.     char cbuf[2]; /* Ditto */
  914. #ifdef BEBOX
  915.     int tid = 0; /* Thread ID */
  916.     int pair[2]; /* Socket Pair */
  917.     CHAR ch;
  918.     CHAR buf[64];
  919. #endif /* BEBOX */
  921. #ifdef BEBOX
  922.     {
  923. /* Create a socket pair to be used for the keyboard input */
  924. if (socketpair(pair)) {
  925.     debug(F110,"conect","unable to create socket pair",0);
  926.     return(-1);
  927. }
  928. debug(F111,"connect","socket pair[0]",pair[0]);
  929. debug(F111,"connect","socket pair[1]",pair[1]);
  931. /* Assign one end of the socket to kbin */
  932. kbin = pair[0];
  933.         tid = spawn_thread(kbdread,
  934.    "Kbd to Socket Pair",
  935.     B_NORMAL_PRIORITY,
  936.    (void *)pair[1]
  937.    );
  938.         resume_thread(tid);
  939. debug(F110,"connect","tid",tid);
  940.     }
  941. #else /* BEBOX */
  942.     kbin = fileno(stdin); /* stdin file descriptor */
  943. #endif /* BEBOX */
  945.     scrnout = fileno(stdout); /* stdout file descriptor */
  947. #ifdef CK_TRIGGER
  948.     makestr(&triggerval,NULL); /* Reset trigger */
  949. #endif /* CK_TRIGGER */
  951. #ifdef XPRINT
  952.     escbufc = 0; /* Reset esc-sequence buffer */
  953.     escbuf[0] = NUL;
  954. #endif /* XPRINT */
  955.     cbuf[1] = NUL;
  957.     ttimoff(); /* Turn off any timer interrupts */
  958.     if (!local) { /* Be sure we're not in remote mode */
  959. #ifdef NETCONN
  960. printf("Sorry, you must SET LINE or SET HOST firstn");
  961. #else
  962. printf("Sorry, you must SET LINE firstn");
  963. #endif /* NETCONN */
  964. return(0);
  965.     }
  966.     if (speed < 0L && network == 0 && ttfdflg == 0) {
  967. printf("Sorry, you must SET SPEED firstn");
  968. return(0);
  969.     }
  970. #ifdef TCPSOCKET
  971.     if (network && !ttpipe && (nettype != NET_TCPB && nettype != NET_PTY)) {
  972. printf("Sorry, network type not supportedn");
  973. return(0);
  974.     }
  975. #endif /* TCPSOCKET */
  977. #ifdef DYNAMIC
  978.     if (!ibuf) {
  979. if (!(ibuf = malloc(IBUFL+1))) { /* Allocate input line buffer */
  980.     printf("Sorry, CONNECT input buffer can't be allocatedn");
  981.     return(0);
  982. } else {
  983.     ibp = ibuf;
  984.     ibc = 0;
  985. }
  986.     }
  987.     if (!obuf) {
  988. if (!(obuf = malloc(OBUFL+1))) { /* Allocate output line buffer */
  989.     printf("Sorry, CONNECT output buffer can't be allocatedn");
  990.     return(0);
  991. } else {
  992.     obp = obuf;
  993.     obc = 0;
  994. }
  995.     }
  996.     if (!kbuf) {
  997. if (!(kbuf = malloc(KBUFL+1))) { /* Allocate keyboard input buffer */
  998.     printf("Sorry, CONNECT keyboard buffer can't be allocatedn");
  999.     return(0);
  1000. }
  1001.     }
  1002.     if (!temp) {
  1003. if (!(temp = malloc(TMPLEN+1))) { /* Allocate temporary buffer */
  1004.     printf("Sorry, CONNECT temporary buffer can't be allocatedn");
  1005.     return(0);
  1006. }
  1007.     }
  1008. #else
  1009.     obp = obuf;
  1010.     obc = 0;
  1011. #endif /* DYNAMIC */
  1013.     kbp = kbuf; /* Always clear these. */
  1014.     *kbp = NUL; /* No need to preserve them between */
  1015.     kbc = 0; /* CONNECT sessions. */
  1017. #ifdef DEBUG
  1018.     if (deblog) {
  1019. debug(F101,"CONNECT conect entry ttyfd","",ttyfd);
  1020. debug(F101,"CONNECT conect entry ibc","",ibc);
  1021. debug(F101,"CONNECT conect entry obc","",obc);
  1022. debug(F101,"CONNECT conect entry kbc","",kbc);
  1023. #ifdef CK_TRIGGER
  1024. debug(F110,"CONNECT conect trigger",tt_trigger[0],0);
  1025. #endif /* CK_TRIGGER */
  1026. if (ttyfd > -1) {
  1027.     n = ttchk();
  1028.     debug(F101,"CONNECT conect entry ttchk","",n);
  1029. }
  1030.     }
  1031. #endif /* DEBUG */
  1033.     if (ttyfd < 0) { /* If communication device not open */
  1034. #ifdef TTLEBUF
  1035.         int n = le_inbuf();
  1036.         debug(F111,"CONNECT le_inbuf()","ttyfd < 0",n);
  1037.         if (n > 0) {
  1038.             while (n--) {
  1039.                 CHAR ch;
  1040.                 le_getchar(&ch);
  1041.                 conoc(ch);
  1042.             }
  1043.             return(0);
  1044.         }
  1045. #endif /* TTLEBUF */
  1047. debug(F101,"CONNECT ttnproto","",ttnproto);
  1048. debug(F111,"CONNECT opening",ttname,0); /* Open it now */
  1049. if (ttopen(ttname,
  1050.    &local,
  1051.    network ? -nettype : mdmtyp,
  1052.    0
  1053.    ) < 0) {
  1054.     sprintf(temp,"Sorry, can't open %s",ttname);
  1055.     perror(temp);
  1056.     debug(F110,"CONNECT open failure",ttname,0);
  1057.     return(0);
  1058. }
  1059. #ifdef IKS_OPTION
  1060. /* If peer is in Kermit server mode, return now. */
  1061. if (TELOPT_SB(TELOPT_KERMIT).kermit.u_start)
  1062.   return(0);
  1063. #endif /* IKS_OPTION */
  1064.     }
  1065.     dohangup = 0; /* Hangup not requested yet */
  1067.     msgflg = !quiet
  1068. #ifdef CK_APC
  1069.       && !apcactive
  1070. #endif /* CK_APC */
  1071. ;
  1073.     if (msgflg) {
  1074. #ifdef NETCONN
  1075. if (network) {
  1076. #ifdef CK_ENCRYPTION
  1077.     extern int me_encrypt, u_encrypt;
  1078.     if (ck_tn_encrypting() && ck_tn_decrypting())
  1079.       printf("SECURE connection to host %s",ttname);
  1080.     else
  1081. #endif /* CK_ENCRYPTION */
  1082.       if (ttpipe || ttpty)
  1083. printf("Connecting via command "%s"",ttname);
  1084.       else
  1085. printf("Connecting to host %s",ttname);
  1086. } else {
  1087. #endif /* NETCONN */
  1088.     printf("Connecting to %s",ttname);
  1089.     if (speed > -1L) printf(", speed %ld",speed);
  1090. #ifdef NETCONN
  1091. }
  1092. #endif /* NETCONN */
  1093. if (tt_escape) {
  1094.     printf(".rnThe escape character is Ctrl-%c (ASCII %d, %s)rn",
  1095.    ctl(escape), escape,
  1096.    (escape == 127 ? "DEL" : ccntab[escape]));
  1097.     printf("Type the escape character followed by C to get back,rn");
  1098.     printf("or followed by ? to see other options.rn");
  1099. } else {
  1100.     printf(".rnnESCAPE CHARACTER IS DISABLEDrnn");
  1101. }
  1102. if (seslog) {
  1103.     printf("(Session logged to %s, ",sesfil);
  1104.     printf("%s)rn", sessft ? "binary" : "text");
  1105. }
  1106. if (debses) printf("Debugging Display...)rn");
  1107.     }
  1109. /* Condition console terminal and communication line */
  1111.     if (conbin((char)escape) < 0) {
  1112. printf("Sorry, can't condition console terminaln");
  1113. fflush(stdout);
  1114. return(0);
  1115.     }
  1116.     debug(F101,"CONNECT cmask","",cmask);
  1117.     debug(F101,"CONNECT cmdmsk","",cmdmsk);
  1118.     debug(F101,"CONNECT speed before ttvt","",speed);
  1119.     if ((n = ttvt(speed,flow)) < 0) { /* Enter "virtual terminal" mode */
  1120. if (!network) {
  1121.     debug(F101,"CONNECT ttvt","",n);
  1122.     tthang(); /* Hang up and close the device. */
  1123.     ttclos(0);
  1124.     if (ttopen(ttname, /* Open it again... */
  1125.        &local,
  1126.        network ? -nettype : mdmtyp,
  1127.        0
  1128.        ) < 0) {
  1129. sprintf(temp,"Sorry, can't reopen %s",ttname);
  1130. perror(temp);
  1131. return(0);
  1132.     }
  1133. #ifdef IKS_OPTION
  1134.     if (TELOPT_SB(TELOPT_KERMIT).kermit.u_start)
  1135.       return(0);
  1136. #endif /* IKS_OPTION */
  1138.     if (ttvt(speed,flow) < 0) { /* Try virtual terminal mode again. */
  1139. conres(); /* Failure this time is fatal. */
  1140. printf("Sorry, Can't condition communication linen");
  1141. return(0);
  1142.     }
  1143. }
  1144.     }
  1145.     debug(F101,"CONNECT ttvt ok, escape","",escape);
  1147.     /* Despite ttvt() this is still needed in HP-UX */
  1148.     /* because of the HP-9000 <RESET> key.*/
  1150.     signal(SIGINT, SIG_IGN);
  1151.     signal(SIGQUIT, SIG_IGN);
  1153.     debug(F101,"CONNECT carrier-watch","",carrier);
  1154.     if (!network && (carrier != CAR_OFF)) {
  1155. int x;
  1156. x = ttgmdm();
  1157. debug(F100,"CONNECT ttgmdm","",x);
  1158. if ((x > -1) && !(x & BM_DCD)) {
  1159. #ifndef NOICP
  1160.     extern int hints;
  1161. #endif /* NOICP */
  1162.     debug(F100,"CONNECT ttgmdm CD test fails","",x);
  1163.     conres();
  1164.     printf("?Carrier required but not detected.n");
  1165. #ifndef NOICP
  1166.     if (!hints)
  1167.       return(0);
  1168.     printf("***********************************n");
  1169.     printf(" Hint: To CONNECT to a serial device thatn");
  1170.     printf(" is not presenting the Carrier Detect signal,n");
  1171.     printf(" first tell C-Kermit to:nn");
  1172.     printf("   SET CARRIER-WATCH OFFnn");
  1173.     printf("***********************************nn");
  1174. #endif /* NOICP */
  1175.     return(0);
  1176. }
  1177. debug(F100,"CONNECT ttgmdm ok","",0);
  1178.     }
  1180.     /* Now we are connected. */
  1182.     if (msgflg || printbar)
  1183.       printf("----------------------------------------------------rn");
  1184.     fflush(stdout);
  1186. #ifndef NOCSETS
  1187. /* Set up character set translations */
  1189.     unicode = 0; /* Assume Unicode won't be involved */
  1190.     tcs = 0; /* "Transfer" or "Other" charset */
  1191.     sxo = rxo = NULL; /* Initialize byte-to-byte functions */
  1192.     sxi = rxi = NULL;
  1193.     if (tcsr != tcsl) { /* Remote and local sets differ... */
  1194. #ifdef UNICODE
  1195. if (tcsr == FC_UTF8 || /* Remote charset is UTF-8 */
  1196.     tcsl == FC_UTF8) { /* or local one is. */
  1197.     xuf = xl_ufc[tcsl]; /* Incoming Unicode to local */
  1198.     if (xuf) {
  1199. tcs = (tcsr == FC_UTF8) ? tcsl : tcsr; /* The "other" set */
  1200. xfu = xl_fcu[tcs]; /* Local byte to remote Unicode */
  1201. if (xfu)
  1202.   unicode = (tcsr == FC_UTF8) ? 1 : 2;
  1203.     }
  1204.     tcssize = fcsinfo[tcs].size; /* Size of other character set. */
  1205. } else {
  1206. #endif /* UNICODE */
  1207.     tcs = gettcs(tcsr,tcsl); /* Get intermediate set. */
  1208.     sxo = xls[tcs][tcsl]; /* translation function */
  1209.     rxo = xlr[tcs][tcsr]; /* pointers for output functions */
  1210.     sxi = xls[tcs][tcsr]; /* and for input functions. */
  1211.     rxi = xlr[tcs][tcsl];
  1212. #ifdef UNICODE
  1213. }
  1214. #endif /* UNICODE */
  1215.     }
  1216. /*
  1217.   This is to prevent use of zmstuff() and zdstuff() by translation functions.
  1218.   They only work with disk i/o, not with communication i/o.  Luckily Russian
  1219.   translation functions don't do any stuffing...
  1220. */
  1221.     langsv = language;
  1222. #ifndef NOCYRIL
  1223.     if (language != L_RUSSIAN)
  1224. #endif /* NOCYRIL */
  1225.       language = L_USASCII;
  1227. #ifdef COMMENT
  1228. #ifdef DEBUG
  1229.     if (deblog) {
  1230. debug(F101,"CONNECT tcs","",tcs);
  1231. debug(F101,"CONNECT tcsl","",tcsl);
  1232. debug(F101,"CONNECT tcsr","",tcsr);
  1233. debug(F101,"CONNECT fcsinfo[tcsl].size","",fcsinfo[tcsl].size);
  1234. debug(F101,"CONNECT fcsinfo[tcsr].size","",fcsinfo[tcsr].size);
  1235. debug(F101,"CONNECT unicode","",unicode);
  1236.     }
  1237. #endif /* DEBUG */
  1238. #endif /* COMMENT */
  1240. #ifdef CK_XYZ
  1241. #ifndef XYZ_INTERNAL
  1242.     {
  1243. extern int binary; /* See about ZMODEM autodownloads */
  1244. char * s;
  1245. s = binary ? ptab[PROTO_Z].p_b_rcmd : ptab[PROTO_Z].p_t_rcmd;
  1246. if (!s) s = "";
  1247. zmdlok = (*s != NUL); /* OK if we have external commands */
  1248.     }
  1249. #endif /* XYZ_INTERNAL */
  1250. #endif /* CK_XYZ */
  1252. #ifndef NOESCSEQ
  1253. /*
  1254.   We need to activate the escape-sequence recognition feature when:
  1255.    (a) translation is elected, AND
  1256.    (b) the local and/or remote set is a 7-bit set other than US ASCII.
  1257.   Or:
  1258.    SET TERMINAL APC is not OFF (handled in the next statement).
  1259. */
  1260.     escseq = (tcs != TC_TRANSP) && /* Not transparent */
  1261.       (fcsinfo[tcsl].size == 128 || fcsinfo[tcsr].size == 128) && /* 7 bits */
  1262. (fcsinfo[tcsl].code != FC_USASCII); /* But not ASCII */
  1263. #endif /* NOESCSEQ */
  1264. #endif /* NOCSETS */
  1266. #ifndef NOESCSEQ
  1267. #ifdef CK_APC
  1268.     escseq = escseq || (apcstatus != APC_OFF);
  1269.     apcactive = 0; /* An APC command is not active */
  1270.     apclength = 0; /* ... */
  1271. #endif /* CK_APC */
  1272. #ifdef XPRINT
  1273.     escseq |= tt_print;
  1274. #endif /* XPRINT */
  1275.     inesc[0] = ES_NORMAL; /* Initial state of recognizer */
  1276.     inesc[1] = ES_NORMAL;
  1277.     debug(F101,"CONNECT escseq","",escseq);
  1278. #endif /* NOESCSEQ */
  1280.     if (ttyfd > -1) { /* (just in case...) */
  1281. what = W_CONNECT; /* Keep track of what we're doing */
  1282. FD_ZERO(&in); /* Clear select() structs */
  1283. FD_ZERO(&out);
  1284. FD_ZERO(&err);
  1285. active = 1;
  1286.     }
  1287.     while (active) { /* Big loop... */
  1288. debug(F100,"CONNECT top of loop","",0);
  1289. gotkbd = 0;
  1290. gotnet = ttpeek(); /* Something sitting in ckutio buf */
  1291. debug(F101,"CONNECT ttpeek","",gotnet);
  1293. if (
  1294. #ifndef NOSETKEY
  1295.     !kmptr /* Check for key macro active */
  1296. #else
  1297.     1
  1298. #endif /* NOSETKEY */
  1299.     ) {
  1300.     if (obc) { /* No key macro - set up for select */
  1301. FD_SET(ttyfd, &out); /* Have stuff to send to net */
  1302.     } else {
  1303. FD_SET(kbin, &in); /* Need to read stuff from keyboard */
  1304.     }
  1305. #ifdef BEBOX
  1306.     if (!(ibc || gotnet > 0))
  1307. FD_SET(ttyfd, &in); /* Need to read stuff from net */
  1308. #else /* BEBOX */
  1309.     if (ibc || gotnet > 0) {
  1310. FD_SET(scrnout, &out); /* Have stuff to put on screen */
  1311.     } else {
  1312. FD_SET(ttyfd, &in); /* Need to read stuff from net */
  1313.     }
  1314. #endif /* BEBOX */
  1315.             FD_SET(ttyfd, &err);
  1316. #ifdef CK_FORWARD_X
  1317.             fwdx_init_fd_set(&in);
  1318. #endif /* CK_FORWARD_X */
  1320.     /* Wait till the first one of the above is ready for i/o */
  1322.     /* NOTE: here we could implement idle timeouts */
  1324.     debug(F100,"CONNECT select() waiting...","",0);
  1325.     c = select(16, &in, &out, &err, 0);
  1326.     debug(F101,"CONNECT select()","",c);
  1327.     if (c < 1) {
  1328. #ifdef EINTR
  1329. if (c == -1) {
  1330.     if (errno == EINTR) {
  1331. continue;
  1332.     }
  1333. }
  1334. #endif /* EINTR */
  1335. sleep(1);
  1336. continue;
  1337.     }
  1338. #ifndef BEBOX
  1339.     if (FD_ISSET(scrnout, &out)) {
  1340. debug(F100,"CONNECT SELECT scrnout","",0);
  1341.     }
  1342. #endif /* BEBOX */
  1343. #ifdef CK_FORWARD_X
  1344.             fwdx_check_sockets(&in);
  1345. #endif /* CK_FORWARD_X */
  1346.     if (FD_ISSET(ttyfd, &in)) { /* Read from net? */
  1347. debug(F110,"CONNECT SELECT ttyfd","in",0);
  1348. FD_CLR(ttyfd, &in);
  1349. gotnet = 1; /* Net is ready */
  1350.     }
  1351.     if (FD_ISSET(kbin, &in)) { /* Read from keyboard? */
  1352. debug(F100,"CONNECT SELECT kbin","",0);
  1353. FD_CLR(kbin, &in);
  1354. gotkbd = 1; /* Keyboard is ready */
  1355.     }
  1356.             if (FD_ISSET(ttyfd, &err)) {
  1357. debug(F110,"CONNECT SELECT ttyfd","err",0);
  1358. FD_CLR(ttyfd, &err);
  1359. #ifdef NETPTY
  1360. #ifdef HAVE_PTYTRAP
  1361. /* Special handling for HP-UX pty i/o */
  1362.                 if (ttpty) {
  1363.                     if (pty_trap_handler(ttyfd) > 0) {
  1364.                         ttclos(0);
  1365.                         goto conret1;
  1366.                     }
  1367.                     continue;
  1368.                 }
  1369. #endif /* HAVE_PTYTRAP */
  1370. #endif /* NETPTY */
  1371. gotnet = 1; /* Net is ready (don't set if pty) */
  1372.             }
  1373. }
  1374. debug(F101,"CONNECT gotkbd","",gotkbd);
  1375. debug(F101,"CONNECT kbc","",kbc);
  1376. #ifndef NOSETKEY
  1377. debug(F101,"CONNECT kmptr","",kmptr);
  1378. #endif /* NOSETKEY */
  1379. while (gotkbd || kbc > 0 /* If we have keyboard chars */
  1380. #ifndef NOSETKEY
  1381.        || kmptr
  1382. #endif /* NOSETKEY */
  1383.        ) {
  1384. #ifndef NOSETKEY
  1385.     if (kmptr) { /* Have current macro? */
  1386. debug(F100,"CONNECT kmptr non NULL","",0);
  1387. if ((c = (CHAR) *kmptr++) == NUL) { /* Get char from it */
  1388.     kmptr = NULL; /* If no more chars,  */
  1389.     debug(F100,"CONNECT macro empty, continuing","",0);
  1390.     continue; /* reset pointer and continue */
  1391. }
  1392. debug(F000,"CONNECT char from macro","",c);
  1393.     } else { /* No macro... */
  1394. #endif /* NOSETKEY */
  1395. #ifdef BEBOX
  1396. {
  1397.     int rc = 0;
  1398.     if ((rc = recv(kbin,buf,1,0)) > 0)
  1399.       c = buf[0];
  1400.     else
  1401.       c = -1;
  1402.     debug(F111,"recv","rc",rc);
  1403.     printf("rnrecv: %c rc=%drn",buf[0],rc);
  1404. }
  1405. #else /* BEBOX */
  1406. c = CONGKS(); /* Yes, read from keyboard */
  1407. #endif /* BEBOX */
  1408. gotkbd = 0; /* Turn off select() result flag */
  1409. #ifndef NOSETKEY
  1410.     }
  1411. #endif /* NOSETKEY */
  1412.     if (c == -1) {
  1413. #ifdef EINTR
  1414. if (errno == EINTR)
  1415.   continue;
  1416. #endif /* EINTR */
  1417. conoc(BEL);
  1418. goto conret0;
  1419.     }
  1420.     c &= cmdmsk; /* Do any requested masking */
  1421. #ifndef NOSETKEY
  1422. /*
  1423.   Note: kmptr is NULL if we got character c from the keyboard, and it is
  1424.   not NULL if it came from a macro.  In the latter case, we must avoid
  1425.   expanding it again.
  1426. */
  1427.     if (!kmptr && macrotab[c]) { /* Macro definition for c? */
  1428. debug(F000,"CONNECT macro key",macrotab[c],c);
  1429. kmptr = macrotab[c]; /* Yes, set up macro pointer */
  1430. continue; /* and restart the loop, */
  1431.     } else c = keymap[c]; /* else use single-char keymap */
  1432. #endif /* NOSETKEY */
  1433.     if (
  1434. #ifndef NOSETKEY
  1435. !kmptr &&
  1436. #endif /* NOSETKEY */
  1437. (tt_escape && (c & 0x7f) == escape)) { /* Escape char? */
  1438. debug(F000,"CONNECT got escape","",c);
  1439. #ifdef BEBOX
  1440. if (recv(kbin,buf,1,0)>=0)
  1441.   c = buf[0];
  1442. else
  1443.   c = -1;
  1444. #else /* BEBOX */
  1445. c = CONGKS() & 0177; /* Read argument */
  1446. #endif /* BEBOX */
  1447. doesc((char) c); /* Handle it */
  1448. continue; /* Back to loop */
  1449.     }
  1450.     csave = c; /* Save it before translation */
  1451. /* for local echoing. */
  1452. #ifndef NOCSETS
  1453.     if (inesc[1] == ES_NORMAL) { /* If not inside escape seq.. */
  1454. /* Translate character sets */
  1455. #ifdef UNICODE
  1456. int x;
  1457. if (unicode == 1) { /* Remote is UTF-8 */
  1458.     outxcount = b_to_u((CHAR)c,outxbuf,OUTXBUFSIZ,tcssize);
  1459.     outxbuf[outxcount] = NUL;
  1460. } else if (unicode == 2) { /* Local is UTF-8 */
  1461.     x = u_to_b((CHAR)c);
  1462.     if (x < 0)
  1463.       continue;
  1464.     outxbuf[0] = (unsigned)(x & 0xff);
  1465.     outxcount = 1;
  1466.     outxbuf[outxcount] = NUL;
  1467. } else {
  1468. #endif /* UNICODE */
  1469.     if (sxo) c = (*sxo)((char)c); /* Local-intermediate */
  1470.     if (rxo) c = (*rxo)((char)c); /* Intermediate-remote */
  1471.     outxbuf[0] = c;
  1472.     outxcount = 1;
  1473.     outxbuf[outxcount] = NUL;
  1474. #ifdef UNICODE
  1475. }
  1476. #endif /* UNICODE */
  1477.     } else {
  1478. outxbuf[0] = c;
  1479. outxcount = 1;
  1480. outxbuf[outxcount] = NUL;
  1481.     }
  1482.     if (escseq)
  1483.       apcrc = chkaes((char)c,1);
  1484. #else
  1485.     outxbuf[0] = c;
  1486.     outxcount = 1;
  1487.     outxbuf[outxcount] = NUL;
  1488. #endif /* NOCSETS */
  1490.     debug(F111,"OUTXBUF",outxbuf,outxcount);
  1492.     for (i = 0; i < outxcount; i++) {
  1493. c = outxbuf[i];
  1494. /*
  1495.  If Shift-In/Shift-Out is selected and we have a 7-bit connection,
  1496.  handle shifting here.
  1497. */
  1498. if (sosi) {  /* Shift-In/Out selected? */
  1499.     if (cmask == 0177) {  /* In 7-bit environment? */
  1500. if (c & 0200) {  /* 8-bit character? */
  1501.     if (outshift == 0) { /* If not shifted, */
  1502. ttoc(dopar(SO)); /* shift. */
  1503. outshift = 1;
  1504.     }
  1505. } else {
  1506.     if (outshift == 1) { /* 7-bit character */
  1507. ttoc(dopar(SI)); /* If shifted, */
  1508. outshift = 0;    /* unshift. */
  1509.     }
  1510. }
  1511.     }
  1512.     if (c == SO) outshift = 1; /* User typed SO */
  1513.     if (c == SI) outshift = 0; /* User typed SI */
  1514. }
  1515. c &= cmask; /* Apply Kermit-to-host mask now. */
  1516. if (c == '15') { /* Carriage Return */
  1517.     int stuff = -1;
  1518.     if (tnlm) { /* TERMINAL NEWLINE ON */
  1519. stuff = LF;  /* Stuff LF */
  1520. #ifdef TNCODE
  1521.     } else if (network && /* TELNET NEWLINE ON/OFF/RAW */
  1522.        (ttnproto == NP_TELNET)) {
  1523. switch (!TELOPT_ME(TELOPT_BINARY) ? tn_nlm : tn_b_nlm){
  1524.   case TNL_CRLF:
  1525.     stuff = LF;
  1526.     break;
  1527.   case TNL_CRNUL:
  1528.     stuff = NUL;
  1529.     break;
  1530. }
  1531. #endif /* TNCODE */
  1532.     }
  1533.     if (stuff > -1) {
  1534. ttoc(dopar('15')); /* Send CR */
  1535. if (duplex) conoc('15'); /* Maybe echo CR */
  1536. c = stuff; /* Char to stuff */
  1537. csave = c;
  1538.     }
  1539. }
  1540. #ifdef TNCODE
  1541. /* If user types the 0xff character (TELNET IAC), it must be doubled. */
  1542. else /* Not CR */
  1543.   if ((dopar((CHAR) c) == IAC) && /* IAC (0xff) */
  1544.       network && (ttnproto == NP_TELNET)) { /* Send one now */
  1545.       ttoc((char)IAC); /* and the other one just below. */
  1546.   }
  1547. #endif /* TNCODE */
  1548. /* Send the character */
  1550. x = ttoc((char)dopar((CHAR) c));
  1551. if (x > -1) {
  1552.     if (duplex) { /* If half duplex, must echo */
  1553. if (debses)
  1554.   conol(dbchr(csave)); /* the original char */
  1555. else /* not the translated one */
  1556.   conoc((char)csave);
  1557. if (seslog) { /* And maybe log it too */
  1558.     c2 = csave;
  1559.     if (sessft == 0 && csave == 'r')
  1560.       c2 = 'n';
  1561.     logchar((char)c2);
  1562. }
  1563.     }
  1564. } else {
  1565.     perror("rnCan't send character");
  1566.     active = 0;
  1567.     break;
  1568. }
  1569.     }
  1570. }
  1571. if (FD_ISSET(ttyfd, &out)) {
  1572.     FD_CLR(ttyfd, &out);
  1573. }
  1574. while (gotnet > 0 || ibc > 0) {
  1575.     gotnet = 0;
  1576.     c = ckcgetc(0); /* Get next character */
  1577.     /* debug(F101,"CONNECT c","",c); */
  1578.     if (c < 0) { /* Failed... */
  1579. ckcputf(); /* Flush CONNECT output buffer */
  1580. if (msgflg) {
  1581.     printf("rnCommunications disconnect ");
  1582. #ifdef COMMENT
  1583.     if ( c == -3
  1584. #ifdef ultrix
  1585. /* This happens on Ultrix if there's no carrier */
  1586. && errno != EIO
  1587. #endif /* ultrix */
  1588. #ifdef UTEK
  1589. /* This happens on UTEK if there's no carrier */
  1590. && errno != EWOULDBLOCK
  1591. #endif /* UTEK */
  1592. )
  1593.       perror("rnCan't read character");
  1594. #endif /* COMMENT */
  1595. }
  1596. #ifdef NOSETBUF
  1597. fflush(stdout);
  1598. #endif /* NOSETBUF */
  1599. tthang(); /* Hang up the connection */
  1600. debug(F111,"CONNECT i/o error 1",ck_errstr(),errno);
  1601. goto conret0;
  1602.     }
  1603. #ifdef TNCODE
  1604.     tx = 0;
  1605.     if ((c == IAC) && network && (ttnproto == NP_TELNET)) {
  1606. #ifdef CK_ENCRYPTION
  1607. int x_auth = TELOPT_ME(TELOPT_AUTHENTICATION);
  1608. #else
  1609. int x_auth = 0;
  1610. #endif /* CK_ENCRYPTION */
  1611. int me_bin = TELOPT_ME(TELOPT_BINARY);
  1612. int u_bin = TELOPT_U(TELOPT_BINARY);
  1613. debug(F100,"CONNECT got IAC","",0);
  1614. ckcputf(); /* Dump screen-output buffer */
  1615. if ((tx = tn_doop((CHAR)(c & 0xff),duplex,ckcgetc)) == 0) {
  1616.     if (me_bin != TELOPT_ME(TELOPT_BINARY)) {
  1617. me_bin = TELOPT_ME(TELOPT_BINARY);
  1618.     } else if (u_bin != TELOPT_U(TELOPT_BINARY)) {
  1619. u_bin = TELOPT_U(TELOPT_BINARY);
  1620. #ifdef CK_ENCRYPTION
  1621. /*
  1622.   Here we have to push back any bytes we have read using block reads, so we
  1623.   can read them again using single-character reads, so they can be decrypted
  1624.   in case there was a switch to encryption in the block.  Note that we can't
  1625.   handle switches in the encryption state itself this way -- which would be
  1626.   nice, since it would eliminate the need for single-character reads.  Why?
  1627.   Because if a series of characters has already been decrypted that shouldn't
  1628.   have been, then (a) it's ruined, and (b) so is the state of the decryption
  1629.   machine.  Too bad.
  1630. */
  1631.     } else if (TELOPT_ME(TELOPT_AUTHENTICATION) != 0 &&
  1632.        TELOPT_ME(TELOPT_AUTHENTICATION) != x_auth
  1633.        ) {
  1634. if (ttpushback((CHAR *)ibp,ibc) > -1) {
  1635.     ibc = 0;
  1636.     ibp = ibuf;
  1637. }
  1638. #endif /* CK_ENCRYPTION */
  1639.     }
  1640.     continue;
  1641. } else if (tx == -1) { /* I/O error */
  1642.     if (msgflg)
  1643.       printf("rnCommunications disconnect ");
  1644. #ifdef NOSETBUF
  1645.     fflush(stdout);
  1646. #endif /* NOSETBUF */
  1647.     debug(F111,"CONNECT i/o error 2",ck_errstr(),errno);
  1648.     goto conret0;
  1649. } else if (tx == -2) { /* I/O error */
  1650.     if (msgflg)
  1651.       printf("rnConnection closed by peer");
  1652. #ifdef NOSETBUF
  1653.     fflush(stdout);
  1654. #endif /* NOSETBUF */
  1655.     debug(F111,"CONNECT i/o error 3",ck_errstr(),errno);
  1656.     goto conret0;
  1657. } else if (tx == -3) { /* I/O error */
  1658.     if (msgflg)
  1659.       printf("rnConnection closed due to telnet policy");
  1660. #ifdef NOSETBUF
  1661.     fflush(stdout);
  1662. #endif /* NOSETBUF */
  1663.     debug(F111,"CONNECT i/o error 4",ck_errstr(),errno);
  1664.     goto conret0;
  1665. } else if ((tx == 1) && (!duplex)) { /* ECHO change */
  1666.     duplex = 1; /* Turn on local echo */
  1667.     continue;
  1668. } else if ((tx == 2) && (duplex)) { /* ECHO change */
  1669.     duplex = 0;
  1670.     continue;
  1671. } else if (tx == 3) { /* Quoted IAC */
  1672.     c = parity ? 127 : 255;
  1673. }
  1674. #ifdef IKS_OPTION
  1675.                 else if (tx == 4) {   /* IKS State Change */
  1676.                     if (TELOPT_SB(TELOPT_KERMIT).kermit.u_start &&
  1677. !tcp_incoming
  1678. ) {
  1679.                         /* here we need to print a msg that the other */
  1680.                         /* side is in SERVER mode and that REMOTE     */
  1681.                         /* commands should be used.  And CONNECT mode */
  1682.                         /* should be ended.                           */
  1683. active = 0;
  1684.                     }
  1685.                 }
  1686. #endif /* IKS_OPTION */
  1687.                 else if (tx == 6) {
  1688.                     /* DO LOGOUT was received */
  1689.     if (msgflg)
  1690.       printf("rnRemote Logout ");
  1691. #ifdef NOSETBUF
  1692.     fflush(stdout);
  1693. #endif /* NOSETBUF */
  1694.     debug(F100,"CONNECT Remote Logout","",0);
  1695.     goto conret0;
  1696.                 } else
  1697.   continue; /* Negotiation OK, get next char. */
  1698.     } else if (parity)
  1699.       c &= 0x7f;
  1701.     /* I'm echoing for the remote */
  1702.             if (TELOPT_ME(TELOPT_ECHO) && tn_rem_echo)
  1703.       ttoc((char)c);
  1705. #endif /* TNCODE */
  1706.     if (debses) { /* Output character to screen */
  1707. char *s; /* Debugging display... */
  1708. s = dbchr(c);
  1709. while (*s)
  1710.   ckcputc(*s++);
  1711.     } else { /* Regular display ... */
  1712. c &= cmask; /* Apply Kermit-to-remote mask */
  1713. if (seslog && sessft) /* If binary session log */
  1714.   logchar((char)c); /* log the character now. */
  1715. #ifndef NOXFER
  1716. #ifdef CK_AUTODL
  1717. /*
  1718.   Autodownload.  Check for Kermit S packet prior to translation, since that
  1719.   can change the packet and make it unrecognizable (as when the terminal
  1720.   character set is an ISO 646 one)...  Ditto for Zmodem start packet.
  1721. */
  1722. if (autodl /* Autodownload enabled? */
  1723. #ifdef IKS_OPTION
  1724.     || TELOPT_SB(TELOPT_KERMIT).kermit.me_start
  1725. #endif /* IKS_OPTION */
  1726.     ) {
  1727.     int k;
  1728.     k = kstart((CHAR)c); /* Kermit S or I packet? */
  1729. #ifdef CK_XYZ
  1730.     if (!k && zmdlok) /* Or an "sz" start? */
  1731.       k = zstart((CHAR)c);
  1732. #endif /* CK_XYZ */
  1733.     if (k) {
  1734. int ksign = 0;
  1735. debug(F101,"CONNECT autodownload k","",k);
  1736. if (k < 0) { /* Minus-Protocol? */
  1737. #ifdef NOSERVER
  1738.     goto noserver; /* Need server mode for this */
  1739. #else
  1740.     ksign = 1; /* Remember */
  1741.     k = 0 - k; /* Convert to actual protocol */
  1742.     justone = 1; /* Flag for protocol module */
  1743. #endif /* NOSERVER */
  1744. } else
  1745.   justone = 0;
  1746. k--; /* Adjust [kz]start's return value */
  1747. if (k == PROTO_K
  1748. #ifdef CK_XYZ
  1749.     || k == PROTO_Z
  1750. #endif /* CK_XYZ */
  1751.     ) {
  1752.                             /* Damage the packet so that it doesn't trigger */
  1753.     /* autodownload detection downstream. */
  1754.                             if (k == PROTO_K) {
  1755.                                 int i, len = strlen((char *)ksbuf);
  1756.                                 for (i = 0; i < len; i++)
  1757.   ckcputc(BS);
  1758.                             }
  1759. #ifdef CK_XYZ
  1760.                             else {
  1761.                                 int i;
  1762.                                 for (i = 0; i < 3; i++)
  1763.   ckcputc(CAN);
  1764.                             }
  1765. #endif /* CK_XYZ */
  1767. #ifndef NOICP
  1768.     sprintf(apcbuf,
  1769.     "set proto %s, %s, set proto %s",
  1770.     ptab[k].p_name,
  1771.     ksign ? "server" : "receive",
  1772.     ptab[protocol].p_name
  1773.     );
  1774.     apclength = strlen(apcbuf);
  1775.     debug(F111,"CONNECT ksbuf",ksbuf,k);
  1776.     debug(F110,"CONNECT autodownload",apcbuf,0);
  1777.     apcactive = APC_LOCAL;
  1778.     ckcputf(); /* Force screen update */
  1779.     goto conret1;
  1780. #else
  1781. /*
  1782.   Here's another way that doesn't require APC, but then we'll have to change
  1783.   all the other CONNECT modules, and then the mainline code that calls them.
  1784. */
  1785.     {
  1786. extern char sstate;
  1787. sstate = ksign ? 'x' : 'v';
  1788. proto();
  1789.     }
  1790. #endif /* NOICP */
  1791. }
  1792.     }
  1793. }
  1794. #ifdef NOSERVER
  1795.       noserver:
  1796. #endif /* NOSERVER */
  1798. #endif /* CK_AUTODL */
  1799. #endif /* NOXFER */
  1800. if (sosi) { /* Handle SI/SO */
  1801.     if (c == SO) { /* Shift Out */
  1802. inshift = 1;
  1803. continue;
  1804.     } else if (c == SI) { /* Shift In */
  1805. inshift = 0;
  1806. continue;
  1807.     }
  1808.     if (inshift) c |= 0200;
  1809. }
  1810. inxbuf[0] = c; /* In case there is no translation */
  1811. inxcount = 1; /* ... */
  1812. #ifndef NOCSETS
  1813. if (inesc[0] == ES_NORMAL /* If not in an escape sequence */
  1814.     && !printing /* and not in transparent print */
  1815.     ) { /* Translate character sets */
  1816. #ifdef UNICODE
  1817.     int x;
  1818.     if (unicode == 1) { /* Remote is UTF-8 */
  1819. x = u_to_b((CHAR)c);
  1820. if (x == -1)
  1821.   continue;
  1822. else if (x == -2) { /* LS or PS */
  1823.     inxbuf[0] = CR;
  1824.     inxbuf[1] = LF;
  1825.     inxcount = 2;
  1826. } else if (x == -9) { /* UTF-8 error */
  1827.     inxbuf[0] = '?';
  1828.     inxbuf[1] = u_to_b2();
  1829.     inxcount = 2;
  1830. } else {
  1831.     inxbuf[0] = (unsigned)(x & 0xff);
  1832. }
  1833. c = inxbuf[0];
  1834.     } else if (unicode == 2) { /* Local is UTF-8 */
  1835. inxcount = b_to_u((CHAR)c,inxbuf,OUTXBUFSIZ,tcssize);
  1836. c = inxbuf[0];
  1837.     } else {
  1838. #endif /* UNICODE */
  1839. if (sxi) c = (*sxi)((CHAR)c);
  1840. if (rxi) c = (*rxi)((CHAR)c);
  1841. inxbuf[0] = c;
  1842. #ifdef UNICODE
  1843.     }
  1844. #endif /* UNICODE */
  1845. }
  1846. #endif /* NOCSETS */
  1848. #ifndef NOESCSEQ
  1849. if (escseq) { /* If handling escape sequences */
  1850.     oldprt = printing;      /* remember printer state */
  1851.     apcrc = chkaes((char)c,0); /* and update escseq state. */
  1852.     if (printing && !oldprt) /* If printer was turned on */
  1853.       continue; /* don't print final char of escseq */
  1854. }
  1855. #ifdef CK_APC
  1856. /*
  1857.   If we are handling APCs, we have several possibilities at this point:
  1858.    1. Ordinary character to be written to the screen.
  1859.    2. An Esc; we can't write it because it might be the beginning of an APC.
  1860.    3. The character following an Esc, in which case we write Esc, then char,
  1861.       but only if we have not just entered an APC sequence.
  1862. */
  1863. if (escseq && apcstatus != APC_OFF) {
  1864.     if (inesc[0] == ES_GOTESC) /* Don't write ESC yet */
  1865.       continue;
  1866.     else if (oldesc[0] == ES_GOTESC && !apcactive) {
  1867. debug(F100,"XXX WRITING ESC","",0);
  1868. ckcputc(ESC); /* Write saved ESC */
  1869. if (seslog && !sessft) logchar((char)ESC);
  1870.     } else if (apcrc) { /* We have an APC */
  1871. debug(F111,"CONNECT APC complete",apcbuf,apclength);
  1872. ckcputf(); /* Force screen update */
  1873. goto conret1;
  1874.     }
  1875. }
  1876. #endif /* CK_APC */
  1877. #endif /* NOESCSEQ */
  1879. debug(F111,"INXBUF",inxbuf,inxcount);
  1880. for (i = 0; i < inxcount; i++) { /* Loop thru */
  1881.     c = inxbuf[i]; /* input expansion buffer... */
  1882.     if (
  1883. #ifdef CK_APC
  1884. !apcactive && /* Don't display APC sequences */
  1885. #endif /* CK_APC */
  1886. !printing /* or transparent print material */
  1888. ) {
  1889. c &= cmdmsk; /* Apply command mask. */
  1890. if (c == CR && tt_crd) { /* SET TERM CR-DISPLA CRLF? */
  1891.     ckcputc(c); /* Yes, output CR */
  1892.     if (seslog && !sessft) logchar((char)c);
  1893.     c = LF; /* and insert a linefeed */
  1894. }
  1895. ckcputc(c); /* Write character to screen */
  1896.     }
  1897.     if (seslog && !sessft) /* Handle session log. */
  1898.       logchar((char)c);
  1899. #ifdef XPRINT
  1900. if (printing && !inesc[0]) { /* Do transparent printing. */
  1901.     /* zchout() can't be used because */
  1902.     /* it's buffered differently. */
  1903.     cbuf[0] = c;
  1904.     zsoutx(ZMFILE,(char *)cbuf,1);
  1905. }
  1906. #endif /* XPRINT */
  1908. #ifdef CK_TRIGGER
  1909.     /* Check for trigger string */
  1910.     if (tt_trigger[0]) {
  1911. int i;
  1912. if ((i = autoexitchk((CHAR)c)) > -1) {
  1913.     makestr(&triggerval,tt_trigger[i]);
  1914.     ckcputf(); /* Force screen update */
  1915. #ifdef NOSETBUF
  1916.     fflush(stdout); /* I mean really force it */
  1917. #endif /* NOSETBUF */
  1918.     goto conret1;
  1919. }
  1920.     }
  1921. #endif /* CK_TRIGGER */
  1922. }
  1923.     }
  1924. }
  1925. #ifndef BEBOX
  1926. if (FD_ISSET(scrnout, &out)) {
  1927.     FD_CLR(scrnout, &out);
  1928. }
  1929. #endif /* BEBOX */
  1930.     } /* End of big loop */
  1931.   conret1: /* Come here to succeed */
  1932.     rc = 1;
  1933.   conret0: /* Common exit point */
  1934. #ifdef BEBOX
  1935.     {
  1936. long ret_val;
  1937. closesocket(pair[0]);
  1938. closesocket(pair[1]);
  1939. x = kill(tid,SIGKILLTHR); /* Kill thread */
  1940. wait_for_thread (tid, &ret_val);
  1941.     }
  1942. #endif /* BEBOX */
  1943.     conres();
  1944.     if (dohangup > 0) {
  1945. #ifndef NODIAL
  1946. extern int dialmhu;
  1947. #endif /* NODIAL */
  1948. #ifdef NETCONN
  1949. if (network)
  1950.   ttclos(0);
  1951. #endif /* NETCONN */
  1953. #ifndef COMMENT
  1954. /*
  1955.   This is bad because if they said SET MODEM HANGUP-METHOD MODEM-COMMAND,
  1956.   they mean it -- we shouldn't fall back on tthang() if mdmhup() fails,
  1957.   because maybe they have some special kind of connection.  On the other
  1958.   hand, making this change prevents dialing from working at all in some
  1959.   cases.  Further study needed.
  1960. */
  1961. #ifndef NODIAL
  1962. if (dohangup > 1) /* User asked for it */
  1963.   if (mdmhup() < 1) /* Maybe hang up via modem */
  1964. #endif /* NODIAL */
  1965.     tthang(); /* And make sure we don't hang up */
  1966. #else
  1967. if (!network) { /* Serial connection. */
  1968.     if (dialmhu) /* Hang up the way they said. */
  1969.       mdmhup();
  1970.     else
  1971.       tthang();
  1972. }
  1973. #endif /* COMMENT */
  1974. dohangup = 0; /* again unless requested again. */
  1975.     }
  1976.     if (quitnow) /* Exit now if requested. */
  1977.       doexit(GOOD_EXIT,xitsta);
  1978.     if (msgflg
  1979. #ifdef CK_APC
  1980. && !apcactive
  1981. #endif /* CK_APC */
  1982. )
  1983.       printf("(Back at %s)", *myhost ? myhost : "local UNIX system");
  1984. #ifdef CK_APC
  1985.     if (!apcactive)
  1986. #endif /* CK_APC */
  1987.       printf("n");
  1988.     what = W_NOTHING; /* So console modes set right. */
  1989. #ifndef NOCSETS
  1990.     language = langsv; /* Restore language */
  1991. #endif /* NOCSETS */
  1992. #ifdef CK_APC
  1993.     debug(F101,"CONNECT exit apcactive","",apcactive);
  1994.     debug(F101,"CONNECT exit justone","",justone);
  1995. #endif /* CK_APC */
  1996.     if (msgflg) {
  1997. #ifdef CK_APC
  1998. if (apcactive == APC_LOCAL)
  1999.   printf("n");
  2000. #endif /* CK_APC */
  2001. printf("----------------------------------------------------n");
  2002. printbar = 1;
  2003.     } else
  2004. printbar = 0;
  2005.     fflush(stdout);
  2006.     return(1);
  2007. }
  2009. /*  H C O N N E  --  Give help message for connect.  */
  2011. #define CXM_SER 1 /* Serial connections only */
  2012. #define CXM_NET 2 /* Network only (but not Telnet) */
  2013. #define CXM_TEL 4 /* Telnet only */
  2015. static struct hmsgtab {
  2016.     char * hmsg;
  2017.     int hflags;
  2018. } hlpmsg[] = {
  2019.     "  ? or H for this message",                0,
  2020.     "  0 (zero) to send the NUL (0) character", 0,
  2021.     "  B to send a BREAK signal (0.275sec)",  CXM_SER,
  2022. #ifdef NETCONN
  2023.     "  B to send a network BREAK",            CXM_NET,
  2024.     "  B to send a Telnet BREAK",             CXM_TEL,
  2025. #endif /* NETCONN */
  2026. #ifdef CK_LBRK
  2027.     "  L to send a Long BREAK (1.5sec)",      CXM_SER,
  2028. #endif /* CK_LBRK */
  2029. #ifdef NETCONN
  2030.     "  I to send a network interrupt packet", CXM_NET,
  2031.     "  I to send a Telnet Interrupt request", CXM_TEL,
  2032. #ifdef TNCODE
  2033.     "  A to send Telnet Are-You-There?",      CXM_TEL,
  2034. #endif /* TNCODE */
  2035. #endif /* NETCONN */
  2036.     "  U to hangup and close the connection", 0,
  2037.     "  Q to hangup and quit Kermit",          0,
  2038.     "  S for status",                         0,
  2039. #ifdef NOPUSH
  2040.     "  ! to push to local shell (disabled)",  0,
  2041.     "  Z to suspend (disabled)",              0,
  2042. #else
  2043.     "  ! to push to local shell",             0,
  2044. #ifdef NOJC
  2045.     "  Z to suspend (disabled)",              0,
  2046. #else
  2047.     "  Z to suspend",                         0,
  2048. #endif /* NOJC */
  2049. #endif /* NOPUSH */
  2050.     "  \ backslash code:",                   0,
  2051.     "    \nnn  decimal character code",      0,
  2052.     "    \Onnn octal character code",        0,
  2053.     "    \Xhh  hexadecimal character code;", 0,
  2054.     "    terminate with Carriage Return.",    0,
  2055.     "  Type the escape character again to send the escape character itself,",0,
  2056.     "  or press the space-bar to resume the CONNECT session.",               0,
  2057.     NULL, 0
  2058. };
  2060. int
  2061. hconne() {
  2062.     int c, i, cxtype;
  2063.     if (network)
  2064.       cxtype = (ttnproto == NP_TELNET) ? CXM_TEL : CXM_NET;
  2065.     else
  2066.       cxtype = CXM_SER;
  2068.     conol("rn----------------------------------------------------rn");
  2069.     conoll("Press:");
  2070.     conol("  C to return to ");
  2071.     conoll(*myhost ? myhost : "the C-Kermit prompt");
  2072.     for (i = 0; hlpmsg[i].hmsg; i++) {
  2073. if (!(hlpmsg[i].hflags) || (hlpmsg[i].hflags == cxtype))
  2074.   conoll(hlpmsg[i].hmsg);
  2075.     }
  2076.     conol("Press a key>"); /* Prompt for command. */
  2077.     c = CONGKS() & 0177; /* Get character, strip any parity. */
  2078.     /* No key mapping or translation here */
  2079.     if (c != CMDQ)
  2080.       conoll("");
  2081.     conoll("----------------------------------------------------");
  2082.     return(c); /* Return it. */
  2083. }
  2086. /*  D O E S C  --  Process an escape character argument  */
  2088. VOID
  2089. #ifdef CK_ANSIC
  2090. doesc(char c)
  2091. #else
  2092. doesc(c) char c;
  2093. #endif /* CK_ANSIC */
  2094. /* doesc */ {
  2095.     CHAR d;
  2097.     debug(F101,"CONNECT doesc","",c);
  2098.     while (1) {
  2099. if (c == escape) { /* Send escape character */
  2100.     d = dopar((CHAR) c); ttoc((char) d); return;
  2101.      } else /* Or else look it up below. */
  2102.     if (isupper(c)) c = tolower(c);
  2104. switch(c) {
  2106.   case 'c': /* Escape back to prompt */
  2107.   case '3':
  2108. #ifdef NOICP
  2109.     conoll("");
  2110.     conoll("");
  2111.     conoll(
  2112. "  WARNING: This version of C-Kermit has no command processor to escape"
  2113.    );
  2114.     conoll(
  2115. "  back to.  To return to your local system, log out from the remote and/or"
  2116.    );
  2117.     conoll(
  2118. "  use the escape character followed by the letter U to close (hang Up) the"
  2119.    );
  2120.     conoll(
  2121. "  connection.  Resuming your session..."
  2122.    );
  2123.     conoll("");
  2124.     return;
  2125. #else
  2126.     active = 0; conol("rn"); return;
  2127. #endif /* NOICP */
  2129.   case 'b': /* Send a BREAK signal */
  2130.   case '2':
  2131.     ttsndb(); return;
  2133. #ifdef NETCONN
  2134.   case 'i': /* Send Interrupt */
  2135.   case '11':
  2136. #ifdef TCPSOCKET
  2137. #ifndef IP
  2138. #define IP 244
  2139. #endif /* IP */
  2140.     if (network && ttnproto == NP_TELNET) { /* TELNET */
  2141. temp[0] = (CHAR) IAC; /* I Am a Command */
  2142. temp[1] = (CHAR) IP; /* Interrupt Process */
  2143. temp[2] = NUL;
  2144. ttol((CHAR *)temp,2);
  2145.     } else
  2146. #endif /* TCPSOCKET */
  2147.       conoc(BEL);
  2148.     return;
  2150. #ifdef TCPSOCKET
  2151.   case 'a': /* "Are You There?" */
  2152.   case '1':
  2153. #ifndef AYT
  2154. #define AYT 246
  2155. #endif /* AYT */
  2156.     if (network && ttnproto == NP_TELNET) {
  2157. temp[0] = (CHAR) IAC; /* I Am a Command */
  2158. temp[1] = (CHAR) AYT; /* Are You There? */
  2159. temp[2] = NUL;
  2160. ttol((CHAR *)temp,2);
  2161.     } else conoc(BEL);
  2162.     return;
  2163. #endif /* TCPSOCKET */
  2164. #endif /* NETCONN */
  2166. #ifdef CK_LBRK
  2167.   case 'l': /* Send a Long BREAK signal */
  2168.     ttsndlb(); return;
  2169. #endif /* CK_LBRK */
  2171.   case 'u': /* Hangup */
  2172.        /* case '10': */ /* No, too dangerous */
  2173.     dohangup = 2; active = 0; conol("rnHanging up "); return;
  2175.   case 'q': /* Quit */
  2176.     dohangup = 2; quitnow = 1; active = 0; conol("rn"); return;
  2178.   case 's': /* Status */
  2179.     conoll("");
  2180.     conoll("----------------------------------------------------");
  2181. #ifdef PTYORPIPE
  2182.     if (ttpipe)
  2183.       sprintf(temp, " Pipe: "%s"", ttname);
  2184.     else if (ttpty)
  2185.       sprintf(temp, " Pty: "%s"", ttname);
  2186.     else
  2187. #endif /* PTYORPIPE */
  2188.       sprintf(temp, " %s: %s", (network ? "Host" : "Device"), ttname);
  2189.     conoll(temp);
  2190.     if (!network && speed >= 0L) {
  2191. sprintf(temp,"Speed %ld", speed);
  2192. conoll(temp);
  2193.     }
  2194.     sprintf(temp," Terminal echo: %s", duplex ? "local" : "remote");
  2195.     conoll(temp);
  2196.     sprintf(temp," Terminal bytesize: %d", (cmask  == 0177) ? 7 : 8);
  2197.     conoll(temp);
  2198.     sprintf(temp," Command bytesize: %d", (cmdmsk == 0177) ? 7 : 8 );
  2199.     conoll(temp);
  2200.     sprintf(temp," Parity: %s", parnam(parity));
  2201.     conoll(temp);
  2202. #ifndef NOXFER
  2203.     sprintf(temp," Autodownload: %s", autodl ? "on" : "off");
  2204.     conoll(temp);
  2205. #endif /* NOXFER */
  2206.     sprintf(temp," Session log: %s", *sesfil ? sesfil : "(none)");
  2207.     conoll(temp);
  2208. #ifndef NOSHOW
  2209.     if (!network) shomdm();
  2210. #endif /* NOSHOW */
  2211. #ifdef CKLOGDIAL
  2212.     {
  2213. long z;
  2214. z = dologshow(0);
  2215. if (z > -1L) {
  2216.     sprintf(temp," Elapsed time: %s",hhmmss(z));
  2217.     conoll(temp);
  2218. }
  2219.     }
  2220. #endif /* CKLOGDIAL */
  2221.     conoll("----------------------------------------------------");
  2222.     return;
  2224.   case 'h': /* Help */
  2225.   case '?': /* Help */
  2226.     c = hconne(); continue;
  2228.   case '0': /* Send a null */
  2229.     c = ''; d = dopar((CHAR) c); ttoc((char) d); return;
  2231.   case 'z': case '32': /* Suspend */
  2232. #ifndef NOPUSH
  2233.     if (!nopush)
  2234.       stptrap(0);
  2235.     else
  2236.       conoc(BEL);
  2237. #else
  2238.     conoc(BEL);
  2239. #endif /* NOPUSH */
  2240.     return;
  2242.   case '@': /* Start inferior command processor */
  2243.   case '!':
  2244. #ifndef NOPUSH
  2245.     if (!nopush) {
  2246. conres();       /* Put console back to normal */
  2247. zshcmd("");       /* Fork a shell. */
  2248. if (conbin((char)escape) < 0) {
  2249.     printf("Error resuming CONNECT sessionn");
  2250.     active = 0;
  2251. }
  2252.     } else conoc(BEL);
  2253. #else
  2254.     conoc(BEL);
  2255. #endif /* NOPUSH */
  2256.     return;
  2258.   case SP: /* Space, ignore */
  2259.     return;
  2261.   default: /* Other */
  2262.     if (c == CMDQ) { /* Backslash escape */
  2263. int x;
  2264. ecbp = ecbuf;
  2265. *ecbp++ = c;
  2266. while (((c = (CONGKS() & cmdmsk)) != 'r') && (c != 'n'))
  2267.   *ecbp++ = c;
  2268. *ecbp = NUL; ecbp = ecbuf;
  2269. x = xxesc(&ecbp); /* Interpret it */
  2270. if (x >= 0) { /* No key mapping here */
  2271.     c = dopar((CHAR) x);
  2272.     ttoc((char) c);
  2273.     return;
  2274. } else { /* Invalid backslash code. */
  2275.     conoc(BEL);
  2276.     return;
  2277. }
  2278.     }
  2279.     conoc(BEL); return;  /* Invalid esc arg, beep */
  2280.      }
  2281.     }
  2282. }
  2283. #endif /* NOLOCAL */