home *** CD-ROM | disk | FTP | other *** search
/ Club Amiga de Montreal - CAM / CAM_CD_1.iso / files / 019.lha / Aterm / lckfns1.c < prev    next >
Encoding:
C/C++ Source or Header  |  1986-11-10  |  27.5 KB  |  909 lines
  1. char *fnsv = "C-Kermit functions, 4LC(001) 21 Jun 85";
  2.  
  3. /*  C K C F N S  --  System-independent Kermit protocol support functions.  */
  4.  
  5. /*  ...Part 1 (others moved to ckcfn2 to make this module small enough) */
  6. /*
  7.  Author: Frank da Cruz (SY.FDC@CU20B),
  8.  Columbia University Center for Computing Activities, January 1985.
  9.  Copyright (C) 1985, Trustees of Columbia University in the City of New York.
  10.  Permission is granted to any individual or institution to use, copy, or
  11.  redistribute this software so long as it is not sold for profit, provided this
  12.  copyright notice is retained.
  13. */
  14. /*
  15.  System-dependent primitives defined in:
  16.  
  17.    lcktio.c -- terminal i/o
  18.    lckfio.c -- file i/o, directory structure
  19. */
  20. #include "stdio.h"
  21. #include "lckerm.h"
  22. #include "lckdeb.h"
  23.  
  24. #ifndef NULL
  25. #define NULL 0
  26. #endif
  27.  
  28. /* Externals from lckmain.c */
  29. extern int spsiz, rpsiz, timint, rtimo, npad, chklen, ebq, ebqflg, rpt, rptq,
  30.  rptflg, capas;
  31. extern int filatr, nxtcas, capflg, wndsiz, wndmax, sldwnd, window;
  32. extern int pktnum, prvpkt, sndtyp, bctr, bctu,
  33.  size, osize, maxsize, spktl, nfils, warn, timef;
  34. extern int parity, speed, turn, turnch,
  35.  delay, displa, pktlog, tralog, seslog, xflg, mypadn;
  36. extern long filcnt, ffc, flci, flco, tlci, tlco, tfc, fsize;
  37. extern int deblog, hcflg, binary, fncnv, local, server, cxseen, czseen;
  38. extern CHAR padch, mypadc, seol, eol, ctlq, myctlq, sstate;
  39. extern CHAR filnam[], sndpkt[], recpkt[], data[], srvcmd[], *srvptr, stchr,
  40.  mystch;
  41. extern CHAR fildat[];
  42. extern CHAR *cmarg, *cmarg2, **cmlist;
  43. long zchki(), zfree();
  44. CHAR *strcpy();
  45.  
  46. /* Variables local to this module */
  47.  
  48. static CHAR *memptr;            /* Pointer for memory strings */
  49.  
  50. static CHAR cmdstr[100];        /* Unix system command string */
  51.  
  52. static int  sndsrc;            /* Flag for where to send from: */
  53.                     /* -1: name in cmdata */
  54.                     /*  0: stdin          */
  55.                     /* >0: list in cmlist */
  56.  
  57. static int  memstr;            /* Flag for input from memory string */
  58. static int t,                 /* Current character */
  59.      next;                /* Next character */
  60.  
  61. /*  E N C S T R  --  Encode a string from memory. */
  62.  
  63. /*  Call this instead of getpkt() if source is a string, rather than a file. */
  64.  
  65. encstr(s) CHAR* s; {
  66.     int m; CHAR *p;
  67.  
  68.     m = memstr; p = memptr;        /* Save these. */
  69.  
  70.     memptr = s;             /* Point to the string. */
  71.     memstr = 1;             /* Flag memory string as source. */
  72.     next = -1;                /* Initialize character lookahead. */
  73.     getpkt(spsiz);            /* Fill a packet from the string. */
  74.     memstr = m;             /* Restore memory string flag */
  75.     memptr = p;             /* and pointer */
  76.     next = -1;                /* Put this back as we found it. */
  77. }
  78.  
  79. /* E N C O D E - Kermit packet encoding procedure */
  80.  
  81. encode(a) CHAR a; {            /* The current character */
  82.     int a7;                /* Low order 7 bits of character */
  83.     int b8;                /* 8th bit of character */
  84.  
  85.     if (rptflg) {            /* Repeat processing? */
  86.     if (a == next) {        /* Got a run... */
  87.         if (++rpt < 94)        /* Below max, just count */
  88.         return;
  89.         else if (rpt == 94) {    /* Reached max, must dump */
  90.         data[size++] = rptq;
  91.         data[size++] = tochar(rpt);
  92.         rpt = 0;
  93.         }
  94.     } else if (rpt == 1) {        /* Run broken, only 2? */
  95.         rpt = 0;            /* Yes, reset repeat flag & count. */
  96.         encode(a);            /* Do the character twice. */
  97.         if (size <= maxsize) osize = size;
  98.         rpt = 0;
  99.         encode(a);
  100.         return;
  101.     } else if (rpt > 1) {        /* More than two */
  102.         data[size++] = rptq;    /* Insert the repeat prefix */
  103.         data[size++] = tochar(++rpt); /* and count. */
  104.         rpt = 0;            /* Reset repeat counter. */
  105.     }
  106.     }
  107.     a7 = a & 0177;            /* Isolate ASCII part */
  108.     b8 = a & 0200;            /* and 8th (parity) bit. */
  109.  
  110.     if (ebqflg && b8) {         /* Do 8th bit prefix if necessary. */
  111.     data[size++] = ebq;
  112.     a = a7;
  113.     }
  114.     if ((a7 < SP) || (a7==DEL)) {    /* Do control prefix if necessary */
  115.     data[size++] = myctlq;
  116.     a = ctl(a);
  117.     }
  118.     if (a7 == myctlq)            /* Prefix the control prefix */
  119.     data[size++] = myctlq;
  120.  
  121.     if ((rptflg) && (a7 == rptq))    /* If it's the repeat prefix, */
  122.     data[size++] = myctlq;        /* quote it if doing repeat counts. */
  123.  
  124.     if ((ebqflg) && (a7 == ebq))    /* Prefix the 8th bit prefix */
  125.     data[size++] = myctlq;        /* if doing 8th-bit prefixes */
  126.  
  127.     data[size++] = a;            /* Finally, insert the character */
  128.     data[size] = '\0';                  /* itself, and mark the end. */
  129. }
  130.  
  131. /* D E C O D E    --  Kermit packet decoding procedure */
  132.  
  133. /* Call with string to be decoded and an output function. */
  134. /* Returns 0 on success, -1 on failure (e.g. disk full).  */
  135.  
  136. decode(buf,fn) CHAR *buf; int (*fn)(); {
  137.     unsigned int a, a7, b8;        /* Low order 7 bits, and the 8th bit */
  138.  
  139.     rpt = 0;                /* Initialize repeat count. */
  140.     while ((a = *buf++) != '\0') {
  141.     if (rptflg) {            /* Repeat processing? */
  142.         if (a == rptq) {        /* Yes, got a repeat prefix? */
  143.         rpt = unchar(*buf++);    /* Yes, get the repeat count, */
  144.         a = *buf++;        /* and get the prefixed character. */
  145.         }
  146.     }
  147.     b8 = 0;             /* Check high order "8th" bit */
  148.     if (ebqflg) {            /* 8th-bit prefixing? */
  149.         if (a == ebq) {        /* Yes, got an 8th-bit prefix? */
  150.         b8 = 0200;        /* Yes, remember this, */
  151.         a = *buf++;        /* and get the prefixed character. */
  152.         }
  153.     }
  154.     if (a == ctlq) {        /* If control prefix, */
  155.         a  = *buf++;        /* get its operand. */
  156.         a7 = a & 0177;        /* Only look at low 7 bits. */
  157.         if ((a7 >= 0100 && a7 <= 0137) || a7 == '?') /* Uncontrollify */
  158.         a = ctl(a);         /* if in control range. */
  159.     }
  160.     a |= b8;            /* OR in the 8th bit */
  161.     if (rpt == 0) rpt = 1;        /* If no repeats, then one */
  162. #ifdef NLCHAR
  163.     if (!binary) {            /* If in text mode, */
  164.         if (a == CR) continue;    /* discard carriage returns, */
  165.         if (a == LF) a = NLCHAR;    /* convert LF to system's newline. */
  166.     }
  167. #endif
  168.     for (; rpt > 0; rpt--) {    /* Output the char RPT times */
  169.         ffc++, tfc++;        /* Count the character */
  170.         if ((*fn)(a) < 0) return(-1); /* Send it to the output function. */
  171.     }
  172.     }
  173.     return(0);
  174. }
  175.  
  176. /*  Output functions passed to 'decode':  */
  177.  
  178. putsrv(c) CHAR c; {    /*  Put character in server command buffer  */
  179.     *srvptr++ = c;
  180.     *srvptr = '\0';     /* Make sure buffer is null-terminated */
  181.     return(0);
  182. }
  183.  
  184.  
  185. putfil(c) CHAR c; {            /*  Output char to file. */
  186.     if (zchout(ZOFILE,c) < 0) {
  187.     czseen = 1;            /* If write error... */
  188.     debug(F101,"putfil zchout write error, setting czseen","",1);
  189.     return(-1);
  190.     }
  191.     return(0);
  192. }
  193.  
  194. /*  G E T P K T -- Fill a packet data field  */
  195.  
  196. /*
  197.  Gets characters from the current source -- file or memory string.
  198.  Encodes the data into the packet, filling the packet optimally.
  199.  
  200.  Uses global variables:
  201.  t     -- current character.
  202.  next  -- next character.
  203.  data  -- the packet data buffer.
  204.  size  -- number of characters in the data buffer.
  205.  
  206. Returns the size as value of the function, and also sets global size,
  207. and fills (and null-terminates) the global data array.
  208.  
  209. Before calling getpkt the first time for a given source (file or string),
  210. set the variable 'next' to -1.
  211. */
  212.  
  213. getpkt(maxsize) int maxsize; {        /* Fill one packet buffer */
  214.     int i;                /* Loop index. */
  215.  
  216.     static CHAR leftover[6] = { '\0', '\0', '\0', '\0', '\0', '\0' };
  217.  
  218.     debug(F101,"getpkt, entering with next","",next);
  219.     debug(F101," t","",t);
  220.  
  221.     if (next < 0) {        /* If first time through, */
  222.     t = getchxx();          /* get first character of file, */
  223.     *leftover = '\0';       /* discard any interrupted leftovers. */
  224.     }
  225.  
  226.     /* Do any leftovers */
  227.  
  228.     for (size = 0; (data[size] = leftover[size]) != '\0'; size++)
  229.     ;
  230.     *leftover = '\0';
  231.  
  232.     /* Now fill up the rest of the packet. */
  233.  
  234.     rpt = 0;                /* Clear out any old repeat count. */
  235.     while(t >= 0) {            /* Until EOF... */
  236.     next = getchxx();          /* Get next character for lookahead. */
  237.     osize = size;            /* Remember current position. */
  238.     encode(t);            /* Encode the current character. */
  239.     t = next;            /* Next is now current. */
  240.     next = 0;            /* No more next. */
  241.  
  242.     if (size == maxsize) {        /* If the packet is exactly full, */
  243.         debug(F101,"getpkt exact fit","",size);
  244.         return(size);        /* and return. */
  245.     }
  246.     if (size > maxsize) {        /* If too big, save some for next. */
  247.         for (i = 0; (leftover[i] = data[osize+i]) != '\0'; i++)
  248.         ;
  249.         debug(F111,"getpkt leftover",leftover,size);
  250.         debug(F101," osize","",osize);
  251.         size = osize;        /* Return truncated packet. */
  252.         data[size] = '\0';
  253.         return(size);
  254.     }
  255.     }
  256.     debug(F101,"getpkt eof/eot","",size);
  257.     return(size);            /* Return any partial final buffer. */
  258. }
  259.  
  260. /*  G E T C H X X  -- Get the next character from file (or pipe). */
  261. /*  renamed by Jan A. van der Eijk, because getch() is a standard C function */
  262. /*
  263.  On systems like Unix, the Macintosh, etc, that use a single character
  264.  (NLCHAR, defined in ckcdeb.h) to separate lines in text files, and
  265.  when in text/ascii mode (binary == 0), this function maps the newline
  266.  character to CRLF.  If NLCHAR is not defined, then this mapping is
  267.  not done, even in text mode.
  268. */
  269. getchxx() {                  /* Get next character */
  270.     int x; CHAR a;            /* The character to return. */
  271.     static int b = 0;            /* A character to remember. */
  272.  
  273.     if (b > 0) {            /* Do we have a LF saved? */
  274.     b = 0;                /* Yes, return that. */
  275.     return(LF);
  276.     }
  277.  
  278.     if (memstr)             /* Try to get the next character */
  279.     x = ((a = *memptr++) == '\0');  /* from the appropriate source, */
  280.     else                /* memory or the current file. */
  281.     x = (zchin(ZIFILE,&a) == -1);
  282.  
  283.     if (x)
  284.     return(-1);            /* No more, return -1 for EOF. */
  285.     else {                /* Otherwise, read the next char. */
  286.     ffc++, tfc++;            /* Count it. */
  287. #ifdef NLCHAR
  288.     if (!binary && (a == NLCHAR)) { /* If nl and we must do nl-CRLF */
  289.         b = 1;            /* mapping, remember a linefeed, */
  290.         return(CR);         /* and return a carriage return. */
  291.     } else return(a);        /* General case, return the char. */
  292. #else
  293.     return(a);
  294. #endif
  295.     }
  296. }
  297.  
  298.  
  299. /*  C A N N E D  --  Check if current file transfer cancelled */
  300.  
  301. canned(buf) CHAR *buf; {
  302.     if (*buf == 'X') cxseen = 1;
  303.     if (*buf == 'Z') czseen = 1;
  304.     debug(F101,"canned: cxseen","",cxseen);
  305.     debug(F101," czseen","",czseen);
  306.     return((czseen || cxseen) ? 1 : 0);
  307. }
  308.  
  309. /*  T I N I T  --  Initialize a transaction  */
  310.  
  311. tinit() {
  312.     memstr = 0;             /* Reset memory-string flag */
  313.     memptr = NULL;            /*  and pointer */
  314.     bctu = 1;                /* Reset block check type to 1 */
  315.     filcnt = 0;             /* Reset file counter */
  316.     tfc = tlci = tlco = 0;        /* Reset character counters */
  317.     prvpkt = -1;            /* Reset packet number */
  318.     pktnum = 0;
  319.     cxseen = czseen = 0;        /* Reset interrupt flags */
  320.     *filnam = '\0';                     /* Clear file name */
  321. }
  322.  
  323.  
  324. /*  R I N I T  --  Respond to S packet    */
  325.  
  326. rinit(d) CHAR *d; {
  327.     CHAR *tp;
  328.     ztime(&tp);
  329.     tlog(F110,"Transaction begins",tp,0l); /* Make transaction log entry */
  330.     tfc = tlci = tlco = 0;
  331.     spar(d);
  332.     rpar(d);
  333.     ack1(d);
  334. }
  335.  
  336. /*  S I N I T  --  Make sure file exists, then send Send-Init packet */
  337.  
  338. sinit() {
  339.     int x; CHAR *tp;
  340.  
  341.     sndsrc = nfils;            /* Where to look for files to send */
  342.     ztime(&tp);
  343.     tlog(F110,"Transaction begins",tp,0l); /* Make transaction log entry */
  344.     debug(F101,"sinit: sndsrc","",sndsrc);
  345.     if (sndsrc < 0) {            /* Must expand from 'send' command */
  346.     nfils = zxpand(cmarg);        /* Look up literal name. */
  347.     if (nfils < 0) {
  348.         screen(SCR_EM,0,0l,"Too many files");
  349.         return(0);
  350.     } else if (nfils == 0) {    /* If none found, */
  351.         CHAR xname[100];        /* convert the name. */
  352.         zrtol(cmarg,xname);
  353.         nfils = zxpand(xname);    /* Look it up again. */
  354.     }
  355.     if (nfils < 1) {        /* If no match, report error. */
  356.         screen(SCR_EM,0,0l,"File not found");
  357.         return(0);
  358.     }
  359.     x = gnfile();            /* Position to first file. */
  360.     if (x < 1) {
  361.         screen(SCR_EM,0,0l,"No readable file to send");
  362.         return(0);
  363.     }
  364.     } else if (sndsrc > 0) {        /* Command line arglist -- */
  365.     x = gnfile();            /* Get the first file from it. */
  366.     if (x < 1) return(0);        /* (if any) */
  367.     } else if (sndsrc == 0) {        /* memory always exist... */
  368.     if ((cmarg2 != NULL) && (*cmarg2)) {
  369.         strcpy(filnam,cmarg2);    /* If F packet, filnam is used */
  370.         cmarg2 = "";                /* if provided, */
  371.     } else                /* otherwise */
  372.         return(0);            /* just use this. */
  373.     tlog(F110,"Sending from",cmdstr,0l);
  374.     }
  375.  
  376.     debug(F101,"sinit: nfils","",nfils);
  377.     debug(F110," filnam",filnam,0);
  378.     debug(F110," cmdstr",cmdstr,0);
  379.     ttflui();                /* Flush input buffer. */
  380.     x = rpar(data);            /* Send a Send-Init packet. */
  381.     if (!local) sleep(delay);
  382.     spack('S',pktnum,x,data);
  383.     return(1);
  384. }
  385.  
  386.  
  387. /*  R C V F I L -- Receive a file  */
  388.  
  389. rcvfil() {
  390.     int x;
  391.     ffc = flci = flco = 0;        /* Init per-file counters */
  392.     srvptr = srvcmd;            /* Decode file name from packet. */
  393.     decode(data,putsrv);
  394.     if (*srvcmd == '\0') *srvcmd = 'x'; /* Watch out for null F packet. */
  395.     screen(SCR_FN,0,0l,srvcmd);     /* Put it on screen */
  396.     tlog(F110,"Receiving",srvcmd,0l);   /* Transaction log entry */
  397.     if (cmarg2 != NULL && *cmarg2 != '\0') {   /* Check for alternate name */
  398.         strcpy(srvcmd,cmarg2);    /* Got one, use it. */
  399.         *cmarg2 = '\0';
  400.     } else if ( fncnv) {        /* Do not allow pathnames being send */
  401.      CHAR xname[100];        /* convert the name. */
  402.      zltor(srvcmd,xname);
  403.      strcpy(srvcmd,xname);
  404.     }
  405.     x = openo(srvcmd,filnam);        /* Try to open it */
  406.     if (x) {
  407.     tlog(F110," as",filnam,0l);
  408.     screen(SCR_AN,0,0l,filnam);
  409.     intmsg(++filcnt);
  410.     } else {
  411.     tlog(F110,"Failure to open",filnam,0l);
  412.     screen(SCR_EM,0,0l,"Can't open file");
  413.     }
  414.     return(x);                /* Pass on return code from openo */
  415. }
  416.  
  417. /*  R E O F  --  Receive End Of File  */
  418.  
  419. reof() {
  420.  
  421.     if (cxseen == 0) cxseen = (*data == 'D');
  422.     clsof();
  423.     if (cxseen || czseen) {
  424.     tlog(F100," *** Discarding","",0l);
  425.     } else {
  426.     tlog(F100," end of file","",0l);
  427.     tlog(F101,"  file characters        ","",ffc);
  428.     tlog(F101,"  communication line in  ","",flci);
  429.     tlog(F101,"  communication line out ","",flco);
  430.     }
  431. }
  432.  
  433. /*  R E O T  --  Receive End Of Transaction  */
  434.  
  435. reot() {
  436.     CHAR *tp;
  437.     cxseen = czseen = 0;
  438.     ztime(&tp);
  439.     tlog(F110,"End of transaction",tp,0l);
  440.     if (filcnt > 1) {
  441.     tlog(F101," files","",filcnt);
  442.     tlog(F101," total file characters   ","",tfc);
  443.     tlog(F101," communication line in   ","",tlci);
  444.     tlog(F101," communication line out  ","",tlco);
  445.     }
  446. }
  447.  
  448. /*  S F I L E -- Send File header packet for global "filnam" */
  449.  
  450. sfile() {
  451.     CHAR pktnam[100];            /* Local copy of name */
  452.  
  453.     if (*cmarg2 != '\0') {              /* If we have a send-as name, */
  454.     strcpy(pktnam,cmarg2);        /* copy it literally, */
  455.     cmarg2 = "";                    /* and blank it out for next time. */
  456.     } else {                /* Otherwise use actual file name: */
  457.     if (fncnv) {            /* If converting names, */
  458.         zltor(filnam,pktnam);    /* convert it to common form, */
  459.     } else {            /* otherwise, */
  460.         strcpy(pktnam,filnam);    /* copy it literally. */
  461.     }
  462.     }
  463.     debug(F110,"sfile",filnam,0);
  464.     debug(F110," pktnam",pktnam,0);
  465.     if (openi(filnam) == 0)        /* Try to open the file */
  466.     return(0);
  467.  
  468.     flci = flco = ffc = 0;        /* OK, Init counters, etc. */
  469.     encstr(pktnam);            /* Encode the name. */
  470.     nxtpkt(&pktnum);            /* Increment the packet number */
  471.     ttflui();                /* Clear pending input */
  472.     spack('F',pktnum,size,data);        /* Send the F packet */
  473.     if (displa) {
  474.     screen(SCR_FN,'F',(long)pktnum,filnam); /* Update screen */
  475.     screen(SCR_AN,0,0l,pktnam);
  476.     screen(SCR_FS,0,(long)fsize,"");
  477.     intmsg(++filcnt);        /* Count file, give interrupt msg */
  478.     }
  479.     tlog(F110,"Sending",filnam,0l);     /* Transaction log entry */
  480.     tlog(F110," as",pktnam,0l);
  481.     next = -1;                /* Init file character lookahead. */
  482.     return(1);
  483. }
  484.  
  485.  
  486. /*  S D A T A -- Send a data packet */
  487.  
  488. sdata() {
  489.     int len;
  490.     if (cxseen || czseen) return(0);    /* If interrupted, done. */
  491.     if ((len = getpkt(spsiz-chklen-3)) == 0) return(0); /* If no data, done. */
  492.     nxtpkt(&pktnum);            /* Increment the packet number */
  493.     spack('D',pktnum,len,data);         /* Send the packet */
  494.     return(1);
  495. }
  496.  
  497.  
  498. /*  S E O F -- Send an End-Of-File packet */
  499.  
  500. seof() {
  501.     nxtpkt(&pktnum);            /* Increment the packet number */
  502.     if (czseen || cxseen) {
  503.     spack('Z',pktnum,1,"D");
  504.     tlog(F100," *** interrupted, sending discard request","",0l);
  505.     } else {
  506.     spack('Z',pktnum,0,"");
  507.     tlog(F100," end of file","",0l);
  508.     tlog(F101,"  file characters        ","",ffc);
  509.     tlog(F101,"  communication line in  ","",flci);
  510.     tlog(F101,"  communication line out ","",flco);
  511.     }
  512. }
  513.  
  514.  
  515. /*  S E O T -- Send an End-Of-Transaction packet */
  516.  
  517. seot() {
  518.     CHAR *tp;
  519.     nxtpkt(&pktnum);            /* Increment the packet number */
  520.     spack('B',pktnum,0,"");
  521.     cxseen = czseen = 0;
  522.     ztime(&tp);
  523.     tlog(F110,"End of transaction",tp,0l);
  524.     if (filcnt > 1) {
  525.     tlog(F101," files","",filcnt);
  526.     tlog(F101," total file characters   ","",tfc);
  527.     tlog(F101," communication line in   ","",tlci);
  528.     tlog(F101," communication line out  ","",tlco);
  529.     }
  530. }
  531.  
  532. /*   R P A R -- Fill the data array with my send-init parameters  */
  533.  
  534. rpar(data) CHAR data[]; {
  535.     data[0] = tochar(rpsiz);        /* Biggest packet I can receive */
  536.     data[1] = tochar(rtimo);        /* When I want to be timed out */
  537.     data[2] = tochar(mypadn);        /* How much padding I need (none) */
  538.     data[3] = ctl(mypadc);        /* Padding character I want */
  539.     data[4] = tochar(eol);        /* End-Of-Line character I want */
  540.     data[5] = CTLQ;            /* Control-Quote character I send */
  541.     if (parity || ebqflg) {        /* 8-bit quoting... */
  542.         data[6] = '&';                        /* If parity or flag on, send &. */
  543.     if ((ebq > 0040 && ebq < 0100) ||   /* If flag off, then turn it on  */
  544.         (ebq > 0140 && ebq < 0177) ||   /* if other side has asked us to */
  545.         (ebq == 'Y')) ebqflg = 1;
  546.     } else {                    /* Normally, */
  547.     data[6] = 'Y';                /* just say we're willing. */
  548.     }
  549.     data[7] = bctr + '0';               /* Block check type */
  550.     data[8] = MYRPTQ;            /* Do repeat counts */
  551.     data[9] = tochar(capas);        /* Capabilities */
  552.     data[10] = tochar(wndmax);        /* Maximum window size I want */
  553.     data[11] = '\0';
  554.     return(11);             /* Return the length. */
  555. }
  556.  
  557. /*   S P A R -- Get the other system's Send-Init parameters.  */
  558.  
  559. spar(data) CHAR data[]; {
  560.     int len, x;
  561.  
  562.     len = strlen(data);         /* Number of fields */
  563.  
  564.     spsiz = (len-- > 0) ? unchar(data[0]) : DSPSIZ;    /* Packet size */
  565.     if (spsiz < 10 || spsiz > DSPSIZ) spsiz = DSPSIZ;
  566.  
  567.     x = (len-- > 0) ? unchar(data[1]) : DMYTIM; /* Timeout */
  568.     if (!timef) {            /* Only use if not overridden */
  569.     timint = x;
  570.     if (timint < 0) timint = DMYTIM;
  571.     }
  572.  
  573.     npad = 0; padch = '\0';                             /* Padding */
  574.     if (len-- > 0) {
  575.     npad = unchar(data[2]);
  576.     if (len-- > 0) padch = ctl(data[3]); else padch = 0;
  577.     }
  578.  
  579.     seol = (len-- > 0) ? unchar(data[4]) : '\r';      /* Terminator he wants */
  580.     if ((seol < 2) || (seol > 037)) seol = '\r';
  581.  
  582.     ctlq = (len-- > 0) ? data[5] : CTLQ;        /* Control prefix */
  583.  
  584.     if (len-- > 0) {
  585.     ebq = data[6];
  586.     if ((ebq > 040 && ebq < 0100) || (ebq > 0140 && ebq < 0177)) {
  587.         ebqflg = 1;
  588.     } else if ((parity || ebqflg) && (ebq == 'Y')) {
  589.         ebqflg = 1;
  590.         ebq = '&';
  591.     } else if (ebq == 'N') {
  592.         ebqflg = 0;
  593.     } else ebqflg = 0;
  594.     } else ebqflg = 0;
  595.  
  596.     chklen = 1;                     /* Block check */
  597.     if (len-- > 0) {
  598.     chklen = data[7] - '0';
  599.     if ((chklen < 1) || (chklen > 3)) chklen = 1;
  600.     }
  601.     bctr = chklen;
  602.  
  603.     if (len-- > 0) {                    /* Repeat prefix */
  604.     rptq = data[8];
  605.     rptflg = ((rptq > 040 && rptq < 0100) || (rptq > 0140 && rptq < 0177));
  606.     } else rptflg = 0;
  607.  
  608.     filatr = 0;
  609.     sldwnd = 0;
  610.     if (len-- > 0)  {                    /* Capabilities */
  611.     capflg = unchar(data[9]) & capas;        /* Supported by both */
  612.     if ( (capflg & 0x0008) == 0x0008) filatr = 1;    /* File attributes ? */
  613.     if ( (capflg & 0x0004) == 0x0004) sldwnd = 1;    /* Sliding windows ? */
  614.     }
  615.     wndsiz = (len-- > 0) ? unchar(data[10]) : 0;      /* Window size he wants */
  616.     if ( wndsiz > wndmax ) wndsiz = wndmax;
  617.     else if ( wndsiz <= 0  ) {
  618.        sldwnd = 0;
  619.        wndsiz = 0;
  620.     }
  621.     if (deblog) sdebu(len);
  622.  
  623. }
  624.  
  625. /*  S D E B U  -- Record spar results in debugging log    */
  626.  
  627. sdebu(len) int len; {
  628.     debug(F111,"spar: data",data,len);
  629.     debug(F101," spsiz ","",spsiz);
  630.     debug(F101," timint","",timint);
  631.     debug(F101," npad  ","",npad);
  632.     debug(F101," padch ","",padch);
  633.     debug(F101," eol   ","",eol);
  634.     debug(F101," ctlq  ","",ctlq);
  635.     debug(F101," ebq   ","",ebq);
  636.     debug(F101," ebqflg","",ebqflg);
  637.     debug(F101," chklen","",chklen);
  638.     debug(F101," rptq  ","",rptq);
  639.     debug(F101," rptflg","",rptflg);
  640.     debug(F101," capflg","",capflg);
  641. }
  642.  
  643. /*  G N F I L E  --  Get the next file name from a file group.    */
  644.  
  645. /*  Returns 1 if there's a next file, 0 otherwise  */
  646.  
  647. gnfile() {
  648.     int x; long y;
  649.  
  650. /* If file group interruption (C-Z) occured, fail.  */
  651.  
  652.     debug(F101,"gnfile: czseen","",czseen);
  653.  
  654.     if (czseen) {
  655.     tlog(F100,"Transaction cancelled","",0l);
  656.     return(0);
  657.     }
  658.  
  659. /* If input was memory string, there is no next file.  */
  660.  
  661.     if (sndsrc == 0) return(0);
  662.  
  663. /* If file list comes from command line args, get the next list element. */
  664.  
  665.     y = -1;
  666.     while (y < 0) {            /* Keep trying till we get one... */
  667.  
  668.     if (sndsrc > 0) {
  669.         if (nfils-- > 0) {
  670.         strcpy(filnam,*cmlist++);
  671.         debug(F111,"gnfile: cmlist filnam",filnam,nfils);
  672.         } else {
  673.         *filnam = '\0';
  674.         debug(F101,"gnfile cmlist: nfils","",nfils);
  675.         return(0);
  676.         }
  677.     }
  678.  
  679. /* Otherwise, step to next element of internal wildcard expansion list. */
  680.  
  681.     if (sndsrc < 0) {
  682.         x = znext(filnam);
  683.         debug(F111,"gnfile znext: filnam",filnam,x);
  684.         if (x == 0) return(0);
  685.     }
  686.  
  687. /* Get here with a filename. */
  688.  
  689.     y = zchki(filnam);        /* Check if file readable */
  690.     if (y < 0) {
  691.         debug(F110,"gnfile skipping:",filnam,0);
  692.         tlog(F111,filnam,"not sent, reason",(long)y);
  693.         screen(SCR_ST,ST_SKIP,0l,filnam);
  694.     } else fsize = y;
  695.     }
  696.     return(1);
  697. }
  698.  
  699. /*  O P E N I  --  Open an existing file for input  */
  700.  
  701. openi(name) CHAR *name; {
  702.     int x, filno;
  703.     if (memstr) return(1);        /* Just return if file is memory. */
  704.  
  705.     debug(F110,"openi",name,0);
  706.     debug(F101," sndsrc","",sndsrc);
  707.  
  708.     filno =  ZIFILE;    /* ... */
  709.  
  710.     debug(F101," file number","",filno);
  711.  
  712.     if (zopeni(filno,name)) {        /* Otherwise, try to open it. */
  713.     debug(F110," ok",name,0);
  714.     return(1);
  715.     } else {                /* If not found, */
  716.     CHAR xname[100];        /* convert the name */
  717.     zrtol(name,xname);        /* to local form and then */
  718.     debug(F110," zrtol:",xname,0);
  719.     x = zopeni(filno,xname);    /* try opening it again. */
  720.     debug(F101," zopeni","",x);
  721.     if (x) {
  722.         debug(F110," ok",xname,0);
  723.         return(1);            /* It worked. */
  724.     } else {
  725.         screen(SCR_EM,0,0l,"Can't open file");  /* It didn't work. */
  726.         tlog(F110,xname,"could not be opened",0l);
  727.         debug(F110," openi failed",xname,0);
  728.         return(0);
  729.     }
  730.     }
  731. }
  732.  
  733. /*  O P E N O  --  Open a new file for output.    */
  734.  
  735. /*  Returns actual name under which the file was opened in string 'name2'. */
  736.  
  737. openo(name,name2) CHAR *name, *name2; {
  738.     CHAR xname[100], *xp;
  739.  
  740.     debug(F110,"openo: name",name,0);
  741.  
  742.     if (cxseen || czseen) {        /* If interrupted, get out before */
  743.     debug(F100," open cancelled","",0); /* destroying existing file. */
  744.     return(1);            /* Pretend to succeed. */
  745.     }
  746.     xp = xname;             /* OK to proceed. */
  747.     if (fncnv)                /* If desired, */
  748.     zrtol(name,xp);         /* convert name to local form */
  749.     else                /* otherwise, */
  750.     strcpy(xname,name);        /* use it literally */
  751.  
  752.     debug(F110,"openo: xname",xname,0);
  753.  
  754.     if (warn) {             /* File collision avoidance? */
  755.     if (zchki(xname) > 0) {     /* Yes, file exists? */
  756.         znewn(xname,&xp);        /* Yes, make new name. */
  757.         strcpy(xname,xp);
  758.         debug(F110," exists, new name ",xname,0);
  759.     }
  760.     }
  761.     if (zopeno(ZOFILE,xname) == 0) {    /* Try to open the file */
  762.     debug(F110,"openo failed",xname,0);
  763.     tlog(F110,"Failure to open",xname,0l);
  764.     return(0);
  765.     } else {
  766.     strcpy(name2,xname);
  767.     debug(F110,"openo ok, name2",name2,0);
  768.     return(1);
  769.     }
  770. }
  771.  
  772.  
  773. /*  C L S I F  --  Close the current input file. */
  774.  
  775. clsif() {
  776.     if (memstr) {            /* If input was memory string, */
  777.     memstr = 0;            /* indicate no more. */
  778.     } else zclose(ZIFILE);        /* else close input file. */
  779.  
  780.     if (czseen || cxseen)
  781.     screen(SCR_ST,ST_DISC,0l,"");
  782.     else
  783.     screen(SCR_ST,ST_OK,0l,"");
  784.     cxseen = hcflg = 0;         /* Reset flags, */
  785.     *filnam = '\0';                     /* and current file name */
  786.     window = 0;             /* Reset window flag */
  787.  
  788. }
  789.  
  790.  
  791. /*  C L S O F  --  Close an output file.  */
  792.  
  793. clsof() {
  794.     zclose(ZOFILE);            /* Close it. */
  795.     if (czseen || cxseen) {
  796.     if (*filnam) zdelet(filnam);    /* Delete it if interrupted. */
  797.     debug(F100,"Discarded","",0);
  798.     tlog(F100,"Discarded","",0l);
  799.     screen(SCR_ST,ST_DISC,0l,"");
  800.     } else {
  801.     if ( filatr) zfpdat(filnam,fildat);    /* Stamp the file with orginal date */
  802.     debug(F100,"Closed","",0);
  803.     screen(SCR_ST,ST_OK,0l,"");
  804.     }
  805.     cxseen = 0;             /* Reset file interruption flag */
  806.     *filnam = '\0';                     /* and current file name. */
  807.     window = 0;             /* Reset window flag */
  808. }
  809.  
  810. /* S A T T R -- Send the attribute packet. */
  811.  
  812. /* send multiple attribute packets, in case the attribute won't fit in
  813.    current packet, set nxtcase to the case we did break out of */
  814.  
  815. sattr() {
  816.  
  817.     int index,len;
  818.  
  819.  
  820.      index = 2;                    /* start of data field */
  821.      switch(nxtcas){
  822.      case 1:
  823.     sprintf(&data[index],"%ld",fsize);    /* Convert to character string */
  824.     len = strlen(&data[index]);          /* Get the length of data field */
  825.     data[index - 2] = '1';                /* set attribute type,file size */
  826.     data[ index - 1 ] = tochar(len);      /* Put it in the packet */
  827.     index += (len + 2);              /* start of next data field */
  828.      case 2:
  829.     if (zfcdat(filnam,&data[index])) {     /* Get the time and date stamp */
  830.          len = strlen(&data[index]);       /* Get the length of data field */
  831.          if ( (index + len) > (spsiz - chklen - 3)) {
  832.           nxtcas = 2;               /* does not fit in packet */
  833.           break ;               /* start here next packet */
  834.          }
  835.          screen(SCR_DT,0,0L,&data[index]);
  836.          data[index - 2] = '#';            /* set attribute type */
  837.          data[index -1] = tochar(len);     /* Put it in the packect */
  838.          index += (len + 2);           /* start of next data field */
  839.     }
  840.      default:
  841.      nxtcas = 1;                   /* we are done for this file */
  842.      break;
  843.      }
  844.      data[index - 2] = '\0';                   /* delimit the string */
  845.      len = strlen(data);
  846.      nxtpkt(&pktnum);             /* Increment the packet number */
  847.      spack('A',pktnum,len,data);         /* Send the packet */
  848.      next = -1;
  849.      if (nxtcas > 1 ) return(1);
  850.      else return(0);            /* Last time called, return 0 */
  851.  
  852. }
  853.  
  854. /* R D A T T R -- Read the attribute packet. */
  855.  
  856. rdattr(data) CHAR data[]; {
  857.  
  858.     int len, index,i;
  859.     CHAR string[100];            /* Local scratch variable */
  860.     long int atol();
  861.  
  862.     len = strlen(data);         /* Number of fields */
  863.  
  864.     index = 0;
  865.     while (1) {
  866.  
  867.      switch(data[index++]){
  868.  
  869.      case '!':                           /*  File length in Kbytes */
  870.          len = unchar(data[index++]);
  871.          for (i=0; i < len; i++  ) string[i] = data[index++];
  872.          string[i] = '\0';
  873.          fsize = (long) (atoi(string) + 1) ;
  874.          screen(SCR_QE,0,fsize,"Approximate file size (Kbytes)");
  875.          fsize = fsize * 1024L;         /* Change size to bytes */
  876.          if ( fsize > zfree(filnam)){
  877.            cxseen = 1 ;     /* Set to true so file will be deleted */
  878.            screen(SCR_EM,0,0L,"Not Enough room to store file");
  879.            return(0);
  880.          }
  881.          break;
  882.       case '#':                          /* ISO Julian file creation date */
  883.          len = unchar(data[index++]);
  884.          for (i=0; i < len; i++ ) fildat[i] = data[index++];
  885.          fildat[i] = '\0';
  886.          screen(SCR_DT,0,0L,fildat);
  887.          break;
  888.       case    '1':                            /* file size in bytes */
  889.          len = unchar(data[index++]);
  890.          for (i=0; i < len; i++  ) string[i] = data[index++];
  891.          string[i] = '\0';
  892.          fsize = atol(string) ;
  893.          screen(SCR_QE,0,fsize,"File size (bytes)");
  894.          if ( fsize > zfree(filnam)) {
  895.            cxseen = 1 ;     /* Set to true so file will be deleted */
  896.            return(0);
  897.          }
  898.          break;
  899.       default:                /* Non supported attributes */
  900.          len = unchar(data[index++]);
  901.          for (i=0; i < len; i++  ) string[i] = data[index++];
  902.          string[i] = '\0';
  903.          break;
  904.       }
  905.       if ( data[index] == '\0') break; /* End of data packet */
  906.     }
  907.    return(1);
  908. }
  909.