facebook/zstd
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add some comments

Browse Source
This commit is contained in:
Nick Terrell 2020-04-27 18:25:30 -07:00
parent f33de06c3e
commit 77a2945c43
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lib/decompress/zstd_decompress.c
View File

@ -1526,6 +1526,7 @@ static int ZSTD_DCtx_isOversizedTooLong(ZSTD_DStream* zds)
return zds->oversizedDuration >= ZSTD_WORKSPACETOOLARGE_MAXDURATION; return zds->oversizedDuration >= ZSTD_WORKSPACETOOLARGE_MAXDURATION;
} }
/* Checks that the output buffer hasn't changed if ZSTD_obm_stable is used. */
static size_t ZSTD_checkOutBuffer(ZSTD_DStream const* zds, ZSTD_outBuffer const* output) static size_t ZSTD_checkOutBuffer(ZSTD_DStream const* zds, ZSTD_outBuffer const* output)
{ {
ZSTD_outBuffer const expect = zds->expectedOutBuffer; ZSTD_outBuffer const expect = zds->expectedOutBuffer;
@ -1543,6 +1544,11 @@ static size_t ZSTD_checkOutBuffer(ZSTD_DStream const* zds, ZSTD_outBuffer const*
RETURN_ERROR(dstBuffer_wrong, "ZSTD_obm_stable enabled but output differs!"); RETURN_ERROR(dstBuffer_wrong, "ZSTD_obm_stable enabled but output differs!");
} }
/* Calls ZSTD_decompressContinue() with the right parameters for ZSTD_decompressStream()
* and updates the stage and the output buffer state. This call is extracted so it can be
* used both when reading directly from the ZSTD_inBuffer, and in buffered input mode.
* NOTE: You must break after calling this function since the streamStage is modified.
*/
static size_t ZSTD_decompressContinueStream( static size_t ZSTD_decompressContinueStream(
ZSTD_DStream* zds, char** op, char* oend, ZSTD_DStream* zds, char** op, char* oend,
void const* src, size_t srcSize) { void const* src, size_t srcSize) {
@ -1559,10 +1565,12 @@ static size_t ZSTD_decompressContinueStream(
zds->streamStage = zdss_flush; zds->streamStage = zdss_flush;
} }
} else { } else {
/* Write directly into the output buffer */
size_t const dstSize = isSkipFrame ? 0 : oend - *op; size_t const dstSize = isSkipFrame ? 0 : oend - *op;
size_t const decodedSize = ZSTD_decompressContinue(zds, *op, dstSize, src, srcSize); size_t const decodedSize = ZSTD_decompressContinue(zds, *op, dstSize, src, srcSize);
FORWARD_IF_ERROR(decodedSize); FORWARD_IF_ERROR(decodedSize);
*op += decodedSize; *op += decodedSize;
/* Flushing is not needed. */
zds->streamStage = zdss_read; zds->streamStage = zdss_read;
assert(*op <= oend); assert(*op <= oend);
assert(zds->outBufferMode == ZSTD_obm_stable); assert(zds->outBufferMode == ZSTD_obm_stable);