Files
2025-05-18 13:04:45 +08:00

199 lines
5.4 KiB
C

/*********************************************************************
Blosc - Blocked Shuffling and Compression Library
Unit tests for basic features in Blosc.
Creation date: 2010-06-07
Author: Francesc Alted <francesc@blosc.org>
See LICENSES/BLOSC.txt for details about copyright and rights to use.
**********************************************************************/
#include "test_common.h"
int tests_run = 0;
/* Global vars */
void *src, *srccpy, *dest, *dest2;
int nbytes, cbytes;
int clevel = 1;
int doshuffle = 0;
size_t typesize = 4;
size_t size = 1000; /* must be divisible by 4 */
/* Check input size > BLOSC_MAX_BUFFERSIZE */
static const char *test_input_too_large(void) {
/* Get a compressed buffer */
cbytes = blosc_compress(clevel, doshuffle, typesize, BLOSC_MAX_BUFFERSIZE + 1, src,
dest, size + BLOSC_MAX_OVERHEAD - 1);
mu_assert("ERROR: cbytes is not 0", cbytes == 0);
return 0;
}
/* Check maxout with maxout < size */
static const char *test_maxout_less(void) {
/* Get a compressed buffer */
cbytes = blosc_compress(clevel, doshuffle, typesize, size, src, dest,
size + BLOSC_MAX_OVERHEAD - 1);
mu_assert("ERROR: cbytes is not 0", cbytes == 0);
return 0;
}
/* Check maxout with maxout < size (memcpy version) */
static const char *test_maxout_less_memcpy(void) {
/* Get a compressed buffer */
cbytes = blosc_compress(0, doshuffle, typesize, size, src, dest,
size + BLOSC_MAX_OVERHEAD - 1);
mu_assert("ERROR: cbytes is not 0", cbytes == 0);
return 0;
}
/* Check maxout with maxout == size */
static const char *test_maxout_equal(void) {
/* Get a compressed buffer */
cbytes = blosc_compress(clevel, doshuffle, typesize, size, src, dest,
size + BLOSC_MAX_OVERHEAD);
mu_assert("ERROR: cbytes is not correct", cbytes == size + BLOSC_MAX_OVERHEAD);
/* Decompress the buffer */
nbytes = blosc_decompress(dest, dest2, size);
mu_assert("ERROR: nbytes incorrect(1)", nbytes == size);
return 0;
}
/* Check maxout with maxout == size (memcpy version) */
static const char *test_maxout_equal_memcpy(void) {
/* Get a compressed buffer */
cbytes = blosc_compress(0, doshuffle, typesize, size, src, dest,
size + BLOSC_MAX_OVERHEAD);
mu_assert("ERROR: cbytes is not correct", cbytes == size + BLOSC_MAX_OVERHEAD);
/* Decompress the buffer */
nbytes = blosc_decompress(dest, dest2, size);
mu_assert("ERROR: nbytes incorrect(1)", nbytes == size);
return 0;
}
/* Check maxout with maxout > size */
static const char *test_maxout_great(void) {
/* Get a compressed buffer */
cbytes = blosc_compress(clevel, doshuffle, typesize, size, src, dest,
size + BLOSC_MAX_OVERHEAD + 1);
mu_assert("ERROR: cbytes is not correct", cbytes == size + BLOSC_MAX_OVERHEAD);
/* Decompress the buffer */
nbytes = blosc_decompress(dest, dest2, size);
mu_assert("ERROR: nbytes incorrect(1)", nbytes == size);
return 0;
}
/* Check maxout with maxout > size (memcpy version) */
static const char *test_maxout_great_memcpy(void) {
/* Get a compressed buffer */
cbytes = blosc_compress(0, doshuffle, typesize, size, src, dest,
size + BLOSC_MAX_OVERHEAD + 1);
mu_assert("ERROR: cbytes is not correct", cbytes == size + BLOSC_MAX_OVERHEAD);
/* Decompress the buffer */
nbytes = blosc_decompress(dest, dest2, size);
mu_assert("ERROR: nbytes incorrect(1)", nbytes == size);
return 0;
}
/* Check maxout with maxout < BLOSC_MAX_OVERHEAD */
static const char *test_max_overhead(void) {
blosc_init();
cbytes = blosc_compress(0, doshuffle, typesize, size, src, dest,
BLOSC_MAX_OVERHEAD - 1);
mu_assert("ERROR: cbytes is not correct", cbytes == 0);
blosc_destroy();
blosc_init();
cbytes = blosc_compress(0, doshuffle, typesize, size, src, dest,
BLOSC_MAX_OVERHEAD - 2);
mu_assert("ERROR: cbytes is not correct", cbytes == 0);
blosc_destroy();
blosc_init();
cbytes = blosc_compress(0, doshuffle, typesize, size, src, dest, 0);
mu_assert("ERROR: cbytes is not correct", cbytes == 0);
blosc_destroy();
return 0;
}
static const char *all_tests(void) {
mu_run_test(test_input_too_large);
mu_run_test(test_maxout_less);
mu_run_test(test_maxout_less_memcpy);
mu_run_test(test_maxout_equal);
mu_run_test(test_maxout_equal_memcpy);
mu_run_test(test_maxout_great);
mu_run_test(test_maxout_great_memcpy);
mu_run_test(test_max_overhead);
return 0;
}
#define BUFFER_ALIGN_SIZE 32
int main(int argc, char **argv) {
int32_t *_src;
const char *result;
size_t i;
printf("STARTING TESTS for %s", argv[0]);
blosc_init();
blosc_set_nthreads(1);
/* Initialize buffers */
src = blosc_test_malloc(BUFFER_ALIGN_SIZE, size);
srccpy = blosc_test_malloc(BUFFER_ALIGN_SIZE, size);
dest = blosc_test_malloc(BUFFER_ALIGN_SIZE, size + BLOSC_MAX_OVERHEAD);
dest2 = blosc_test_malloc(BUFFER_ALIGN_SIZE, size);
_src = (int32_t *)src;
for (i=0; i < (size/4); i++) {
_src[i] = (int32_t)i;
}
memcpy(srccpy, src, size);
/* Run all the suite */
result = all_tests();
if (result != 0) {
printf(" (%s)\n", result);
}
else {
printf(" ALL TESTS PASSED");
}
printf("\tTests run: %d\n", tests_run);
blosc_test_free(src);
blosc_test_free(srccpy);
blosc_test_free(dest);
blosc_test_free(dest2);
blosc_destroy();
return result != 0;
}