diff options
Diffstat (limited to 'src/third_party/wiredtiger/ext/compressors/nop/nop_compress.c')
-rw-r--r-- | src/third_party/wiredtiger/ext/compressors/nop/nop_compress.c | 158 |
1 files changed, 76 insertions, 82 deletions
diff --git a/src/third_party/wiredtiger/ext/compressors/nop/nop_compress.c b/src/third_party/wiredtiger/ext/compressors/nop/nop_compress.c index dd0902fca5a..8bf60e5f25f 100644 --- a/src/third_party/wiredtiger/ext/compressors/nop/nop_compress.c +++ b/src/third_party/wiredtiger/ext/compressors/nop/nop_compress.c @@ -36,11 +36,11 @@ /*! [WT_COMPRESSOR initialization structure] */ /* Local compressor structure. */ typedef struct { - WT_COMPRESSOR compressor; /* Must come first */ + WT_COMPRESSOR compressor; /* Must come first */ - WT_EXTENSION_API *wt_api; /* Extension API */ + WT_EXTENSION_API *wt_api; /* Extension API */ - unsigned long nop_calls; /* Count of calls */ + unsigned long nop_calls; /* Count of calls */ } NOP_COMPRESSOR; /*! [WT_COMPRESSOR initialization structure] */ @@ -48,140 +48,134 @@ typedef struct { /*! [WT_COMPRESSOR compress] */ /* * nop_compress -- - * A simple compression example that passes data through unchanged. + * A simple compression example that passes data through unchanged. */ static int -nop_compress(WT_COMPRESSOR *compressor, WT_SESSION *session, - uint8_t *src, size_t src_len, - uint8_t *dst, size_t dst_len, - size_t *result_lenp, int *compression_failed) +nop_compress(WT_COMPRESSOR *compressor, WT_SESSION *session, uint8_t *src, size_t src_len, + uint8_t *dst, size_t dst_len, size_t *result_lenp, int *compression_failed) { - NOP_COMPRESSOR *nop_compressor = (NOP_COMPRESSOR *)compressor; + NOP_COMPRESSOR *nop_compressor = (NOP_COMPRESSOR *)compressor; - (void)session; /* Unused parameters */ + (void)session; /* Unused parameters */ - ++nop_compressor->nop_calls; /* Call count */ + ++nop_compressor->nop_calls; /* Call count */ - *compression_failed = 0; - if (dst_len < src_len) { - *compression_failed = 1; - return (0); - } + *compression_failed = 0; + if (dst_len < src_len) { + *compression_failed = 1; + return (0); + } - memcpy(dst, src, src_len); - *result_lenp = src_len; + memcpy(dst, src, src_len); + *result_lenp = src_len; - return (0); + return (0); } /*! [WT_COMPRESSOR compress] */ /*! [WT_COMPRESSOR decompress] */ /* * nop_decompress -- - * A simple decompression example that passes data through unchanged. + * A simple decompression example that passes data through unchanged. */ static int -nop_decompress(WT_COMPRESSOR *compressor, WT_SESSION *session, - uint8_t *src, size_t src_len, - uint8_t *dst, size_t dst_len, - size_t *result_lenp) +nop_decompress(WT_COMPRESSOR *compressor, WT_SESSION *session, uint8_t *src, size_t src_len, + uint8_t *dst, size_t dst_len, size_t *result_lenp) { - NOP_COMPRESSOR *nop_compressor = (NOP_COMPRESSOR *)compressor; + NOP_COMPRESSOR *nop_compressor = (NOP_COMPRESSOR *)compressor; - (void)session; /* Unused parameters */ - (void)src_len; + (void)session; /* Unused parameters */ + (void)src_len; - ++nop_compressor->nop_calls; /* Call count */ + ++nop_compressor->nop_calls; /* Call count */ - /* - * The destination length is the number of uncompressed bytes we're - * expected to return. - */ - memcpy(dst, src, dst_len); - *result_lenp = dst_len; - return (0); + /* + * The destination length is the number of uncompressed bytes we're expected to return. + */ + memcpy(dst, src, dst_len); + *result_lenp = dst_len; + return (0); } /*! [WT_COMPRESSOR decompress] */ /*! [WT_COMPRESSOR presize] */ /* * nop_pre_size -- - * A simple pre-size example that returns the source length. + * A simple pre-size example that returns the source length. */ static int -nop_pre_size(WT_COMPRESSOR *compressor, WT_SESSION *session, - uint8_t *src, size_t src_len, - size_t *result_lenp) +nop_pre_size( + WT_COMPRESSOR *compressor, WT_SESSION *session, uint8_t *src, size_t src_len, size_t *result_lenp) { - NOP_COMPRESSOR *nop_compressor = (NOP_COMPRESSOR *)compressor; + NOP_COMPRESSOR *nop_compressor = (NOP_COMPRESSOR *)compressor; - (void)session; /* Unused parameters */ - (void)src; + (void)session; /* Unused parameters */ + (void)src; - ++nop_compressor->nop_calls; /* Call count */ + ++nop_compressor->nop_calls; /* Call count */ - *result_lenp = src_len; - return (0); + *result_lenp = src_len; + return (0); } /*! [WT_COMPRESSOR presize] */ /*! [WT_COMPRESSOR terminate] */ /* * nop_terminate -- - * WiredTiger no-op compression termination. + * WiredTiger no-op compression termination. */ static int nop_terminate(WT_COMPRESSOR *compressor, WT_SESSION *session) { - NOP_COMPRESSOR *nop_compressor = (NOP_COMPRESSOR *)compressor; + NOP_COMPRESSOR *nop_compressor = (NOP_COMPRESSOR *)compressor; - (void)session; /* Unused parameters */ + (void)session; /* Unused parameters */ - ++nop_compressor->nop_calls; /* Call count */ + ++nop_compressor->nop_calls; /* Call count */ - /* Free the allocated memory. */ - free(compressor); + /* Free the allocated memory. */ + free(compressor); - return (0); + return (0); } /*! [WT_COMPRESSOR terminate] */ /*! [WT_COMPRESSOR initialization function] */ /* * wiredtiger_extension_init -- - * A simple shared library compression example. + * A simple shared library compression example. */ int wiredtiger_extension_init(WT_CONNECTION *connection, WT_CONFIG_ARG *config) { - NOP_COMPRESSOR *nop_compressor; - int ret; - - (void)config; /* Unused parameters */ - - if ((nop_compressor = calloc(1, sizeof(NOP_COMPRESSOR))) == NULL) - return (errno); - - /* - * Allocate a local compressor structure, with a WT_COMPRESSOR structure - * as the first field, allowing us to treat references to either type of - * structure as a reference to the other type. - * - * Heap memory (not static), because it can support multiple databases. - */ - nop_compressor->compressor.compress = nop_compress; - nop_compressor->compressor.decompress = nop_decompress; - nop_compressor->compressor.pre_size = nop_pre_size; - nop_compressor->compressor.terminate = nop_terminate; - - nop_compressor->wt_api = connection->get_extension_api(connection); - - /* Load the compressor */ - if ((ret = connection->add_compressor( - connection, "nop", (WT_COMPRESSOR *)nop_compressor, NULL)) == 0) - return (0); - - free(nop_compressor); - return (ret); + NOP_COMPRESSOR *nop_compressor; + int ret; + + (void)config; /* Unused parameters */ + + if ((nop_compressor = calloc(1, sizeof(NOP_COMPRESSOR))) == NULL) + return (errno); + + /* + * Allocate a local compressor structure, with a WT_COMPRESSOR structure + * as the first field, allowing us to treat references to either type of + * structure as a reference to the other type. + * + * Heap memory (not static), because it can support multiple databases. + */ + nop_compressor->compressor.compress = nop_compress; + nop_compressor->compressor.decompress = nop_decompress; + nop_compressor->compressor.pre_size = nop_pre_size; + nop_compressor->compressor.terminate = nop_terminate; + + nop_compressor->wt_api = connection->get_extension_api(connection); + + /* Load the compressor */ + if ((ret = connection->add_compressor( + connection, "nop", (WT_COMPRESSOR *)nop_compressor, NULL)) == 0) + return (0); + + free(nop_compressor); + return (ret); } /*! [WT_COMPRESSOR initialization function] */ |