krak/zstd
1
0
Fork 0
mirror of https://github.com/facebook/zstd.git synced 2025-10-31 16:47:48 +02:00
Code Issues Releases 1 Activity

updated examples

Browse Source
This commit is contained in:
Yann Collet
2016-08-17 01:48:43 +02:00
parent 53e17fbd5e
commit 2065879793
2 changed files with 14 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
examples/streaming_compression.c
View File

@@ -93,18 +93,18 @@ static void compressFile_orDie(const char* fname, const char* outName, int cLeve
if (ZSTD_isError(initResult)) { fprintf(stderr, "ZSTD_initCStream() error \n"); exit(11); }
while( (read = fread_orDie(buffIn, toRead, fin)) ) {
ZSTD_rCursor cursin = { buffIn, read };
while (cursin.size) {
ZSTD_wCursor cursout = { buffOut, buffOutSize, 0 };
toRead = ZSTD_compressStream(cstream, &cursout , &cursin);
fwrite_orDie(buffOut, cursout.nbBytesWritten, fout);
ZSTD_inBuffer input = { buffIn, read, 0 };
while (input.pos < input.size) {
ZSTD_outBuffer output = { buffOut, buffOutSize, 0 };
toRead = ZSTD_compressStream(cstream, &output , &input);
fwrite_orDie(buffOut, output.pos, fout);
}
}
ZSTD_wCursor cursout = { buffOut, buffOutSize, 0 };
size_t const remainingToFlush = ZSTD_endStream(cstream, &cursout);
ZSTD_outBuffer output = { buffOut, buffOutSize, 0 };
size_t const remainingToFlush = ZSTD_endStream(cstream, &output);
if (remainingToFlush) { fprintf(stderr, "not fully flushed"); exit(12); }
fwrite_orDie(buffOut, cursout.nbBytesWritten, fout);
fwrite_orDie(buffOut, output.pos, fout);
fclose_orDie(fout);
fclose_orDie(fin);

11
examples/streaming_decompression.c
View File

@@ -83,11 +83,12 @@ static void decompressFile_orDie(const char* fname)
if (ZSTD_isError(initResult)) { fprintf(stderr, "ZSTD_initDStream() error \n"); exit(11); }
while( (read = fread_orDie(buffIn, toRead, fin)) ) {
ZSTD_rCursor cursin = { buffIn, read };
while (cursin.size) {
ZSTD_wCursor cursout = { buffOut, buffOutSize, 0 };
toRead = ZSTD_decompressStream(dstream, &cursout , &cursin);
/* note : data is just "sinked" into buffOut */
ZSTD_inBuffer input = { buffIn, read, 0 };
while (input.pos < input.size) {
ZSTD_outBuffer output = { buffOut, buffOutSize, 0 };
toRead = ZSTD_decompressStream(dstream, &output , &input);
/* note : data is just "sinked" into buffOut
a more complete example would write it to disk or stdout */
}
}