crzsz.sh

Linux下基于Z-MODEM的串口通讯程序源码

X *  Assumes file name frame is in secbuf
X */
rzfile()
{
X	register c, n;
X
X	Eofseen=FALSE;
X	n = 20; rxbytes = 0l;
X
X	if (c = procheader(secbuf)) {
X		return (tryzhdrtype = c);
X	}
X
X	for (;;) {
#ifdef SEGMENTS
X		chinseg = 0;
#endif
X		stohdr(rxbytes);
X		zshhdr(4,ZRPOS, Txhdr);
nxthdr:
X		switch (c = zgethdr(Rxhdr)) {
X		default:
X			vfile("rzfile: Wrong header %d", c);
X			if ( --n < 0) {
X				sprintf(endmsg, "rzfile: Wrong header %d", c);
X				return ERROR;
X			}
X			continue;
X		case ZCAN:
X			sprintf(endmsg, "Sender CANcelled");
X			return ERROR;
X		case ZNAK:
#ifdef SEGMENTS
X			putsec(secbuf, chinseg);
X			chinseg = 0;
#endif
X			if ( --n < 0) {
X				sprintf(endmsg, "rzfile: got ZNAK", c);
X				return ERROR;
X			}
X			continue;
X		case TIMEOUT:
#ifdef SEGMENTS
X			putsec(secbuf, chinseg);
X			chinseg = 0;
#endif
X			if ( --n < 0) {
X				sprintf(endmsg, "rzfile: TIMEOUT", c);
X				return ERROR;
X			}
X			continue;
X		case ZFILE:
X			zrdata(secbuf, 1024);
X			continue;
X		case ZEOF:
#ifdef SEGMENTS
X			putsec(secbuf, chinseg);
X			chinseg = 0;
#endif
X			if (rclhdr(Rxhdr) != rxbytes) {
X				/*
X				 * Ignore eof if it's at wrong place - force
X				 *  a timeout because the eof might have gone
X				 *  out before we sent our zrpos.
X				 */
X				errors = 0;  goto nxthdr;
X			}
X			if (closeit()) {
X				tryzhdrtype = ZFERR;
X				vfile("rzfile: closeit returned <> 0");
X				sprintf(endmsg,"Error closing file");
X				return ERROR;
X			}
X			vfile("rzfile: normal EOF");
X			return c;
X		case ERROR:	/* Too much garbage in header search error */
#ifdef SEGMENTS
X			putsec(secbuf, chinseg);
X			chinseg = 0;
#endif
X			if ( --n < 0) {
X				sprintf(endmsg, "Persistent CRC or other ERROR");
X				return ERROR;
X			}
X			zmputs(Attn);
X			continue;
X		case ZSKIP:
#ifdef SEGMENTS
X			putsec(secbuf, chinseg);
X			chinseg = 0;
#endif
X			Modtime = 1;
X			closeit();
X			sprintf(endmsg, "Sender SKIPPED file");
X			return c;
X		case ZDATA:
X			if (rclhdr(Rxhdr) != rxbytes) {
X				if ( --n < 0) {
X					sprintf(endmsg,"Data has bad addr");
X					return ERROR;
X				}
#ifdef SEGMENTS
X				putsec(secbuf, chinseg);
X				chinseg = 0;
#endif
X				zmputs(Attn);  continue;
X			}
moredata:
X			fprintf(stderr, "%7ld ZMODEM%s\n",
X			  rxbytes, Crc32r?" CRC-32":"");
#ifdef SEGMENTS
X			if (chinseg >= (1024 * SEGMENTS)) {
X				putsec(secbuf, chinseg);
X				chinseg = 0;
X			}
X			switch (c = zrdata(secbuf+chinseg, 1024))
#else
X			switch (c = zrdata(secbuf, 1024))
#endif
X			{
X			case ZCAN:
#ifdef SEGMENTS
X				putsec(secbuf, chinseg);
X				chinseg = 0;
#endif
X				sprintf(endmsg, "Sender CANcelled");
X				return ERROR;
X			case ERROR:	/* CRC error */
#ifdef SEGMENTS
X				putsec(secbuf, chinseg);
X				chinseg = 0;
#endif
X				if ( --n < 0) {
X					sprintf(endmsg, "Persistent CRC or other ERROR");
X					return ERROR;
X				}
X				zmputs(Attn);
X				continue;
X			case TIMEOUT:
#ifdef SEGMENTS
X				putsec(secbuf, chinseg);
X				chinseg = 0;
#endif
X				if ( --n < 0) {
X					sprintf(endmsg, "TIMEOUT");
X					return ERROR;
X				}
X				continue;
X			case GOTCRCW:
X				n = 20;
#ifdef SEGMENTS
X				chinseg += Rxcount;
X				putsec(secbuf, chinseg);
X				chinseg = 0;
#else
X				putsec(secbuf, Rxcount);
#endif
X				rxbytes += Rxcount;
X				stohdr(rxbytes);
X				sendline(XON);
X				zshhdr(4,ZACK, Txhdr);
X				goto nxthdr;
X			case GOTCRCQ:
X				n = 20;
#ifdef SEGMENTS
X				chinseg += Rxcount;
#else
X				putsec(secbuf, Rxcount);
#endif
X				rxbytes += Rxcount;
X				stohdr(rxbytes);
X				zshhdr(4,ZACK, Txhdr);
X				goto moredata;
X			case GOTCRCG:
X				n = 20;
#ifdef SEGMENTS
X				chinseg += Rxcount;
#else
X				putsec(secbuf, Rxcount);
#endif
X				rxbytes += Rxcount;
X				goto moredata;
X			case GOTCRCE:
X				n = 20;
#ifdef SEGMENTS
X				chinseg += Rxcount;
#else
X				putsec(secbuf, Rxcount);
#endif
X				rxbytes += Rxcount;
X				goto nxthdr;
X			}
X		}
X	}
}
X
X
/*
X * Close the receive dataset, return OK or ERROR
X */
closeit()
{
X	time_t time();
X
X	if (fout == stdout) {
X		fflush(stdout);  fout = 0;  return OK;
X	}
X	if (fclose(fout)==ERROR) {
X		fprintf(stderr, "File close ERROR\n");
X		return ERROR;
X	}
X	if (Modtime) {
X		timep[0] = time(NULL);
X		timep[1] = Modtime;
X		utime(Pathname, timep);
X	}
X	return OK;
}
X
X
/*
X * Strip leading ! if present, do shell escape. 
X */
sys2(s)
register char *s;
{
X	if (*s == '!')
X		++s;
X	return system(s);
}
/*
X * Strip leading ! if present, do exec.
X */
void
exec2(s)
register char *s;
{
X	if (*s == '!')
X		++s;
X	mode(0);
X	execl("/bin/sh", "sh", "-c", s);
}
X
/* End of crz.c */
SHAR_EOF
chmod 0664 crz.c ||
echo 'restore of crz.c failed'
Wc_c="`wc -c < 'crz.c'`"
test 27738 -eq "$Wc_c" ||
	echo 'crz.c: original size 27738, current size' "$Wc_c"
fi
# ============= csz.c ==============
if test -f 'csz.c' -a X"$1" != X"-c"; then
	echo 'x - skipping csz.c (File already exists)'
else
echo 'x - extracting csz.c (Text)'
sed 's/^X//' << 'SHAR_EOF' > 'csz.c' &&
#define VERSION "1.03 10-01-99"
X
/*
X **************************************************************************
X *
X * csz.c By Chuck Forsberg,  Omen Technology INC
X *    Copyright 1998 Omen Technology Inc All Rights Reserved
X * 
X *********************************************************************
X *********************************************************************
X * 
X *
X *	This version implements numerous enhancements including ZMODEM
X *	Run Length Encoding and variable length headers.  These
X *	features were not funded by the original Telenet development
X *	contract.
X * 
X * 
X *  Any programs which incorporate part or all of this code must be
X *  provided in source form with this notice intact except by
X *  prior written permission from Omen Technology Incorporated.
X *  This includes compiled executables of this program.
X *
X *   The .doc files and the file "mailer.crz" must also be included.
X * 
X * Use of this software for commercial or administrative purposes
X * except when exclusively limited to interfacing Omen Technology
X * products requires license payment of $20.00 US per user
X * (less in quantity, see mailer.crz).  Use of this code by
X * inclusion, decompilation, reverse engineering or any other means
X * constitutes agreement to these conditions and acceptance of
X * liability to license the materials and payment of reasonable
X * legal costs necessary to enforce this license agreement.
X *
X *
X *		Omen Technology Inc
X *		Post Office Box 4681
X *		Portland OR 97208
X *
X *	This code is made available in the hope it will be useful,
X *	BUT WITHOUT ANY WARRANTY OF ANY KIND OR LIABILITY FOR ANY
X *	DAMAGES OF ANY KIND.
X *
X *  USG UNIX (3.0) ioctl conventions courtesy Jeff Martin
X */
X
char *Copyright = "Copyright 1998 Omen Technology Inc All Rights Reserved";
X
char *substr();
X
#define LOGFILE "/tmp/cszlog"
#define LOGFILE2 "cszlog"
#include <stdio.h>
#include <signal.h>
#include <ctype.h>
#include <errno.h>
extern int errno;
#define STATIC
X
#define PATHLEN 1000
#define OK 0
#define FALSE 0
#ifdef TRUE
#undef TRUE
#endif
#define TRUE 1
#define ERROR (-1)
/* Ward Christensen / CP/M parameters - Don't change these! */
#define ENQ 005
#define CAN ('X'&037)
#define XOFF ('s'&037)
#define XON ('q'&037)
#define SOH 1
#define STX 2
#define EOT 4
#define ACK 6
#define NAK 025
#define SYN 026
#define CPMEOF 032
#define WANTCRC 0103	/* send C not NAK to get crc not checksum */
#define WANTG 0107	/* Send G not NAK to get nonstop batch xmsn */
#define TIMEOUT (-2)
#define RCDO (-3)
#define GCOUNT (-4)
#define RETRYMAX 10
X
X
#define HOWMANY 2
STATIC int Zmodem=0;		/* ZMODEM protocol requested by receiver */
unsigned Baudrate = 9600;		/* Default, set by first mode() call */
STATIC unsigned Txwindow;	/* Control the size of the transmitted window */
STATIC unsigned Txwspac;	/* Spacing between zcrcq requests */
STATIC unsigned Txwcnt;	/* Counter used to space ack requests */
STATIC long Lrxpos;	/* Receiver's last reported offset */
STATIC int errors;
char Zsendmask[33];	/* Additional control chars to mask */
X
#include "rbsb.c"	/* most of the system dependent stuff here */
X
#include "crctab.c"
X
STATIC int Filesleft;
STATIC long Totalleft;
X
/*
X * Attention string to be executed by receiver to interrupt streaming data
X *  when an error is detected.  A pause (0336) may be needed before the
X *  ^C (03) or after it.
X */
#ifdef READCHECK
STATIC char Myattn[] = { 0 };
#else
#ifdef USG
STATIC char Myattn[] = { 03, 0336, 0 };
#endif
#endif
X
FILE *in;
X
STATIC int Canseek = 1;	/* 1: Can seek 0: only rewind -1: neither (pipe) */
X
#ifndef SMALL
#ifndef TXBSIZE
#define TXBSIZE 32768
#endif
X
#define TXBMASK (TXBSIZE-1)
STATIC char Txb[TXBSIZE + 1024];	/* Circular buffer for file reads */
STATIC char *txbuf = Txb;		/* Pointer to current file segment */
#else
char txbuf[1024];
#endif
X
X
STATIC long vpos = 0;		/* Number of bytes read from file */
X
STATIC char Lastrx;
STATIC char Crcflg;
STATIC int Modem2=0;		/* XMODEM Protocol - don't send pathnames */
STATIC int Fullname=0;		/* transmit full pathname */
STATIC int Unlinkafter=0;	/* Unlink file after it is sent */
STATIC int firstsec;
STATIC int errcnt=0;		/* number of files unreadable */
STATIC int Skipbitch=0;
STATIC int Skipcount=0;		/* Count of skipped files */
STATIC int blklen=128;		/* length of transmitted records */
STATIC int Optiong;		/* Let it rip no wait for sector ACK's */
STATIC int Eofseen;		/* EOF seen on input set by zfilbuf */
STATIC int BEofseen;		/* EOF seen on input set by fooseek */
STATIC int Totsecs;		/* total number of sectors this file */
STATIC int Filcnt=0;		/* count of number of files opened */
STATIC unsigned Rxbuflen=16384;	/* Receiver's max buffer length */
STATIC long Tframlen = 0;	/* Override for tx frame length */
STATIC int blkopt=0;		/* Override value for zmodem blklen */
STATIC int Rxflags = 0;
STATIC long bytcnt, maxbytcnt;
STATIC int Wantfcs32 = TRUE;	/* want to send 32 bit FCS */
STATIC char Lzconv;	/* Local ZMODEM file conversion request */
STATIC char Lzmanag;	/* Local ZMODEM file management request */
STATIC int Lskipnocor;
STATIC char Lztrans;
STATIC int Command;		/* Send a command, then exit. */
STATIC char *Cmdstr;		/* Pointer to the command string */
STATIC int Cmdack1;		/* Rx ACKs command, then do it */
STATIC int Exitcode;
STATIC long Lastsync;	/* Last offset to which we got a ZRPOS */
STATIC int Beenhereb4;		/* How many times we've been ZRPOS'd here */
X
STATIC jmp_buf intrjmp;	/* For the interrupt on RX CAN */
X
X
/* send cancel string to get the other end to shut up */
canit()
{
X	static char canistr[] = {
X	 24,24,24,24,24,24,24,24,24,24,8,8,8,8,8,8,8,8,8,8,0
X	};
X
X	zmputs(canistr);
X	Lleft=0;	/* Do read next time ... */
}
X
X
/* called by signal interrupt or terminate to clean things up */
void
bibi(n)
{
X	canit(); fflush(stdout); mode(0);
X	fprintf(stderr, "csz: caught signal %d; exiting\n", n);
X	if (n == SIGQUIT)
X		abort();
X	if (n == 99)
X		fprintf(stderr, "mode(2) in rbsb.c not implemented!!\n");
X	exit(3);
}
X
/* Called when ZMODEM gets an interrupt (^X) */
void
onintr(c)
{
X	signal(SIGINT, SIG_IGN);
X	longjmp(intrjmp, -1);
}
X
STATIC int Zctlesc;	/* Encode control characters */
STATIC int Nozmodem = 0;	/* If invoked as "sb" */
STATIC char *Progname = "csz";
STATIC int Zrwindow = 1400;	/* RX window size (controls garbage count) */
X
X
/*
X * Log an error
X */
void
zperr1(s,p,u)
char *s, *p, *u;
{
X	fprintf(stderr, "Retry %d: ", errors);
X	fprintf(stderr, s);
X	fprintf(stderr, "\n");
}
X
void
zperr2(s,p,u)
char *s, *p, *u;
{
X	fprintf(stderr, "Retry %d: ", errors);
X	fprintf(stderr, s, p);
X	fprintf(stderr, "\n");
}
X
void
zperr3(s,p,u)
char *s, *p, *u;
{
X	fprintf(stderr, "Retry %d: ", errors);
X	fprintf(stderr, s, p, u);
X	fprintf(stderr, "\n");
}
X
X
#include "zm.c"
#include "zmr.c"
X
main(argc, argv)
char *argv[];
{
X	register char *cp;
X	register npats;
X	char **patts;
X
X	if ((cp = getenv("ZNULLS")) && *cp)
X		Znulls = atoi(cp);
X	Tty = 1;  Ttystream = stdout;
X	chkinvok(argv[0]);
X
X	Rxtimeout = 600;
X	npats=0;
X	if (argc<2)
X		usage();
X	while (--argc) {
X		cp = *++argv;
X		if (*cp++ == '-' && *cp) {
X			while ( *cp) {
X				if (isdigit(*cp)) {
X					++cp;  continue;
X				}
X				switch(*cp++) {
X				case '+':
X					Lzmanag = ZMAPND; break;
X				case 'a':
X					if (Nozmodem || Modem2)
X						usage();
X					Lzconv = ZCNL;  break;
X				case 'b':
X					Lzconv = ZCBIN; break;
X				case 'c':
X					Lzmanag = ZMCHNG;  break;
X				case 'f':
X					Fullname=TRUE; break;
X				case 'e':
X					Zctlesc = 1; break;
X				case 'k':
X					blklen=1024; break;
X				case 'L':
X					if (isdigit(*cp))
X						blkopt = atoi(cp);
X					else {
X						if (--argc < 1)
X							usage();
X						blkopt = atoi(*++argv);
X					}