From 62ebbabd32dfccb5363cb245c06f7affb7535727 Mon Sep 17 00:00:00 2001
From: Paul Cruz <paulcruz74@fb.com>
Date: Mon, 10 Jul 2017 09:36:22 -0700
Subject: [PATCH] updated error checking in each thread

---
 contrib/adaptive-compression/multi.c | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/contrib/adaptive-compression/multi.c b/contrib/adaptive-compression/multi.c
index 78d9ca15..4c3f584e 100644
--- a/contrib/adaptive-compression/multi.c
+++ b/contrib/adaptive-compression/multi.c
@@ -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;
             }
         }