From c9f49198b858a89781562d07a35772712c272b8a Mon Sep 17 00:00:00 2001 From: Paul Cruz Date: Wed, 5 Jul 2017 09:49:27 -0700 Subject: [PATCH] fixed TODOs --- contrib/adaptive-compression/v2.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/contrib/adaptive-compression/v2.c b/contrib/adaptive-compression/v2.c index df6bf5705..c25f1db82 100644 --- a/contrib/adaptive-compression/v2.c +++ b/contrib/adaptive-compression/v2.c @@ -174,13 +174,13 @@ static void* outputThread(void* arg) size_t const compressedSize = job->compressedSize; if (ZSTD_isError(compressedSize)) { DISPLAY("Error: an error occurred during compression\n"); - return arg; /* TODO: return something else if error */ + return arg; } { size_t const writeSize = fwrite(ctx->jobs[currJob].dst.start, 1, compressedSize, ctx->dstFile); if (writeSize != compressedSize) { DISPLAY("Error: an error occurred during file write operation\n"); - return arg; /* TODO: return something else if error */ + return arg; } } } @@ -262,7 +262,7 @@ int main(int argCount, const char* argv[]) BYTE* const src = malloc(FILE_CHUNK_SIZE); FILE* const srcFile = fopen(srcFilename, "rb"); size_t fileSize = getFileSize(srcFilename); - size_t const numJobsPrelim = (fileSize >> 22) + 1; /* TODO: figure out why can't divide here */ + size_t const numJobsPrelim = (fileSize / ((size_t)FILE_CHUNK_SIZE)); size_t const numJobs = (numJobsPrelim * FILE_CHUNK_SIZE) == fileSize ? numJobsPrelim : numJobsPrelim + 1; int ret = 0; adaptCCtx* ctx = NULL;