/* WARNING -- This C source program generated by Wart preprocessor. */ /* Do not edit this file; edit the Wart-format source file instead, */ /* and then run it through Wart to produce a new C source file. */ /* Wart Version Info: */ char *wartv = "Wart Version 2A(009) 14 Jan 92"; char *protv = "C-Kermit Protocol Module 5A(072), 18 Sep 94"; /* -*-C-*- */ /* C K C P R O -- C-Kermit Protocol Module, in Wart preprocessor notation. */ /* Author: Frank da Cruz (fdc@columbia.edu, FDCCU@CUVMA.BITNET), Columbia University Academic Information Systems, New York City. Copyright (C) 1985, 1994, Trustees of Columbia University in the City of New York. The C-Kermit software may not be, in whole or in part, licensed or sold for profit as a software product itself, nor may it be included in or distributed with commercial products or otherwise distributed by commercial concerns to their clients or customers without written permission of the Office of Kermit Development and Distribution, Columbia University. This copyright notice must not be removed, altered, or obscured. */ #include "ckcsym.h" #include "ckcdeb.h" #include "ckcasc.h" #include "ckcker.h" /* Note -- This file may also be preprocessed by the UNIX Lex program, but you must indent the above #include statements before using Lex, and then restore them to the left margin in the resulting C program before compilation. Also, the invocation of the "wart()" function below must be replaced by an invocation of the "yylex()" function. It might also be necessary to remove comments in the %%...%% section. */ /* State definitions for Wart (or Lex) */ #define ipkt 1 #define rfile 2 #define rattr 3 #define rdata 4 #define ssinit 5 #define ssfile 6 #define ssattr 7 #define ssdata 8 #define sseof 9 #define sseot 10 #define serve 11 #define generic 12 #define get 13 #define rgen 14 /* External C-Kermit variable declarations */ extern char *versio, *srvtxt, *cmarg, *cmarg2, **cmlist, *rf_err; extern char filnam[], ttname[]; extern CHAR sstate, *rpar(), *srvptr, *data; extern int timint, rtimo, nfils, hcflg, xflg, flow, mdmtyp, network; extern int rejection; #ifdef NETCONN #ifdef CK_SPEED extern int ttnproto; /* Network protocol */ extern short ctlp[]; /* Control-character prefix table */ #endif /* CK_SPEED */ #endif /* NETCONN */ extern int cxseen, czseen, server, srvdis, local, displa, bctu, bctr, bctl; extern int quiet, tsecs, parity, backgrd, nakstate, atcapu, wslotn, winlo; extern int wslots, success, xitsta, rprintf, discard, cdtimo, keep, fdispla; extern int timef, stdinf, rscapu, sendmode, epktflg; extern int binary, bsave, bsavef, savmod, fncnv; extern long speed, ffc; extern char *DIRCMD, *DIRCM2, *DELCMD, *TYPCMD, *SPACMD, *SPACM2, *WHOCMD; extern CHAR *rdatap; extern struct zattr iattr; #ifdef pdp11 extern CHAR srvcmd[]; extern CHAR *pktmsg; #else #ifdef DYNAMIC extern CHAR *srvcmd; extern CHAR *pktmsg; #else extern CHAR srvcmd[]; extern CHAR pktmsg[]; #endif /* DYNAMIC */ #endif /* pdp11 */ #ifndef NOSPL extern int cmdlvl; char querybuf[QBUFL+1] = { NUL, NUL }; /* QUERY response buffer */ char *qbufp = querybuf; /* Pointer to it */ int qbufn = 0; /* Length of data in it */ extern int query; /* Query-active flag */ #else extern int tlevel; #endif /* NOSPL */ #ifdef NOMSEND extern int sndsrc; #endif /* NOMSEND */ /* Flags for the ENABLE and DISABLE commands */ extern int en_cwd, en_del, en_dir, en_fin, en_get, en_bye, en_hos, en_sen, en_spa, en_set, en_typ, en_who; #ifndef NOSPL extern int en_asg, en_que; #endif /* NOSPL */ /* Global variables declared here */ int what = W_NOTHING; /* What I am doing */ int whatru = 0; /* What are you */ /* Local variables */ static char vstate = 0; /* Saved State */ static char vcmd = 0; /* Saved Command */ static int x; /* General-purpose integer */ static char *s; /* General-purpose string pointer */ /* Macros - Note, BEGIN is predefined by Wart (and Lex) as "state = ", */ /* BEGIN is NOT a GOTO! */ #define TINIT if (tinit() < 0) return(-9) #define SERVE TINIT; nakstate = 1; what = W_NOTHING; cmarg2 = ""; BEGIN serve #ifdef COMMENT #define RESUME if (server) {SERVE;} else { if(!local)msleep(100); return(0); } #else #define RESUME if (server) { SERVE; } else { return(0); } #endif /* COMMENT */ #define QUIT x=quiet; quiet=1; clsif(); clsof(1); tsecs=gtimer(); quiet=x; \ return(1) #define BEGIN state = int state = 0; int wart() { int c,actno; extern char tbl[]; while (1) { c = input() - 32; if (c < 0 || c > 95) c = 0; if ((actno = tbl[c + state*96]) != -1) switch(actno) { case 1: { TINIT; /* Do Send command */ if (sinit() >= 0) BEGIN ssinit; else RESUME; } break; case 2: { TINIT; nakstate = 1; BEGIN get; } break; case 3: { /* Get */ TINIT; vstate = get; vcmd = 0; if (sipkt('I') >= 0) BEGIN ipkt; else RESUME; } break; case 4: { /* Host */ TINIT; vstate = rgen; vcmd = 'C'; if (sipkt('I') >= 0) BEGIN ipkt; else RESUME; } break; case 5: { TINIT; /* Kermit */ vstate = rgen; vcmd = 'K'; if (sipkt('I') >= 0) BEGIN ipkt; else RESUME; } break; case 6: { /* Generic */ TINIT; vstate = rgen; vcmd = 'G'; if (sipkt('I') >= 0) BEGIN ipkt; else RESUME; } break; case 7: { SERVE; } break; case 8: { int b1, b2; if (!data) TINIT; /* "ABEND" -- Tell other side. */ #ifndef pdp11 if (epktflg) { /* If because of E-PACKET command */ b1 = bctl; b2 = bctu; /* Save block check type */ bctl = bctu = 1; /* set it to 1 */ } #endif /* pdp11 */ errpkt((CHAR *)"User cancelled"); /* Send the packet */ #ifndef pdp11 if (epktflg) { /* Restore the block check */ epktflg = 0; bctl = b1; bctu = b2; } screen(SCR_EM,0,0L,"User cancelled"); #endif /* pdp11 */ success = 0; return(0); /* Return from protocol. */ } break; case 9: { /* Receive Send-Init packet. */ if (state == serve && !en_sen) { /* Not allowed if in server mode */ errpkt((CHAR *)"SEND disabled"); /* and SEND is disabled. */ SERVE; } else { /* OK to go ahead. */ nakstate = 1; /* Can send NAKs from here. */ rinit(rdatap); /* Set parameters */ bctu = bctr; /* Switch to agreed-upon block check */ bctl = (bctu == 4) ? 2 : bctu; /* Set block-check length */ what = W_RECV; /* Remember we're receiving */ resetc(); /* Reset counters */ rtimer(); /* Reset timer */ BEGIN rfile; /* Go into receive-file state */ } } break; case 10: { /* Get ack for I-packet */ int x = 0; spar(rdatap); /* Set parameters */ winlo = 0; /* Set window-low back to zero */ if (vcmd) { /* If sending a generic command */ x = scmd(vcmd,(CHAR *)cmarg); /* Do that */ vcmd = 0; /* and then un-remember it. */ } else if (vstate == get) x = srinit(); /* If sending GET command, do that. */ if (x < 0) { /* If command was too long */ errpkt((CHAR *)"Command too long for server"); /* cancel both sides. */ ermsg("Command too long for server"); success = 0; RESUME; } else { rtimer(); /* Reset the elapsed seconds timer. */ winlo = 0; /* Window back to 0, again. */ nakstate = 1; /* Can send NAKs from here. */ BEGIN vstate; /* Switch to desired state */ } } break; case 11: { /* Ignore Error reply to I packet */ int x = 0; winlo = 0; /* Set window-low back to zero */ if (vcmd) { /* In case other Kermit doesn't */ x = scmd(vcmd,(CHAR *)cmarg); /* understand I-packets. */ vcmd = 0; /* Otherwise act as above... */ } else if (vstate == get) x = srinit(); if (x < 0) { /* If command was too long */ errpkt((CHAR *)"Command too long for server"); /* cancel both sides. */ ermsg("Command too long for server"); success = 0; RESUME; } else { winlo = 0; /* Back to packet 0 again. */ freerpkt(winlo); /* Discard the Error packet. */ nakstate = 1; /* Can send NAKs from here. */ BEGIN vstate; } } break; case 12: { /* Resend of previous I-pkt ACK, same seq number! */ srinit(); /* Send the GET packet again. */ } break; case 13: { /* Get I-packet */ spar(rdatap); /* Set parameters from it */ ack1(rpar()); /* Respond with our own parameters */ pktinit(); /* Reinitialize packet numbers */ } break; case 14: { /* Get Receive-Init (GET) */ debug(F100,"R","",0); if (!en_get) { /* Only if not disabled! */ errpkt((CHAR *)"GET disabled"); SERVE; } else { /* OK to go ahead. */ #ifdef WHATAMI if (whatru & WM_FLAG) { /* Did we get WHATAMI info? */ #ifdef VMS if (binary != XYFT_I && binary != XYFT_L) #else #ifdef OS2 if (binary != XYFT_L) #endif /* OS2 */ #endif /* VMS */ binary = (whatru & WM_FMODE) ? /* Yes, set transfer mode */ XYFT_B : XYFT_T; /* automatically */ bsave = bsavef = savmod = 0; fncnv = (whatru & WM_FNAME) ? 1 : 0; /* And name conversion */ } #endif /* WHATAMI */ srvptr = srvcmd; /* Point to server command buffer */ decode(rdatap,putsrv,0); /* Decode the GET command into it */ /* Accept multiple filespecs */ cmarg2 = ""; /* Don't use cmarg2 */ cmarg = ""; /* Don't use cmarg */ #ifndef NOMSEND /* New way. */ nfils = fnparse((char *)srvcmd); /* Use cmlist instead */ #else nfils = 0 - zxpand((char *)srvcmd); #endif /* NOMSEND */ nakstate = 0; /* Now I'm the sender! */ if (sinit() >= 0) { /* Send Send-Init */ timint = chktimo(rtimo,timef); /* Switch to per-packet timer */ BEGIN ssinit; /* If successful, switch state */ } else { SERVE; } /* Else back to server command wait */ } } break; case 15: { /* Generic server command */ srvptr = srvcmd; /* Point to command buffer */ decode(rdatap,putsrv,0); /* Decode packet data into it */ putsrv('\0'); /* Insert a couple nulls */ putsrv('\0'); /* for termination */ if (srvcmd[0]) { sstate = srvcmd[0]; /* Set requested start state */ nakstate = 0; /* Now I'm the sender. */ what = W_REMO; /* Doing a REMOTE command. */ if (timint < 1) timint = chktimo(rtimo,timef); /* Switch to per-packet timer */ BEGIN generic; /* Switch to generic command state */ } else { errpkt((CHAR *)"Badly formed server command"); /* report error */ SERVE; /* & go back to server command wait */ } } break; case 16: { /* Receive Host command */ if (!en_hos) { errpkt((CHAR *)"REMOTE HOST disabled"); SERVE; } else { srvptr = srvcmd; /* Point to command buffer */ decode(rdatap,putsrv,0); /* Decode command packet into it */ putsrv('\0'); /* Null-terminate */ nakstate = 0; /* Now sending, not receiving */ if (syscmd((char *)srvcmd,"")) { /* Try to execute the command */ what = W_REMO; /* Doing a REMOTE command. */ if (timint < 1) timint = chktimo(rtimo,timef); /* Switch to per-packet timer */ BEGIN ssinit; /* If OK, send back its output */ } else { /* Otherwise */ errpkt((CHAR *)"Can't do system command"); /* report error */ SERVE; /* & go back to server command wait */ } } } break; case 17: { /* User typed Ctrl-C... */ if (!en_fin) { errpkt((CHAR *)"QUIT disabled"); SERVE; } else { success = 0; QUIT; } } break; case 18: { /* Server got a NAK in command-wait */ errpkt((CHAR *)"Did you say RECEIVE instead of GET?"); SERVE; } break; case 19: { /* Any other command in this state */ if (c != ('E' - SP) && c != ('Y' - SP)) /* except E and Y packets. */ errpkt((CHAR *)"Unimplemented server function"); /* If we answer an E with an E, we get an infinite loop. */ /* A Y (ACK) can show up here if we sent back a short-form reply to */ /* a G packet and it was echoed. ACKs can be safely ignored here. */ SERVE; /* Go back to server command wait. */ } break; case 20: { /* Got REMOTE CWD command */ if (!en_cwd) { errpkt((CHAR *)"REMOTE CD disabled"); SERVE; } else { if (!cwd((char *)(srvcmd+1))) errpkt((CHAR *)"Can't change directory"); SERVE; /* Back to server command wait */ } } break; case 21: { /* Got REMOTE PWD command */ if (!en_cwd) { errpkt((CHAR *)"REMOTE CD disabled"); SERVE; } else { if (encstr((CHAR *)zgtdir()) > -1) /* Get & encode current directory */ ack1(data); /* If it fits, send it back in ACK */ SERVE; /* Back to server command wait */ } } break; case 22: { /* REMOTE DIRECTORY command */ char *n2; if (!en_dir) { /* If DIR is disabled, */ errpkt((CHAR *)"REMOTE DIRECTORY disabled"); /* refuse. */ SERVE; } else { /* DIR is enabled. */ if (!en_cwd) { /* But if CWD is disabled */ zstrip((char *)(srvcmd+2),&n2); /* and they included a pathname, */ if (strcmp((char *)(srvcmd+2),n2)) { /* refuse. */ errpkt((CHAR *)"Access denied"); SERVE; /* Remember, this is not a goto! */ } } if (state == generic) { /* It's OK to go ahead. */ n2 = (*(srvcmd+2)) ? DIRCMD : DIRCM2; if (syscmd(n2,(char *)(srvcmd+2))) /* If it can be done */ BEGIN ssinit; /* send the results back */ else { /* otherwise */ errpkt((CHAR *)"Can't list directory"); /* report failure, */ SERVE; /* return to server command wait */ } } } } break; case 23: { /* REMOTE DELETE (Erase) command */ char *n2; if (!en_del) { errpkt((CHAR *)"REMOTE DELETE disabled"); SERVE; } else { if (!en_cwd) { /* But if CWD is disabled */ zstrip((char *)(srvcmd+2),&n2); /* and they included a pathname, */ if (strcmp((char *)(srvcmd+2),n2)) { /* refuse. */ errpkt((CHAR *)"Access denied"); SERVE; /* Remember, this is not a goto! */ } } if (state == generic) { /* It's OK to go ahead. */ if (syscmd(DELCMD,(char *)(srvcmd+2))) /* Try to do it */ BEGIN ssinit; /* If OK send results back */ else { /* otherwise */ errpkt((CHAR *)"Can't remove file"); /* report failure */ SERVE; /* & return to server command wait */ } } } } break; case 24: { /* FINISH */ if (!en_fin) { errpkt((CHAR *)"FINISH disabled"); SERVE; } else { ack(); /* Acknowledge */ screen(SCR_TC,0,0L,""); /* Display */ return(0); /* Done */ } } break; case 25: { /* BYE (LOGOUT) */ if (!en_bye) { errpkt((CHAR *)"BYE disabled"); SERVE; } else { ack(); /* Acknowledge */ ttres(); /* Reset the terminal */ screen(SCR_TC,0,0L,""); /* Display */ doclean(); /* Clean up files, etc */ #ifdef DEBUG debug(F100,"C-Kermit BYE","",0); zclose(ZDFILE); #endif /* DEBUG */ return(zkself()); /* Try to log self out */ } } break; case 26: { /* REMOTE HELP */ extern char * hlptxt; if (sndhlp(hlptxt)) BEGIN ssinit; /* Try to send it */ else { /* If not ok, */ errpkt((CHAR *)"Can't send help"); /* send error message instead */ SERVE; /* and return to server command wait */ } } break; case 27: { /* REMOTE SET */ if (!en_set) { errpkt((CHAR *)"REMOTE SET disabled"); SERVE; } else { if (remset((char *)(srvcmd+1))) /* Try to do what they ask */ ack(); /* If OK, then acknowledge */ else /* Otherwise */ errpkt((CHAR *)"Unknown REMOTE SET parameter"); /* give error msg */ SERVE; /* Return to server command wait */ } } break; case 28: { /* REMOTE TYPE */ char *n2; if (!en_typ) { errpkt((CHAR *)"REMOTE TYPE disabled"); SERVE; } else { if (!en_cwd) { /* But if CWD is disabled */ zstrip((char *)(srvcmd+2),&n2); /* and they included a pathname, */ if (strcmp((char *)(srvcmd+2),n2)) { /* refuse. */ errpkt((CHAR *)"Access denied"); SERVE; /* Remember, this is not a goto! */ } } if (state == generic) { /* It's OK to go ahead. */ if (syscmd(TYPCMD,(char *)(srvcmd+2))) /* Try */ BEGIN ssinit; /* OK */ else { /* not OK */ errpkt((CHAR *)"Can't type file"); /* give error message */ SERVE; /* wait for next server command */ } } } } break; case 29: { /* REMOTE SPACE */ if (!en_spa) { errpkt((CHAR *)"REMOTE SPACE disabled"); SERVE; } else { x = srvcmd[1]; /* Get area to check */ x = ((x == '\0') || (x == SP) #ifdef OS2 || (x == '!') || (srvcmd[3] == ':') #endif /* OS2 */ ); if (!x && !en_cwd) { /* If CWD disabled and they gave */ errpkt((CHAR *)"Access denied"); /* a non-default area, */ SERVE; /* refuse. */ } else { #ifdef OS2 _PROTOTYP(int sndspace,(int)); if (sndspace(x ? toupper(srvcmd[2]) : 0)) BEGIN ssinit; /* Try to send it */ else { /* If not ok, */ errpkt((CHAR *)"Can't send space"); /* send error message */ SERVE; /* and return to server command wait */ } #else x = (x ? syscmd(SPACMD,"") : syscmd(SPACM2,(char *)(srvcmd+2))); if (x) { /* If we got the info */ BEGIN ssinit; /* send it */ } else { /* otherwise */ errpkt((CHAR *)"Can't check space"); /* send error message */ SERVE; /* and await next server command */ } #endif /* OS2 */ } } } break; case 30: { /* REMOTE WHO */ if (!en_who) { errpkt((CHAR *)"REMOTE WHO disabled"); SERVE; } else { if (syscmd(WHOCMD,(char *)(srvcmd+2))) /* The now-familiar scenario. */ BEGIN ssinit; else { errpkt((CHAR *)"Can't do who command"); SERVE; } } } break; case 31: { /* Variable query or set */ #ifndef NOSPL _PROTOTYP( int addmac, (char *, char *) ); _PROTOTYP( int zzstring, (char *, char **, int *) ); char c; c = *(srvcmd+2); /* Q = Query, S = Set */ if (c == 'Q') { /* Query */ if (!en_que) { /* Security */ errpkt((CHAR *)"REMOTE QUERY disabled"); SERVE; } else { /* Query allowed */ int n; char *p, *q; qbufp = querybuf; /* Wipe out old stuff */ qbufn = 0; querybuf[0] = NUL; p = (char *) srvcmd + 3; /* Pointer for making wrapper */ n = strlen((char *)srvcmd); /* Position of end */ c = *(srvcmd+4); /* Which type of variable */ if (*(srvcmd+6) == CMDQ) { /* Starts with command quote? */ p = (char *) srvcmd + 6; /* Take it literally */ } else { /* They played by the rules */ *(srvcmd+3) = CMDQ; /* Stuff wrapping into buffer */ *(srvcmd+5) = '('; /* around variable name */ *(srvcmd+n) = ')'; *(srvcmd+n+1) = NUL; if (c == 'K') { /* Kermit variable */ *(srvcmd+4) = 'v'; /* so make it \v(...) */ } else if (c == 'S') { /* System variable */ *(srvcmd+4) = '$'; /* so it's \$(...) */ } else if (c == 'G') { /* Non-\ Global variable */ *(srvcmd+4) = 'm'; /* so wrap it in \m(...) */ } } /* Now evaluate it */ n = QBUFL; /* Max length */ q = querybuf; /* Where to put it */ if (zzstring(p,&q,&n) < 0) { errpkt((n > 0) ? (CHAR *)"Can't get value" : (CHAR *)"Value too long" ); SERVE; } else { if (encstr((CHAR *)querybuf) > -1) { /* Encode it */ ack1(data); /* If it fits, send it back in ACK */ SERVE; } else if (sndhlp(querybuf)) { /* Long form response */ BEGIN ssinit; } else { /* sndhlp() fails */ errpkt((CHAR *)"Can't send value"); SERVE; } } } } else if (c == 'S') { /* Set (assign) */ if (!en_asg) { /* Security */ errpkt((CHAR *)"REMOTE ASSIGN disabled"); SERVE; } else { /* OK */ int n; n = xunchar(*(srvcmd+3)); /* Length of name */ n = 3 + n + 1; /* Position of length of value */ *(srvcmd+n) = NUL; /* Don't need it */ if (addmac((char *)(srvcmd+4),(char *)(srvcmd+n+1)) < 0) errpkt((CHAR *)"REMOTE ASSIGN failed"); else ack(); SERVE; } } else { errpkt((CHAR *)"Badly formed server command"); SERVE; } #else errpkt((CHAR *)"Variable query/set not available"); SERVE; #endif /* NOSPL */ } break; case 32: { if (!en_fin) { /* Ctrl-C typed */ errpkt((CHAR *)"QUIT disabled"); SERVE; } else { success = 0; QUIT; } } break; case 33: { /* Anything else in this state... */ errpkt((CHAR *)"Unimplemented REMOTE command"); /* Complain */ SERVE; /* and return to server command wait */ } break; case 34: { /* Short-Form reply */ #ifndef NOSPL if (query) { /* If to query, */ qbufp = querybuf; /* initialize query response buffer */ qbufn = 0; querybuf[0] = NUL; } #endif /* NOSPL */ decode(rdatap,puttrm,0); /* Text is in ACK Data field */ if (rdatap) /* If we had data */ if (*rdatap) conoll(""); /* Then add a CRLF */ RESUME; } break; case 35: { /* File header */ xflg = 0; /* Not screen data */ if (!rcvfil(filnam)) { /* Figure out local filename */ errpkt((CHAR *)rf_err); /* Trouble */ screen(SCR_EM,0,0L,rf_err); RESUME; } else { /* OK to receive */ encstr((CHAR *)filnam); /* Encode the local filename */ ack1(data); /* Send it back in ACK */ initattr(&iattr); /* Clear file attribute structure */ if (window(wslotn) < 0) { /* Allocate negotiated window slots */ errpkt((CHAR *)"Can't open window"); RESUME; } BEGIN rattr; /* Now expect Attribute packets */ } } break; case 36: { /* X-packet instead of file header */ xflg = 1; /* Screen data */ ack(); /* Acknowledge the X-packet */ initattr(&iattr); /* Initialize attribute structure */ if (window(wslotn) < 0) { /* allocate negotiated window slots */ errpkt((CHAR *)"Can't open window"); RESUME; } #ifndef NOSPL if (query) { /* If this is the response to */ qbufp = querybuf; /* a query that we sent, initialize */ qbufn = 0; /* the response buffer */ querybuf[0] = NUL; } #endif /* NOSPL */ what = W_REMO; /* we're doing a REMOTE command */ BEGIN rattr; /* Expect Attribute packets */ } break; case 37: { /* Attribute packet */ if (gattr(rdatap,&iattr) == 0) { /* Read into attribute structure */ #ifdef CK_RESEND ack1((CHAR *)iattr.reply.val); /* Reply with data */ #else ack(); /* If OK, acknowledge */ #endif /* CK_RESEND */ } else { /* Otherwise */ ack1((CHAR *)iattr.reply.val); /* refuse to accept the file */ screen(SCR_ST,ST_REFU,0L,getreason(iattr.reply.val)); /* give reason */ } } break; case 38: { /* First data packet */ if (discard) { /* if we're discarding the file */ ack1((CHAR *)"X"); /* just ack the data like this. */ BEGIN rdata; /* and wait for more data packets. */ } else { /* Not discarding. */ rf_err = "Can't open file"; if (xflg) { /* If screen data */ x = opent(&iattr); /* "open" the screen */ } else /* otherwise */ x = opena(filnam,&iattr); /* open the file, with attributes */ if (x) { /* If file was opened ok */ if (decode(rdatap, #ifndef NOSPL query ? puttrm : #endif /* NOSPL */ putfil, 1) < 0) { errpkt((CHAR *)"Error writing data"); RESUME; } ack(); /* acknowledge it */ BEGIN rdata; /* and switch to receive-data state */ } else { /* otherwise */ errpkt((CHAR *) rf_err); /* send error message */ RESUME; /* and quit. */ } } } break; case 39: { /* EOT, no more files */ ack(); /* Acknowledge */ tsecs = gtimer(); /* Get timing for statistics */ reot(); /* Do EOT things */ RESUME; /* and quit */ } break; case 40: { /* Data packet */ if (cxseen || discard) /* If file interrupt */ ack1((CHAR *)"X"); /* put "X" in ACK */ else if (czseen) /* If file-group interrupt */ ack1((CHAR *)"Z"); /* put "Z" in ACK */ else if (decode(rdatap, #ifndef NOSPL query ? puttrm : #endif /* NOSPL */ putfil, 1) < 0) { errpkt((CHAR *)"Error writing data"); /* If failure, */ clsof(!keep); /* Close & keep/discard the file */ RESUME; /* Send ACK only after data */ } else ack(); /* written to file OK. */ } break; case 41: { /* EOF immediately after A-Packet. */ rf_err = "Can't create file"; if (discard) { /* Discarding a real file... */ x = 1; } else if (xflg) { /* Zero-length file. If screen data */ x = opent(&iattr); /* "open" the screen */ } else { /* otherwise */ x = opena(filnam,&iattr); /* open the file, with attributes. */ } if (!x || reof(filnam, &iattr) < 0) { /* Now close & dispose of the file */ errpkt((CHAR *) rf_err); /* If problem, send error msg */ RESUME; /* and quit */ } else { /* otherwise */ ack(); /* acknowledge the EOF packet */ BEGIN rfile; /* and await another file */ } } break; case 42: { /* End Of File (EOF) Packet */ /* wslots = 1; */ /* Window size back to 1 */ #ifndef COHERENT /* Coherent compiler blows up on this switch() statement. */ x = reof(filnam, &iattr); /* Handle the EOF packet */ switch (x) { /* reof() sets the success flag */ case -3: /* If problem, send error msg */ errpkt((CHAR *)"Can't print file"); /* Fatal */ RESUME; break; case -2: errpkt((CHAR *)"Can't mail file"); /* Fatal */ RESUME; break; case 2: case 3: screen(SCR_EM,0,0L,"Can't delete temp file"); /* Not fatal */ RESUME; break; default: if (x < 0) { /* Fatal */ errpkt((CHAR *)"Can't close file"); RESUME; } else { /* Success */ #ifndef NOSPL if (query) /* Query reponses generally */ conoll(""); /* don't have line terminators */ #endif /* NOSPL */ ack(); /* Acknowledge the EOF packet */ BEGIN rfile; /* and await another file */ } } #else if (reof(filnam, &iattr) < 0) { /* Close and dispose of the file */ errpkt((CHAR *)"Error at end of file"); RESUME; } else { /* reof() sets success flag */ ack(); BEGIN rfile; } #endif /* COHERENT */ } break; case 43: { /* ACK for Send-Init */ spar(rdatap); /* set parameters from it */ bctu = bctr; /* switch to agreed-upon block check */ bctl = (bctu == 4) ? 2 : bctu; /* Set block-check length */ #ifdef CK_RESEND if ((sendmode == SM_RESEND) && (!atcapu || !rscapu)) { /* RESEND */ errpkt((CHAR *) "RESEND capabilities not negotiated"); ermsg("RESEND capabilities not negotiated"); RESUME; } else { #endif /* CK_RESEND */ what = W_SEND; /* Remember we're sending */ x = sfile(xflg); /* Send X or F header packet */ if (x) { /* If the packet was sent OK */ resetc(); /* reset per-transaction counters */ rtimer(); /* reset timers */ BEGIN ssfile; /* and switch to receive-file state */ } else { /* otherwise send error msg & quit */ s = xflg ? "Can't execute command" : "Can't open file"; errpkt((CHAR *)s); RESUME; } #ifdef CK_RESEND } #endif /* CK_RESEND */ } break; case 44: { /* R packet was retransmitted. */ xsinit(); /* Resend packet 0 */ } break; case 45: { /* Same deal if G packet comes again */ xsinit(); } break; case 46: { /* Same deal if C packet comes again */ xsinit(); } break; case 47: { /* ACK for F packet */ srvptr = srvcmd; /* Point to string buffer */ decode(rdatap,putsrv,0); /* Decode data field, if any */ putsrv('\0'); /* Terminate with null */ ffc = 0L; /* Reset file byte counter */ if (*srvcmd) { /* If remote name was recorded */ if (fdispla == XYFD_C) screen(SCR_AN,0,0L,(char *)srvcmd); tlog(F110," remote name:",(char *) srvcmd,0L); /* Transaction log. */ } if (atcapu) { /* If attributes are to be used */ if (sattr(xflg | stdinf) < 0) { /* set and send them */ errpkt((CHAR *)"Can't send attributes"); /* if problem, say so */ RESUME; /* and quit */ } else BEGIN ssattr; /* if ok, switch to attribute state */ } else { if (window(wslotn) < 0) { errpkt((CHAR *)"Can't open window"); RESUME; } if (sdata() < 0) { /* No attributes, send data */ clsif(); /* If not ok, close input file, */ window(1); /* put window size back to 1, */ seof((CHAR *)""); /* send EOF packet, */ BEGIN sseof; /* and switch to EOF state. */ } else BEGIN ssdata; /* All ok, switch to send-data state */ } } break; case 48: { /* Got ACK to A packet */ ffc = 0L; /* Reset file byte counter */ if (rsattr(rdatap) < 0) { /* Was the file refused? */ discard = 1; /* Set the discard flag */ clsif(); /* Close the file */ sxeof((CHAR *)"D"); /* send EOF with "discard" code */ BEGIN sseof; /* switch to send-EOF state */ } else { if (window(wslotn) < 0) { /* Allocate negotiated window slots */ errpkt((CHAR *)"Can't open window"); RESUME; } if (sdata() < 0) { /* File accepted, send data */ clsif(); /* If problem, close input file */ window(1); /* Window size back to 1... */ seof((CHAR *)""); /* send EOF packet */ BEGIN sseof; /* and switch to send-EOF state. */ } else { /* All ok, enter send-data state. */ BEGIN ssdata; } } } break; case 49: { /* Got ACK to Data packet */ canned(rdatap); /* Check if file transfer cancelled */ if (sdata() < 0) { /* Try to send next data */ clsif(); /* If no more data, close file */ window(1); /* Window size back to 1... */ if (cxseen || czseen) /* If interrupted */ seof((CHAR *)"D"); /* send special EOF packet */ else seof((CHAR *)""); /* Otherwise regular EOF packet */ BEGIN sseof; /* And enter send-eof state */ } } break; case 50: { /* Got ACK to EOF */ success = (cxseen == 0 && czseen == 0); /* Transfer status... */ if (success && rejection > 0) /* If rejected, succeed if */ if (rejection != '#' && /* reason was date */ rejection != 1 && rejection != '?') /* or name; */ success = 0; /* fail otherwise. */ cxseen = 0; /* This goes back to zero. */ if (gnfile() > 0) { /* Any more files to send? */ if (sfile(xflg)) /* Yes, try to send next file header */ BEGIN ssfile; /* if ok, enter send-file state */ else { /* otherwise */ errpkt((CHAR *)"Can't open file"); /* send error message */ RESUME; /* and quit */ } } else { /* No next file */ tsecs = gtimer(); /* get statistics timers */ seot(); /* send EOT packet */ BEGIN sseot; /* enter send-eot state */ } } break; case 51: { /* Got ACK to EOT */ RESUME; /* All done, just quit */ } break; case 52: { /* Got Error packet, in any state */ char *s = ""; if (pktmsg) /* Or we sent one. */ if (*pktmsg) /* If so, this was the message. */ s = (char *)pktmsg; if (!*s) /* We received an Error packet */ s = (char *)rdatap; /* with this message. */ if (!*s) /* Hopefully we'll never see this. */ s = "Unknown error"; ermsg(s); /* Issue the message. */ success = 0; /* For IF SUCCESS/FAIL. */ debug(F111,"ckcpro.w sstate at E pkt",s,sstate); x = quiet; quiet = 1; /* Close files silently, */ clsif(); clsof(1); /* discarding any output file. */ tsecs = gtimer(); /* Get timers */ quiet = x; /* restore quiet state */ /* If we are executing commands from a command file or macro, let the command file or macro decide whether to exit, based on SET { TAKE, MACRO } ERROR. */ if ( #ifndef NOSPL cmdlvl == 0 #else tlevel < 0 #endif /* NOSPL */ ) if (backgrd && !server) fatal("Protocol error"); xitsta |= what; /* Save this for doexit(). */ RESUME; } break; case 53: { success = 0; QUIT; } break; case 54: { /* Anything not accounted for above */ errpkt((CHAR *)"Unexpected packet type"); /* Give error message */ xitsta |= what; /* Save this for doexit(). */ RESUME; /* and quit */ } break; } } } char tbl[] = { -1, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 52, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 8, 54, 4, 54, 54, 54, 6, 54, 54, 54, 5, 54, 54, 54, 54, 54, 53, 3, 1, 54, 54, 2, 54, 7, 54, 54, 54, 54, 54, 54, 54, -1, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 11, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 10, 54, 54, 54, 54, 54, 54, 54, 8, 54, 4, 54, 54, 54, 6, 54, 54, 54, 5, 54, 54, 54, 54, 54, 53, 3, 1, 54, 54, 2, 54, 7, 54, 54, 54, 54, 54, 54, 54, -1, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 39, 54, 54, 52, 35, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 36, 54, 54, 54, 54, 54, 54, 54, 54, 8, 54, 4, 54, 54, 54, 6, 54, 54, 54, 5, 54, 54, 54, 54, 54, 53, 3, 1, 54, 54, 2, 54, 7, 54, 54, 54, 54, 54, 54, 54, -1, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 37, 54, 54, 38, 52, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 41, 54, 54, 54, 54, 54, 54, 8, 54, 4, 54, 54, 54, 6, 54, 54, 54, 5, 54, 54, 54, 54, 54, 53, 3, 1, 54, 54, 2, 54, 7, 54, 54, 54, 54, 54, 54, 54, -1, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 40, 52, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 42, 54, 54, 54, 54, 54, 54, 8, 54, 4, 54, 54, 54, 6, 54, 54, 54, 5, 54, 54, 54, 54, 54, 53, 3, 1, 54, 54, 2, 54, 7, 54, 54, 54, 54, 54, 54, 54, -1, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 46, 54, 52, 54, 45, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 44, 54, 54, 54, 54, 54, 54, 43, 54, 54, 54, 54, 54, 54, 54, 8, 54, 4, 54, 54, 54, 6, 54, 54, 54, 5, 54, 54, 54, 54, 54, 53, 3, 1, 54, 54, 2, 54, 7, 54, 54, 54, 54, 54, 54, 54, -1, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 52, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 47, 54, 54, 54, 54, 54, 54, 54, 8, 54, 4, 54, 54, 54, 6, 54, 54, 54, 5, 54, 54, 54, 54, 54, 53, 3, 1, 54, 54, 2, 54, 7, 54, 54, 54, 54, 54, 54, 54, -1, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 52, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 48, 54, 54, 54, 54, 54, 54, 54, 8, 54, 4, 54, 54, 54, 6, 54, 54, 54, 5, 54, 54, 54, 54, 54, 53, 3, 1, 54, 54, 2, 54, 7, 54, 54, 54, 54, 54, 54, 54, -1, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 52, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 49, 54, 54, 54, 54, 54, 54, 54, 8, 54, 4, 54, 54, 54, 6, 54, 54, 54, 5, 54, 54, 54, 54, 54, 53, 3, 1, 54, 54, 2, 54, 7, 54, 54, 54, 54, 54, 54, 54, -1, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 52, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 50, 54, 54, 54, 54, 54, 54, 54, 8, 54, 4, 54, 54, 54, 6, 54, 54, 54, 5, 54, 54, 54, 54, 54, 53, 3, 1, 54, 54, 2, 54, 7, 54, 54, 54, 54, 54, 54, 54, -1, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 52, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 51, 54, 54, 54, 54, 54, 54, 54, 8, 54, 4, 54, 54, 54, 6, 54, 54, 54, 5, 54, 54, 54, 54, 54, 53, 3, 1, 54, 54, 2, 54, 7, 54, 54, 54, 54, 54, 54, 54, -1, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 16, 19, 19, 19, 15, 19, 13, 19, 19, 19, 19, 18, 19, 19, 19, 14, 9, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 19, 8, 19, 4, 19, 19, 19, 6, 19, 19, 19, 5, 19, 19, 19, 19, 19, 17, 3, 1, 19, 19, 2, 19, 7, 19, 19, 19, 19, 19, 19, 19, -1, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 33, 21, 33, 20, 22, 23, 24, 33, 26, 33, 33, 33, 25, 33, 33, 33, 33, 33, 33, 27, 28, 29, 31, 30, 33, 33, 33, 33, 33, 33, 33, 33, 33, 8, 33, 4, 33, 33, 33, 6, 33, 33, 33, 5, 33, 33, 33, 33, 33, 32, 3, 1, 33, 33, 2, 33, 7, 33, 33, 33, 33, 33, 33, 33, -1, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 52, 54, 54, 54, 13, 54, 54, 54, 54, 54, 54, 54, 54, 54, 9, 54, 54, 54, 54, 54, 12, 54, 54, 54, 54, 54, 54, 54, 8, 54, 4, 54, 54, 54, 6, 54, 54, 54, 5, 54, 54, 54, 54, 54, 53, 3, 1, 54, 54, 2, 54, 7, 54, 54, 54, 54, 54, 54, 54, 0, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 52, 35, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 54, 9, 54, 54, 54, 54, 36, 34, 54, 54, 54, 54, 54, 54, 54, 8, 54, 4, 54, 54, 54, 6, 54, 54, 54, 5, 54, 54, 54, 54, 54, 53, 3, 1, 54, 54, 2, 54, 7, 54, 54, 54, 54, 54, 54, 54 }; /* P R O T O -- Protocol entry function */ VOID proto() { int x; long lx; /* Set up the communication line for file transfer. */ if (local && (speed < 0L) && (network == 0)) { screen(SCR_EM,0,0L,"Sorry, you must 'set speed' first"); return; } x = -1; if (ttopen(ttname,&x,mdmtyp,cdtimo) < 0) { debug(F111,"failed: proto ttopen local",ttname,local); screen(SCR_EM,0,0L,"Can't open line"); return; } if (x > -1) local = x; debug(F111,"proto ttopen local",ttname,local); lx = (local && !network) ? speed : -1; #ifdef NETCONN #ifdef CK_SPEED /* If we are a TELNET client, force quoting of IAC. Note hardwired "1" rather than NP_TELNET symbol, so we don't have to schlurp in ckcnet.h. */ if (network && ttnproto == 1) { ctlp[255] = ctlp[CR] = 1; if (parity == 'e' || parity == 'm') ctlp[127] = 1; } #endif /* CK_SPEED */ #endif /* NETCONN */ if (ttpkt(lx,flow,parity) < 0) { /* Put line in packet mode, */ screen(SCR_EM,0,0L,"Can't condition line"); return; } if (!local) connoi(); /* No console interrupts if remote */ if (sstate == 'x') { /* If entering server mode, */ server = 1; /* set flag, */ debug(F101,"server backgrd","",backgrd); debug(F101,"server quiet","",quiet); if (!quiet && !backgrd) { debug(F100,"SHOULD NOT SEE THIS IF IN BACKGROUND!","",0); if (!local) { /* and issue appropriate message. */ conoll(srvtxt); conoll("KERMIT READY TO SERVE..."); } else { conol("Entering server mode on "); conoll(ttname); conoll("Type Ctrl-C to quit."); if (srvdis) intmsg(-1L); } } } else server = 0; #ifdef VMS if (!quiet && !backgrd) /* So message doesn't overwrite prompt */ conoll(""); if (local) conres(); /* So Ctrl-C will work */ #endif /* VMS */ /* If in remote mode, not shushed, not in background, and at top command level, issue a helpful message telling what to do... */ if (!local && !quiet && !backgrd) { if (sstate == 'v') { conoll("Return to your local Kermit and give a SEND command."); conoll(""); conoll("KERMIT READY TO RECEIVE..."); } else if (sstate == 's') { conoll("Return to your local Kermit and give a RECEIVE command."); conoll(""); conoll("KERMIT READY TO SEND..."); } else if ( sstate == 'g' || sstate == 'r' || sstate == 'c' ) { conoll("Return to your local Kermit and give a SERVER command."); conoll(""); conoll((sstate == 'r') ? "KERMIT READY TO GET..." : "KERMIT READY TO SEND SERVER COMMAND..."); } } #ifdef COMMENT if (!local) sleep(1); #endif /* COMMENT */ /* The 'wart()' function is generated by the wart program. It gets a character from the input() routine and then based on that character and the current state, selects the appropriate action, according to the state table above, which is transformed by the wart program into a big case statement. The function is active for one transaction. */ rtimer(); /* Reset elapsed-time timer */ resetc(); /* & other per-transaction counters. */ wart(); /* Enter the state table switcher. */ if (server) { /* Back from packet protocol. */ if (!quiet && !backgrd) { /* Give appropriate message */ conoll(""); conoll("C-Kermit server done"); } } /* Note: the following is necessary in case we have just done a remote-mode file transfer, in which case the controlling terminal modes have been changed by ttpkt(). In particular, special characters like Ctrl-C and Ctrl-\ might have been turned off (see ttpkt). So this call to ttres() is essential. */ #ifndef OS2 if (!local) #endif /* OS2 */ ttres(); /* Reset the communication device */ screen(SCR_TC,0,0L,""); /* Transaction complete */ server = 0; /* Not a server any more */ }