lib/zstd
1
0
Fork 0
mirror of https://github.com/facebook/zstd.git synced 2025-08-05 19:15:58 +03:00
Code Activity

seekable_format: Fix conversion warnings in parallel_compression

Browse Source
This commit is contained in:
Dave Vasilevsky
2025-05-07 02:12:29 -04:00
committed by Yann Collet
parent 13cb7a10ae
commit 448a09ff78
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
contrib/seekable_format/examples/parallel_compression.c
View File

@@ -110,7 +110,7 @@ static void flushFrame(struct state* state, struct job* job)
fwrite_orDie(job->dst, job->dstSize, state->fout); fwrite_orDie(job->dst, job->dstSize, state->fout);
free(job->dst); free(job->dst);
size_t ret = ZSTD_seekable_logFrame(state->frameLog, job->dstSize, job->srcSize, job->checksum); size_t ret = ZSTD_seekable_logFrame(state->frameLog, (unsigned)job->dstSize, (unsigned)job->srcSize, job->checksum);
if (ZSTD_isError(ret)) { if (ZSTD_isError(ret)) {
fprintf(stderr, "ZSTD_seekable_logFrame() error : %s \n", ZSTD_getErrorName(ret)); fprintf(stderr, "ZSTD_seekable_logFrame() error : %s \n", ZSTD_getErrorName(ret));
exit(12); exit(12);
@@ -141,7 +141,7 @@ static void compressFrame(void* opaque)
{ {
struct job* job = opaque; struct job* job = opaque;
job->checksum = XXH64(job->src, job->srcSize, 0); job->checksum = (unsigned)XXH64(job->src, job->srcSize, 0);
size_t ret = ZSTD_compress(job->dst, job->dstSize, job->src, job->srcSize, job->state->compressionLevel); size_t ret = ZSTD_compress(job->dst, job->dstSize, job->src, job->srcSize, job->state->compressionLevel);
if (ZSTD_isError(ret)) { if (ZSTD_isError(ret)) {
@@ -179,7 +179,7 @@ static void openInOut_orDie(const char* fname, FILE** fin, FILE** fout) {
} }
} }
static void compressFile_orDie(const char* fname, int cLevel, unsigned frameSize, int nbThreads) static void compressFile_orDie(const char* fname, int cLevel, unsigned frameSize, size_t nbThreads)
{ {
struct state state = { struct state state = {
.nextID = 0, .nextID = 0,
@@ -197,7 +197,7 @@ static void compressFile_orDie(const char* fname, int cLevel, unsigned frameSize
openInOut_orDie(fname, &fin, &state.fout); openInOut_orDie(fname, &fin, &state.fout);
if (ZSTD_compressBound(frameSize) > 0xFFFFFFFFU) { fprintf(stderr, "Frame size too large \n"); exit(10); } if (ZSTD_compressBound(frameSize) > 0xFFFFFFFFU) { fprintf(stderr, "Frame size too large \n"); exit(10); }
unsigned dstSize = ZSTD_compressBound(frameSize); size_t dstSize = ZSTD_compressBound(frameSize);
for (size_t id = 0; 1; id++) { for (size_t id = 0; 1; id++) {
struct job* job = malloc_orDie(sizeof(struct job)); struct job* job = malloc_orDie(sizeof(struct job));
@@ -245,7 +245,7 @@ int main(int argc, const char** argv) {
{ const char* const inFileName = argv[1]; { const char* const inFileName = argv[1];
unsigned const frameSize = (unsigned)atoi(argv[2]); unsigned const frameSize = (unsigned)atoi(argv[2]);
int const nbThreads = atoi(argv[3]); size_t const nbThreads = (size_t)atoi(argv[3]);
compressFile_orDie(inFileName, 5, frameSize, nbThreads); compressFile_orDie(inFileName, 5, frameSize, nbThreads);
} }