intgz_errnum;

constchar*errmsg;

errmsg=gzerror(gzf,&gz_errnum);

errmsg=fio_gzerror(gzf,&gz_errnum);

if (gz_errnum==Z_ERRNO)

returnstrerror(errnum);

interrnum;

constchar*errmsg;

errmsg=gzerror(gzf,&errnum);

errmsg=fio_gzerror(gzf,&errnum);

if (errnum==Z_ERRNO)

returnstrerror(errno);

{

z_streamstrm;

intfd;

interrnum;

boolcompress;

booleof;

Bytefbuf[ZLIB_BUFFER_SIZE];

fioGZFile*gz= (fioGZFile*)malloc(sizeof(fioGZFile));

memset(&gz->strm,0,sizeof(gz->strm));

gz->eof=0;

if (strcmp(mode,PG_BINARY_W)==0)/* compress */

{

gz->strm.next_out=gz->buf;

}

elseif (rc!=Z_OK)

{

gz->errnum=rc;

return-1;

}

if (gz->strm.avail_out!=size)

}

}

constchar*fio_gzerror(gzFilef,int*errnum)

{

if ((size_t)f&FIO_GZ_REMOTE_MARKER)

{

fioGZFile*gz= (fioGZFile*)((size_t)f-FIO_GZ_REMOTE_MARKER);

if (errnum)

*errnum=gz->errnum;

returngz->strm.msg;

}

{

returngzerror(f,errnum);

}

}

z_off_tfio_gzseek(gzFilef,z_off_toffset,intwhence)

{

Assert(!((size_t)f&FIO_GZ_REMOTE_MARKER));

#definePAGE_CHECKSUM_MISMATCH (-256)

#defineSYS_CHECK(cmd) do if ((cmd) < 0) { fprintf(stderr, "%s:%d: (%s) %s\n", __FILE__, __LINE__, #cmd, strerror(errno)); exit(EXIT_FAILURE); } while (0)

#defineIO_CHECK(cmd,size) do { int _rc = (cmd); if (_rc != (size)) { fprintf(stderr, "%s:%d: proceeds %d bytes instead of %d: %s\n", __FILE__, __LINE__, _rc, (int)(size), _rc< 0 ? "end of data" : strerror(errno)); exit(EXIT_FAILURE); } } while (0)

#defineIO_CHECK(cmd,size) do { int _rc = (cmd); if (_rc != (size))if (remote_agent){ fprintf(stderr, "%s:%d: proceeds %d bytes instead of %d: %s\n", __FILE__, __LINE__, _rc, (int)(size), _rc>= 0 ? "end of data" : strerror(errno)); exit(EXIT_FAILURE); } else elog(ERROR, "Communication error: %s", _rc >= 0 ? "end of data" : strerror(errno)); } while (0)

{

externintfio_gzwrite(gzFilef,voidconst*buf,unsignedsize);

externintfio_gzeof(gzFilef);

externz_off_tfio_gzseek(gzFilef,z_off_toffset,intwhence);

externconstchar*fio_gzerror(gzFilefile,int*errnum);