Lines Matching refs:writeJob
1220 IOJob_t *writeJob = NULL; in FIO_compressGzFrame() local
1236 writeJob = AIO_WritePool_acquireJob(ress->writeCtx); in FIO_compressGzFrame()
1239 strm.next_out = (Bytef*)writeJob->buffer; in FIO_compressGzFrame()
1240 strm.avail_out = (uInt)writeJob->bufferSize; in FIO_compressGzFrame()
1260 { size_t const cSize = writeJob->bufferSize - strm.avail_out; in FIO_compressGzFrame()
1262 writeJob->usedBufferSize = cSize; in FIO_compressGzFrame()
1263 AIO_WritePool_enqueueAndReacquireWriteJob(&writeJob); in FIO_compressGzFrame()
1265 strm.next_out = (Bytef*)writeJob->buffer; in FIO_compressGzFrame()
1266 strm.avail_out = (uInt)writeJob->bufferSize; in FIO_compressGzFrame()
1282 { size_t const cSize = writeJob->bufferSize - strm.avail_out; in FIO_compressGzFrame()
1284 writeJob->usedBufferSize = cSize; in FIO_compressGzFrame()
1285 AIO_WritePool_enqueueAndReacquireWriteJob(&writeJob); in FIO_compressGzFrame()
1287 strm.next_out = (Bytef*)writeJob->buffer; in FIO_compressGzFrame()
1288 strm.avail_out = (uInt)writeJob->bufferSize; in FIO_compressGzFrame()
1300 AIO_WritePool_releaseIoJob(writeJob); in FIO_compressGzFrame()
1317 IOJob_t *writeJob = NULL; in FIO_compressLzmaFrame() local
1335 writeJob =AIO_WritePool_acquireJob(ress->writeCtx); in FIO_compressLzmaFrame()
1336 strm.next_out = (BYTE*)writeJob->buffer; in FIO_compressLzmaFrame()
1337 strm.avail_out = writeJob->bufferSize; in FIO_compressLzmaFrame()
1359 { size_t const compBytes = writeJob->bufferSize - strm.avail_out; in FIO_compressLzmaFrame()
1361 writeJob->usedBufferSize = compBytes; in FIO_compressLzmaFrame()
1362 AIO_WritePool_enqueueAndReacquireWriteJob(&writeJob); in FIO_compressLzmaFrame()
1364 strm.next_out = (BYTE*)writeJob->buffer; in FIO_compressLzmaFrame()
1365 strm.avail_out = writeJob->bufferSize; in FIO_compressLzmaFrame()
1381 AIO_WritePool_releaseIoJob(writeJob); in FIO_compressLzmaFrame()
1409 IOJob_t* writeJob = AIO_WritePool_acquireJob(ress->writeCtx); in FIO_compressLz4Frame() local
1428 assert(LZ4F_compressBound(blockSize, &prefs) <= writeJob->bufferSize); in FIO_compressLz4Frame()
1431 size_t headerSize = LZ4F_compressBegin(ctx, writeJob->buffer, writeJob->bufferSize, &prefs); in FIO_compressLz4Frame()
1435 writeJob->usedBufferSize = headerSize; in FIO_compressLz4Frame()
1436 AIO_WritePool_enqueueAndReacquireWriteJob(&writeJob); in FIO_compressLz4Frame()
1445 size_t const outSize = LZ4F_compressUpdate(ctx, writeJob->buffer, writeJob->bufferSize, in FIO_compressLz4Frame()
1462 writeJob->usedBufferSize = outSize; in FIO_compressLz4Frame()
1463 AIO_WritePool_enqueueAndReacquireWriteJob(&writeJob); in FIO_compressLz4Frame()
1471 headerSize = LZ4F_compressEnd(ctx, writeJob->buffer, writeJob->bufferSize, NULL); in FIO_compressLz4Frame()
1476 writeJob->usedBufferSize = headerSize; in FIO_compressLz4Frame()
1477 AIO_WritePool_enqueueAndReacquireWriteJob(&writeJob); in FIO_compressLz4Frame()
1483 AIO_WritePool_releaseIoJob(writeJob); in FIO_compressLz4Frame()
1498 IOJob_t* writeJob = AIO_WritePool_acquireJob(ressPtr->writeCtx); in FIO_compressZstdFrame() local
1563 ZSTD_outBuffer outBuff = setOutBuffer( writeJob->buffer, writeJob->bufferSize, 0 ); in FIO_compressZstdFrame()
1577 writeJob->usedBufferSize = outBuff.pos; in FIO_compressZstdFrame()
1578 AIO_WritePool_enqueueAndReacquireWriteJob(&writeJob); in FIO_compressZstdFrame()
1721 AIO_WritePool_releaseIoJob(writeJob); in FIO_compressZstdFrame()
2378 IOJob_t *writeJob = AIO_WritePool_acquireJob(ress->writeCtx); in FIO_passThrough() local
2384 assert(writeSize <= writeJob->bufferSize); in FIO_passThrough()
2385 memcpy(writeJob->buffer, ress->readCtx->srcBuffer, writeSize); in FIO_passThrough()
2386 writeJob->usedBufferSize = writeSize; in FIO_passThrough()
2387 AIO_WritePool_enqueueAndReacquireWriteJob(&writeJob); in FIO_passThrough()
2392 AIO_WritePool_releaseIoJob(writeJob); in FIO_passThrough()
2442 IOJob_t* writeJob = AIO_WritePool_acquireJob(ress->writeCtx); in FIO_decompressZstdFrame() local
2443 assert(writeJob); in FIO_decompressZstdFrame()
2459 ZSTD_outBuffer outBuff= setOutBuffer( writeJob->buffer, writeJob->bufferSize, 0 ); in FIO_decompressZstdFrame()
2466 AIO_WritePool_releaseIoJob(writeJob); in FIO_decompressZstdFrame()
2471 writeJob->usedBufferSize = outBuff.pos; in FIO_decompressZstdFrame()
2472 AIO_WritePool_enqueueAndReacquireWriteJob(&writeJob); in FIO_decompressZstdFrame()
2494 AIO_WritePool_releaseIoJob(writeJob); in FIO_decompressZstdFrame()
2499 AIO_WritePool_releaseIoJob(writeJob); in FIO_decompressZstdFrame()
2514 IOJob_t *writeJob = NULL; in FIO_decompressGzFrame() local
2525 writeJob = AIO_WritePool_acquireJob(ress->writeCtx); in FIO_decompressGzFrame()
2526 strm.next_out = (Bytef*)writeJob->buffer; in FIO_decompressGzFrame()
2527 strm.avail_out = (uInt)writeJob->bufferSize; in FIO_decompressGzFrame()
2548 { size_t const decompBytes = writeJob->bufferSize - strm.avail_out; in FIO_decompressGzFrame()
2550 writeJob->usedBufferSize = decompBytes; in FIO_decompressGzFrame()
2551 AIO_WritePool_enqueueAndReacquireWriteJob(&writeJob); in FIO_decompressGzFrame()
2553 strm.next_out = (Bytef*)writeJob->buffer; in FIO_decompressGzFrame()
2554 strm.avail_out = (uInt)writeJob->bufferSize; in FIO_decompressGzFrame()
2567 AIO_WritePool_releaseIoJob(writeJob); in FIO_decompressGzFrame()
2583 IOJob_t *writeJob = NULL; in FIO_decompressLzmaFrame() local
2600 writeJob = AIO_WritePool_acquireJob(ress->writeCtx); in FIO_decompressLzmaFrame()
2601 strm.next_out = (BYTE*)writeJob->buffer; in FIO_decompressLzmaFrame()
2602 strm.avail_out = writeJob->bufferSize; in FIO_decompressLzmaFrame()
2625 { size_t const decompBytes = writeJob->bufferSize - strm.avail_out; in FIO_decompressLzmaFrame()
2627 writeJob->usedBufferSize = decompBytes; in FIO_decompressLzmaFrame()
2628 AIO_WritePool_enqueueAndReacquireWriteJob(&writeJob); in FIO_decompressLzmaFrame()
2630 strm.next_out = (BYTE*)writeJob->buffer; in FIO_decompressLzmaFrame()
2631 strm.avail_out = writeJob->bufferSize; in FIO_decompressLzmaFrame()
2638 AIO_WritePool_releaseIoJob(writeJob); in FIO_decompressLzmaFrame()
2653 IOJob_t *writeJob = NULL; in FIO_decompressLz4Frame() local
2660 writeJob = AIO_WritePool_acquireJob(ress->writeCtx); in FIO_decompressLz4Frame()
2665 size_t decodedBytes = writeJob->bufferSize; in FIO_decompressLz4Frame()
2675 decodedBytes = writeJob->bufferSize; in FIO_decompressLz4Frame()
2676 …nextToLoad = LZ4F_decompress(dCtx, writeJob->buffer, &decodedBytes, (char*)(ress->readCtx->srcBuff… in FIO_decompressLz4Frame()
2685 fullBufferDecoded = decodedBytes == writeJob->bufferSize; in FIO_decompressLz4Frame()
2690 writeJob->usedBufferSize = decodedBytes; in FIO_decompressLz4Frame()
2691 AIO_WritePool_enqueueAndReacquireWriteJob(&writeJob); in FIO_decompressLz4Frame()
2707 AIO_WritePool_releaseIoJob(writeJob); in FIO_decompressLz4Frame()