Lines Matching refs:zfp
1352 ZSTD_frameProgression const zfp = ZSTD_getFrameProgression(ress.cctx);
1353 double const cShare = (double)zfp.produced / (zfp.consumed + !zfp.consumed/*avoid div0*/) * 100;
1359 (unsigned)((zfp.ingested - zfp.consumed) >> 20),
1360 (unsigned)(zfp.consumed >> 20),
1361 (unsigned)(zfp.produced >> 20),
1377 DISPLAYLEVEL(2, "Read : %2u ", (unsigned)(zfp.consumed >> 20));
1388 if (zfp.currentJobID > 1) { /* only possible if nbWorkers >= 1 */
1390 unsigned long long newlyProduced = zfp.produced - previous_zfp_update.produced;
1391 unsigned long long newlyFlushed = zfp.flushed - previous_zfp_update.flushed;
1392 assert(zfp.produced >= previous_zfp_update.produced);
1399 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)*/
1400 && (zfp.nbActiveWorkers == 0) /* confirmed : no compression ongoing */
1406 previous_zfp_update = zfp;
1418 if (zfp.currentJobID > lastJobID) {
1422 if (zfp.currentJobID > (unsigned)(prefs->nbWorkers+1)) { /* warm up period, to fill all workers */
1427 unsigned long long newlyIngested = zfp.ingested - previous_zfp_correction.ingested;
1428 unsigned long long newlyConsumed = zfp.consumed - previous_zfp_correction.consumed;
1429 unsigned long long newlyProduced = zfp.produced - previous_zfp_correction.produced;
1430 unsigned long long newlyFlushed = zfp.flushed - previous_zfp_correction.flushed;
1431 previous_zfp_correction = zfp;
1467 lastJobID = zfp.currentJobID;
1468 } /* if (zfp.currentJobID > lastJobID) */