lib/zstd
1
0
Fork 0
mirror of https://github.com/facebook/zstd.git synced 2025-08-01 09:47:01 +03:00
Code Activity

Use correct types in LZMA comp/decomp (#3497)

Browse Source 
Bytef and uInt are zlib types, not available when zlib is disabled

Fixes: 1598e6c634 ("Async write for decompression")
Fixes: cc0657f27d ("AsyncIO compression part 2 - added async read and asyncio to compression code (#3022)")
This commit is contained in:
Alex Xu
2023-02-14 00:30:56 +00:00
committed by GitHub
parent 30cb0a4f25
commit 886de7bc04
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
programs/fileio.c
View File

@ -1173,8 +1173,8 @@ FIO_compressLzmaFrame(cRess_t* ress,
} }
writeJob =AIO_WritePool_acquireJob(ress->writeCtx); writeJob =AIO_WritePool_acquireJob(ress->writeCtx);
strm.next_out = (Bytef*)writeJob->buffer; strm.next_out = (BYTE*)writeJob->buffer;
strm.avail_out = (uInt)writeJob->bufferSize; strm.avail_out = writeJob->bufferSize;
strm.next_in = 0; strm.next_in = 0;
strm.avail_in = 0; strm.avail_in = 0;
@ -1201,7 +1201,7 @@ FIO_compressLzmaFrame(cRess_t* ress,
writeJob->usedBufferSize = compBytes; writeJob->usedBufferSize = compBytes;
AIO_WritePool_enqueueAndReacquireWriteJob(&writeJob); AIO_WritePool_enqueueAndReacquireWriteJob(&writeJob);
outFileSize += compBytes; outFileSize += compBytes;
strm.next_out = (Bytef*)writeJob->buffer; strm.next_out = (BYTE*)writeJob->buffer;
strm.avail_out = writeJob->bufferSize; strm.avail_out = writeJob->bufferSize;
} } } }
if (srcFileSize == UTIL_FILESIZE_UNKNOWN) if (srcFileSize == UTIL_FILESIZE_UNKNOWN)
@ -2316,8 +2316,8 @@ FIO_decompressLzmaFrame(dRess_t* ress,
} }
writeJob = AIO_WritePool_acquireJob(ress->writeCtx); writeJob = AIO_WritePool_acquireJob(ress->writeCtx);
strm.next_out = (Bytef*)writeJob->buffer; strm.next_out = (BYTE*)writeJob->buffer;
strm.avail_out = (uInt)writeJob->bufferSize; strm.avail_out = writeJob->bufferSize;
strm.next_in = (BYTE const*)ress->readCtx->srcBuffer; strm.next_in = (BYTE const*)ress->readCtx->srcBuffer;
strm.avail_in = ress->readCtx->srcBufferLoaded; strm.avail_in = ress->readCtx->srcBufferLoaded;
@ -2345,7 +2345,7 @@ FIO_decompressLzmaFrame(dRess_t* ress,
writeJob->usedBufferSize = decompBytes; writeJob->usedBufferSize = decompBytes;
AIO_WritePool_enqueueAndReacquireWriteJob(&writeJob); AIO_WritePool_enqueueAndReacquireWriteJob(&writeJob);
outFileSize += decompBytes; outFileSize += decompBytes;
strm.next_out = (Bytef*)writeJob->buffer; strm.next_out = (BYTE*)writeJob->buffer;
strm.avail_out = writeJob->bufferSize; strm.avail_out = writeJob->bufferSize;
} } } }
if (ret == LZMA_STREAM_END) break; if (ret == LZMA_STREAM_END) break;