![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to ckcpro.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [MW Coherent from dump] / coherent / e / bin / cku179|
Return to ckcpro.c CVS log | Up to [MW Coherent from dump] / coherent / e / bin / cku179 |
1.1 ! root 1: ! 2: /* WARNING -- This C source program generated by Wart preprocessor. */ ! 3: /* Do not edit this file; edit the Wart-format source file instead, */ ! 4: /* and then run it through Wart to produce a new C source file. */ ! 5: ! 6: /* Wart Version Info: */ ! 7: char *wartv = "Wart Version 2A(009) 14 Jan 92"; ! 8: ! 9: char *protv = "C-Kermit Protocol Module 5A(043), 25 Dec 91"; /* -*-C-*- */ ! 10: ! 11: /* C K C P R O -- C-Kermit Protocol Module, in Wart preprocessor notation. */ ! 12: /* ! 13: Author: Frank da Cruz ([email protected], [email protected]), ! 14: Columbia University Center for Computing Activities. ! 15: First released January 1985. ! 16: Copyright (C) 1985, 1992, Trustees of Columbia University in the City of New ! 17: York. Permission is granted to any individual or institution to use, copy, or ! 18: redistribute this software so long as it is not sold for profit, provided this ! 19: copyright notice is retained. ! 20: */ ! 21: #include "ckcdeb.h" ! 22: #include "ckcasc.h" ! 23: #include "ckcker.h" ! 24: /* ! 25: Note -- This file may also be preprocessed by the Unix Lex program, but ! 26: you must indent the above #include statements before using Lex, and then ! 27: restore them to the left margin in the resulting C program before compilation. ! 28: Also, the invocation of the "wart()" function below must be replaced by an ! 29: invocation of the "yylex()" function. It might also be necessary to remove ! 30: comments in the %%...%% section. ! 31: */ ! 32: ! 33: /* State definitions for Wart (or Lex) */ ! 34: #define ipkt 1 ! 35: #define rfile 2 ! 36: #define rattr 3 ! 37: #define rdata 4 ! 38: #define ssinit 5 ! 39: #define ssfile 6 ! 40: #define ssattr 7 ! 41: #define ssdata 8 ! 42: #define sseof 9 ! 43: #define sseot 10 ! 44: #define serve 11 ! 45: #define generic 12 ! 46: #define get 13 ! 47: #define rgen 14 ! 48: ! 49: /* External C-Kermit variable declarations */ ! 50: extern char *versio, *srvtxt, *cmarg, *cmarg2, **cmlist; ! 51: extern char filnam[], ttname[]; ! 52: extern CHAR sstate, *rpar(), encbuf[], *srvptr, *data; ! 53: extern int timint, pkttim, nfils, hcflg, xflg, flow, mdmtyp, network; ! 54: extern int cxseen, czseen, server, srvdis, local, displa, bctu, bctr, quiet; ! 55: extern int tsecs, parity, backgrd, nakstate, atcapu, wslotn, winlo; ! 56: extern int wslots, success, xitsta, rprintf, discard, cdtimo, keep; ! 57: extern long speed; ! 58: extern char *DIRCMD, *DIRCM2, *DELCMD, *TYPCMD, *SPACMD, *SPACM2, *WHOCMD; ! 59: extern CHAR *rdatap; ! 60: extern struct zattr iattr; ! 61: #ifdef DYNAMIC ! 62: extern CHAR *srvcmd; ! 63: #else ! 64: extern CHAR srvcmd[]; ! 65: #endif /* DYNAMIC */ ! 66: ! 67: #ifndef NOSPL ! 68: extern int cmdlvl; ! 69: #else ! 70: extern int tlevel; ! 71: #endif /* NOSPL */ ! 72: ! 73: #ifdef NOMSEND ! 74: extern int sndsrc; ! 75: #endif /* NOMSEND */ ! 76: ! 77: /* Flags for the ENABLE and DISABLE commands */ ! 78: extern int ! 79: en_cwd, en_del, en_dir, en_fin, en_get, en_bye, ! 80: en_hos, en_sen, en_spa, en_set, en_typ, en_who; ! 81: ! 82: /* Global variables declared here */ ! 83: ! 84: int what = W_NOTHING; /* What we're doing */ ! 85: ! 86: /* Local variables */ ! 87: ! 88: static char vstate = 0; /* Saved State */ ! 89: static char vcmd = 0; /* Saved Command */ ! 90: ! 91: static int x; /* General-purpose integer */ ! 92: static char *s; /* General-purpose string pointer */ ! 93: ! 94: /* Macros - Note, BEGIN is predefined by Wart (and Lex) as "state = ", */ ! 95: /* BEGIN is NOT a GOTO! */ ! 96: #define TINIT if (tinit() < 0) return(-9) ! 97: #define SERVE TINIT; nakstate = 1; what = W_NOTHING; BEGIN serve ! 98: #define RESUME if (server) { SERVE; } else { sleep(2); return(0); } ! 99: #define QUIT x=quiet; quiet=1; clsif(); clsof(1); tsecs=gtimer(); quiet=x; \ ! 100: return(1) ! 101: ! 102: ! 103: #define BEGIN state = ! 104: ! 105: int state = 0; ! 106: ! 107: int ! 108: wart() ! 109: { ! 110: int c,actno; ! 111: extern char tbl[]; ! 112: while (1) { ! 113: c = input() - 32; ! 114: if (c < 0 || c > 95) c = 0; ! 115: if ((actno = tbl[c + state*96]) != -1) ! 116: switch(actno) { ! 117: case 1: ! 118: { TINIT; /* Do Send command */ ! 119: if (sinit()) BEGIN ssinit; ! 120: else RESUME; } ! 121: break; ! 122: case 2: ! 123: { TINIT; nakstate = 1; BEGIN get; } ! 124: break; ! 125: case 3: ! 126: { TINIT; vstate = get; vcmd = 0; sipkt('I'); BEGIN ipkt; } ! 127: break; ! 128: case 4: ! 129: { TINIT; vstate = rgen; vcmd = 'C'; sipkt('I'); BEGIN ipkt; } ! 130: break; ! 131: case 5: ! 132: { TINIT; vstate = rgen; vcmd = 'K'; sipkt('I'); BEGIN ipkt; } ! 133: break; ! 134: case 6: ! 135: { TINIT; vstate = rgen; vcmd = 'G'; sipkt('I'); BEGIN ipkt; } ! 136: break; ! 137: case 7: ! 138: { sleep(1); SERVE; } ! 139: break; ! 140: case 8: ! 141: { if (!data) TINIT; /* "ABEND" -- Tell other side. */ ! 142: errpkt((CHAR *)"User cancelled"); ! 143: success = 0; ! 144: return(0); } ! 145: break; ! 146: case 9: ! 147: { /* Receive Send-Init packet. */ ! 148: if (state == serve && !en_sen) { /* Not allowed if in server mode */ ! 149: errpkt((CHAR *)"SEND disabled"); /* and SEND is disabled. */ ! 150: SERVE; ! 151: } else { /* OK to go ahead. */ ! 152: nakstate = 1; /* Can send NAKs from here. */ ! 153: rinit(rdatap); /* Set parameters */ ! 154: bctu = bctr; /* Switch to agreed-upon block check */ ! 155: timint = pkttim; /* Switch to per-packet timer */ ! 156: chktimo(); /* Check & adjust timeout */ ! 157: resetc(); /* Reset counters */ ! 158: rtimer(); /* Reset timer */ ! 159: what = W_RECV; /* Remember we're receiving */ ! 160: BEGIN rfile; /* Go into receive-file state */ ! 161: } ! 162: } ! 163: break; ! 164: case 10: ! 165: { /* Get ack for I-packet */ ! 166: spar(rdatap); /* Set parameters */ ! 167: #ifdef COMMENT ! 168: getsbuf(winlo = 0); /* Set window-low back to zero */ ! 169: #else ! 170: winlo = 0; ! 171: #endif ! 172: if (vcmd) { /* If sending a generic command */ ! 173: scmd(vcmd,(CHAR *)cmarg); /* Do that */ ! 174: vcmd = 0; /* and then un-remember it. */ ! 175: } else if (vstate == get) srinit(); /* If sending GET command, do that */ ! 176: winlo = 0; /* Again! */ ! 177: nakstate = 1; /* Can send NAKs from here. */ ! 178: BEGIN vstate; /* Switch to desired state */ ! 179: } ! 180: break; ! 181: case 11: ! 182: { /* Ignore Error reply to I packet */ ! 183: #ifdef COMMENT ! 184: getsbuf(winlo = 0); /* Set window-low back to zero */ ! 185: #else ! 186: winlo = 0; ! 187: #endif ! 188: if (vcmd) { /* in case other Kermit doesn't */ ! 189: scmd(vcmd,(CHAR *)cmarg); /* understand I-packets. */ ! 190: vcmd = 0; /* Otherwise act as above... */ ! 191: } else if (vstate == get) srinit(); ! 192: winlo = 0; /* Back to packet 0 again. */ ! 193: freerpkt(winlo); /* Discard the Error packet. */ ! 194: nakstate = 1; /* Can send NAKs from here. */ ! 195: BEGIN vstate; ! 196: } ! 197: break; ! 198: case 12: ! 199: { /* Resend of previous I-pkt ACK, same seq number! */ ! 200: srinit(); ! 201: } ! 202: break; ! 203: case 13: ! 204: { /* Get I-packet */ ! 205: spar(rdatap); /* Set parameters from it */ ! 206: ack1(rpar()); /* Respond with our own parameters */ ! 207: pktinit(); /* Reinitialize packet numbers */ ! 208: } ! 209: break; ! 210: case 14: ! 211: { /* Get Receive-Init (GET) */ ! 212: debug(F100,"<serve>R","",0); ! 213: if (!en_get) { /* Only if not disabled! */ ! 214: errpkt((CHAR *)"GET disabled"); ! 215: SERVE; ! 216: } else { /* OK to go ahead. */ ! 217: srvptr = srvcmd; /* Point to server command buffer */ ! 218: decode(rdatap,putsrv,0); /* Decode the GET command into it */ ! 219: /* Accept multiple filespecs */ ! 220: cmarg2 = ""; /* Don't use cmarg2 */ ! 221: cmarg = ""; /* Don't use cmarg */ ! 222: #ifndef NOMSEND /* New way. */ ! 223: nfils = fnparse((char *)srvcmd); /* Use cmlist instead */ ! 224: #else ! 225: nfils = 0 - zxpand((char *)srvcmd); ! 226: #endif /* NOMSEND */ ! 227: nakstate = 0; /* Now I'm the sender! */ ! 228: if (sinit()) { /* Send Send-Init */ ! 229: timint = pkttim; /* Switch to per-packet timer */ ! 230: BEGIN ssinit; /* If successful, switch state */ ! 231: } else { SERVE; } /* Else back to server command wait */ ! 232: } ! 233: } ! 234: break; ! 235: case 15: ! 236: { /* Generic server command */ ! 237: srvptr = srvcmd; /* Point to command buffer */ ! 238: decode(rdatap,putsrv,0); /* Decode packet data into it */ ! 239: putsrv('\0'); /* Insert a couple nulls */ ! 240: putsrv('\0'); /* for termination */ ! 241: if (srvcmd[0]) { ! 242: sstate = srvcmd[0]; /* Set requested start state */ ! 243: nakstate = 0; /* Now I'm the sender. */ ! 244: what = W_REMO; /* Doing a REMOTE command. */ ! 245: timint = pkttim; /* Switch to per-packet timer */ ! 246: BEGIN generic; /* Switch to generic command state */ ! 247: } else { ! 248: errpkt((CHAR *)"Badly formed server command"); /* report error */ ! 249: SERVE; /* & go back to server command wait */ ! 250: } ! 251: } ! 252: break; ! 253: case 16: ! 254: { /* Receive Host command */ ! 255: if (!en_hos) { ! 256: errpkt((CHAR *)"REMOTE HOST disabled"); ! 257: SERVE; ! 258: } else { ! 259: srvptr = srvcmd; /* Point to command buffer */ ! 260: decode(rdatap,putsrv,0); /* Decode command packet into it */ ! 261: putsrv('\0'); /* Null-terminate */ ! 262: nakstate = 0; /* Now sending, not receiving */ ! 263: if (syscmd((char *)srvcmd,"")) { /* Try to execute the command */ ! 264: what = W_REMO; /* Doing a REMOTE command. */ ! 265: timint = pkttim; /* Switch to per-packet timer */ ! 266: BEGIN ssinit; /* If OK, send back its output */ ! 267: } else { /* Otherwise */ ! 268: errpkt((CHAR *)"Can't do system command"); /* report error */ ! 269: SERVE; /* & go back to server command wait */ ! 270: } ! 271: } ! 272: } ! 273: break; ! 274: case 17: ! 275: { /* User typed Ctrl-C... */ ! 276: if (!en_fin) { ! 277: errpkt((CHAR *)"QUIT disabled"); ! 278: SERVE; ! 279: } else { ! 280: success = 0; QUIT; ! 281: } ! 282: } ! 283: break; ! 284: case 18: ! 285: { /* Any other command in this state */ ! 286: errpkt((CHAR *)"Unimplemented server function"); /* we don't know about */ ! 287: SERVE; /* back to server command wait */ ! 288: } ! 289: break; ! 290: case 19: ! 291: { /* Got REMOTE CWD command */ ! 292: if (!en_cwd) { ! 293: errpkt((CHAR *)"REMOTE CD disabled"); ! 294: SERVE; ! 295: } else { ! 296: if (!cwd((char *)(srvcmd+1))) errpkt((CHAR *)"Can't change directory"); ! 297: SERVE; /* Back to server command wait */ ! 298: } ! 299: } ! 300: break; ! 301: case 20: ! 302: { /* REMOTE DIRECTORY command */ ! 303: char *n2; ! 304: if (!en_dir) { /* If DIR is disabled, */ ! 305: errpkt((CHAR *)"REMOTE DIRECTORY disabled"); /* refuse. */ ! 306: SERVE; ! 307: } else { /* DIR is enabled. */ ! 308: if (!en_cwd) { /* But if CWD is disabled */ ! 309: zstrip((char *)(srvcmd+2),&n2); /* and they included a pathname, */ ! 310: if (strcmp((char *)(srvcmd+2),n2)) { /* refuse. */ ! 311: errpkt((CHAR *)"Access denied"); ! 312: SERVE; /* Remember, this is not a goto! */ ! 313: } ! 314: } ! 315: if (state == generic) { /* It's OK to go ahead. */ ! 316: n2 = (*(srvcmd+2)) ? DIRCMD : DIRCM2; ! 317: if (syscmd(n2,(char *)(srvcmd+2))) /* If it can be done */ ! 318: BEGIN ssinit; /* send the results back */ ! 319: else { /* otherwise */ ! 320: errpkt((CHAR *)"Can't list directory"); /* report failure, */ ! 321: SERVE; /* return to server command wait */ ! 322: } ! 323: } ! 324: } ! 325: } ! 326: break; ! 327: case 21: ! 328: { /* REMOTE DELETE (Erase) command */ ! 329: char *n2; ! 330: if (!en_del) { ! 331: errpkt((CHAR *)"REMOTE DELETE disabled"); ! 332: SERVE; ! 333: } else { ! 334: if (!en_cwd) { /* But if CWD is disabled */ ! 335: zstrip((char *)(srvcmd+2),&n2); /* and they included a pathname, */ ! 336: if (strcmp((char *)(srvcmd+2),n2)) { /* refuse. */ ! 337: errpkt((CHAR *)"Access denied"); ! 338: SERVE; /* Remember, this is not a goto! */ ! 339: } ! 340: } ! 341: if (state == generic) { /* It's OK to go ahead. */ ! 342: if (syscmd(DELCMD,(char *)(srvcmd+2))) /* Try to do it */ ! 343: BEGIN ssinit; /* If OK send results back */ ! 344: else { /* otherwise */ ! 345: errpkt((CHAR *)"Can't remove file"); /* report failure */ ! 346: SERVE; /* & return to server command wait */ ! 347: } ! 348: } ! 349: } ! 350: } ! 351: break; ! 352: case 22: ! 353: { /* FINISH */ ! 354: if (!en_fin) { ! 355: errpkt((CHAR *)"FINISH disabled"); ! 356: SERVE; ! 357: } else { ! 358: ack(); /* Acknowledge */ ! 359: screen(SCR_TC,0,0l,""); /* Display */ ! 360: return(0); /* Done */ ! 361: } ! 362: } ! 363: break; ! 364: case 23: ! 365: { /* BYE (LOGOUT) */ ! 366: if (!en_bye) { ! 367: errpkt((CHAR *)"BYE disabled"); ! 368: SERVE; ! 369: } else { ! 370: ack(); /* Acknowledge */ ! 371: ttres(); /* Reset the terminal */ ! 372: screen(SCR_TC,0,0l,""); /* Display */ ! 373: doclean(); /* Clean up files, etc */ ! 374: return(zkself()); /* Try to log self out */ ! 375: } ! 376: } ! 377: break; ! 378: case 24: ! 379: { /* REMOTE HELP */ ! 380: if (sndhlp()) BEGIN ssinit; /* Try to send it */ ! 381: else { /* If not ok, */ ! 382: errpkt((CHAR *)"Can't send help"); /* send error message instead */ ! 383: SERVE; /* and return to server command wait */ ! 384: } ! 385: } ! 386: break; ! 387: case 25: ! 388: { /* REMOTE SET */ ! 389: if (!en_set) { ! 390: errpkt((CHAR *)"REMOTE SET disabled"); ! 391: SERVE; ! 392: } else { ! 393: if (remset((char *)(srvcmd+1))) /* Try to do what they ask */ ! 394: ack(); /* If OK, then acknowledge */ ! 395: else /* Otherwise */ ! 396: errpkt((CHAR *)"Unknown REMOTE SET parameter"); /* give error msg */ ! 397: SERVE; /* Return to server command wait */ ! 398: } ! 399: } ! 400: break; ! 401: case 26: ! 402: { /* REMOTE TYPE */ ! 403: char *n2; ! 404: if (!en_typ) { ! 405: errpkt((CHAR *)"REMOTE TYPE disabled"); ! 406: SERVE; ! 407: } else { ! 408: if (!en_cwd) { /* But if CWD is disabled */ ! 409: zstrip((char *)(srvcmd+2),&n2); /* and they included a pathname, */ ! 410: if (strcmp((char *)(srvcmd+2),n2)) { /* refuse. */ ! 411: errpkt((CHAR *)"Access denied"); ! 412: SERVE; /* Remember, this is not a goto! */ ! 413: } ! 414: } ! 415: if (state == generic) { /* It's OK to go ahead. */ ! 416: if (syscmd(TYPCMD,(char *)(srvcmd+2))) /* Try */ ! 417: BEGIN ssinit; /* OK */ ! 418: else { /* not OK */ ! 419: errpkt((CHAR *)"Can't type file"); /* give error message */ ! 420: SERVE; /* wait for next server command */ ! 421: } ! 422: } ! 423: } ! 424: } ! 425: break; ! 426: case 27: ! 427: { /* REMOTE SPACE */ ! 428: if (!en_spa) { ! 429: errpkt((CHAR *)"REMOTE SPACE disabled"); ! 430: SERVE; ! 431: } else { ! 432: x = *(srvcmd+1); /* Get area to check */ ! 433: x = ((x == '\0') || (x == SP)); ! 434: if (!x && !en_cwd) { /* If CWD disabled and they gave */ ! 435: errpkt((CHAR *)"Access denied"); /* a non-default area, */ ! 436: SERVE; /* refuse. */ ! 437: } else { ! 438: x = (x ? syscmd(SPACMD,"") : syscmd(SPACM2,(char *)(srvcmd+2))); ! 439: if (x) { /* If we got the info */ ! 440: BEGIN ssinit; /* send it */ ! 441: } else { /* otherwise */ ! 442: errpkt((CHAR *)"Can't check space"); /* send error message */ ! 443: SERVE; /* and await next server command */ ! 444: } ! 445: } ! 446: } ! 447: } ! 448: break; ! 449: case 28: ! 450: { /* REMOTE WHO */ ! 451: if (!en_who) { ! 452: errpkt((CHAR *)"REMOTE WHO disabled"); ! 453: SERVE; ! 454: } else { ! 455: if (syscmd(WHOCMD,(char *)(srvcmd+2))) /* The now-familiar scenario. */ ! 456: BEGIN ssinit; ! 457: else { ! 458: errpkt((CHAR *)"Can't do who command"); ! 459: SERVE; ! 460: } ! 461: } ! 462: } ! 463: break; ! 464: case 29: ! 465: { ! 466: if (!en_fin) { /* Ctrl-C typed */ ! 467: errpkt((CHAR *)"QUIT disabled"); ! 468: SERVE; ! 469: } else { ! 470: success = 0; QUIT; ! 471: } ! 472: } ! 473: break; ! 474: case 30: ! 475: { /* Anything else in this state... */ ! 476: errpkt((CHAR *)"Unimplemented REMOTE command"); /* Complain */ ! 477: SERVE; /* and return to server command wait */ ! 478: } ! 479: break; ! 480: case 31: ! 481: { /* Short-Form reply */ ! 482: decode(rdatap,puttrm,0); /* in ACK Data field */ ! 483: RESUME; ! 484: } ! 485: break; ! 486: case 32: ! 487: { /* File header */ ! 488: xflg = 0; /* Not screen data */ ! 489: if (!rcvfil(filnam)) { /* Figure out local filename */ ! 490: errpkt((CHAR *)"Can't transform filename"); /* Trouble */ ! 491: RESUME; ! 492: } else { /* OK to receive */ ! 493: encstr((CHAR *)filnam); /* Encode the name */ ! 494: ack1((CHAR *)(encbuf+7)); /* Send it back in ACK */ ! 495: initattr(&iattr); /* Clear file attribute structure */ ! 496: window(wslotn); /* allocate negotiated window slots */ ! 497: BEGIN rattr; /* Now expect Attribute packets */ ! 498: } ! 499: } ! 500: break; ! 501: case 33: ! 502: { /* X-packet instead of file header */ ! 503: xflg = 1; /* Screen data */ ! 504: ack(); /* Acknowledge the X-packet */ ! 505: initattr(&iattr); /* Initialize attribute structure */ ! 506: window(wslotn); /* allocate negotiated window slots */ ! 507: what = W_REMO; /* we're doing a REMOTE command */ ! 508: BEGIN rattr; /* Expect Attribute packets */ ! 509: } ! 510: break; ! 511: case 34: ! 512: { /* Attribute packet */ ! 513: if (discard) { /* If SET FILE COLLISION DISCARD */ ! 514: ack1((CHAR *)"N"); /* refuse it */ ! 515: } else if (gattr(rdatap,&iattr) == 0) /* Read into attribute structure */ ! 516: ack(); /* If OK, acknowledge */ ! 517: else /* Otherwise */ ! 518: ack1((CHAR *)iattr.reply.val); /* refuse to accept the file */ ! 519: } ! 520: break; ! 521: case 35: ! 522: { /* First data packet */ ! 523: if (discard) { /* if we're discarding the file */ ! 524: ack1((CHAR *)"X"); /* just ack the data like this. */ ! 525: BEGIN rdata; /* and wait for more data packets. */ ! 526: } else { /* Not discarding. */ ! 527: if (xflg) /* If screen data */ ! 528: x = opent(&iattr); /* "open" the screen */ ! 529: else /* otherwise */ ! 530: x = opena(filnam,&iattr); /* open the file, with attributes */ ! 531: if (x) { /* If file was opened ok */ ! 532: if (decode(rdatap,putfil,1) < 0) { /* decode first data packet */ ! 533: errpkt((CHAR *)"Error writing data"); ! 534: RESUME; ! 535: } ! 536: ack(); /* acknowledge it */ ! 537: BEGIN rdata; /* and switch to receive-data state */ ! 538: } else { /* otherwise */ ! 539: errpkt((CHAR *)"Can't open file"); /* send error message */ ! 540: RESUME; /* and quit. */ ! 541: } ! 542: } ! 543: } ! 544: break; ! 545: case 36: ! 546: { /* EOT, no more files */ ! 547: ack(); /* Acknowledge */ ! 548: tsecs = gtimer(); /* Get timing for statistics */ ! 549: reot(); /* Do EOT things */ ! 550: RESUME; /* and quit */ ! 551: } ! 552: break; ! 553: case 37: ! 554: { /* Data packet */ ! 555: if (cxseen || discard) /* If file interrupt */ ! 556: ack1((CHAR *)"X"); /* put "X" in ACK */ ! 557: else if (czseen) /* If file-group interrupt */ ! 558: ack1((CHAR *)"Z"); /* put "Z" in ACK */ ! 559: else if (decode(rdatap,putfil,1) < 0) { /* Normal case, decode to file */ ! 560: errpkt((CHAR *)"Error writing data"); /* If failure, */ ! 561: clsof(!keep); /* Close & keep/discard the file */ ! 562: RESUME; /* Send ACK only after data */ ! 563: } else ack(); /* written to file OK. */ ! 564: } ! 565: break; ! 566: case 38: ! 567: { /* EOF immediately after A-Packet. */ ! 568: if (xflg) /* Zero-length file. If screen data */ ! 569: x = opent(&iattr); /* "open" the screen */ ! 570: else /* otherwise */ ! 571: x = opena(filnam,&iattr); /* open the file, with attributes. */ ! 572: if (!x || reof(filnam, &iattr) < 0) { /* Now close & dispose of the file */ ! 573: errpkt((CHAR *)"Can't create file"); /* If problem, send error msg */ ! 574: RESUME; /* and quit */ ! 575: } else { /* otherwise */ ! 576: ack(); /* acknowledge the EOF packet */ ! 577: success = 1; ! 578: BEGIN rfile; /* and await another file */ ! 579: } ! 580: } ! 581: break; ! 582: case 39: ! 583: { /* End Of File (EOF) Packet */ ! 584: /* wslots = 1; */ /* Window size back to 1 */ ! 585: if (discard) { /* If discarding, there's no file */ ! 586: discard = 0; /* to close, just reset the discard */ ! 587: ack(); /* flag, ack, and proceed normally. */ ! 588: success = 1; /* Count this as a success. */ ! 589: BEGIN rfile; ! 590: } else ! 591: #ifndef COHERENT ! 592: /* ! 593: Coherent compiler blows up on this switch() statement. ! 594: */ ! 595: switch (x = reof(filnam, &iattr)) { ! 596: case -3: /* If problem, send error msg */ ! 597: errpkt((CHAR *)"Can't print file"); ! 598: RESUME; ! 599: break; ! 600: case -2: ! 601: errpkt((CHAR *)"Can't mail file"); ! 602: RESUME; ! 603: break; ! 604: case 2: ! 605: case 3: ! 606: errpkt((CHAR *)"Can't delete temp file"); ! 607: RESUME; ! 608: break; ! 609: default: ! 610: if (x < 0) { ! 611: errpkt((CHAR *)"Can't close file"); ! 612: RESUME; ! 613: } else { /* Success */ ! 614: success = 1; ! 615: ack(); /* Acknowledge the EOF packet */ ! 616: BEGIN rfile; /* and await another file */ ! 617: } ! 618: } ! 619: #else ! 620: if (reof(filnam, &iattr) < 0) { /* Close and dispose of the file */ ! 621: errpkt((CHAR *)"Error at end of file"); ! 622: RESUME; ! 623: } else { ! 624: ack(); ! 625: success = 1; ! 626: BEGIN rfile; ! 627: } ! 628: #endif /* COHERENT */ ! 629: } ! 630: break; ! 631: case 40: ! 632: { /* ACK for Send-Init */ ! 633: spar(rdatap); /* set parameters from it */ ! 634: bctu = bctr; /* switch to agreed-upon block check */ ! 635: what = W_SEND; /* Remember we're sending */ ! 636: x = sfile(xflg); /* Send X or F header packet */ ! 637: if (x) { /* If the packet was sent OK */ ! 638: resetc(); /* reset per-transaction counters */ ! 639: rtimer(); /* reset timers */ ! 640: chktimo(); /* Check & adjust timeout */ ! 641: BEGIN ssfile; /* and switch to receive-file state */ ! 642: } else { /* otherwise send error msg & quit */ ! 643: s = xflg ? "Can't execute command" : "Can't open file"; ! 644: errpkt((CHAR *)s); ! 645: RESUME; ! 646: } ! 647: } ! 648: break; ! 649: case 41: ! 650: { /* R packet was retransmitted. */ ! 651: xsinit(); /* Resend packet 0 */ ! 652: } ! 653: break; ! 654: case 42: ! 655: { /* Same deal if G packet comes again */ ! 656: xsinit(); ! 657: } ! 658: break; ! 659: case 43: ! 660: { /* Same deal if C packet comes again */ ! 661: xsinit(); ! 662: } ! 663: break; ! 664: case 44: ! 665: { /* ACK for F packet */ ! 666: srvptr = srvcmd; /* Point to string buffer */ ! 667: decode(rdatap,putsrv,0); /* Decode data field, if any */ ! 668: putsrv('\0'); /* Terminate with null */ ! 669: if (*srvcmd) /* If remote name was recorded */ ! 670: tlog(F110," stored as",(char *) srvcmd,0L); /* Log in transaction log. */ ! 671: if (atcapu) { /* If attributes are to be used */ ! 672: if (sattr(xflg) < 0) { /* set and send them */ ! 673: errpkt((CHAR *)"Can't send attributes"); /* if problem, say so */ ! 674: RESUME; /* and quit */ ! 675: } else BEGIN ssattr; /* if ok, switch to attribute state */ ! 676: } else { ! 677: window(wslotn); ! 678: if (sdata() < 0) { /* No attributes, send data */ ! 679: clsif(); /* If not ok, close input file, */ ! 680: window(wslots = 1); /* put window size back to 1, */ ! 681: seof((CHAR *)""); /* send EOF packet, */ ! 682: BEGIN sseof; /* and switch to EOF state. */ ! 683: } else BEGIN ssdata; /* All ok, switch to send-data state */ ! 684: } ! 685: } ! 686: break; ! 687: case 45: ! 688: { /* Got ACK to A packet */ ! 689: if (rsattr(rdatap) < 0) { /* Was the file refused? */ ! 690: clsif(); /* yes, close it */ ! 691: sxeof((CHAR *)"D"); /* send EOF with "discard" code */ ! 692: BEGIN sseof; /* switch to send-EOF state */ ! 693: } else { ! 694: window(wslotn); /* Allocate negotiated window. */ ! 695: if (sdata() < 0) { /* File accepted, send data */ ! 696: clsif(); /* If problem, close input file */ ! 697: window(wslots = 1); /* Window size back to 1... */ ! 698: seof((CHAR *)""); /* send EOF packet */ ! 699: BEGIN sseof; /* and switch to send-EOF state. */ ! 700: } else { /* All ok, enter send-data state. */ ! 701: BEGIN ssdata; ! 702: } ! 703: } ! 704: } ! 705: break; ! 706: case 46: ! 707: { /* Got ACK to Data packet */ ! 708: canned(rdatap); /* Check if file transfer cancelled */ ! 709: if (sdata() < 0) { /* Try to send next data */ ! 710: clsif(); /* If no more data, close file */ ! 711: window(wslots = 1); /* Window size back to 1... */ ! 712: if (cxseen || czseen) /* If interrupted */ ! 713: seof((CHAR *)"D"); /* send special EOF packet */ ! 714: else seof((CHAR *)""); /* Otherwise regular EOF packet */ ! 715: BEGIN sseof; /* And enter send-eof state */ ! 716: } ! 717: } ! 718: break; ! 719: case 47: ! 720: { /* Got ACK to EOF */ ! 721: success = (cxseen == 0 && czseen == 0); /* Set this for IF command */ ! 722: cxseen = 0; /* This goes back to zero. */ ! 723: if (gnfile() > 0) { /* Any more files to send? */ ! 724: if (sfile(xflg)) /* Yes, try to send next file header */ ! 725: BEGIN ssfile; /* if ok, enter send-file state */ ! 726: else { /* otherwise */ ! 727: errpkt((CHAR *)"Can't open file"); /* send error message */ ! 728: RESUME; /* and quit */ ! 729: } ! 730: } else { /* No next file */ ! 731: tsecs = gtimer(); /* get statistics timers */ ! 732: seot(); /* send EOT packet */ ! 733: BEGIN sseot; /* enter send-eot state */ ! 734: } ! 735: } ! 736: break; ! 737: case 48: ! 738: { /* Got ACK to EOT */ ! 739: RESUME; /* All done, just quit */ ! 740: } ! 741: break; ! 742: case 49: ! 743: { /* Got Error packet, in any state */ ! 744: ermsg((char *)rdatap); /* Issue message. */ ! 745: success = 0; /* For IF SUCCESS/FAIL. */ ! 746: debug(F101,"ckcpro.w sstate at E pkt","",sstate); ! 747: x = quiet; quiet = 1; /* Close files silently, */ ! 748: clsif(); clsof(1); /* discarding any output file. */ ! 749: tsecs = gtimer(); /* Get timers */ ! 750: quiet = x; /* restore quiet state */ ! 751: if (backgrd && !server) fatal("Protocol error"); ! 752: xitsta |= what; /* Save this for doexit(). */ ! 753: RESUME; ! 754: } ! 755: break; ! 756: case 50: ! 757: { QUIT; } ! 758: break; ! 759: case 51: ! 760: { /* Anything not accounted for above */ ! 761: errpkt((CHAR *)"Unexpected packet type"); /* Give error message */ ! 762: xitsta |= what; /* Save this for doexit(). */ ! 763: RESUME; /* and quit */ ! 764: } ! 765: break; ! 766: ! 767: } ! 768: } ! 769: } ! 770: ! 771: char tbl[] = { ! 772: -1, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 773: 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 774: 51, 51, 51, 51, 51, 49, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 775: 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 776: 51, 8, 51, 4, 51, 51, 51, 6, 51, 51, 51, 5, 51, 51, 51, 51, ! 777: 51, 50, 3, 1, 51, 51, 2, 51, 7, 51, 51, 51, 51, 51, 51, 51, ! 778: -1, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 779: 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 780: 51, 51, 51, 51, 51, 11, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 781: 51, 51, 51, 51, 51, 51, 51, 51, 51, 10, 51, 51, 51, 51, 51, 51, ! 782: 51, 8, 51, 4, 51, 51, 51, 6, 51, 51, 51, 5, 51, 51, 51, 51, ! 783: 51, 50, 3, 1, 51, 51, 2, 51, 7, 51, 51, 51, 51, 51, 51, 51, ! 784: -1, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 785: 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 786: 51, 51, 36, 51, 51, 49, 32, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 787: 51, 51, 51, 51, 51, 51, 51, 51, 33, 51, 51, 51, 51, 51, 51, 51, ! 788: 51, 8, 51, 4, 51, 51, 51, 6, 51, 51, 51, 5, 51, 51, 51, 51, ! 789: 51, 50, 3, 1, 51, 51, 2, 51, 7, 51, 51, 51, 51, 51, 51, 51, ! 790: -1, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 791: 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 792: 51, 34, 51, 51, 35, 49, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 793: 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 38, 51, 51, 51, 51, 51, ! 794: 51, 8, 51, 4, 51, 51, 51, 6, 51, 51, 51, 5, 51, 51, 51, 51, ! 795: 51, 50, 3, 1, 51, 51, 2, 51, 7, 51, 51, 51, 51, 51, 51, 51, ! 796: -1, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 797: 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 798: 51, 51, 51, 51, 37, 49, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 799: 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 39, 51, 51, 51, 51, 51, ! 800: 51, 8, 51, 4, 51, 51, 51, 6, 51, 51, 51, 5, 51, 51, 51, 51, ! 801: 51, 50, 3, 1, 51, 51, 2, 51, 7, 51, 51, 51, 51, 51, 51, 51, ! 802: -1, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 803: 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 804: 51, 51, 51, 43, 51, 49, 51, 42, 51, 51, 51, 51, 51, 51, 51, 51, ! 805: 51, 51, 41, 51, 51, 51, 51, 51, 51, 40, 51, 51, 51, 51, 51, 51, ! 806: 51, 8, 51, 4, 51, 51, 51, 6, 51, 51, 51, 5, 51, 51, 51, 51, ! 807: 51, 50, 3, 1, 51, 51, 2, 51, 7, 51, 51, 51, 51, 51, 51, 51, ! 808: -1, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 809: 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 810: 51, 51, 51, 51, 51, 49, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 811: 51, 51, 51, 51, 51, 51, 51, 51, 51, 44, 51, 51, 51, 51, 51, 51, ! 812: 51, 8, 51, 4, 51, 51, 51, 6, 51, 51, 51, 5, 51, 51, 51, 51, ! 813: 51, 50, 3, 1, 51, 51, 2, 51, 7, 51, 51, 51, 51, 51, 51, 51, ! 814: -1, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 815: 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 816: 51, 51, 51, 51, 51, 49, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 817: 51, 51, 51, 51, 51, 51, 51, 51, 51, 45, 51, 51, 51, 51, 51, 51, ! 818: 51, 8, 51, 4, 51, 51, 51, 6, 51, 51, 51, 5, 51, 51, 51, 51, ! 819: 51, 50, 3, 1, 51, 51, 2, 51, 7, 51, 51, 51, 51, 51, 51, 51, ! 820: -1, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 821: 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 822: 51, 51, 51, 51, 51, 49, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 823: 51, 51, 51, 51, 51, 51, 51, 51, 51, 46, 51, 51, 51, 51, 51, 51, ! 824: 51, 8, 51, 4, 51, 51, 51, 6, 51, 51, 51, 5, 51, 51, 51, 51, ! 825: 51, 50, 3, 1, 51, 51, 2, 51, 7, 51, 51, 51, 51, 51, 51, 51, ! 826: -1, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 827: 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 828: 51, 51, 51, 51, 51, 49, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 829: 51, 51, 51, 51, 51, 51, 51, 51, 51, 47, 51, 51, 51, 51, 51, 51, ! 830: 51, 8, 51, 4, 51, 51, 51, 6, 51, 51, 51, 5, 51, 51, 51, 51, ! 831: 51, 50, 3, 1, 51, 51, 2, 51, 7, 51, 51, 51, 51, 51, 51, 51, ! 832: -1, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 833: 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 834: 51, 51, 51, 51, 51, 49, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 835: 51, 51, 51, 51, 51, 51, 51, 51, 51, 48, 51, 51, 51, 51, 51, 51, ! 836: 51, 8, 51, 4, 51, 51, 51, 6, 51, 51, 51, 5, 51, 51, 51, 51, ! 837: 51, 50, 3, 1, 51, 51, 2, 51, 7, 51, 51, 51, 51, 51, 51, 51, ! 838: -1, 18, 18, 18, 18, 18, 18, 18, 18, 18, 18, 18, 18, 18, 18, 18, ! 839: 18, 18, 18, 18, 18, 18, 18, 18, 18, 18, 18, 18, 18, 18, 18, 18, ! 840: 18, 18, 18, 16, 18, 18, 18, 15, 18, 13, 18, 18, 18, 18, 18, 18, ! 841: 18, 18, 14, 9, 18, 18, 18, 18, 18, 18, 18, 18, 18, 18, 18, 18, ! 842: 18, 8, 18, 4, 18, 18, 18, 6, 18, 18, 18, 5, 18, 18, 18, 18, ! 843: 18, 17, 3, 1, 18, 18, 2, 18, 7, 18, 18, 18, 18, 18, 18, 18, ! 844: -1, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, ! 845: 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, ! 846: 30, 30, 30, 19, 20, 21, 22, 30, 24, 30, 30, 30, 23, 30, 30, 30, ! 847: 30, 30, 30, 25, 26, 27, 30, 28, 30, 30, 30, 30, 30, 30, 30, 30, ! 848: 30, 8, 30, 4, 30, 30, 30, 6, 30, 30, 30, 5, 30, 30, 30, 30, ! 849: 30, 29, 3, 1, 30, 30, 2, 30, 7, 30, 30, 30, 30, 30, 30, 30, ! 850: -1, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 851: 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 852: 51, 51, 51, 51, 51, 49, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 853: 51, 51, 51, 9, 51, 51, 51, 51, 51, 12, 51, 51, 51, 51, 51, 51, ! 854: 51, 8, 51, 4, 51, 51, 51, 6, 51, 51, 51, 5, 51, 51, 51, 51, ! 855: 51, 50, 3, 1, 51, 51, 2, 51, 7, 51, 51, 51, 51, 51, 51, 51, ! 856: 0, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 857: 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 858: 51, 51, 51, 51, 51, 49, 32, 51, 51, 51, 51, 51, 51, 51, 51, 51, ! 859: 51, 51, 51, 9, 51, 51, 51, 51, 33, 31, 51, 51, 51, 51, 51, 51, ! 860: 51, 8, 51, 4, 51, 51, 51, 6, 51, 51, 51, 5, 51, 51, 51, 51, ! 861: 51, 50, 3, 1, 51, 51, 2, 51, 7, 51, 51, 51, 51, 51, 51, 51 }; ! 862: ! 863: ! 864: /* P R O T O -- Protocol entry function */ ! 865: ! 866: VOID ! 867: proto() { ! 868: ! 869: int x; ! 870: long lx; ! 871: ! 872: /* Set up the communication line for file transfer. */ ! 873: ! 874: if (local && (speed < 0L) && (network == 0)) { ! 875: screen(SCR_EM,0,0l,"Sorry, you must 'set speed' first"); ! 876: return; ! 877: } ! 878: x = -1; ! 879: if (ttopen(ttname,&x,mdmtyp,cdtimo) < 0) { ! 880: debug(F111,"failed: proto ttopen local",ttname,local); ! 881: screen(SCR_EM,0,0l,"Can't open line"); ! 882: return; ! 883: } ! 884: if (x > -1) local = x; ! 885: debug(F111,"proto ttopen local",ttname,local); ! 886: ! 887: lx = (local && !network) ? speed : -1; ! 888: if (ttpkt(lx,flow,parity) < 0) { /* Put line in packet mode, */ ! 889: screen(SCR_EM,0,0l,"Can't condition line"); ! 890: return; ! 891: } ! 892: if (!local) connoi(); /* No console interrupts if remote */ ! 893: ! 894: if (sstate == 'x') { /* If entering server mode, */ ! 895: server = 1; /* set flag, */ ! 896: debug(F101,"server backgrd","",backgrd); ! 897: debug(F101,"server quiet","",quiet); ! 898: if (!quiet && !backgrd) { ! 899: debug(F100,"SHOULD NOT SEE THIS IF IN BACKGROUND!","",0); ! 900: if (!local) /* and issue appropriate message. */ ! 901: conol(srvtxt); ! 902: else { ! 903: conol("Entering server mode on "); ! 904: conoll(ttname); ! 905: conoll("Type Ctrl-C to quit."); ! 906: if (srvdis) intmsg(-1L); ! 907: } ! 908: } ! 909: } else server = 0; ! 910: #ifdef VMS ! 911: if (!quiet && !backgrd) /* So message doesn't overwrite prompt */ ! 912: conoll(""); ! 913: if (local) conres(); /* So Ctrl-C will work */ ! 914: #endif /* VMS */ ! 915: if (sstate == 'v' && !local && !quiet && !backgrd && ! 916: #ifndef NOSPL ! 917: cmdlvl == 0 ! 918: #else ! 919: tlevel < 0 ! 920: #endif /* NOSPL */ ! 921: ) ! 922: conoll("Escape back to your local Kermit and give a SEND command..."); ! 923: if (sstate == 's' && !local && !quiet && !backgrd && ! 924: #ifndef NOSPL ! 925: cmdlvl == 0 ! 926: #else ! 927: tlevel < 0 ! 928: #endif /* NOSPL */ ! 929: ) ! 930: conoll("Escape back to your local Kermit and give a RECEIVE command..."); ! 931: sleep(1); ! 932: /* ! 933: The 'wart()' function is generated by the wart program. It gets a ! 934: character from the input() routine and then based on that character and ! 935: the current state, selects the appropriate action, according to the state ! 936: table above, which is transformed by the wart program into a big case ! 937: statement. The function is active for one transaction. ! 938: */ ! 939: wart(); /* Enter the state table switcher. */ ! 940: ! 941: if (server) { /* Back from packet protocol. */ ! 942: server = 0; ! 943: if (!quiet && !backgrd) { /* Give appropriate message */ ! 944: conoll(""); ! 945: conoll("C-Kermit server done"); ! 946: } ! 947: } ! 948: /* ! 949: Note: the following is necessary in case we have just done a remote-mode ! 950: file transfer, in which case the controlling terminal modes have been ! 951: changed by ttpkt(). In particular, special characters like Ctrl-C and ! 952: Ctrl-\ might have been turned off (see ttpkt). So this call to ttres() is ! 953: essential. ! 954: */ ! 955: if (!local) ttres(); /* Reset the terminal */ ! 956: screen(SCR_TC,0,0l,""); /* Transaction complete */ ! 957: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.