mirrors/zstd
0
0
Fork 0
mirror of https://github.com/facebook/zstd.git synced 2024-11-24 03:16:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

updated error checking in each thread

Browse Source
This commit is contained in:
Paul Cruz 2017-07-10 09:36:22 -07:00
parent c3ae23d459
commit 62ebbabd32
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
contrib/adaptive-compression/multi.c
View File

@ -284,12 +284,14 @@ static void* outputThread(void* arg)
size_t const compressedSize = job->compressedSize;
if (ZSTD_isError(compressedSize)) {
DISPLAY("Error: an error occurred during compression\n");
ctx->threadError = 1;
return arg;
}
{
size_t const writeSize = fwrite(job->dst.start, 1, compressedSize, ctx->dstFile);
if (writeSize != compressedSize) {
DISPLAY("Error: an error occurred during file write operation\n");
ctx->threadError = 1;
return arg;
}
}
@ -429,6 +431,7 @@ static int compressFilename(const char* const srcFilename, const char* const dst
size_t const readSize = fread(src, 1, FILE_CHUNK_SIZE, srcFile);
if (readSize != FILE_CHUNK_SIZE && !feof(srcFile)) {
DISPLAY("Error: problem occurred during read from src file\n");
ctx->threadError = 1;
ret = 1;
goto cleanup;
}
@ -438,6 +441,7 @@ static int compressFilename(const char* const srcFilename, const char* const dst
int const error = createCompressionJob(ctx, src, readSize);
if (error != 0) {
ret = error;
ctx->threadError = 1;
goto cleanup;
}
}