facebook/zstd
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fixed TODOs

Browse Source
This commit is contained in:
Paul Cruz 2017-07-05 09:49:27 -07:00
parent 9a147d8671
commit c9f49198b8
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
contrib/adaptive-compression/v2.c
View File

@ -174,13 +174,13 @@ static void* outputThread(void* arg)
size_t const compressedSize = job->compressedSize; size_t const compressedSize = job->compressedSize;
if (ZSTD_isError(compressedSize)) { if (ZSTD_isError(compressedSize)) {
DISPLAY("Error: an error occurred during compression\n"); 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); size_t const writeSize = fwrite(ctx->jobs[currJob].dst.start, 1, compressedSize, ctx->dstFile);
if (writeSize != compressedSize) { if (writeSize != compressedSize) {
DISPLAY("Error: an error occurred during file write operation\n"); 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); BYTE* const src = malloc(FILE_CHUNK_SIZE);
FILE* const srcFile = fopen(srcFilename, "rb"); FILE* const srcFile = fopen(srcFilename, "rb");
size_t fileSize = getFileSize(srcFilename); 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; size_t const numJobs = (numJobsPrelim * FILE_CHUNK_SIZE) == fileSize ? numJobsPrelim : numJobsPrelim + 1;
int ret = 0; int ret = 0;
adaptCCtx* ctx = NULL; adaptCCtx* ctx = NULL;