Skip to content

Commit cec20cc

Browse files
committed
[refer #PGPRO-1745] Rewrite fio_gz* support
1 parent f025b90 commit cec20cc

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/utils/file.c

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -853,7 +853,7 @@ fio_gzread(gzFile f, void *buf, unsigned size)
853853
{
854854
gz->strm.next_in = gz->buf;
855855
}
856-
rc = read(gz->fd, gz->strm.next_in + gz->strm.avail_in, gz->buf + ZLIB_BUFFER_SIZE - gz->strm.next_in - gz->strm.avail_in);
856+
rc = fio_read(gz->fd, gz->strm.next_in + gz->strm.avail_in, gz->buf + ZLIB_BUFFER_SIZE - gz->strm.next_in - gz->strm.avail_in);
857857
if (rc > 0)
858858
{
859859
gz->strm.avail_in += rc;
@@ -902,7 +902,7 @@ fio_gzwrite(gzFile f, void const* buf, unsigned size)
902902
break;
903903
}
904904
}
905-
rc = write(gz->fd, gz->strm.next_out, ZLIB_BUFFER_SIZE - gz->strm.avail_out);
905+
rc = fio_write(gz->fd, gz->strm.next_out, ZLIB_BUFFER_SIZE - gz->strm.avail_out);
906906
if (rc >= 0)
907907
{
908908
gz->strm.next_out += rc;
@@ -935,7 +935,7 @@ fio_gzclose(gzFile f)
935935
rc = deflate(&gz->strm, Z_FINISH);
936936
Assert(rc == Z_STREAM_END && gz->strm.avail_out != ZLIB_BUFFER_SIZE);
937937
deflateEnd(&gz->strm);
938-
rc = write(gz->fd, gz->buf, ZLIB_BUFFER_SIZE - gz->strm.avail_out);
938+
rc = fio_write(gz->fd, gz->buf, ZLIB_BUFFER_SIZE - gz->strm.avail_out);
939939
if (rc != ZLIB_BUFFER_SIZE - gz->strm.avail_out)
940940
{
941941
return -1;

0 commit comments

Comments
 (0)