receive.c

Gcomm is a serial communications program similar to seyon, but more modern, and easier to use. Works

	  0x78, 0x37, 0x35, 0x2c, 0x20, 0x30, 0x78, 0x36, 
	  0x34, 0x2c, 0x20, 0x30, 0x78, 0x36, 0x35, 0x2c, 
	  0x20, 0x30, 0x78, 0x32, 0x30, 0x2c, 0x20, 0x30, 
	  0x78, 0x32, 0x32, 0x2c, 0x20, 0x0a, 0x09, 0x20, 
	  0x20, 0x30, 0x78, 0x37, 0x38, 0x2c, 0x20, 0x30, 
	  0x78, 0x36, 0x64, 0x2c, 0x20, 0x30, 0x78, 0x36, 
	  0x66, 0x2c, 0x20, 0x30, 0x78, 0x36, 0x34, 0x2c, 
	  0x20, 0x30, 0x78, 0x36, 0x35, 0x2c, 0x20, 0x30, 
	  0x78, 0x36, 0x64, 0x2c, 0x20, 0x30, 0x78, 0x32, 
	  0x65, 0x2c, 0x20, 0x30, 0x78, 0x36, 0x38, 0x2c, 
	  0x20, 0x0a, 0x09, 0x20, 0x20, 0x30, 0x78, 0x32, 
	  0x32, 0x2c, 0x20, 0x30, 0x78, 0x30, 0x61, 0x2c, 
	  0x20, 0x30, 0x78, 0x30, 0x61, 0x2c, 0x20, 0x30, 
	  0x78, 0x30, 0x61, 0x2c, 0x20, 0x30, 0x78, 0x36, 
	  0x39, 0x2c, 0x20, 0x30, 0x78, 0x36, 0x65, 0x2c, 
	  0x20, 0x30, 0x78, 0x37, 0x34, 0x2c, 0x20, 0x30, 
	  0x78, 0x30, 0x61, 0x2c, 0x20, 0x0a, 0x09, 0x20, 
	  0x20, 0x30, 0x78, 0x37, 0x33, 0x2c, 0x20, 0x30, 
	  0x78, 0x36, 0x35, 0x2c, 0x20, 0x30, 0x78, 0x36, 
	  0x65, 0x2c, 0x20, 0x30, 0x78, 0x36, 0x34, 0x2c, 
	  0x20, 0x30, 0x78, 0x34, 0x33, 0x2c, 0x20, 0x30, 
	  0x78, 0x36, 0x18, 0x6a, 0x4a, 0xe5, 0x72, 0x71, 
	} ;

#define	E(b)	{b, sizeof(b)}
static	struct {u_char *am; int len} Amsgs[] = {
	  E(Amsg0),
	  E(Amsg1),
	  E(Amsg2),
	  E(Amsg3),
	  E(Amsg4),} ;

#endif	/* TEST */

	/* try to trap uninit. variables */
	memset(&info,0xa5,sizeof(info)) ;

	info.zrinitflags = CANFDX|CANOVIO|CANBRK|CANFC32 ;
	info.packetsize = 128 ;
	info.bufsize = 0 ;

#ifdef	TEST
	done = ZmodemRInit(&info) ;
	for(i=0; !done; ++i )
	  done = ZmodemRcv(Amsgs[i].am, Amsgs[i].len, &info) ;

#else
	if( argc < 2 )
	  exit(2) ;

	info.ifd = open(argv[1], O_RDWR) ;

	if( info.ifd == -1 )
	  exit(1) ;

	tcgetattr(info.ifd,&old_settings) ;
	new_settings = old_settings ;

	new_settings.c_iflag &=
	  ~(ISTRIP|INLCR|IGNCR|ICRNL|IUCLC|IXON|IXOFF|IMAXBEL) ;
	new_settings.c_oflag = 0 ;
	new_settings.c_cflag = B300|CS8|CREAD|CLOCAL ;
	new_settings.c_lflag = 0 ;
	new_settings.c_cc[VMIN] = 32 ;
	new_settings.c_cc[VTIME] = 1 ;
	tcsetattr(info.ifd,TCSADRAIN, &new_settings) ;

	done = ZmodemRInit(&info) ;

	while(!done)
	{
	  FD_ZERO(&readfds) ;
	  FD_SET(info.ifd, &readfds) ;
	  timeout.tv_sec = info.timeout ;
	  timeout.tv_usec = 0 ;
	  i = select(info.ifd+1, &readfds,NULL,NULL, &timeout) ;
	  if( i<0 )
	    perror("select") ;
	  else if( i==0 )
	    done = ZmodemTimeout(&info) ;
	  else {
	    len = read(info.ifd, buffer, sizeof(buffer)) ;
	    done = ZmodemRcv(buffer, len, &info) ;
	  }
	}

	tcsetattr(info.ifd,TCSADRAIN, &old_settings) ;
#endif	/* TEST */
	exit(0) ;
}




int
ZXmitStr(buffer, len, info)
	u_char	*buffer ;
	int	len ;
	ZModem	*info ;
{
	int	i,j ;
	u_char	c ;
extern	double	drand48() ;

#ifdef	TEST
	for(i=0; i<len; i += 16)
	{
	  printf("   ") ;
	  for(j=0; j<16 && i+j<len; ++j)
	    printf("%2.2x ", buffer[i+j]) ;
	  for(; j<16; ++j)
	    printf("   ") ;
	  printf("  |") ;
	  for(j=0; j<16 && i+j<len; ++j)
	    putchar(((c=buffer[i+j]) < 040 || c >= 0177) ? '.' : c ) ;
	  printf("|\n") ;
	}
#else

#ifdef	COMMENT
/* TEST: randomly corrupt one out of every 300 bytes */
for(i=0; i<len; ++i)
  if( drand48() < 1./300. ) {
    fprintf(stderr, "byte %d was %2.2x, is", i, buffer[i]) ;
    buffer[i] ^= 1<<(lrand48()&7) ;
    fprintf(stderr, " %2.2x\n", buffer[i]) ;
  }
#endif	/* COMMENT */

	if( write(info->ifd, buffer, len) != len )
	  return ZmErrSys ;
#endif	/* TEST */

	return 0 ;
}


void
ZIFlush(info)
	ZModem	*info ;
{
}

void
ZOFlush(info)
	ZModem	*info ;
{
}

void
ZStatus(i,j,str)
{
	fprintf(stderr,"status %d=%d\n",i,j) ;
}


int
ZAttn(info)
	ZModem	*info ;
{
	char	*ptr ;
	int	i = 0 ;

	for(ptr = info->attn; *ptr != '\0'; ++ptr) {
	  if( *ptr == ATTNBRK )
	    ioctl(info->ifd, TCSBRK, 0) ;
	  else if( *ptr == ATTNPSE )
	    sleep(1) ;
	  else
	    write(info->ifd, ptr, 1) ;
	}
	return 0 ;
}


FILE *
ZOpenFile(name, crc, info)
	char	*name ;
	u_long	crc ;
	ZModem	*info ;
{
	struct stat	buf ;
	int		exists ;	/* file already exists */
static	int		changeCount = 0 ;
	char		name2[MAXPATHLEN] ;
	int		apnd = 0 ;
	int		f0,f1,f2,f3 ;

	/* TODO: if absolute path, do we want to allow it?
	 * if relative path, do we want to prepend something?
	 */

	if( *name == '/' )	/* for now, disallow absolute paths */
	  return NULL ;

	if( stat(name, &buf) == 0 )
	  exists = 1 ;
	else if( errno == ENOENT )
	  exists = 0 ;
	else
	  return NULL ;


	/* if remote end has not specified transfer flags, we can
	 * accept the local definitions
	 */

	if( f0 == ZCRESUM ) {	/* if exists, and we already have it, return */
	  if( exists  &&  buf.st_size == info->len )
	    return NULL ;
	  apnd = 1 ;
	}

	/* reject if file not found and it most be there (ZMSKNOLOC) */
	if( !exists && (f1 & ZMSKNOLOC) )
	  return NULL ;

	switch( f1 & ZMMASK ) {
	  case 0:	/* Implementation-dependent.  In this case, we
			 * reject if file exists (and ZMSKNOLOC not set) */
	    if( exists && !(f1 & ZMSKNOLOC) )
	      return NULL ;
	    break ;

	  case ZMNEWL:	/* take if newer or longer than file on disk */
	    if( exists  &&  info->date <= buf.st_mtime  &&
		info->len <= buf.st_size )
	      return NULL ;
	    break ;

	  case ZMCRC:		/* take if different CRC or length */
	    if( exists  &&  info->len == buf.st_size && crc == FileCrc(name) )
	      return NULL ;
	    break ;

	  case ZMAPND:	/* append */
	    apnd = 1 ;
	  case ZMCLOB:	/* unconditional replace */
	    break ;

	  case ZMNEW:	/* take if newer than file on disk */
	    if( exists  &&  info->date <= buf.st_mtime )
	      return NULL ;
	    break ;

	  case ZMDIFF:	/* take if different date or length */
	    if( exists  &&  info->date == buf.st_mtime  &&
		info->len == buf.st_size )
	      return NULL ;
	    break ;

	  case ZMPROT:	/* only if dest does not exist */
	    if( exists )
	      return NULL ;
	    break ;

	  case ZMCHNG:	/* invent new filename if exists */
	    if( exists ) {
	      while( exists ) {
		sprintf(name2, "%s_%d", name, changeCount++) ;
		exists = stat(name2, &buf) == 0 || errno != ENOENT ;
	      }
	      name = name2 ;
	    }
	    break ;
	}

	/* here if we've decided to accept */
	if( exists && !apnd && unlink(name) != 0 )
	  return NULL ;

	/* TODO: build directory path if needed */

	return fopen(name, apnd ? "a" : "w") ;
}


int
ZWriteFile(buffer, len, file, info)
	u_char	*buffer ;
	int	len ;
	FILE	*file ;
	ZModem	*info ;
{
	/* TODO: if ZCNL set in info->f0, convert
	 * newlines to local convention
	 */

	return fwrite(buffer, 1, len, file) == len ? 0 : ZmErrSys ;
}


int
ZCloseFile(info)
	ZModem *info ;
{
	fclose(info->file) ;
	chmod(info->filename, info->mode&0777) ;
}