/***************************************************************************** * * $Id: ymrecv.c,v 1.13 2005/10/11 20:49:48 mbse Exp $ * Purpose ...............: Ymodem receiver * ***************************************************************************** * Copyright (C) 1997-2005 * * Michiel Broek FIDO: 2:280/2802 * Beekmansbos 10 * 1971 BV IJmuiden * the Netherlands * * This file is part of MBSE BBS. * * This BBS is free software; you can redistribute it and/or modify it * under the terms of the GNU General Public License as published by the * Free Software Foundation; either version 2, or (at your option) any * later version. * * MBSE BBS is distributed in the hope that it will be useful, but * WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * General Public License for more details. * * You should have received a copy of the GNU General Public License * along with MBSE BBS; see the file COPYING. If not, write to the Free * Software Foundation, 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA. *****************************************************************************/ #include "../config.h" #include "../lib/mbselib.h" #include "../lib/mbse.h" #include "ttyio.h" #include "timeout.h" #include "transfer.h" #include "zmmisc.h" #include "zmrecv.h" #include "ymsend.h" #include "ymrecv.h" static int Firstsec; static int eof_seen; static int errors; static int Gflg = FALSE; static char NAKchar; extern int Bytesleft; extern off_t rxbytes; extern int Crcflg; extern char Lastrx; extern char *secbuf; #define sendline(c) PUTCHAR((c & 0377)) int wcgetsec(size_t *, char *, unsigned int); int wcrxpn(char *); int wcrx(void); int ymrcvfiles(int want1k, int wantG) { int rc = 0; NAKchar = NAK; Crcflg = Gflg = FALSE; if (protocol == ZM_YMODEM) { NAKchar = WANTCRC; Crcflg = TRUE; } if (want1k) { Crcflg = TRUE; NAKchar = WANTCRC; } if (wantG) { Crcflg = Gflg = TRUE; NAKchar = WANTG; } Syslog('x', "%s: ymrcvfiles(%s, %s)", protname(), want1k ? "TRUE":"FALSE", wantG ? "TRUE":"FALSE"); Syslog('x', "%s: NAK character will be %s", protname(), printablec(NAKchar)); for (;;) { rxbytes = 0l; if (wcrxpn(secbuf) == TERROR) { rc = 2; break; } if (secbuf[0] == 0) { Syslog('+', "%s: end of batch", protname()); break; } if (procheader(secbuf) == ZFERR) { canit(1); rc = 2; break; } if (wcrx() == TERROR) { rc = 2; break; } } Syslog('x', "%s: ymrcvfiles rc=%d", protname(), rc); return rc; } /* * Fetch a pathname from the other end as a C ctyle ASCIZ string. * Length is indeterminate as long as less than Blklen * A null string represents no more files (YMODEM) */ int wcrxpn(char *rpn) { register int c; size_t Blklen = 0; /* record length of received packets */ purgeline(0); Syslog('x', "%s: wcrxpn() crc=%s", protname(), Crcflg ? "true":"false"); et_tu: Firstsec = TRUE; eof_seen = FALSE; Syslog('x', "Send %s", printablec(NAKchar)); sendline(NAKchar); purgeline(0); /* Do read next time ... */ while ((c = wcgetsec(&Blklen, rpn, 10)) != 0) { if (c == WCEOT) { Syslog('x', "Pathname fetch returned EOT"); sendline(ACK); purgeline(0); /* Do read next time ... */ goto et_tu; } return TERROR; } sendline(ACK); return OK; } int wcrx(void) { register int sectnum, sectcurr; register char sendchar; size_t Blklen; int bytes_received = 0; Firstsec = TRUE; sectnum = 0; eof_seen = FALSE; sendchar = NAKchar; Syslog('x', "%s: wcrx, request type %s", protname(), printablec(sendchar)); for (;;) { sendline(sendchar); /* send it now, we're ready! */ purgeline(0); /* Do read next time ... */ /* * Keep connections alive */ Nopper(); alarm_on(); sectcurr = wcgetsec(&Blklen, secbuf, (unsigned int) ((sectnum & 0177) ? 5 : 13)); Syslog('x', "%s: got sector %d size %d", protname(), sectcurr, Blklen); if (sectcurr == ((sectnum+1) &0377)) { sectnum++; /* if using xmodem we don't know how long a file is */ if (Bytesleft && (Bytesleft - bytes_received) < Blklen) Blklen = Bytesleft - bytes_received; bytes_received += Blklen; rxbytes += Blklen; if (putsec(secbuf, Blklen) == ERROR) return ERROR; sendchar = ACK; } else if (sectcurr == (sectnum & 0377)) { Syslog('x', "Received dup Sector"); sendchar = ACK; } else if (sectcurr == WCEOT) { if (closeit(1)) return ERROR; sendline(ACK); purgeline(0); /* Do read next time ... */ return OK; } else if (sectcurr == TERROR) return ERROR; else { Syslog('x', "Sync Error"); return ERROR; } } } int wcgetsec(size_t *Blklen, char *rxbuf, unsigned int maxtime) { register int Checksum, wcj, firstch; register unsigned short oldcrc; register char *p; int sectcurr; for (Lastrx = errors = 0; errors < RETRYMAX; errors++) { if ((firstch = GETCHAR(maxtime)) == STX) { *Blklen = 1024; goto get2; } if (firstch == SOH) { *Blklen=128; get2: Syslog('x', "wcgetsec: firstch=%s, maxtime=%d, check=%s", printablec(firstch), maxtime, Crcflg?"CRC":"Checksum"); sectcurr = GETCHAR(1); if ((sectcurr + (oldcrc = GETCHAR(1))) == 0377) { oldcrc = Checksum = 0; for (p = rxbuf, wcj = *Blklen; --wcj >= 0; ) { if ((firstch = GETCHAR(1)) < 0) goto bilge; oldcrc = updcrc16(firstch, oldcrc); Checksum += (*p++ = firstch); } if ((firstch = GETCHAR(1)) < 0) goto bilge; if (Crcflg) { oldcrc = updcrc16(firstch, oldcrc); if ((firstch = GETCHAR(1)) < 0) goto bilge; oldcrc = updcrc16(firstch, oldcrc); if (oldcrc & 0xFFFF) Syslog('x', "CRC"); else { Firstsec=FALSE; return sectcurr; } } else if (((Checksum - firstch) & 0377) == 0) { Firstsec = FALSE; return sectcurr; } else Syslog('x', "Checksum"); } else Syslog('x', "Sector number garbled"); } /* make sure eot really is eot and not just mixmash */ else if (firstch == EOT && GETCHAR(1) == TIMEOUT) return WCEOT; else if (firstch == CAN) { if (Lastrx == CAN) { Syslog('+', "%s: sender Cancelled during transfer", protname()); return TERROR; } else { Lastrx=CAN; continue; } } else if (firstch == TIMEOUT) { if (Firstsec) goto humbug; bilge: Syslog('x', "TIMEOUT"); } else Syslog('x', "Got 0%o sector header", firstch); humbug: Lastrx = 0; { int cnt = 1000; while (cnt-- && GETCHAR(1) != TIMEOUT); } if (Firstsec) { sendline(NAKchar); Syslog('x', "%s: send %s", protname(), printablec(NAKchar)); purgeline(0); /* Do read next time ... */ } else { maxtime = 5; sendline(NAK); Syslog('x', "%s: send NAK", protname()); purgeline(0); /* Do read next time ... */ } } /* try to stop the bubble machine. */ canit(STDOUT_FILENO); return TERROR; }