lib/zstd
1
0
Fork 0
mirror of https://github.com/facebook/zstd.git synced 2025-07-30 22:23:13 +03:00
Code Activity

minor : update streaming_compression example

Browse Source 
display a warning when requesting multi-threading
while linking to a library that doesn't support multi-threading.
This commit is contained in:
Yann Collet
2023-04-26 12:45:23 -07:00
parent e256e43274
commit 6ec18aed31
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
examples/streaming_compression.c
View File

@ -42,7 +42,13 @@ static void compressFile_orDie(const char* fname, const char* outName, int cLeve
*/ */
CHECK_ZSTD( ZSTD_CCtx_setParameter(cctx, ZSTD_c_compressionLevel, cLevel) ); CHECK_ZSTD( ZSTD_CCtx_setParameter(cctx, ZSTD_c_compressionLevel, cLevel) );
CHECK_ZSTD( ZSTD_CCtx_setParameter(cctx, ZSTD_c_checksumFlag, 1) ); CHECK_ZSTD( ZSTD_CCtx_setParameter(cctx, ZSTD_c_checksumFlag, 1) );
ZSTD_CCtx_setParameter(cctx, ZSTD_c_nbWorkers, nbThreads); if (nbThreads > 1) {
size_t const r = ZSTD_CCtx_setParameter(cctx, ZSTD_c_nbWorkers, nbThreads);
if (ZSTD_isError(r)) {
fprintf (stderr, "Note: the linked libzstd library doesn't support multithreading. "
"Reverting to single-thread mode. \n");
}
}
/* This loop read from the input file, compresses that entire chunk, /* This loop read from the input file, compresses that entire chunk,
* and writes all output produced to the output file. * and writes all output produced to the output file.
@ -117,7 +123,7 @@ int main(int argc, const char** argv)
} }
int cLevel = 1; int cLevel = 1;
int nbThreads = 4; int nbThreads = 1;
if (argc >= 3) { if (argc >= 3) {
cLevel = atoi (argv[2]); cLevel = atoi (argv[2]);