Lines Matching refs:readCtx
1073 ReadPoolCtx_t *readCtx; member
1142 ress.readCtx = AIO_ReadPool_create(prefs, ZSTD_CStreamInSize()); in FIO_createCResources()
1207 AIO_ReadPool_free(ress->readCtx); in FIO_freeCResources()
1245 AIO_ReadPool_fillBuffer(ress->readCtx, ZSTD_CStreamInSize()); in FIO_compressGzFrame()
1246 if (ress->readCtx->srcBufferLoaded == 0) break; in FIO_compressGzFrame()
1247 inFileSize += ress->readCtx->srcBufferLoaded; in FIO_compressGzFrame()
1248 strm.next_in = (z_const unsigned char*)ress->readCtx->srcBuffer; in FIO_compressGzFrame()
1249 strm.avail_in = (uInt)ress->readCtx->srcBufferLoaded; in FIO_compressGzFrame()
1255 AIO_ReadPool_consumeBytes(ress->readCtx, availBefore - strm.avail_in); in FIO_compressGzFrame()
1343 size_t const inSize = AIO_ReadPool_fillBuffer(ress->readCtx, ZSTD_CStreamInSize()); in FIO_compressLzmaFrame()
1344 if (ress->readCtx->srcBufferLoaded == 0) action = LZMA_FINISH; in FIO_compressLzmaFrame()
1346 strm.next_in = (BYTE const*)ress->readCtx->srcBuffer; in FIO_compressLzmaFrame()
1347 strm.avail_in = ress->readCtx->srcBufferLoaded; in FIO_compressLzmaFrame()
1353 AIO_ReadPool_consumeBytes(ress->readCtx, availBefore - strm.avail_in); in FIO_compressLzmaFrame()
1417 assert(blockSize <= ress->readCtx->base.jobBufferSize); in FIO_compressLz4Frame()
1440 inFileSize += AIO_ReadPool_fillBuffer(ress->readCtx, blockSize); in FIO_compressLz4Frame()
1443 while (ress->readCtx->srcBufferLoaded) { in FIO_compressLz4Frame()
1444 size_t inSize = MIN(blockSize, ress->readCtx->srcBufferLoaded); in FIO_compressLz4Frame()
1446 ress->readCtx->srcBuffer, inSize, NULL); in FIO_compressLz4Frame()
1466 AIO_ReadPool_consumeBytes(ress->readCtx, inSize); in FIO_compressLz4Frame()
1467 inFileSize += AIO_ReadPool_fillBuffer(ress->readCtx, blockSize); in FIO_compressLz4Frame()
1550 size_t const inSize = AIO_ReadPool_fillBuffer(ress.readCtx, ZSTD_CStreamInSize()); in FIO_compressZstdFrame()
1551 … ZSTD_inBuffer inBuff = setInBuffer( ress.readCtx->srcBuffer, ress.readCtx->srcBufferLoaded, 0 ); in FIO_compressZstdFrame()
1555 if ((ress.readCtx->srcBufferLoaded == 0) || (*readsize == fileSize)) in FIO_compressZstdFrame()
1566 AIO_ReadPool_consumeBytes(ress.readCtx, inBuff.pos - oldIPos); in FIO_compressZstdFrame()
1843 assert(AIO_ReadPool_getFile(ress.readCtx) != NULL); in FIO_compressFilename_dstFile()
2068 AIO_ReadPool_setAsync(ress.readCtx, 0); in FIO_compressFilename_srcFile()
2071 AIO_ReadPool_setAsync(ress.readCtx, 1); in FIO_compressFilename_srcFile()
2075 AIO_ReadPool_setFile(ress.readCtx, srcFile); in FIO_compressFilename_srcFile()
2080 AIO_ReadPool_closeFile(ress.readCtx); in FIO_compressFilename_srcFile()
2319 ReadPoolCtx_t *readCtx; member
2361 ress.readCtx = AIO_ReadPool_create(prefs, ZSTD_DStreamInSize()); in FIO_createDResources()
2370 AIO_ReadPool_free(ress.readCtx); in FIO_freeDResources()
2379 AIO_ReadPool_fillBuffer(ress->readCtx, blockSize); in FIO_passThrough()
2381 while(ress->readCtx->srcBufferLoaded) { in FIO_passThrough()
2383 writeSize = MIN(blockSize, ress->readCtx->srcBufferLoaded); in FIO_passThrough()
2385 memcpy(writeJob->buffer, ress->readCtx->srcBuffer, writeSize); in FIO_passThrough()
2388 AIO_ReadPool_consumeBytes(ress->readCtx, writeSize); in FIO_passThrough()
2389 AIO_ReadPool_fillBuffer(ress->readCtx, blockSize); in FIO_passThrough()
2391 assert(ress->readCtx->reachedEof); in FIO_passThrough()
2412 err = ZSTD_getFrameHeader(&header, ress->readCtx->srcBuffer, ress->readCtx->srcBufferLoaded); in FIO_zstdErrorHelp()
2454 AIO_ReadPool_fillBuffer(ress->readCtx, ZSTD_FRAMEHEADERSIZE_MAX); in FIO_decompressZstdFrame()
2458 …ZSTD_inBuffer inBuff = setInBuffer( ress->readCtx->srcBuffer, ress->readCtx->srcBufferLoaded, 0 ); in FIO_decompressZstdFrame()
2483 AIO_ReadPool_consumeBytes(ress->readCtx, inBuff.pos); in FIO_decompressZstdFrame()
2489 if (ress->readCtx->srcBufferLoaded < toDecode) { in FIO_decompressZstdFrame()
2490 size_t const readSize = AIO_ReadPool_fillBuffer(ress->readCtx, toDecode); in FIO_decompressZstdFrame()
2528 strm.avail_in = (uInt)ress->readCtx->srcBufferLoaded; in FIO_decompressGzFrame()
2529 strm.next_in = (z_const unsigned char*)ress->readCtx->srcBuffer; in FIO_decompressGzFrame()
2534 AIO_ReadPool_consumeAndRefill(ress->readCtx); in FIO_decompressGzFrame()
2535 if (ress->readCtx->srcBufferLoaded == 0) flush = Z_FINISH; in FIO_decompressGzFrame()
2536 strm.next_in = (z_const unsigned char*)ress->readCtx->srcBuffer; in FIO_decompressGzFrame()
2537 strm.avail_in = (uInt)ress->readCtx->srcBufferLoaded; in FIO_decompressGzFrame()
2560 AIO_ReadPool_consumeBytes(ress->readCtx, ress->readCtx->srcBufferLoaded - strm.avail_in); in FIO_decompressGzFrame()
2603 strm.next_in = (BYTE const*)ress->readCtx->srcBuffer; in FIO_decompressLzmaFrame()
2604 strm.avail_in = ress->readCtx->srcBufferLoaded; in FIO_decompressLzmaFrame()
2609 AIO_ReadPool_consumeAndRefill(ress->readCtx); in FIO_decompressLzmaFrame()
2610 if (ress->readCtx->srcBufferLoaded == 0) action = LZMA_FINISH; in FIO_decompressLzmaFrame()
2611 strm.next_in = (BYTE const*)ress->readCtx->srcBuffer; in FIO_decompressLzmaFrame()
2612 strm.avail_in = ress->readCtx->srcBufferLoaded; in FIO_decompressLzmaFrame()
2636 AIO_ReadPool_consumeBytes(ress->readCtx, ress->readCtx->srcBufferLoaded - strm.avail_in); in FIO_decompressLzmaFrame()
2669 AIO_ReadPool_fillBuffer(ress->readCtx, nextToLoad); in FIO_decompressLz4Frame()
2670 if(!ress->readCtx->srcBufferLoaded) break; /* reached end of file */ in FIO_decompressLz4Frame()
2672 …while ((pos < ress->readCtx->srcBufferLoaded) || fullBufferDecoded) { /* still to read, or still … in FIO_decompressLz4Frame()
2674 size_t remaining = ress->readCtx->srcBufferLoaded - pos; in FIO_decompressLz4Frame()
2676 …oad = LZ4F_decompress(dCtx, writeJob->buffer, &decodedBytes, (char*)(ress->readCtx->srcBuffer)+pos, in FIO_decompressLz4Frame()
2684 assert(pos <= ress->readCtx->srcBufferLoaded); in FIO_decompressLz4Frame()
2699 AIO_ReadPool_consumeBytes(ress->readCtx, pos); in FIO_decompressLz4Frame()
2744 AIO_ReadPool_fillBuffer(ress.readCtx, toRead); in FIO_decompressFrames()
2745 buf = (const BYTE*)ress.readCtx->srcBuffer; in FIO_decompressFrames()
2746 if (ress.readCtx->srcBufferLoaded==0) { in FIO_decompressFrames()
2754 if (ress.readCtx->srcBufferLoaded < toRead) { /* not enough input to check magic number */ in FIO_decompressFrames()
2761 if (ZSTD_isFrame(buf, ress.readCtx->srcBufferLoaded)) { in FIO_decompressFrames()
2904 AIO_ReadPool_setAsync(ress.readCtx, 0); in FIO_decompressSrcFile()
2907 AIO_ReadPool_setAsync(ress.readCtx, 1); in FIO_decompressSrcFile()
2911 AIO_ReadPool_setFile(ress.readCtx, srcFile); in FIO_decompressSrcFile()
2915 AIO_ReadPool_setFile(ress.readCtx, NULL); in FIO_decompressSrcFile()