Lines Matching refs:zfp
1425 ZSTD_frameProgression const zfp = ZSTD_getFrameProgression(ress.cctx); in FIO_compressZstdFrame() local
1426 …double const cShare = (double)zfp.produced / (double)(zfp.consumed + !zfp.consumed/*avoid div0*/) … in FIO_compressZstdFrame()
1427 …L_HumanReadableSize_t const buffered_hrs = UTIL_makeHumanReadableSize(zfp.ingested - zfp.consumed); in FIO_compressZstdFrame()
1428 … UTIL_HumanReadableSize_t const consumed_hrs = UTIL_makeHumanReadableSize(zfp.consumed); in FIO_compressZstdFrame()
1429 … UTIL_HumanReadableSize_t const produced_hrs = UTIL_makeHumanReadableSize(zfp.produced); in FIO_compressZstdFrame()
1465 if (zfp.currentJobID > 1) { /* only possible if nbWorkers >= 1 */ in FIO_compressZstdFrame()
1467 … unsigned long long newlyProduced = zfp.produced - previous_zfp_update.produced; in FIO_compressZstdFrame()
1468 unsigned long long newlyFlushed = zfp.flushed - previous_zfp_update.flushed; in FIO_compressZstdFrame()
1469 assert(zfp.produced >= previous_zfp_update.produced); in FIO_compressZstdFrame()
1476 …if ( (zfp.consumed == previous_zfp_update.consumed) /* no data compressed : no data available, o… in FIO_compressZstdFrame()
1477 … && (zfp.nbActiveWorkers == 0) /* confirmed : no compression ongoing */ in FIO_compressZstdFrame()
1483 previous_zfp_update = zfp; in FIO_compressZstdFrame()
1495 if (zfp.currentJobID > lastJobID) { in FIO_compressZstdFrame()
1499 …if (zfp.currentJobID > (unsigned)(prefs->nbWorkers+1)) { /* warm up period, to fill all workers … in FIO_compressZstdFrame()
1504 … unsigned long long newlyIngested = zfp.ingested - previous_zfp_correction.ingested; in FIO_compressZstdFrame()
1505 … unsigned long long newlyConsumed = zfp.consumed - previous_zfp_correction.consumed; in FIO_compressZstdFrame()
1506 … unsigned long long newlyProduced = zfp.produced - previous_zfp_correction.produced; in FIO_compressZstdFrame()
1507 … unsigned long long newlyFlushed = zfp.flushed - previous_zfp_correction.flushed; in FIO_compressZstdFrame()
1508 previous_zfp_correction = zfp; in FIO_compressZstdFrame()
1544 lastJobID = zfp.currentJobID; in FIO_compressZstdFrame()