summaryrefslogtreecommitdiff
path: root/src/third_party/wiredtiger/ext/compressors/nop/nop_compress.c
diff options
context:
space:
mode:
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.c158
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] */