fixing error when file size is multiple of job size (in which case, the srcSize of the last job is 0)
This commit is contained in:
@@ -450,7 +450,7 @@ static void* compressionThread(void* arg)
|
|||||||
/* reset compressed size */
|
/* reset compressed size */
|
||||||
job->compressedSize = 0;
|
job->compressedSize = 0;
|
||||||
|
|
||||||
while (remaining != 0) {
|
do {
|
||||||
size_t const actualBlockSize = MIN(remaining, compressionBlockSize);
|
size_t const actualBlockSize = MIN(remaining, compressionBlockSize);
|
||||||
DEBUG(2, "remaining: %zu\n", remaining);
|
DEBUG(2, "remaining: %zu\n", remaining);
|
||||||
DEBUG(2, "actualBlockSize: %zu\n", actualBlockSize);
|
DEBUG(2, "actualBlockSize: %zu\n", actualBlockSize);
|
||||||
@@ -505,7 +505,7 @@ static void* compressionThread(void* arg)
|
|||||||
}
|
}
|
||||||
pthread_mutex_unlock(&ctx->completion_mutex.pMutex);
|
pthread_mutex_unlock(&ctx->completion_mutex.pMutex);
|
||||||
}
|
}
|
||||||
}
|
} while (remaining != 0);
|
||||||
job->dst.size = job->compressedSize;
|
job->dst.size = job->compressedSize;
|
||||||
}
|
}
|
||||||
pthread_mutex_lock(&ctx->jobCompressed_mutex.pMutex);
|
pthread_mutex_lock(&ctx->jobCompressed_mutex.pMutex);
|
||||||
|
|||||||
Reference in New Issue
Block a user