diff options
Diffstat (limited to 'sys/contrib/openzfs/module/zfs/gzip.c')
-rw-r--r-- | sys/contrib/openzfs/module/zfs/gzip.c | 111 |
1 files changed, 111 insertions, 0 deletions
diff --git a/sys/contrib/openzfs/module/zfs/gzip.c b/sys/contrib/openzfs/module/zfs/gzip.c new file mode 100644 index 000000000000..d183e9984564 --- /dev/null +++ b/sys/contrib/openzfs/module/zfs/gzip.c @@ -0,0 +1,111 @@ +// SPDX-License-Identifier: CDDL-1.0 +/* + * CDDL HEADER START + * + * The contents of this file are subject to the terms of the + * Common Development and Distribution License (the "License"). + * You may not use this file except in compliance with the License. + * + * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE + * or https://opensource.org/licenses/CDDL-1.0. + * See the License for the specific language governing permissions + * and limitations under the License. + * + * When distributing Covered Code, include this CDDL HEADER in each + * file and include the License file at usr/src/OPENSOLARIS.LICENSE. + * If applicable, add the following below this CDDL HEADER, with the + * fields enclosed by brackets "[]" replaced with your own identifying + * information: Portions Copyright [yyyy] [name of copyright owner] + * + * CDDL HEADER END + */ + +/* + * Copyright 2007 Sun Microsystems, Inc. All rights reserved. + * Use is subject to license terms. + */ + + + +#include <sys/debug.h> +#include <sys/types.h> +#include <sys/qat.h> +#include <sys/zio_compress.h> + +#ifdef _KERNEL + +#include <sys/zmod.h> +typedef size_t zlen_t; +#define compress_func z_compress_level +#define uncompress_func z_uncompress + +#else /* _KERNEL */ + +#include <zlib.h> +typedef uLongf zlen_t; +#define compress_func compress2 +#define uncompress_func uncompress + +#endif + +static size_t +zfs_gzip_compress_buf(void *s_start, void *d_start, size_t s_len, + size_t d_len, int n) +{ + int ret; + zlen_t dstlen = d_len; + + ASSERT(d_len <= s_len); + + /* check if hardware accelerator can be used */ + if (qat_dc_use_accel(s_len)) { + ret = qat_compress(QAT_COMPRESS, s_start, s_len, d_start, + d_len, &dstlen); + if (ret == CPA_STATUS_SUCCESS) { + return ((size_t)dstlen); + } else if (ret == CPA_STATUS_INCOMPRESSIBLE) { + if (d_len != s_len) + return (s_len); + + memcpy(d_start, s_start, s_len); + return (s_len); + } + /* if hardware compression fails, do it again with software */ + } + + if (compress_func(d_start, &dstlen, s_start, s_len, n) != Z_OK) { + if (d_len != s_len) + return (s_len); + + memcpy(d_start, s_start, s_len); + return (s_len); + } + + return ((size_t)dstlen); +} + +static int +zfs_gzip_decompress_buf(void *s_start, void *d_start, size_t s_len, + size_t d_len, int n) +{ + (void) n; + zlen_t dstlen = d_len; + + ASSERT(d_len >= s_len); + + /* check if hardware accelerator can be used */ + if (qat_dc_use_accel(d_len)) { + if (qat_compress(QAT_DECOMPRESS, s_start, s_len, + d_start, d_len, &dstlen) == CPA_STATUS_SUCCESS) + return (0); + /* if hardware de-compress fail, do it again with software */ + } + + if (uncompress_func(d_start, &dstlen, s_start, s_len) != Z_OK) + return (-1); + + return (0); +} + +ZFS_COMPRESS_WRAP_DECL(zfs_gzip_compress) +ZFS_DECOMPRESS_WRAP_DECL(zfs_gzip_decompress) |