Lines Matching refs:bytesRead
60 std::uint64_t bytesRead; in handleOneInput() local
70 [&state, &outs, &executor, inputFd, inputSize, &options, &bytesRead] { in handleOneInput()
71 bytesRead = asyncCompressChunks( in handleOneInput()
84 readExecutor.add([&state, &outs, &executor, inputFd, &bytesRead] { in handleOneInput()
85 bytesRead = asyncDecompressFrames(state, outs, executor, inputFd); in handleOneInput()
96 static_cast<double>(bytesRead + !bytesRead); in handleOneInput()
99 inputFileName.c_str(), ratio * 100, bytesRead, bytesWritten, in handleOneInput()
365 auto bytesRead = in readData() local
367 *totalBytesRead += bytesRead; in readData()
368 queue.push(buffer.splitAt(bytesRead)); in readData()
386 std::uint64_t bytesRead = 0; in asyncCompressChunks() local
408 status = readData(*in, ZSTD_CStreamInSize(), step, fd, &bytesRead); in asyncCompressChunks()
411 return bytesRead; in asyncCompressChunks()
518 auto bytesRead = std::fread(buffer.data(), 1, buffer.size(), fd); in asyncDecompressFrames() local
519 totalBytesRead += bytesRead; in asyncDecompressFrames()
521 if (bytesRead == 0 && status != FileStatus::Continue) { in asyncDecompressFrames()
524 buffer.subtract(buffer.size() - bytesRead); in asyncDecompressFrames()