zstd/decompress/zstd_decompress.c

44  *  (defined as: no byte read from input, and no byte flushed to output)
507  *  note : this function does not consume input, it only reads it.
568     /* check input validity */
971                 "specifying more input bytes than size of frame(s). "
984     RETURN_ERROR_IF(srcSize, srcSize_wrong, "input not entirely consumed");
1045  * Similar to ZSTD_nextSrcSizeToDecompress(), but when a block input can be streamed,
1046  * we allow taking a partial block as the input. Currently only raw uncompressed blocks can
1050  * output, and avoid copying the input.
1052  * @param inputSize - The total amount of input that the caller currently has.
1827  * used both when reading directly from the ZSTD_inBuffer, and in buffered input mode.
1859 size_t ZSTD_decompressStream(ZSTD_DStream* zds, ZSTD_outBuffer* output, ZSTD_inBuffer* input)
1861     const char* const src = (const char*)input->src;
1862     const char* const istart = input->pos != 0 ? src + input->pos : src;
1863     const char* const iend = input->size != 0 ? src + input->size : src;
1873         input->pos > input->size,
1876         (U32)input->pos, (U32)input->size);
1882     DEBUGLOG(5, "input size : %u", (U32)(input->size - input->pos));
1906                 if (hSize != 0) {   /* need more input */
1910                     if (toLoad > remainingInput) {   /* not enough input to load full header */
1915                         input->pos = input->size;
2022             if (ip==iend) { someMoreWork = 0; break; }   /* no more input */
2043                 if (loadedSize < toLoad) { someMoreWork = 0; break; }   /* not enough input, wait for more */
2045                 /* decode loaded input */
2046                 zds->inPos = 0;   /* input is consumed */
2077     input->pos = (size_t)(ip - (const char*)(input->src));
2097                     if (input->pos >= input->size) {
2102                     input->pos++;  /* release hostage */
2107                 input->pos--;   /* note : pos > 0, otherwise, impossible to finish reading last block */
2125     ZSTD_inBuffer  input  = { src, srcSize, *srcPos };
2127     size_t const cErr = ZSTD_decompressStream(dctx, &output, &input);
2129     *srcPos = input.pos;