|
@@ -1,5 +1,5 @@
|
|
/*
|
|
/*
|
|
- * Copyright (c) 2016-present, Yann Collet, Facebook, Inc.
|
|
|
|
|
|
+ * Copyright (c) 2016-2020, Yann Collet, Facebook, Inc.
|
|
* All rights reserved.
|
|
* All rights reserved.
|
|
*
|
|
*
|
|
* This source code is licensed under both the BSD-style license (found in the
|
|
* This source code is licensed under both the BSD-style license (found in the
|
|
@@ -56,19 +56,19 @@
|
|
* Dependencies
|
|
* Dependencies
|
|
*********************************************************/
|
|
*********************************************************/
|
|
#include <string.h> /* memcpy, memmove, memset */
|
|
#include <string.h> /* memcpy, memmove, memset */
|
|
-#include "cpu.h" /* bmi2 */
|
|
|
|
-#include "mem.h" /* low level memory routines */
|
|
|
|
|
|
+#include "../common/cpu.h" /* bmi2 */
|
|
|
|
+#include "../common/mem.h" /* low level memory routines */
|
|
#define FSE_STATIC_LINKING_ONLY
|
|
#define FSE_STATIC_LINKING_ONLY
|
|
-#include "fse.h"
|
|
|
|
|
|
+#include "../common/fse.h"
|
|
#define HUF_STATIC_LINKING_ONLY
|
|
#define HUF_STATIC_LINKING_ONLY
|
|
-#include "huf.h"
|
|
|
|
-#include "zstd_internal.h" /* blockProperties_t */
|
|
|
|
|
|
+#include "../common/huf.h"
|
|
|
|
+#include "../common/zstd_internal.h" /* blockProperties_t */
|
|
#include "zstd_decompress_internal.h" /* ZSTD_DCtx */
|
|
#include "zstd_decompress_internal.h" /* ZSTD_DCtx */
|
|
#include "zstd_ddict.h" /* ZSTD_DDictDictContent */
|
|
#include "zstd_ddict.h" /* ZSTD_DDictDictContent */
|
|
#include "zstd_decompress_block.h" /* ZSTD_decompressBlock_internal */
|
|
#include "zstd_decompress_block.h" /* ZSTD_decompressBlock_internal */
|
|
|
|
|
|
#if defined(ZSTD_LEGACY_SUPPORT) && (ZSTD_LEGACY_SUPPORT>=1)
|
|
#if defined(ZSTD_LEGACY_SUPPORT) && (ZSTD_LEGACY_SUPPORT>=1)
|
|
-# include "zstd_legacy.h"
|
|
|
|
|
|
+# include "../legacy/zstd_legacy.h"
|
|
#endif
|
|
#endif
|
|
|
|
|
|
|
|
|
|
@@ -111,7 +111,12 @@ static void ZSTD_initDCtx_internal(ZSTD_DCtx* dctx)
|
|
dctx->legacyContext = NULL;
|
|
dctx->legacyContext = NULL;
|
|
dctx->previousLegacyVersion = 0;
|
|
dctx->previousLegacyVersion = 0;
|
|
dctx->noForwardProgress = 0;
|
|
dctx->noForwardProgress = 0;
|
|
|
|
+ dctx->oversizedDuration = 0;
|
|
dctx->bmi2 = ZSTD_cpuid_bmi2(ZSTD_cpuid());
|
|
dctx->bmi2 = ZSTD_cpuid_bmi2(ZSTD_cpuid());
|
|
|
|
+ dctx->outBufferMode = ZSTD_obm_buffered;
|
|
|
|
+#ifdef FUZZING_BUILD_MODE_UNSAFE_FOR_PRODUCTION
|
|
|
|
+ dctx->dictContentEndForFuzzing = NULL;
|
|
|
|
+#endif
|
|
}
|
|
}
|
|
|
|
|
|
ZSTD_DCtx* ZSTD_initStaticDCtx(void *workspace, size_t workspaceSize)
|
|
ZSTD_DCtx* ZSTD_initStaticDCtx(void *workspace, size_t workspaceSize)
|
|
@@ -208,7 +213,7 @@ unsigned ZSTD_isFrame(const void* buffer, size_t size)
|
|
static size_t ZSTD_frameHeaderSize_internal(const void* src, size_t srcSize, ZSTD_format_e format)
|
|
static size_t ZSTD_frameHeaderSize_internal(const void* src, size_t srcSize, ZSTD_format_e format)
|
|
{
|
|
{
|
|
size_t const minInputSize = ZSTD_startingInputLength(format);
|
|
size_t const minInputSize = ZSTD_startingInputLength(format);
|
|
- RETURN_ERROR_IF(srcSize < minInputSize, srcSize_wrong);
|
|
|
|
|
|
+ RETURN_ERROR_IF(srcSize < minInputSize, srcSize_wrong, "");
|
|
|
|
|
|
{ BYTE const fhd = ((const BYTE*)src)[minInputSize-1];
|
|
{ BYTE const fhd = ((const BYTE*)src)[minInputSize-1];
|
|
U32 const dictID= fhd & 3;
|
|
U32 const dictID= fhd & 3;
|
|
@@ -256,7 +261,7 @@ size_t ZSTD_getFrameHeader_advanced(ZSTD_frameHeader* zfhPtr, const void* src, s
|
|
zfhPtr->frameType = ZSTD_skippableFrame;
|
|
zfhPtr->frameType = ZSTD_skippableFrame;
|
|
return 0;
|
|
return 0;
|
|
}
|
|
}
|
|
- RETURN_ERROR(prefix_unknown);
|
|
|
|
|
|
+ RETURN_ERROR(prefix_unknown, "");
|
|
}
|
|
}
|
|
|
|
|
|
/* ensure there is enough `srcSize` to fully read/decode frame header */
|
|
/* ensure there is enough `srcSize` to fully read/decode frame header */
|
|
@@ -280,7 +285,7 @@ size_t ZSTD_getFrameHeader_advanced(ZSTD_frameHeader* zfhPtr, const void* src, s
|
|
if (!singleSegment) {
|
|
if (!singleSegment) {
|
|
BYTE const wlByte = ip[pos++];
|
|
BYTE const wlByte = ip[pos++];
|
|
U32 const windowLog = (wlByte >> 3) + ZSTD_WINDOWLOG_ABSOLUTEMIN;
|
|
U32 const windowLog = (wlByte >> 3) + ZSTD_WINDOWLOG_ABSOLUTEMIN;
|
|
- RETURN_ERROR_IF(windowLog > ZSTD_WINDOWLOG_MAX, frameParameter_windowTooLarge);
|
|
|
|
|
|
+ RETURN_ERROR_IF(windowLog > ZSTD_WINDOWLOG_MAX, frameParameter_windowTooLarge, "");
|
|
windowSize = (1ULL << windowLog);
|
|
windowSize = (1ULL << windowLog);
|
|
windowSize += (windowSize >> 3) * (wlByte&7);
|
|
windowSize += (windowSize >> 3) * (wlByte&7);
|
|
}
|
|
}
|
|
@@ -352,14 +357,14 @@ static size_t readSkippableFrameSize(void const* src, size_t srcSize)
|
|
size_t const skippableHeaderSize = ZSTD_SKIPPABLEHEADERSIZE;
|
|
size_t const skippableHeaderSize = ZSTD_SKIPPABLEHEADERSIZE;
|
|
U32 sizeU32;
|
|
U32 sizeU32;
|
|
|
|
|
|
- RETURN_ERROR_IF(srcSize < ZSTD_SKIPPABLEHEADERSIZE, srcSize_wrong);
|
|
|
|
|
|
+ RETURN_ERROR_IF(srcSize < ZSTD_SKIPPABLEHEADERSIZE, srcSize_wrong, "");
|
|
|
|
|
|
sizeU32 = MEM_readLE32((BYTE const*)src + ZSTD_FRAMEIDSIZE);
|
|
sizeU32 = MEM_readLE32((BYTE const*)src + ZSTD_FRAMEIDSIZE);
|
|
RETURN_ERROR_IF((U32)(sizeU32 + ZSTD_SKIPPABLEHEADERSIZE) < sizeU32,
|
|
RETURN_ERROR_IF((U32)(sizeU32 + ZSTD_SKIPPABLEHEADERSIZE) < sizeU32,
|
|
- frameParameter_unsupported);
|
|
|
|
|
|
+ frameParameter_unsupported, "");
|
|
{
|
|
{
|
|
size_t const skippableSize = skippableHeaderSize + sizeU32;
|
|
size_t const skippableSize = skippableHeaderSize + sizeU32;
|
|
- RETURN_ERROR_IF(skippableSize > srcSize, srcSize_wrong);
|
|
|
|
|
|
+ RETURN_ERROR_IF(skippableSize > srcSize, srcSize_wrong, "");
|
|
return skippableSize;
|
|
return skippableSize;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -439,7 +444,7 @@ static size_t ZSTD_decodeFrameHeader(ZSTD_DCtx* dctx, const void* src, size_t he
|
|
* harder.
|
|
* harder.
|
|
*/
|
|
*/
|
|
RETURN_ERROR_IF(dctx->fParams.dictID && (dctx->dictID != dctx->fParams.dictID),
|
|
RETURN_ERROR_IF(dctx->fParams.dictID && (dctx->dictID != dctx->fParams.dictID),
|
|
- dictionary_wrong);
|
|
|
|
|
|
+ dictionary_wrong, "");
|
|
#endif
|
|
#endif
|
|
if (dctx->fParams.checksumFlag) XXH64_reset(&dctx->xxhState, 0);
|
|
if (dctx->fParams.checksumFlag) XXH64_reset(&dctx->xxhState, 0);
|
|
return 0;
|
|
return 0;
|
|
@@ -559,17 +564,6 @@ unsigned long long ZSTD_decompressBound(const void* src, size_t srcSize)
|
|
* Frame decoding
|
|
* Frame decoding
|
|
***************************************************************/
|
|
***************************************************************/
|
|
|
|
|
|
-
|
|
|
|
-void ZSTD_checkContinuity(ZSTD_DCtx* dctx, const void* dst)
|
|
|
|
-{
|
|
|
|
- if (dst != dctx->previousDstEnd) { /* not contiguous */
|
|
|
|
- dctx->dictEnd = dctx->previousDstEnd;
|
|
|
|
- dctx->virtualStart = (const char*)dst - ((const char*)(dctx->previousDstEnd) - (const char*)(dctx->prefixStart));
|
|
|
|
- dctx->prefixStart = dst;
|
|
|
|
- dctx->previousDstEnd = dst;
|
|
|
|
- }
|
|
|
|
-}
|
|
|
|
-
|
|
|
|
/** ZSTD_insertBlock() :
|
|
/** ZSTD_insertBlock() :
|
|
* insert `src` block into `dctx` history. Useful to track uncompressed blocks. */
|
|
* insert `src` block into `dctx` history. Useful to track uncompressed blocks. */
|
|
size_t ZSTD_insertBlock(ZSTD_DCtx* dctx, const void* blockStart, size_t blockSize)
|
|
size_t ZSTD_insertBlock(ZSTD_DCtx* dctx, const void* blockStart, size_t blockSize)
|
|
@@ -587,9 +581,9 @@ static size_t ZSTD_copyRawBlock(void* dst, size_t dstCapacity,
|
|
DEBUGLOG(5, "ZSTD_copyRawBlock");
|
|
DEBUGLOG(5, "ZSTD_copyRawBlock");
|
|
if (dst == NULL) {
|
|
if (dst == NULL) {
|
|
if (srcSize == 0) return 0;
|
|
if (srcSize == 0) return 0;
|
|
- RETURN_ERROR(dstBuffer_null);
|
|
|
|
|
|
+ RETURN_ERROR(dstBuffer_null, "");
|
|
}
|
|
}
|
|
- RETURN_ERROR_IF(srcSize > dstCapacity, dstSize_tooSmall);
|
|
|
|
|
|
+ RETURN_ERROR_IF(srcSize > dstCapacity, dstSize_tooSmall, "");
|
|
memcpy(dst, src, srcSize);
|
|
memcpy(dst, src, srcSize);
|
|
return srcSize;
|
|
return srcSize;
|
|
}
|
|
}
|
|
@@ -600,9 +594,9 @@ static size_t ZSTD_setRleBlock(void* dst, size_t dstCapacity,
|
|
{
|
|
{
|
|
if (dst == NULL) {
|
|
if (dst == NULL) {
|
|
if (regenSize == 0) return 0;
|
|
if (regenSize == 0) return 0;
|
|
- RETURN_ERROR(dstBuffer_null);
|
|
|
|
|
|
+ RETURN_ERROR(dstBuffer_null, "");
|
|
}
|
|
}
|
|
- RETURN_ERROR_IF(regenSize > dstCapacity, dstSize_tooSmall);
|
|
|
|
|
|
+ RETURN_ERROR_IF(regenSize > dstCapacity, dstSize_tooSmall, "");
|
|
memset(dst, b, regenSize);
|
|
memset(dst, b, regenSize);
|
|
return regenSize;
|
|
return regenSize;
|
|
}
|
|
}
|
|
@@ -618,7 +612,7 @@ static size_t ZSTD_decompressFrame(ZSTD_DCtx* dctx,
|
|
{
|
|
{
|
|
const BYTE* ip = (const BYTE*)(*srcPtr);
|
|
const BYTE* ip = (const BYTE*)(*srcPtr);
|
|
BYTE* const ostart = (BYTE* const)dst;
|
|
BYTE* const ostart = (BYTE* const)dst;
|
|
- BYTE* const oend = ostart + dstCapacity;
|
|
|
|
|
|
+ BYTE* const oend = dstCapacity != 0 ? ostart + dstCapacity : ostart;
|
|
BYTE* op = ostart;
|
|
BYTE* op = ostart;
|
|
size_t remainingSrcSize = *srcSizePtr;
|
|
size_t remainingSrcSize = *srcSizePtr;
|
|
|
|
|
|
@@ -627,15 +621,15 @@ static size_t ZSTD_decompressFrame(ZSTD_DCtx* dctx,
|
|
/* check */
|
|
/* check */
|
|
RETURN_ERROR_IF(
|
|
RETURN_ERROR_IF(
|
|
remainingSrcSize < ZSTD_FRAMEHEADERSIZE_MIN(dctx->format)+ZSTD_blockHeaderSize,
|
|
remainingSrcSize < ZSTD_FRAMEHEADERSIZE_MIN(dctx->format)+ZSTD_blockHeaderSize,
|
|
- srcSize_wrong);
|
|
|
|
|
|
+ srcSize_wrong, "");
|
|
|
|
|
|
/* Frame Header */
|
|
/* Frame Header */
|
|
{ size_t const frameHeaderSize = ZSTD_frameHeaderSize_internal(
|
|
{ size_t const frameHeaderSize = ZSTD_frameHeaderSize_internal(
|
|
ip, ZSTD_FRAMEHEADERSIZE_PREFIX(dctx->format), dctx->format);
|
|
ip, ZSTD_FRAMEHEADERSIZE_PREFIX(dctx->format), dctx->format);
|
|
if (ZSTD_isError(frameHeaderSize)) return frameHeaderSize;
|
|
if (ZSTD_isError(frameHeaderSize)) return frameHeaderSize;
|
|
RETURN_ERROR_IF(remainingSrcSize < frameHeaderSize+ZSTD_blockHeaderSize,
|
|
RETURN_ERROR_IF(remainingSrcSize < frameHeaderSize+ZSTD_blockHeaderSize,
|
|
- srcSize_wrong);
|
|
|
|
- FORWARD_IF_ERROR( ZSTD_decodeFrameHeader(dctx, ip, frameHeaderSize) );
|
|
|
|
|
|
+ srcSize_wrong, "");
|
|
|
|
+ FORWARD_IF_ERROR( ZSTD_decodeFrameHeader(dctx, ip, frameHeaderSize) , "");
|
|
ip += frameHeaderSize; remainingSrcSize -= frameHeaderSize;
|
|
ip += frameHeaderSize; remainingSrcSize -= frameHeaderSize;
|
|
}
|
|
}
|
|
|
|
|
|
@@ -648,7 +642,7 @@ static size_t ZSTD_decompressFrame(ZSTD_DCtx* dctx,
|
|
|
|
|
|
ip += ZSTD_blockHeaderSize;
|
|
ip += ZSTD_blockHeaderSize;
|
|
remainingSrcSize -= ZSTD_blockHeaderSize;
|
|
remainingSrcSize -= ZSTD_blockHeaderSize;
|
|
- RETURN_ERROR_IF(cBlockSize > remainingSrcSize, srcSize_wrong);
|
|
|
|
|
|
+ RETURN_ERROR_IF(cBlockSize > remainingSrcSize, srcSize_wrong, "");
|
|
|
|
|
|
switch(blockProperties.blockType)
|
|
switch(blockProperties.blockType)
|
|
{
|
|
{
|
|
@@ -663,13 +657,15 @@ static size_t ZSTD_decompressFrame(ZSTD_DCtx* dctx,
|
|
break;
|
|
break;
|
|
case bt_reserved :
|
|
case bt_reserved :
|
|
default:
|
|
default:
|
|
- RETURN_ERROR(corruption_detected);
|
|
|
|
|
|
+ RETURN_ERROR(corruption_detected, "invalid block type");
|
|
}
|
|
}
|
|
|
|
|
|
if (ZSTD_isError(decodedSize)) return decodedSize;
|
|
if (ZSTD_isError(decodedSize)) return decodedSize;
|
|
if (dctx->fParams.checksumFlag)
|
|
if (dctx->fParams.checksumFlag)
|
|
XXH64_update(&dctx->xxhState, op, decodedSize);
|
|
XXH64_update(&dctx->xxhState, op, decodedSize);
|
|
- op += decodedSize;
|
|
|
|
|
|
+ if (decodedSize != 0)
|
|
|
|
+ op += decodedSize;
|
|
|
|
+ assert(ip != NULL);
|
|
ip += cBlockSize;
|
|
ip += cBlockSize;
|
|
remainingSrcSize -= cBlockSize;
|
|
remainingSrcSize -= cBlockSize;
|
|
if (blockProperties.lastBlock) break;
|
|
if (blockProperties.lastBlock) break;
|
|
@@ -677,14 +673,14 @@ static size_t ZSTD_decompressFrame(ZSTD_DCtx* dctx,
|
|
|
|
|
|
if (dctx->fParams.frameContentSize != ZSTD_CONTENTSIZE_UNKNOWN) {
|
|
if (dctx->fParams.frameContentSize != ZSTD_CONTENTSIZE_UNKNOWN) {
|
|
RETURN_ERROR_IF((U64)(op-ostart) != dctx->fParams.frameContentSize,
|
|
RETURN_ERROR_IF((U64)(op-ostart) != dctx->fParams.frameContentSize,
|
|
- corruption_detected);
|
|
|
|
|
|
+ corruption_detected, "");
|
|
}
|
|
}
|
|
if (dctx->fParams.checksumFlag) { /* Frame content checksum verification */
|
|
if (dctx->fParams.checksumFlag) { /* Frame content checksum verification */
|
|
U32 const checkCalc = (U32)XXH64_digest(&dctx->xxhState);
|
|
U32 const checkCalc = (U32)XXH64_digest(&dctx->xxhState);
|
|
U32 checkRead;
|
|
U32 checkRead;
|
|
- RETURN_ERROR_IF(remainingSrcSize<4, checksum_wrong);
|
|
|
|
|
|
+ RETURN_ERROR_IF(remainingSrcSize<4, checksum_wrong, "");
|
|
checkRead = MEM_readLE32(ip);
|
|
checkRead = MEM_readLE32(ip);
|
|
- RETURN_ERROR_IF(checkRead != checkCalc, checksum_wrong);
|
|
|
|
|
|
+ RETURN_ERROR_IF(checkRead != checkCalc, checksum_wrong, "");
|
|
ip += 4;
|
|
ip += 4;
|
|
remainingSrcSize -= 4;
|
|
remainingSrcSize -= 4;
|
|
}
|
|
}
|
|
@@ -741,7 +737,7 @@ static size_t ZSTD_decompressMultiFrame(ZSTD_DCtx* dctx,
|
|
(unsigned)magicNumber, ZSTD_MAGICNUMBER);
|
|
(unsigned)magicNumber, ZSTD_MAGICNUMBER);
|
|
if ((magicNumber & ZSTD_MAGIC_SKIPPABLE_MASK) == ZSTD_MAGIC_SKIPPABLE_START) {
|
|
if ((magicNumber & ZSTD_MAGIC_SKIPPABLE_MASK) == ZSTD_MAGIC_SKIPPABLE_START) {
|
|
size_t const skippableSize = readSkippableFrameSize(src, srcSize);
|
|
size_t const skippableSize = readSkippableFrameSize(src, srcSize);
|
|
- FORWARD_IF_ERROR(skippableSize);
|
|
|
|
|
|
+ FORWARD_IF_ERROR(skippableSize, "readSkippableFrameSize failed");
|
|
assert(skippableSize <= srcSize);
|
|
assert(skippableSize <= srcSize);
|
|
|
|
|
|
src = (const BYTE *)src + skippableSize;
|
|
src = (const BYTE *)src + skippableSize;
|
|
@@ -751,11 +747,11 @@ static size_t ZSTD_decompressMultiFrame(ZSTD_DCtx* dctx,
|
|
|
|
|
|
if (ddict) {
|
|
if (ddict) {
|
|
/* we were called from ZSTD_decompress_usingDDict */
|
|
/* we were called from ZSTD_decompress_usingDDict */
|
|
- FORWARD_IF_ERROR(ZSTD_decompressBegin_usingDDict(dctx, ddict));
|
|
|
|
|
|
+ FORWARD_IF_ERROR(ZSTD_decompressBegin_usingDDict(dctx, ddict), "");
|
|
} else {
|
|
} else {
|
|
/* this will initialize correctly with no dict if dict == NULL, so
|
|
/* this will initialize correctly with no dict if dict == NULL, so
|
|
* use this in all cases but ddict */
|
|
* use this in all cases but ddict */
|
|
- FORWARD_IF_ERROR(ZSTD_decompressBegin_usingDict(dctx, dict, dictSize));
|
|
|
|
|
|
+ FORWARD_IF_ERROR(ZSTD_decompressBegin_usingDict(dctx, dict, dictSize), "");
|
|
}
|
|
}
|
|
ZSTD_checkContinuity(dctx, dst);
|
|
ZSTD_checkContinuity(dctx, dst);
|
|
|
|
|
|
@@ -776,7 +772,8 @@ static size_t ZSTD_decompressMultiFrame(ZSTD_DCtx* dctx,
|
|
"error.");
|
|
"error.");
|
|
if (ZSTD_isError(res)) return res;
|
|
if (ZSTD_isError(res)) return res;
|
|
assert(res <= dstCapacity);
|
|
assert(res <= dstCapacity);
|
|
- dst = (BYTE*)dst + res;
|
|
|
|
|
|
+ if (res != 0)
|
|
|
|
+ dst = (BYTE*)dst + res;
|
|
dstCapacity -= res;
|
|
dstCapacity -= res;
|
|
}
|
|
}
|
|
moreThan1Frame = 1;
|
|
moreThan1Frame = 1;
|
|
@@ -824,7 +821,7 @@ size_t ZSTD_decompress(void* dst, size_t dstCapacity, const void* src, size_t sr
|
|
#if defined(ZSTD_HEAPMODE) && (ZSTD_HEAPMODE>=1)
|
|
#if defined(ZSTD_HEAPMODE) && (ZSTD_HEAPMODE>=1)
|
|
size_t regenSize;
|
|
size_t regenSize;
|
|
ZSTD_DCtx* const dctx = ZSTD_createDCtx();
|
|
ZSTD_DCtx* const dctx = ZSTD_createDCtx();
|
|
- RETURN_ERROR_IF(dctx==NULL, memory_allocation);
|
|
|
|
|
|
+ RETURN_ERROR_IF(dctx==NULL, memory_allocation, "NULL pointer!");
|
|
regenSize = ZSTD_decompressDCtx(dctx, dst, dstCapacity, src, srcSize);
|
|
regenSize = ZSTD_decompressDCtx(dctx, dst, dstCapacity, src, srcSize);
|
|
ZSTD_freeDCtx(dctx);
|
|
ZSTD_freeDCtx(dctx);
|
|
return regenSize;
|
|
return regenSize;
|
|
@@ -842,6 +839,24 @@ size_t ZSTD_decompress(void* dst, size_t dstCapacity, const void* src, size_t sr
|
|
****************************************/
|
|
****************************************/
|
|
size_t ZSTD_nextSrcSizeToDecompress(ZSTD_DCtx* dctx) { return dctx->expected; }
|
|
size_t ZSTD_nextSrcSizeToDecompress(ZSTD_DCtx* dctx) { return dctx->expected; }
|
|
|
|
|
|
|
|
+/**
|
|
|
|
+ * Similar to ZSTD_nextSrcSizeToDecompress(), but when when a block input can be streamed,
|
|
|
|
+ * we allow taking a partial block as the input. Currently only raw uncompressed blocks can
|
|
|
|
+ * be streamed.
|
|
|
|
+ *
|
|
|
|
+ * For blocks that can be streamed, this allows us to reduce the latency until we produce
|
|
|
|
+ * output, and avoid copying the input.
|
|
|
|
+ *
|
|
|
|
+ * @param inputSize - The total amount of input that the caller currently has.
|
|
|
|
+ */
|
|
|
|
+static size_t ZSTD_nextSrcSizeToDecompressWithInputSize(ZSTD_DCtx* dctx, size_t inputSize) {
|
|
|
|
+ if (!(dctx->stage == ZSTDds_decompressBlock || dctx->stage == ZSTDds_decompressLastBlock))
|
|
|
|
+ return dctx->expected;
|
|
|
|
+ if (dctx->bType != bt_raw)
|
|
|
|
+ return dctx->expected;
|
|
|
|
+ return MIN(MAX(inputSize, 1), dctx->expected);
|
|
|
|
+}
|
|
|
|
+
|
|
ZSTD_nextInputType_e ZSTD_nextInputType(ZSTD_DCtx* dctx) {
|
|
ZSTD_nextInputType_e ZSTD_nextInputType(ZSTD_DCtx* dctx) {
|
|
switch(dctx->stage)
|
|
switch(dctx->stage)
|
|
{
|
|
{
|
|
@@ -874,7 +889,7 @@ size_t ZSTD_decompressContinue(ZSTD_DCtx* dctx, void* dst, size_t dstCapacity, c
|
|
{
|
|
{
|
|
DEBUGLOG(5, "ZSTD_decompressContinue (srcSize:%u)", (unsigned)srcSize);
|
|
DEBUGLOG(5, "ZSTD_decompressContinue (srcSize:%u)", (unsigned)srcSize);
|
|
/* Sanity check */
|
|
/* Sanity check */
|
|
- RETURN_ERROR_IF(srcSize != dctx->expected, srcSize_wrong, "not allowed");
|
|
|
|
|
|
+ RETURN_ERROR_IF(srcSize != ZSTD_nextSrcSizeToDecompressWithInputSize(dctx, srcSize), srcSize_wrong, "not allowed");
|
|
if (dstCapacity) ZSTD_checkContinuity(dctx, dst);
|
|
if (dstCapacity) ZSTD_checkContinuity(dctx, dst);
|
|
|
|
|
|
switch (dctx->stage)
|
|
switch (dctx->stage)
|
|
@@ -899,7 +914,7 @@ size_t ZSTD_decompressContinue(ZSTD_DCtx* dctx, void* dst, size_t dstCapacity, c
|
|
case ZSTDds_decodeFrameHeader:
|
|
case ZSTDds_decodeFrameHeader:
|
|
assert(src != NULL);
|
|
assert(src != NULL);
|
|
memcpy(dctx->headerBuffer + (dctx->headerSize - srcSize), src, srcSize);
|
|
memcpy(dctx->headerBuffer + (dctx->headerSize - srcSize), src, srcSize);
|
|
- FORWARD_IF_ERROR(ZSTD_decodeFrameHeader(dctx, dctx->headerBuffer, dctx->headerSize));
|
|
|
|
|
|
+ FORWARD_IF_ERROR(ZSTD_decodeFrameHeader(dctx, dctx->headerBuffer, dctx->headerSize), "");
|
|
dctx->expected = ZSTD_blockHeaderSize;
|
|
dctx->expected = ZSTD_blockHeaderSize;
|
|
dctx->stage = ZSTDds_decodeBlockHeader;
|
|
dctx->stage = ZSTDds_decodeBlockHeader;
|
|
return 0;
|
|
return 0;
|
|
@@ -941,29 +956,41 @@ size_t ZSTD_decompressContinue(ZSTD_DCtx* dctx, void* dst, size_t dstCapacity, c
|
|
case bt_compressed:
|
|
case bt_compressed:
|
|
DEBUGLOG(5, "ZSTD_decompressContinue: case bt_compressed");
|
|
DEBUGLOG(5, "ZSTD_decompressContinue: case bt_compressed");
|
|
rSize = ZSTD_decompressBlock_internal(dctx, dst, dstCapacity, src, srcSize, /* frame */ 1);
|
|
rSize = ZSTD_decompressBlock_internal(dctx, dst, dstCapacity, src, srcSize, /* frame */ 1);
|
|
|
|
+ dctx->expected = 0; /* Streaming not supported */
|
|
break;
|
|
break;
|
|
case bt_raw :
|
|
case bt_raw :
|
|
|
|
+ assert(srcSize <= dctx->expected);
|
|
rSize = ZSTD_copyRawBlock(dst, dstCapacity, src, srcSize);
|
|
rSize = ZSTD_copyRawBlock(dst, dstCapacity, src, srcSize);
|
|
|
|
+ FORWARD_IF_ERROR(rSize, "ZSTD_copyRawBlock failed");
|
|
|
|
+ assert(rSize == srcSize);
|
|
|
|
+ dctx->expected -= rSize;
|
|
break;
|
|
break;
|
|
case bt_rle :
|
|
case bt_rle :
|
|
rSize = ZSTD_setRleBlock(dst, dstCapacity, *(const BYTE*)src, dctx->rleSize);
|
|
rSize = ZSTD_setRleBlock(dst, dstCapacity, *(const BYTE*)src, dctx->rleSize);
|
|
|
|
+ dctx->expected = 0; /* Streaming not supported */
|
|
break;
|
|
break;
|
|
case bt_reserved : /* should never happen */
|
|
case bt_reserved : /* should never happen */
|
|
default:
|
|
default:
|
|
- RETURN_ERROR(corruption_detected);
|
|
|
|
|
|
+ RETURN_ERROR(corruption_detected, "invalid block type");
|
|
}
|
|
}
|
|
- if (ZSTD_isError(rSize)) return rSize;
|
|
|
|
|
|
+ FORWARD_IF_ERROR(rSize, "");
|
|
RETURN_ERROR_IF(rSize > dctx->fParams.blockSizeMax, corruption_detected, "Decompressed Block Size Exceeds Maximum");
|
|
RETURN_ERROR_IF(rSize > dctx->fParams.blockSizeMax, corruption_detected, "Decompressed Block Size Exceeds Maximum");
|
|
DEBUGLOG(5, "ZSTD_decompressContinue: decoded size from block : %u", (unsigned)rSize);
|
|
DEBUGLOG(5, "ZSTD_decompressContinue: decoded size from block : %u", (unsigned)rSize);
|
|
dctx->decodedSize += rSize;
|
|
dctx->decodedSize += rSize;
|
|
if (dctx->fParams.checksumFlag) XXH64_update(&dctx->xxhState, dst, rSize);
|
|
if (dctx->fParams.checksumFlag) XXH64_update(&dctx->xxhState, dst, rSize);
|
|
|
|
+ dctx->previousDstEnd = (char*)dst + rSize;
|
|
|
|
+
|
|
|
|
+ /* Stay on the same stage until we are finished streaming the block. */
|
|
|
|
+ if (dctx->expected > 0) {
|
|
|
|
+ return rSize;
|
|
|
|
+ }
|
|
|
|
|
|
if (dctx->stage == ZSTDds_decompressLastBlock) { /* end of frame */
|
|
if (dctx->stage == ZSTDds_decompressLastBlock) { /* end of frame */
|
|
DEBUGLOG(4, "ZSTD_decompressContinue: decoded size from frame : %u", (unsigned)dctx->decodedSize);
|
|
DEBUGLOG(4, "ZSTD_decompressContinue: decoded size from frame : %u", (unsigned)dctx->decodedSize);
|
|
RETURN_ERROR_IF(
|
|
RETURN_ERROR_IF(
|
|
dctx->fParams.frameContentSize != ZSTD_CONTENTSIZE_UNKNOWN
|
|
dctx->fParams.frameContentSize != ZSTD_CONTENTSIZE_UNKNOWN
|
|
&& dctx->decodedSize != dctx->fParams.frameContentSize,
|
|
&& dctx->decodedSize != dctx->fParams.frameContentSize,
|
|
- corruption_detected);
|
|
|
|
|
|
+ corruption_detected, "");
|
|
if (dctx->fParams.checksumFlag) { /* another round for frame checksum */
|
|
if (dctx->fParams.checksumFlag) { /* another round for frame checksum */
|
|
dctx->expected = 4;
|
|
dctx->expected = 4;
|
|
dctx->stage = ZSTDds_checkChecksum;
|
|
dctx->stage = ZSTDds_checkChecksum;
|
|
@@ -974,7 +1001,6 @@ size_t ZSTD_decompressContinue(ZSTD_DCtx* dctx, void* dst, size_t dstCapacity, c
|
|
} else {
|
|
} else {
|
|
dctx->stage = ZSTDds_decodeBlockHeader;
|
|
dctx->stage = ZSTDds_decodeBlockHeader;
|
|
dctx->expected = ZSTD_blockHeaderSize;
|
|
dctx->expected = ZSTD_blockHeaderSize;
|
|
- dctx->previousDstEnd = (char*)dst + rSize;
|
|
|
|
}
|
|
}
|
|
return rSize;
|
|
return rSize;
|
|
}
|
|
}
|
|
@@ -984,7 +1010,7 @@ size_t ZSTD_decompressContinue(ZSTD_DCtx* dctx, void* dst, size_t dstCapacity, c
|
|
{ U32 const h32 = (U32)XXH64_digest(&dctx->xxhState);
|
|
{ U32 const h32 = (U32)XXH64_digest(&dctx->xxhState);
|
|
U32 const check32 = MEM_readLE32(src);
|
|
U32 const check32 = MEM_readLE32(src);
|
|
DEBUGLOG(4, "ZSTD_decompressContinue: checksum : calculated %08X :: %08X read", (unsigned)h32, (unsigned)check32);
|
|
DEBUGLOG(4, "ZSTD_decompressContinue: checksum : calculated %08X :: %08X read", (unsigned)h32, (unsigned)check32);
|
|
- RETURN_ERROR_IF(check32 != h32, checksum_wrong);
|
|
|
|
|
|
+ RETURN_ERROR_IF(check32 != h32, checksum_wrong, "");
|
|
dctx->expected = 0;
|
|
dctx->expected = 0;
|
|
dctx->stage = ZSTDds_getFrameHeaderSize;
|
|
dctx->stage = ZSTDds_getFrameHeaderSize;
|
|
return 0;
|
|
return 0;
|
|
@@ -1005,7 +1031,7 @@ size_t ZSTD_decompressContinue(ZSTD_DCtx* dctx, void* dst, size_t dstCapacity, c
|
|
|
|
|
|
default:
|
|
default:
|
|
assert(0); /* impossible */
|
|
assert(0); /* impossible */
|
|
- RETURN_ERROR(GENERIC); /* some compiler require default to do something */
|
|
|
|
|
|
+ RETURN_ERROR(GENERIC, "impossible to reach"); /* some compiler require default to do something */
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
@@ -1016,6 +1042,10 @@ static size_t ZSTD_refDictContent(ZSTD_DCtx* dctx, const void* dict, size_t dict
|
|
dctx->virtualStart = (const char*)dict - ((const char*)(dctx->previousDstEnd) - (const char*)(dctx->prefixStart));
|
|
dctx->virtualStart = (const char*)dict - ((const char*)(dctx->previousDstEnd) - (const char*)(dctx->prefixStart));
|
|
dctx->prefixStart = dict;
|
|
dctx->prefixStart = dict;
|
|
dctx->previousDstEnd = (const char*)dict + dictSize;
|
|
dctx->previousDstEnd = (const char*)dict + dictSize;
|
|
|
|
+#ifdef FUZZING_BUILD_MODE_UNSAFE_FOR_PRODUCTION
|
|
|
|
+ dctx->dictContentBeginForFuzzing = dctx->prefixStart;
|
|
|
|
+ dctx->dictContentEndForFuzzing = dctx->previousDstEnd;
|
|
|
|
+#endif
|
|
return 0;
|
|
return 0;
|
|
}
|
|
}
|
|
|
|
|
|
@@ -1029,7 +1059,7 @@ ZSTD_loadDEntropy(ZSTD_entropyDTables_t* entropy,
|
|
const BYTE* dictPtr = (const BYTE*)dict;
|
|
const BYTE* dictPtr = (const BYTE*)dict;
|
|
const BYTE* const dictEnd = dictPtr + dictSize;
|
|
const BYTE* const dictEnd = dictPtr + dictSize;
|
|
|
|
|
|
- RETURN_ERROR_IF(dictSize <= 8, dictionary_corrupted);
|
|
|
|
|
|
+ RETURN_ERROR_IF(dictSize <= 8, dictionary_corrupted, "dict is too small");
|
|
assert(MEM_readLE32(dict) == ZSTD_MAGIC_DICTIONARY); /* dict must be valid */
|
|
assert(MEM_readLE32(dict) == ZSTD_MAGIC_DICTIONARY); /* dict must be valid */
|
|
dictPtr += 8; /* skip header = magic + dictID */
|
|
dictPtr += 8; /* skip header = magic + dictID */
|
|
|
|
|
|
@@ -1048,16 +1078,16 @@ ZSTD_loadDEntropy(ZSTD_entropyDTables_t* entropy,
|
|
dictPtr, dictEnd - dictPtr,
|
|
dictPtr, dictEnd - dictPtr,
|
|
workspace, workspaceSize);
|
|
workspace, workspaceSize);
|
|
#endif
|
|
#endif
|
|
- RETURN_ERROR_IF(HUF_isError(hSize), dictionary_corrupted);
|
|
|
|
|
|
+ RETURN_ERROR_IF(HUF_isError(hSize), dictionary_corrupted, "");
|
|
dictPtr += hSize;
|
|
dictPtr += hSize;
|
|
}
|
|
}
|
|
|
|
|
|
{ short offcodeNCount[MaxOff+1];
|
|
{ short offcodeNCount[MaxOff+1];
|
|
unsigned offcodeMaxValue = MaxOff, offcodeLog;
|
|
unsigned offcodeMaxValue = MaxOff, offcodeLog;
|
|
size_t const offcodeHeaderSize = FSE_readNCount(offcodeNCount, &offcodeMaxValue, &offcodeLog, dictPtr, dictEnd-dictPtr);
|
|
size_t const offcodeHeaderSize = FSE_readNCount(offcodeNCount, &offcodeMaxValue, &offcodeLog, dictPtr, dictEnd-dictPtr);
|
|
- RETURN_ERROR_IF(FSE_isError(offcodeHeaderSize), dictionary_corrupted);
|
|
|
|
- RETURN_ERROR_IF(offcodeMaxValue > MaxOff, dictionary_corrupted);
|
|
|
|
- RETURN_ERROR_IF(offcodeLog > OffFSELog, dictionary_corrupted);
|
|
|
|
|
|
+ RETURN_ERROR_IF(FSE_isError(offcodeHeaderSize), dictionary_corrupted, "");
|
|
|
|
+ RETURN_ERROR_IF(offcodeMaxValue > MaxOff, dictionary_corrupted, "");
|
|
|
|
+ RETURN_ERROR_IF(offcodeLog > OffFSELog, dictionary_corrupted, "");
|
|
ZSTD_buildFSETable( entropy->OFTable,
|
|
ZSTD_buildFSETable( entropy->OFTable,
|
|
offcodeNCount, offcodeMaxValue,
|
|
offcodeNCount, offcodeMaxValue,
|
|
OF_base, OF_bits,
|
|
OF_base, OF_bits,
|
|
@@ -1068,9 +1098,9 @@ ZSTD_loadDEntropy(ZSTD_entropyDTables_t* entropy,
|
|
{ short matchlengthNCount[MaxML+1];
|
|
{ short matchlengthNCount[MaxML+1];
|
|
unsigned matchlengthMaxValue = MaxML, matchlengthLog;
|
|
unsigned matchlengthMaxValue = MaxML, matchlengthLog;
|
|
size_t const matchlengthHeaderSize = FSE_readNCount(matchlengthNCount, &matchlengthMaxValue, &matchlengthLog, dictPtr, dictEnd-dictPtr);
|
|
size_t const matchlengthHeaderSize = FSE_readNCount(matchlengthNCount, &matchlengthMaxValue, &matchlengthLog, dictPtr, dictEnd-dictPtr);
|
|
- RETURN_ERROR_IF(FSE_isError(matchlengthHeaderSize), dictionary_corrupted);
|
|
|
|
- RETURN_ERROR_IF(matchlengthMaxValue > MaxML, dictionary_corrupted);
|
|
|
|
- RETURN_ERROR_IF(matchlengthLog > MLFSELog, dictionary_corrupted);
|
|
|
|
|
|
+ RETURN_ERROR_IF(FSE_isError(matchlengthHeaderSize), dictionary_corrupted, "");
|
|
|
|
+ RETURN_ERROR_IF(matchlengthMaxValue > MaxML, dictionary_corrupted, "");
|
|
|
|
+ RETURN_ERROR_IF(matchlengthLog > MLFSELog, dictionary_corrupted, "");
|
|
ZSTD_buildFSETable( entropy->MLTable,
|
|
ZSTD_buildFSETable( entropy->MLTable,
|
|
matchlengthNCount, matchlengthMaxValue,
|
|
matchlengthNCount, matchlengthMaxValue,
|
|
ML_base, ML_bits,
|
|
ML_base, ML_bits,
|
|
@@ -1081,9 +1111,9 @@ ZSTD_loadDEntropy(ZSTD_entropyDTables_t* entropy,
|
|
{ short litlengthNCount[MaxLL+1];
|
|
{ short litlengthNCount[MaxLL+1];
|
|
unsigned litlengthMaxValue = MaxLL, litlengthLog;
|
|
unsigned litlengthMaxValue = MaxLL, litlengthLog;
|
|
size_t const litlengthHeaderSize = FSE_readNCount(litlengthNCount, &litlengthMaxValue, &litlengthLog, dictPtr, dictEnd-dictPtr);
|
|
size_t const litlengthHeaderSize = FSE_readNCount(litlengthNCount, &litlengthMaxValue, &litlengthLog, dictPtr, dictEnd-dictPtr);
|
|
- RETURN_ERROR_IF(FSE_isError(litlengthHeaderSize), dictionary_corrupted);
|
|
|
|
- RETURN_ERROR_IF(litlengthMaxValue > MaxLL, dictionary_corrupted);
|
|
|
|
- RETURN_ERROR_IF(litlengthLog > LLFSELog, dictionary_corrupted);
|
|
|
|
|
|
+ RETURN_ERROR_IF(FSE_isError(litlengthHeaderSize), dictionary_corrupted, "");
|
|
|
|
+ RETURN_ERROR_IF(litlengthMaxValue > MaxLL, dictionary_corrupted, "");
|
|
|
|
+ RETURN_ERROR_IF(litlengthLog > LLFSELog, dictionary_corrupted, "");
|
|
ZSTD_buildFSETable( entropy->LLTable,
|
|
ZSTD_buildFSETable( entropy->LLTable,
|
|
litlengthNCount, litlengthMaxValue,
|
|
litlengthNCount, litlengthMaxValue,
|
|
LL_base, LL_bits,
|
|
LL_base, LL_bits,
|
|
@@ -1091,13 +1121,13 @@ ZSTD_loadDEntropy(ZSTD_entropyDTables_t* entropy,
|
|
dictPtr += litlengthHeaderSize;
|
|
dictPtr += litlengthHeaderSize;
|
|
}
|
|
}
|
|
|
|
|
|
- RETURN_ERROR_IF(dictPtr+12 > dictEnd, dictionary_corrupted);
|
|
|
|
|
|
+ RETURN_ERROR_IF(dictPtr+12 > dictEnd, dictionary_corrupted, "");
|
|
{ int i;
|
|
{ int i;
|
|
size_t const dictContentSize = (size_t)(dictEnd - (dictPtr+12));
|
|
size_t const dictContentSize = (size_t)(dictEnd - (dictPtr+12));
|
|
for (i=0; i<3; i++) {
|
|
for (i=0; i<3; i++) {
|
|
U32 const rep = MEM_readLE32(dictPtr); dictPtr += 4;
|
|
U32 const rep = MEM_readLE32(dictPtr); dictPtr += 4;
|
|
RETURN_ERROR_IF(rep==0 || rep > dictContentSize,
|
|
RETURN_ERROR_IF(rep==0 || rep > dictContentSize,
|
|
- dictionary_corrupted);
|
|
|
|
|
|
+ dictionary_corrupted, "");
|
|
entropy->rep[i] = rep;
|
|
entropy->rep[i] = rep;
|
|
} }
|
|
} }
|
|
|
|
|
|
@@ -1115,7 +1145,7 @@ static size_t ZSTD_decompress_insertDictionary(ZSTD_DCtx* dctx, const void* dict
|
|
|
|
|
|
/* load entropy tables */
|
|
/* load entropy tables */
|
|
{ size_t const eSize = ZSTD_loadDEntropy(&dctx->entropy, dict, dictSize);
|
|
{ size_t const eSize = ZSTD_loadDEntropy(&dctx->entropy, dict, dictSize);
|
|
- RETURN_ERROR_IF(ZSTD_isError(eSize), dictionary_corrupted);
|
|
|
|
|
|
+ RETURN_ERROR_IF(ZSTD_isError(eSize), dictionary_corrupted, "");
|
|
dict = (const char*)dict + eSize;
|
|
dict = (const char*)dict + eSize;
|
|
dictSize -= eSize;
|
|
dictSize -= eSize;
|
|
}
|
|
}
|
|
@@ -1138,6 +1168,7 @@ size_t ZSTD_decompressBegin(ZSTD_DCtx* dctx)
|
|
dctx->entropy.hufTable[0] = (HUF_DTable)((HufLog)*0x1000001); /* cover both little and big endian */
|
|
dctx->entropy.hufTable[0] = (HUF_DTable)((HufLog)*0x1000001); /* cover both little and big endian */
|
|
dctx->litEntropy = dctx->fseEntropy = 0;
|
|
dctx->litEntropy = dctx->fseEntropy = 0;
|
|
dctx->dictID = 0;
|
|
dctx->dictID = 0;
|
|
|
|
+ dctx->bType = bt_reserved;
|
|
ZSTD_STATIC_ASSERT(sizeof(dctx->entropy.rep) == sizeof(repStartValue));
|
|
ZSTD_STATIC_ASSERT(sizeof(dctx->entropy.rep) == sizeof(repStartValue));
|
|
memcpy(dctx->entropy.rep, repStartValue, sizeof(repStartValue)); /* initial repcodes */
|
|
memcpy(dctx->entropy.rep, repStartValue, sizeof(repStartValue)); /* initial repcodes */
|
|
dctx->LLTptr = dctx->entropy.LLTable;
|
|
dctx->LLTptr = dctx->entropy.LLTable;
|
|
@@ -1149,11 +1180,11 @@ size_t ZSTD_decompressBegin(ZSTD_DCtx* dctx)
|
|
|
|
|
|
size_t ZSTD_decompressBegin_usingDict(ZSTD_DCtx* dctx, const void* dict, size_t dictSize)
|
|
size_t ZSTD_decompressBegin_usingDict(ZSTD_DCtx* dctx, const void* dict, size_t dictSize)
|
|
{
|
|
{
|
|
- FORWARD_IF_ERROR( ZSTD_decompressBegin(dctx) );
|
|
|
|
|
|
+ FORWARD_IF_ERROR( ZSTD_decompressBegin(dctx) , "");
|
|
if (dict && dictSize)
|
|
if (dict && dictSize)
|
|
RETURN_ERROR_IF(
|
|
RETURN_ERROR_IF(
|
|
ZSTD_isError(ZSTD_decompress_insertDictionary(dctx, dict, dictSize)),
|
|
ZSTD_isError(ZSTD_decompress_insertDictionary(dctx, dict, dictSize)),
|
|
- dictionary_corrupted);
|
|
|
|
|
|
+ dictionary_corrupted, "");
|
|
return 0;
|
|
return 0;
|
|
}
|
|
}
|
|
|
|
|
|
@@ -1172,7 +1203,7 @@ size_t ZSTD_decompressBegin_usingDDict(ZSTD_DCtx* dctx, const ZSTD_DDict* ddict)
|
|
DEBUGLOG(4, "DDict is %s",
|
|
DEBUGLOG(4, "DDict is %s",
|
|
dctx->ddictIsCold ? "~cold~" : "hot!");
|
|
dctx->ddictIsCold ? "~cold~" : "hot!");
|
|
}
|
|
}
|
|
- FORWARD_IF_ERROR( ZSTD_decompressBegin(dctx) );
|
|
|
|
|
|
+ FORWARD_IF_ERROR( ZSTD_decompressBegin(dctx) , "");
|
|
if (ddict) { /* NULL ddict is equivalent to no dictionary */
|
|
if (ddict) { /* NULL ddict is equivalent to no dictionary */
|
|
ZSTD_copyDDictParameters(dctx, ddict);
|
|
ZSTD_copyDDictParameters(dctx, ddict);
|
|
}
|
|
}
|
|
@@ -1263,11 +1294,11 @@ size_t ZSTD_DCtx_loadDictionary_advanced(ZSTD_DCtx* dctx,
|
|
ZSTD_dictLoadMethod_e dictLoadMethod,
|
|
ZSTD_dictLoadMethod_e dictLoadMethod,
|
|
ZSTD_dictContentType_e dictContentType)
|
|
ZSTD_dictContentType_e dictContentType)
|
|
{
|
|
{
|
|
- RETURN_ERROR_IF(dctx->streamStage != zdss_init, stage_wrong);
|
|
|
|
|
|
+ RETURN_ERROR_IF(dctx->streamStage != zdss_init, stage_wrong, "");
|
|
ZSTD_clearDict(dctx);
|
|
ZSTD_clearDict(dctx);
|
|
if (dict && dictSize != 0) {
|
|
if (dict && dictSize != 0) {
|
|
dctx->ddictLocal = ZSTD_createDDict_advanced(dict, dictSize, dictLoadMethod, dictContentType, dctx->customMem);
|
|
dctx->ddictLocal = ZSTD_createDDict_advanced(dict, dictSize, dictLoadMethod, dictContentType, dctx->customMem);
|
|
- RETURN_ERROR_IF(dctx->ddictLocal == NULL, memory_allocation);
|
|
|
|
|
|
+ RETURN_ERROR_IF(dctx->ddictLocal == NULL, memory_allocation, "NULL pointer!");
|
|
dctx->ddict = dctx->ddictLocal;
|
|
dctx->ddict = dctx->ddictLocal;
|
|
dctx->dictUses = ZSTD_use_indefinitely;
|
|
dctx->dictUses = ZSTD_use_indefinitely;
|
|
}
|
|
}
|
|
@@ -1286,7 +1317,7 @@ size_t ZSTD_DCtx_loadDictionary(ZSTD_DCtx* dctx, const void* dict, size_t dictSi
|
|
|
|
|
|
size_t ZSTD_DCtx_refPrefix_advanced(ZSTD_DCtx* dctx, const void* prefix, size_t prefixSize, ZSTD_dictContentType_e dictContentType)
|
|
size_t ZSTD_DCtx_refPrefix_advanced(ZSTD_DCtx* dctx, const void* prefix, size_t prefixSize, ZSTD_dictContentType_e dictContentType)
|
|
{
|
|
{
|
|
- FORWARD_IF_ERROR(ZSTD_DCtx_loadDictionary_advanced(dctx, prefix, prefixSize, ZSTD_dlm_byRef, dictContentType));
|
|
|
|
|
|
+ FORWARD_IF_ERROR(ZSTD_DCtx_loadDictionary_advanced(dctx, prefix, prefixSize, ZSTD_dlm_byRef, dictContentType), "");
|
|
dctx->dictUses = ZSTD_use_once;
|
|
dctx->dictUses = ZSTD_use_once;
|
|
return 0;
|
|
return 0;
|
|
}
|
|
}
|
|
@@ -1303,8 +1334,8 @@ size_t ZSTD_DCtx_refPrefix(ZSTD_DCtx* dctx, const void* prefix, size_t prefixSiz
|
|
size_t ZSTD_initDStream_usingDict(ZSTD_DStream* zds, const void* dict, size_t dictSize)
|
|
size_t ZSTD_initDStream_usingDict(ZSTD_DStream* zds, const void* dict, size_t dictSize)
|
|
{
|
|
{
|
|
DEBUGLOG(4, "ZSTD_initDStream_usingDict");
|
|
DEBUGLOG(4, "ZSTD_initDStream_usingDict");
|
|
- FORWARD_IF_ERROR( ZSTD_DCtx_reset(zds, ZSTD_reset_session_only) );
|
|
|
|
- FORWARD_IF_ERROR( ZSTD_DCtx_loadDictionary(zds, dict, dictSize) );
|
|
|
|
|
|
+ FORWARD_IF_ERROR( ZSTD_DCtx_reset(zds, ZSTD_reset_session_only) , "");
|
|
|
|
+ FORWARD_IF_ERROR( ZSTD_DCtx_loadDictionary(zds, dict, dictSize) , "");
|
|
return ZSTD_startingInputLength(zds->format);
|
|
return ZSTD_startingInputLength(zds->format);
|
|
}
|
|
}
|
|
|
|
|
|
@@ -1320,8 +1351,8 @@ size_t ZSTD_initDStream(ZSTD_DStream* zds)
|
|
* this function cannot fail */
|
|
* this function cannot fail */
|
|
size_t ZSTD_initDStream_usingDDict(ZSTD_DStream* dctx, const ZSTD_DDict* ddict)
|
|
size_t ZSTD_initDStream_usingDDict(ZSTD_DStream* dctx, const ZSTD_DDict* ddict)
|
|
{
|
|
{
|
|
- FORWARD_IF_ERROR( ZSTD_DCtx_reset(dctx, ZSTD_reset_session_only) );
|
|
|
|
- FORWARD_IF_ERROR( ZSTD_DCtx_refDDict(dctx, ddict) );
|
|
|
|
|
|
+ FORWARD_IF_ERROR( ZSTD_DCtx_reset(dctx, ZSTD_reset_session_only) , "");
|
|
|
|
+ FORWARD_IF_ERROR( ZSTD_DCtx_refDDict(dctx, ddict) , "");
|
|
return ZSTD_startingInputLength(dctx->format);
|
|
return ZSTD_startingInputLength(dctx->format);
|
|
}
|
|
}
|
|
|
|
|
|
@@ -1330,14 +1361,14 @@ size_t ZSTD_initDStream_usingDDict(ZSTD_DStream* dctx, const ZSTD_DDict* ddict)
|
|
* this function cannot fail */
|
|
* this function cannot fail */
|
|
size_t ZSTD_resetDStream(ZSTD_DStream* dctx)
|
|
size_t ZSTD_resetDStream(ZSTD_DStream* dctx)
|
|
{
|
|
{
|
|
- FORWARD_IF_ERROR(ZSTD_DCtx_reset(dctx, ZSTD_reset_session_only));
|
|
|
|
|
|
+ FORWARD_IF_ERROR(ZSTD_DCtx_reset(dctx, ZSTD_reset_session_only), "");
|
|
return ZSTD_startingInputLength(dctx->format);
|
|
return ZSTD_startingInputLength(dctx->format);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
size_t ZSTD_DCtx_refDDict(ZSTD_DCtx* dctx, const ZSTD_DDict* ddict)
|
|
size_t ZSTD_DCtx_refDDict(ZSTD_DCtx* dctx, const ZSTD_DDict* ddict)
|
|
{
|
|
{
|
|
- RETURN_ERROR_IF(dctx->streamStage != zdss_init, stage_wrong);
|
|
|
|
|
|
+ RETURN_ERROR_IF(dctx->streamStage != zdss_init, stage_wrong, "");
|
|
ZSTD_clearDict(dctx);
|
|
ZSTD_clearDict(dctx);
|
|
if (ddict) {
|
|
if (ddict) {
|
|
dctx->ddict = ddict;
|
|
dctx->ddict = ddict;
|
|
@@ -1354,9 +1385,9 @@ size_t ZSTD_DCtx_setMaxWindowSize(ZSTD_DCtx* dctx, size_t maxWindowSize)
|
|
ZSTD_bounds const bounds = ZSTD_dParam_getBounds(ZSTD_d_windowLogMax);
|
|
ZSTD_bounds const bounds = ZSTD_dParam_getBounds(ZSTD_d_windowLogMax);
|
|
size_t const min = (size_t)1 << bounds.lowerBound;
|
|
size_t const min = (size_t)1 << bounds.lowerBound;
|
|
size_t const max = (size_t)1 << bounds.upperBound;
|
|
size_t const max = (size_t)1 << bounds.upperBound;
|
|
- RETURN_ERROR_IF(dctx->streamStage != zdss_init, stage_wrong);
|
|
|
|
- RETURN_ERROR_IF(maxWindowSize < min, parameter_outOfBound);
|
|
|
|
- RETURN_ERROR_IF(maxWindowSize > max, parameter_outOfBound);
|
|
|
|
|
|
+ RETURN_ERROR_IF(dctx->streamStage != zdss_init, stage_wrong, "");
|
|
|
|
+ RETURN_ERROR_IF(maxWindowSize < min, parameter_outOfBound, "");
|
|
|
|
+ RETURN_ERROR_IF(maxWindowSize > max, parameter_outOfBound, "");
|
|
dctx->maxWindowSize = maxWindowSize;
|
|
dctx->maxWindowSize = maxWindowSize;
|
|
return 0;
|
|
return 0;
|
|
}
|
|
}
|
|
@@ -1379,6 +1410,10 @@ ZSTD_bounds ZSTD_dParam_getBounds(ZSTD_dParameter dParam)
|
|
bounds.upperBound = (int)ZSTD_f_zstd1_magicless;
|
|
bounds.upperBound = (int)ZSTD_f_zstd1_magicless;
|
|
ZSTD_STATIC_ASSERT(ZSTD_f_zstd1 < ZSTD_f_zstd1_magicless);
|
|
ZSTD_STATIC_ASSERT(ZSTD_f_zstd1 < ZSTD_f_zstd1_magicless);
|
|
return bounds;
|
|
return bounds;
|
|
|
|
+ case ZSTD_d_stableOutBuffer:
|
|
|
|
+ bounds.lowerBound = (int)ZSTD_obm_buffered;
|
|
|
|
+ bounds.upperBound = (int)ZSTD_obm_stable;
|
|
|
|
+ return bounds;
|
|
default:;
|
|
default:;
|
|
}
|
|
}
|
|
bounds.error = ERROR(parameter_unsupported);
|
|
bounds.error = ERROR(parameter_unsupported);
|
|
@@ -1398,12 +1433,12 @@ static int ZSTD_dParam_withinBounds(ZSTD_dParameter dParam, int value)
|
|
}
|
|
}
|
|
|
|
|
|
#define CHECK_DBOUNDS(p,v) { \
|
|
#define CHECK_DBOUNDS(p,v) { \
|
|
- RETURN_ERROR_IF(!ZSTD_dParam_withinBounds(p, v), parameter_outOfBound); \
|
|
|
|
|
|
+ RETURN_ERROR_IF(!ZSTD_dParam_withinBounds(p, v), parameter_outOfBound, ""); \
|
|
}
|
|
}
|
|
|
|
|
|
size_t ZSTD_DCtx_setParameter(ZSTD_DCtx* dctx, ZSTD_dParameter dParam, int value)
|
|
size_t ZSTD_DCtx_setParameter(ZSTD_DCtx* dctx, ZSTD_dParameter dParam, int value)
|
|
{
|
|
{
|
|
- RETURN_ERROR_IF(dctx->streamStage != zdss_init, stage_wrong);
|
|
|
|
|
|
+ RETURN_ERROR_IF(dctx->streamStage != zdss_init, stage_wrong, "");
|
|
switch(dParam) {
|
|
switch(dParam) {
|
|
case ZSTD_d_windowLogMax:
|
|
case ZSTD_d_windowLogMax:
|
|
if (value == 0) value = ZSTD_WINDOWLOG_LIMIT_DEFAULT;
|
|
if (value == 0) value = ZSTD_WINDOWLOG_LIMIT_DEFAULT;
|
|
@@ -1414,9 +1449,13 @@ size_t ZSTD_DCtx_setParameter(ZSTD_DCtx* dctx, ZSTD_dParameter dParam, int value
|
|
CHECK_DBOUNDS(ZSTD_d_format, value);
|
|
CHECK_DBOUNDS(ZSTD_d_format, value);
|
|
dctx->format = (ZSTD_format_e)value;
|
|
dctx->format = (ZSTD_format_e)value;
|
|
return 0;
|
|
return 0;
|
|
|
|
+ case ZSTD_d_stableOutBuffer:
|
|
|
|
+ CHECK_DBOUNDS(ZSTD_d_stableOutBuffer, value);
|
|
|
|
+ dctx->outBufferMode = (ZSTD_outBufferMode_e)value;
|
|
|
|
+ return 0;
|
|
default:;
|
|
default:;
|
|
}
|
|
}
|
|
- RETURN_ERROR(parameter_unsupported);
|
|
|
|
|
|
+ RETURN_ERROR(parameter_unsupported, "");
|
|
}
|
|
}
|
|
|
|
|
|
size_t ZSTD_DCtx_reset(ZSTD_DCtx* dctx, ZSTD_ResetDirective reset)
|
|
size_t ZSTD_DCtx_reset(ZSTD_DCtx* dctx, ZSTD_ResetDirective reset)
|
|
@@ -1428,7 +1467,7 @@ size_t ZSTD_DCtx_reset(ZSTD_DCtx* dctx, ZSTD_ResetDirective reset)
|
|
}
|
|
}
|
|
if ( (reset == ZSTD_reset_parameters)
|
|
if ( (reset == ZSTD_reset_parameters)
|
|
|| (reset == ZSTD_reset_session_and_parameters) ) {
|
|
|| (reset == ZSTD_reset_session_and_parameters) ) {
|
|
- RETURN_ERROR_IF(dctx->streamStage != zdss_init, stage_wrong);
|
|
|
|
|
|
+ RETURN_ERROR_IF(dctx->streamStage != zdss_init, stage_wrong, "");
|
|
ZSTD_clearDict(dctx);
|
|
ZSTD_clearDict(dctx);
|
|
dctx->format = ZSTD_f_zstd1;
|
|
dctx->format = ZSTD_f_zstd1;
|
|
dctx->maxWindowSize = ZSTD_MAXWINDOWSIZE_DEFAULT;
|
|
dctx->maxWindowSize = ZSTD_MAXWINDOWSIZE_DEFAULT;
|
|
@@ -1449,7 +1488,7 @@ size_t ZSTD_decodingBufferSize_min(unsigned long long windowSize, unsigned long
|
|
unsigned long long const neededSize = MIN(frameContentSize, neededRBSize);
|
|
unsigned long long const neededSize = MIN(frameContentSize, neededRBSize);
|
|
size_t const minRBSize = (size_t) neededSize;
|
|
size_t const minRBSize = (size_t) neededSize;
|
|
RETURN_ERROR_IF((unsigned long long)minRBSize != neededSize,
|
|
RETURN_ERROR_IF((unsigned long long)minRBSize != neededSize,
|
|
- frameParameter_windowTooLarge);
|
|
|
|
|
|
+ frameParameter_windowTooLarge, "");
|
|
return minRBSize;
|
|
return minRBSize;
|
|
}
|
|
}
|
|
|
|
|
|
@@ -1467,30 +1506,94 @@ size_t ZSTD_estimateDStreamSize_fromFrame(const void* src, size_t srcSize)
|
|
ZSTD_frameHeader zfh;
|
|
ZSTD_frameHeader zfh;
|
|
size_t const err = ZSTD_getFrameHeader(&zfh, src, srcSize);
|
|
size_t const err = ZSTD_getFrameHeader(&zfh, src, srcSize);
|
|
if (ZSTD_isError(err)) return err;
|
|
if (ZSTD_isError(err)) return err;
|
|
- RETURN_ERROR_IF(err>0, srcSize_wrong);
|
|
|
|
|
|
+ RETURN_ERROR_IF(err>0, srcSize_wrong, "");
|
|
RETURN_ERROR_IF(zfh.windowSize > windowSizeMax,
|
|
RETURN_ERROR_IF(zfh.windowSize > windowSizeMax,
|
|
- frameParameter_windowTooLarge);
|
|
|
|
|
|
+ frameParameter_windowTooLarge, "");
|
|
return ZSTD_estimateDStreamSize((size_t)zfh.windowSize);
|
|
return ZSTD_estimateDStreamSize((size_t)zfh.windowSize);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
/* ***** Decompression ***** */
|
|
/* ***** Decompression ***** */
|
|
|
|
|
|
-MEM_STATIC size_t ZSTD_limitCopy(void* dst, size_t dstCapacity, const void* src, size_t srcSize)
|
|
|
|
|
|
+static int ZSTD_DCtx_isOverflow(ZSTD_DStream* zds, size_t const neededInBuffSize, size_t const neededOutBuffSize)
|
|
{
|
|
{
|
|
- size_t const length = MIN(dstCapacity, srcSize);
|
|
|
|
- memcpy(dst, src, length);
|
|
|
|
- return length;
|
|
|
|
|
|
+ return (zds->inBuffSize + zds->outBuffSize) >= (neededInBuffSize + neededOutBuffSize) * ZSTD_WORKSPACETOOLARGE_FACTOR;
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+static void ZSTD_DCtx_updateOversizedDuration(ZSTD_DStream* zds, size_t const neededInBuffSize, size_t const neededOutBuffSize)
|
|
|
|
+{
|
|
|
|
+ if (ZSTD_DCtx_isOverflow(zds, neededInBuffSize, neededOutBuffSize))
|
|
|
|
+ zds->oversizedDuration++;
|
|
|
|
+ else
|
|
|
|
+ zds->oversizedDuration = 0;
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+static int ZSTD_DCtx_isOversizedTooLong(ZSTD_DStream* zds)
|
|
|
|
+{
|
|
|
|
+ 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)
|
|
|
|
+{
|
|
|
|
+ ZSTD_outBuffer const expect = zds->expectedOutBuffer;
|
|
|
|
+ /* No requirement when ZSTD_obm_stable is not enabled. */
|
|
|
|
+ if (zds->outBufferMode != ZSTD_obm_stable)
|
|
|
|
+ return 0;
|
|
|
|
+ /* Any buffer is allowed in zdss_init, this must be the same for every other call until
|
|
|
|
+ * the context is reset.
|
|
|
|
+ */
|
|
|
|
+ if (zds->streamStage == zdss_init)
|
|
|
|
+ return 0;
|
|
|
|
+ /* The buffer must match our expectation exactly. */
|
|
|
|
+ if (expect.dst == output->dst && expect.pos == output->pos && expect.size == output->size)
|
|
|
|
+ return 0;
|
|
|
|
+ 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(
|
|
|
|
+ ZSTD_DStream* zds, char** op, char* oend,
|
|
|
|
+ void const* src, size_t srcSize) {
|
|
|
|
+ int const isSkipFrame = ZSTD_isSkipFrame(zds);
|
|
|
|
+ if (zds->outBufferMode == ZSTD_obm_buffered) {
|
|
|
|
+ size_t const dstSize = isSkipFrame ? 0 : zds->outBuffSize - zds->outStart;
|
|
|
|
+ size_t const decodedSize = ZSTD_decompressContinue(zds,
|
|
|
|
+ zds->outBuff + zds->outStart, dstSize, src, srcSize);
|
|
|
|
+ FORWARD_IF_ERROR(decodedSize, "");
|
|
|
|
+ if (!decodedSize && !isSkipFrame) {
|
|
|
|
+ zds->streamStage = zdss_read;
|
|
|
|
+ } else {
|
|
|
|
+ zds->outEnd = zds->outStart + decodedSize;
|
|
|
|
+ zds->streamStage = zdss_flush;
|
|
|
|
+ }
|
|
|
|
+ } else {
|
|
|
|
+ /* Write directly into the output buffer */
|
|
|
|
+ size_t const dstSize = isSkipFrame ? 0 : oend - *op;
|
|
|
|
+ size_t const decodedSize = ZSTD_decompressContinue(zds, *op, dstSize, src, srcSize);
|
|
|
|
+ FORWARD_IF_ERROR(decodedSize, "");
|
|
|
|
+ *op += decodedSize;
|
|
|
|
+ /* Flushing is not needed. */
|
|
|
|
+ zds->streamStage = zdss_read;
|
|
|
|
+ assert(*op <= oend);
|
|
|
|
+ assert(zds->outBufferMode == ZSTD_obm_stable);
|
|
|
|
+ }
|
|
|
|
+ return 0;
|
|
|
|
+}
|
|
|
|
|
|
size_t ZSTD_decompressStream(ZSTD_DStream* zds, ZSTD_outBuffer* output, ZSTD_inBuffer* input)
|
|
size_t ZSTD_decompressStream(ZSTD_DStream* zds, ZSTD_outBuffer* output, ZSTD_inBuffer* input)
|
|
{
|
|
{
|
|
- const char* const istart = (const char*)(input->src) + input->pos;
|
|
|
|
- const char* const iend = (const char*)(input->src) + input->size;
|
|
|
|
|
|
+ const char* const src = (const char*)input->src;
|
|
|
|
+ const char* const istart = input->pos != 0 ? src + input->pos : src;
|
|
|
|
+ const char* const iend = input->size != 0 ? src + input->size : src;
|
|
const char* ip = istart;
|
|
const char* ip = istart;
|
|
- char* const ostart = (char*)(output->dst) + output->pos;
|
|
|
|
- char* const oend = (char*)(output->dst) + output->size;
|
|
|
|
|
|
+ char* const dst = (char*)output->dst;
|
|
|
|
+ char* const ostart = output->pos != 0 ? dst + output->pos : dst;
|
|
|
|
+ char* const oend = output->size != 0 ? dst + output->size : dst;
|
|
char* op = ostart;
|
|
char* op = ostart;
|
|
U32 someMoreWork = 1;
|
|
U32 someMoreWork = 1;
|
|
|
|
|
|
@@ -1506,6 +1609,7 @@ size_t ZSTD_decompressStream(ZSTD_DStream* zds, ZSTD_outBuffer* output, ZSTD_inB
|
|
"forbidden. out: pos: %u vs size: %u",
|
|
"forbidden. out: pos: %u vs size: %u",
|
|
(U32)output->pos, (U32)output->size);
|
|
(U32)output->pos, (U32)output->size);
|
|
DEBUGLOG(5, "input size : %u", (U32)(input->size - input->pos));
|
|
DEBUGLOG(5, "input size : %u", (U32)(input->size - input->pos));
|
|
|
|
+ FORWARD_IF_ERROR(ZSTD_checkOutBuffer(zds, output), "");
|
|
|
|
|
|
while (someMoreWork) {
|
|
while (someMoreWork) {
|
|
switch(zds->streamStage)
|
|
switch(zds->streamStage)
|
|
@@ -1516,6 +1620,7 @@ size_t ZSTD_decompressStream(ZSTD_DStream* zds, ZSTD_outBuffer* output, ZSTD_inB
|
|
zds->lhSize = zds->inPos = zds->outStart = zds->outEnd = 0;
|
|
zds->lhSize = zds->inPos = zds->outStart = zds->outEnd = 0;
|
|
zds->legacyVersion = 0;
|
|
zds->legacyVersion = 0;
|
|
zds->hostageByte = 0;
|
|
zds->hostageByte = 0;
|
|
|
|
+ zds->expectedOutBuffer = *output;
|
|
/* fall-through */
|
|
/* fall-through */
|
|
|
|
|
|
case zdss_loadHeader :
|
|
case zdss_loadHeader :
|
|
@@ -1543,7 +1648,7 @@ size_t ZSTD_decompressStream(ZSTD_DStream* zds, ZSTD_outBuffer* output, ZSTD_inB
|
|
"legacy support is incompatible with static dctx");
|
|
"legacy support is incompatible with static dctx");
|
|
FORWARD_IF_ERROR(ZSTD_initLegacyStream(&zds->legacyContext,
|
|
FORWARD_IF_ERROR(ZSTD_initLegacyStream(&zds->legacyContext,
|
|
zds->previousLegacyVersion, legacyVersion,
|
|
zds->previousLegacyVersion, legacyVersion,
|
|
- dict, dictSize));
|
|
|
|
|
|
+ dict, dictSize), "");
|
|
zds->legacyVersion = zds->previousLegacyVersion = legacyVersion;
|
|
zds->legacyVersion = zds->previousLegacyVersion = legacyVersion;
|
|
{ size_t const hint = ZSTD_decompressLegacyStream(zds->legacyContext, legacyVersion, output, input);
|
|
{ size_t const hint = ZSTD_decompressLegacyStream(zds->legacyContext, legacyVersion, output, input);
|
|
if (hint==0) zds->streamStage = zdss_init; /* or stay in stage zdss_loadHeader */
|
|
if (hint==0) zds->streamStage = zdss_init; /* or stay in stage zdss_loadHeader */
|
|
@@ -1570,7 +1675,8 @@ size_t ZSTD_decompressStream(ZSTD_DStream* zds, ZSTD_outBuffer* output, ZSTD_inB
|
|
} }
|
|
} }
|
|
|
|
|
|
/* check for single-pass mode opportunity */
|
|
/* check for single-pass mode opportunity */
|
|
- if (zds->fParams.frameContentSize && zds->fParams.windowSize /* skippable frame if == 0 */
|
|
|
|
|
|
+ if (zds->fParams.frameContentSize != ZSTD_CONTENTSIZE_UNKNOWN
|
|
|
|
+ && zds->fParams.frameType != ZSTD_skippableFrame
|
|
&& (U64)(size_t)(oend-op) >= zds->fParams.frameContentSize) {
|
|
&& (U64)(size_t)(oend-op) >= zds->fParams.frameContentSize) {
|
|
size_t const cSize = ZSTD_findFrameCompressedSize(istart, iend-istart);
|
|
size_t const cSize = ZSTD_findFrameCompressedSize(istart, iend-istart);
|
|
if (cSize <= (size_t)(iend-istart)) {
|
|
if (cSize <= (size_t)(iend-istart)) {
|
|
@@ -1586,15 +1692,23 @@ size_t ZSTD_decompressStream(ZSTD_DStream* zds, ZSTD_outBuffer* output, ZSTD_inB
|
|
break;
|
|
break;
|
|
} }
|
|
} }
|
|
|
|
|
|
|
|
+ /* Check output buffer is large enough for ZSTD_odm_stable. */
|
|
|
|
+ if (zds->outBufferMode == ZSTD_obm_stable
|
|
|
|
+ && zds->fParams.frameType != ZSTD_skippableFrame
|
|
|
|
+ && zds->fParams.frameContentSize != ZSTD_CONTENTSIZE_UNKNOWN
|
|
|
|
+ && (U64)(size_t)(oend-op) < zds->fParams.frameContentSize) {
|
|
|
|
+ RETURN_ERROR(dstSize_tooSmall, "ZSTD_obm_stable passed but ZSTD_outBuffer is too small");
|
|
|
|
+ }
|
|
|
|
+
|
|
/* Consume header (see ZSTDds_decodeFrameHeader) */
|
|
/* Consume header (see ZSTDds_decodeFrameHeader) */
|
|
DEBUGLOG(4, "Consume header");
|
|
DEBUGLOG(4, "Consume header");
|
|
- FORWARD_IF_ERROR(ZSTD_decompressBegin_usingDDict(zds, ZSTD_getDDict(zds)));
|
|
|
|
|
|
+ FORWARD_IF_ERROR(ZSTD_decompressBegin_usingDDict(zds, ZSTD_getDDict(zds)), "");
|
|
|
|
|
|
if ((MEM_readLE32(zds->headerBuffer) & ZSTD_MAGIC_SKIPPABLE_MASK) == ZSTD_MAGIC_SKIPPABLE_START) { /* skippable frame */
|
|
if ((MEM_readLE32(zds->headerBuffer) & ZSTD_MAGIC_SKIPPABLE_MASK) == ZSTD_MAGIC_SKIPPABLE_START) { /* skippable frame */
|
|
zds->expected = MEM_readLE32(zds->headerBuffer + ZSTD_FRAMEIDSIZE);
|
|
zds->expected = MEM_readLE32(zds->headerBuffer + ZSTD_FRAMEIDSIZE);
|
|
zds->stage = ZSTDds_skipFrame;
|
|
zds->stage = ZSTDds_skipFrame;
|
|
} else {
|
|
} else {
|
|
- FORWARD_IF_ERROR(ZSTD_decodeFrameHeader(zds, zds->headerBuffer, zds->lhSize));
|
|
|
|
|
|
+ FORWARD_IF_ERROR(ZSTD_decodeFrameHeader(zds, zds->headerBuffer, zds->lhSize), "");
|
|
zds->expected = ZSTD_blockHeaderSize;
|
|
zds->expected = ZSTD_blockHeaderSize;
|
|
zds->stage = ZSTDds_decodeBlockHeader;
|
|
zds->stage = ZSTDds_decodeBlockHeader;
|
|
}
|
|
}
|
|
@@ -1605,40 +1719,48 @@ size_t ZSTD_decompressStream(ZSTD_DStream* zds, ZSTD_outBuffer* output, ZSTD_inB
|
|
(U32)(zds->maxWindowSize >> 10) );
|
|
(U32)(zds->maxWindowSize >> 10) );
|
|
zds->fParams.windowSize = MAX(zds->fParams.windowSize, 1U << ZSTD_WINDOWLOG_ABSOLUTEMIN);
|
|
zds->fParams.windowSize = MAX(zds->fParams.windowSize, 1U << ZSTD_WINDOWLOG_ABSOLUTEMIN);
|
|
RETURN_ERROR_IF(zds->fParams.windowSize > zds->maxWindowSize,
|
|
RETURN_ERROR_IF(zds->fParams.windowSize > zds->maxWindowSize,
|
|
- frameParameter_windowTooLarge);
|
|
|
|
|
|
+ frameParameter_windowTooLarge, "");
|
|
|
|
|
|
/* Adapt buffer sizes to frame header instructions */
|
|
/* Adapt buffer sizes to frame header instructions */
|
|
{ size_t const neededInBuffSize = MAX(zds->fParams.blockSizeMax, 4 /* frame checksum */);
|
|
{ size_t const neededInBuffSize = MAX(zds->fParams.blockSizeMax, 4 /* frame checksum */);
|
|
- size_t const neededOutBuffSize = ZSTD_decodingBufferSize_min(zds->fParams.windowSize, zds->fParams.frameContentSize);
|
|
|
|
- if ((zds->inBuffSize < neededInBuffSize) || (zds->outBuffSize < neededOutBuffSize)) {
|
|
|
|
- size_t const bufferSize = neededInBuffSize + neededOutBuffSize;
|
|
|
|
- DEBUGLOG(4, "inBuff : from %u to %u",
|
|
|
|
- (U32)zds->inBuffSize, (U32)neededInBuffSize);
|
|
|
|
- DEBUGLOG(4, "outBuff : from %u to %u",
|
|
|
|
- (U32)zds->outBuffSize, (U32)neededOutBuffSize);
|
|
|
|
- if (zds->staticSize) { /* static DCtx */
|
|
|
|
- DEBUGLOG(4, "staticSize : %u", (U32)zds->staticSize);
|
|
|
|
- assert(zds->staticSize >= sizeof(ZSTD_DCtx)); /* controlled at init */
|
|
|
|
- RETURN_ERROR_IF(
|
|
|
|
- bufferSize > zds->staticSize - sizeof(ZSTD_DCtx),
|
|
|
|
- memory_allocation);
|
|
|
|
- } else {
|
|
|
|
- ZSTD_free(zds->inBuff, zds->customMem);
|
|
|
|
- zds->inBuffSize = 0;
|
|
|
|
- zds->outBuffSize = 0;
|
|
|
|
- zds->inBuff = (char*)ZSTD_malloc(bufferSize, zds->customMem);
|
|
|
|
- RETURN_ERROR_IF(zds->inBuff == NULL, memory_allocation);
|
|
|
|
- }
|
|
|
|
- zds->inBuffSize = neededInBuffSize;
|
|
|
|
- zds->outBuff = zds->inBuff + zds->inBuffSize;
|
|
|
|
- zds->outBuffSize = neededOutBuffSize;
|
|
|
|
- } }
|
|
|
|
|
|
+ size_t const neededOutBuffSize = zds->outBufferMode == ZSTD_obm_buffered
|
|
|
|
+ ? ZSTD_decodingBufferSize_min(zds->fParams.windowSize, zds->fParams.frameContentSize)
|
|
|
|
+ : 0;
|
|
|
|
+
|
|
|
|
+ ZSTD_DCtx_updateOversizedDuration(zds, neededInBuffSize, neededOutBuffSize);
|
|
|
|
+
|
|
|
|
+ { int const tooSmall = (zds->inBuffSize < neededInBuffSize) || (zds->outBuffSize < neededOutBuffSize);
|
|
|
|
+ int const tooLarge = ZSTD_DCtx_isOversizedTooLong(zds);
|
|
|
|
+
|
|
|
|
+ if (tooSmall || tooLarge) {
|
|
|
|
+ size_t const bufferSize = neededInBuffSize + neededOutBuffSize;
|
|
|
|
+ DEBUGLOG(4, "inBuff : from %u to %u",
|
|
|
|
+ (U32)zds->inBuffSize, (U32)neededInBuffSize);
|
|
|
|
+ DEBUGLOG(4, "outBuff : from %u to %u",
|
|
|
|
+ (U32)zds->outBuffSize, (U32)neededOutBuffSize);
|
|
|
|
+ if (zds->staticSize) { /* static DCtx */
|
|
|
|
+ DEBUGLOG(4, "staticSize : %u", (U32)zds->staticSize);
|
|
|
|
+ assert(zds->staticSize >= sizeof(ZSTD_DCtx)); /* controlled at init */
|
|
|
|
+ RETURN_ERROR_IF(
|
|
|
|
+ bufferSize > zds->staticSize - sizeof(ZSTD_DCtx),
|
|
|
|
+ memory_allocation, "");
|
|
|
|
+ } else {
|
|
|
|
+ ZSTD_free(zds->inBuff, zds->customMem);
|
|
|
|
+ zds->inBuffSize = 0;
|
|
|
|
+ zds->outBuffSize = 0;
|
|
|
|
+ zds->inBuff = (char*)ZSTD_malloc(bufferSize, zds->customMem);
|
|
|
|
+ RETURN_ERROR_IF(zds->inBuff == NULL, memory_allocation, "");
|
|
|
|
+ }
|
|
|
|
+ zds->inBuffSize = neededInBuffSize;
|
|
|
|
+ zds->outBuff = zds->inBuff + zds->inBuffSize;
|
|
|
|
+ zds->outBuffSize = neededOutBuffSize;
|
|
|
|
+ } } }
|
|
zds->streamStage = zdss_read;
|
|
zds->streamStage = zdss_read;
|
|
/* fall-through */
|
|
/* fall-through */
|
|
|
|
|
|
case zdss_read:
|
|
case zdss_read:
|
|
DEBUGLOG(5, "stage zdss_read");
|
|
DEBUGLOG(5, "stage zdss_read");
|
|
- { size_t const neededInSize = ZSTD_nextSrcSizeToDecompress(zds);
|
|
|
|
|
|
+ { size_t const neededInSize = ZSTD_nextSrcSizeToDecompressWithInputSize(zds, iend - ip);
|
|
DEBUGLOG(5, "neededInSize = %u", (U32)neededInSize);
|
|
DEBUGLOG(5, "neededInSize = %u", (U32)neededInSize);
|
|
if (neededInSize==0) { /* end of frame */
|
|
if (neededInSize==0) { /* end of frame */
|
|
zds->streamStage = zdss_init;
|
|
zds->streamStage = zdss_init;
|
|
@@ -1646,15 +1768,9 @@ size_t ZSTD_decompressStream(ZSTD_DStream* zds, ZSTD_outBuffer* output, ZSTD_inB
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
if ((size_t)(iend-ip) >= neededInSize) { /* decode directly from src */
|
|
if ((size_t)(iend-ip) >= neededInSize) { /* decode directly from src */
|
|
- int const isSkipFrame = ZSTD_isSkipFrame(zds);
|
|
|
|
- size_t const decodedSize = ZSTD_decompressContinue(zds,
|
|
|
|
- zds->outBuff + zds->outStart, (isSkipFrame ? 0 : zds->outBuffSize - zds->outStart),
|
|
|
|
- ip, neededInSize);
|
|
|
|
- if (ZSTD_isError(decodedSize)) return decodedSize;
|
|
|
|
|
|
+ FORWARD_IF_ERROR(ZSTD_decompressContinueStream(zds, &op, oend, ip, neededInSize), "");
|
|
ip += neededInSize;
|
|
ip += neededInSize;
|
|
- if (!decodedSize && !isSkipFrame) break; /* this was just a header */
|
|
|
|
- zds->outEnd = zds->outStart + decodedSize;
|
|
|
|
- zds->streamStage = zdss_flush;
|
|
|
|
|
|
+ /* Function modifies the stage so we must break */
|
|
break;
|
|
break;
|
|
} }
|
|
} }
|
|
if (ip==iend) { someMoreWork = 0; break; } /* no more input */
|
|
if (ip==iend) { someMoreWork = 0; break; } /* no more input */
|
|
@@ -1666,6 +1782,8 @@ size_t ZSTD_decompressStream(ZSTD_DStream* zds, ZSTD_outBuffer* output, ZSTD_inB
|
|
size_t const toLoad = neededInSize - zds->inPos;
|
|
size_t const toLoad = neededInSize - zds->inPos;
|
|
int const isSkipFrame = ZSTD_isSkipFrame(zds);
|
|
int const isSkipFrame = ZSTD_isSkipFrame(zds);
|
|
size_t loadedSize;
|
|
size_t loadedSize;
|
|
|
|
+ /* At this point we shouldn't be decompressing a block that we can stream. */
|
|
|
|
+ assert(neededInSize == ZSTD_nextSrcSizeToDecompressWithInputSize(zds, iend - ip));
|
|
if (isSkipFrame) {
|
|
if (isSkipFrame) {
|
|
loadedSize = MIN(toLoad, (size_t)(iend-ip));
|
|
loadedSize = MIN(toLoad, (size_t)(iend-ip));
|
|
} else {
|
|
} else {
|
|
@@ -1679,17 +1797,11 @@ size_t ZSTD_decompressStream(ZSTD_DStream* zds, ZSTD_outBuffer* output, ZSTD_inB
|
|
if (loadedSize < toLoad) { someMoreWork = 0; break; } /* not enough input, wait for more */
|
|
if (loadedSize < toLoad) { someMoreWork = 0; break; } /* not enough input, wait for more */
|
|
|
|
|
|
/* decode loaded input */
|
|
/* decode loaded input */
|
|
- { size_t const decodedSize = ZSTD_decompressContinue(zds,
|
|
|
|
- zds->outBuff + zds->outStart, zds->outBuffSize - zds->outStart,
|
|
|
|
- zds->inBuff, neededInSize);
|
|
|
|
- if (ZSTD_isError(decodedSize)) return decodedSize;
|
|
|
|
- zds->inPos = 0; /* input is consumed */
|
|
|
|
- if (!decodedSize && !isSkipFrame) { zds->streamStage = zdss_read; break; } /* this was just a header */
|
|
|
|
- zds->outEnd = zds->outStart + decodedSize;
|
|
|
|
- } }
|
|
|
|
- zds->streamStage = zdss_flush;
|
|
|
|
- /* fall-through */
|
|
|
|
-
|
|
|
|
|
|
+ zds->inPos = 0; /* input is consumed */
|
|
|
|
+ FORWARD_IF_ERROR(ZSTD_decompressContinueStream(zds, &op, oend, zds->inBuff, neededInSize), "");
|
|
|
|
+ /* Function modifies the stage so we must break */
|
|
|
|
+ break;
|
|
|
|
+ }
|
|
case zdss_flush:
|
|
case zdss_flush:
|
|
{ size_t const toFlushSize = zds->outEnd - zds->outStart;
|
|
{ size_t const toFlushSize = zds->outEnd - zds->outStart;
|
|
size_t const flushedSize = ZSTD_limitCopy(op, oend-op, zds->outBuff + zds->outStart, toFlushSize);
|
|
size_t const flushedSize = ZSTD_limitCopy(op, oend-op, zds->outBuff + zds->outStart, toFlushSize);
|
|
@@ -1712,17 +1824,21 @@ size_t ZSTD_decompressStream(ZSTD_DStream* zds, ZSTD_outBuffer* output, ZSTD_inB
|
|
|
|
|
|
default:
|
|
default:
|
|
assert(0); /* impossible */
|
|
assert(0); /* impossible */
|
|
- RETURN_ERROR(GENERIC); /* some compiler require default to do something */
|
|
|
|
|
|
+ RETURN_ERROR(GENERIC, "impossible to reach"); /* some compiler require default to do something */
|
|
} }
|
|
} }
|
|
|
|
|
|
/* result */
|
|
/* result */
|
|
input->pos = (size_t)(ip - (const char*)(input->src));
|
|
input->pos = (size_t)(ip - (const char*)(input->src));
|
|
output->pos = (size_t)(op - (char*)(output->dst));
|
|
output->pos = (size_t)(op - (char*)(output->dst));
|
|
|
|
+
|
|
|
|
+ /* Update the expected output buffer for ZSTD_obm_stable. */
|
|
|
|
+ zds->expectedOutBuffer = *output;
|
|
|
|
+
|
|
if ((ip==istart) && (op==ostart)) { /* no forward progress */
|
|
if ((ip==istart) && (op==ostart)) { /* no forward progress */
|
|
zds->noForwardProgress ++;
|
|
zds->noForwardProgress ++;
|
|
if (zds->noForwardProgress >= ZSTD_NO_FORWARD_PROGRESS_MAX) {
|
|
if (zds->noForwardProgress >= ZSTD_NO_FORWARD_PROGRESS_MAX) {
|
|
- RETURN_ERROR_IF(op==oend, dstSize_tooSmall);
|
|
|
|
- RETURN_ERROR_IF(ip==iend, srcSize_wrong);
|
|
|
|
|
|
+ RETURN_ERROR_IF(op==oend, dstSize_tooSmall, "");
|
|
|
|
+ RETURN_ERROR_IF(ip==iend, srcSize_wrong, "");
|
|
assert(0);
|
|
assert(0);
|
|
}
|
|
}
|
|
} else {
|
|
} else {
|