Home | History | Annotate | Download | only in programs

Lines Matching defs:zfp

1585                 ZSTD_frameProgression const zfp = ZSTD_getFrameProgression(ress.cctx);
1590                 if (zfp.currentJobID > 1) {  /* only possible if nbWorkers >= 1 */
1592                     unsigned long long newlyProduced = zfp.produced - previous_zfp_update.produced;
1593                     unsigned long long newlyFlushed = zfp.flushed - previous_zfp_update.flushed;
1594                     assert(zfp.produced >= previous_zfp_update.produced);
1601                     if ( (zfp.consumed == previous_zfp_update.consumed)   /* no data compressed : no data available, or no more buffer to compress to, OR compression is really slow (compression of a single block is slower than update rate)*/
1602                         && (zfp.nbActiveWorkers == 0)                       /* confirmed : no compression ongoing */
1608                     previous_zfp_update = zfp;
1620                 if (zfp.currentJobID > lastJobID) {
1624                     if (zfp.currentJobID > (unsigned)(prefs->nbWorkers+1)) {   /* warm up period, to fill all workers */
1629                             unsigned long long newlyIngested = zfp.ingested - previous_zfp_correction.ingested;
1630                             unsigned long long newlyConsumed = zfp.consumed - previous_zfp_correction.consumed;
1631                             unsigned long long newlyProduced = zfp.produced - previous_zfp_correction.produced;
1632                             unsigned long long newlyFlushed  = zfp.flushed  - previous_zfp_correction.flushed;
1633                             previous_zfp_correction = zfp;
1669                     lastJobID = zfp.currentJobID;
1670                 }  /* if (zfp.currentJobID > lastJobID) */
1675                 ZSTD_frameProgression const zfp = ZSTD_getFrameProgression(ress.cctx);
1676                 double const cShare = (double)zfp.produced / (double)(zfp.consumed + !zfp.consumed/*avoid div0*/) * 100;
1677                 UTIL_HumanReadableSize_t const buffered_hrs = UTIL_makeHumanReadableSize(zfp.ingested - zfp.consumed);
1678                 UTIL_HumanReadableSize_t const consumed_hrs = UTIL_makeHumanReadableSize(zfp.consumed);
1679                 UTIL_HumanReadableSize_t const produced_hrs = UTIL_makeHumanReadableSize(zfp.produced);