From: Tao Liu <ltao@redhat.com>
To: kexec@lists.infradead.org
Cc: k-hagio-ab@nec.com, Tao Liu <ltao@redhat.com>
Subject: [PATCH 06/11] makedumpfile: Add parallel threads zstd compression processing
Date: Fri, 10 Sep 2021 18:33:13 +0800 [thread overview]
Message-ID: <20210910103318.292017-7-ltao@redhat.com> (raw)
In-Reply-To: <20210910103318.292017-1-ltao@redhat.com>
Signed-off-by: Tao Liu <ltao@redhat.com>
---
makedumpfile.c | 26 ++++++++++++++++++++++++++
makedumpfile.h | 6 ++++++
2 files changed, 32 insertions(+)
diff --git a/makedumpfile.c b/makedumpfile.c
index 76a7a77..af21a84 100644
--- a/makedumpfile.c
+++ b/makedumpfile.c
@@ -3892,6 +3892,12 @@ initial_for_parallel()
strerror(errno));
return FALSE;
}
+#endif
+#ifdef USEZSTD
+ if ((ZSTD_CCTX_PARALLEL(i) = ZSTD_createCCtx()) == NULL) {
+ MSG("Can't allocate ZSTD_CCtx.\n");
+ return FALSE;
+ }
#endif
}
@@ -4000,6 +4006,10 @@ free_for_parallel()
if (WRKMEM_PARALLEL(i) != NULL)
free(WRKMEM_PARALLEL(i));
#endif
+#ifdef USEZSTD
+ if (ZSTD_CCTX_PARALLEL(i) != NULL)
+ ZSTD_freeCCtx(ZSTD_CCTX_PARALLEL(i));
+#endif
}
free(info->threads);
@@ -8166,6 +8176,9 @@ kdump_thread_function_cyclic(void *arg) {
#ifdef USELZO
lzo_bytep wrkmem = WRKMEM_PARALLEL(kdump_thread_args->thread_num);
#endif
+#ifdef USEZSTD
+ ZSTD_CCtx *cctx = ZSTD_CCTX_PARALLEL(kdump_thread_args->thread_num);
+#endif
buf = BUF_PARALLEL(kdump_thread_args->thread_num);
buf_out = BUF_OUT_PARALLEL(kdump_thread_args->thread_num);
@@ -8298,6 +8311,19 @@ kdump_thread_function_cyclic(void *arg) {
DUMP_DH_COMPRESSED_SNAPPY;
page_data_buf[index].size = size_out;
memcpy(page_data_buf[index].buf, buf_out, size_out);
+#endif
+#ifdef USEZSTD
+ } else if ((info->flag_compress
+ & DUMP_DH_COMPRESSED_ZSTD)
+ && (size_out = ZSTD_compressCCtx(cctx,
+ buf_out, kdump_thread_args->len_buf_out,
+ buf, info->page_size, ZSTD_dfast))
+ && (!ZSTD_isError(size_out))
+ && (size_out < info->page_size)) {
+ page_data_buf[index].flags =
+ DUMP_DH_COMPRESSED_ZSTD;
+ page_data_buf[index].size = size_out;
+ memcpy(page_data_buf[index].buf, buf_out, size_out);
#endif
} else {
page_data_buf[index].flags = 0;
diff --git a/makedumpfile.h b/makedumpfile.h
index a1a8cc2..d583249 100644
--- a/makedumpfile.h
+++ b/makedumpfile.h
@@ -484,6 +484,9 @@ do { \
#ifdef USELZO
#define WRKMEM_PARALLEL(i) info->parallel_info[i].wrkmem
#endif
+#ifdef USEZSTD
+#define ZSTD_CCTX_PARALLEL(i) info->parallel_info[i].zstd_cctx
+#endif
/*
* kernel version
*
@@ -1328,6 +1331,9 @@ struct parallel_info {
#ifdef USELZO
lzo_bytep wrkmem;
#endif
+#ifdef USEZSTD
+ ZSTD_CCtx *zstd_cctx;
+#endif
};
struct ppc64_vmemmap {
--
2.29.2
_______________________________________________
kexec mailing list
kexec@lists.infradead.org
http://lists.infradead.org/mailman/listinfo/kexec
next prev parent reply other threads:[~2021-09-10 10:36 UTC|newest]
Thread overview: 20+ messages / expand[flat|nested] mbox.gz Atom feed top
2021-09-10 10:33 [PATCH 00/11] makedumpfile: Add zstd support for makedumpfile Tao Liu
2021-09-10 10:33 ` [PATCH 01/11] makedumpfile: Add dump header for zstd Tao Liu
2021-09-10 10:33 ` [PATCH 02/11] makedumpfile: Add command-line processing " Tao Liu
2021-09-10 10:33 ` [PATCH 03/11] makedumpfile: Add zstd build support Tao Liu
2021-09-10 10:33 ` [PATCH 04/11] makedumpfile: Notify zstd unsupporting when disabled Tao Liu
2021-09-10 10:33 ` [PATCH 05/11] makedumpfile: Add single thread zstd compression processing Tao Liu
2021-09-10 10:33 ` Tao Liu [this message]
2021-09-10 10:33 ` [PATCH 07/11] makedumpfile: Add single thread zstd uncompression processing Tao Liu
2021-09-10 10:33 ` [PATCH 08/11] makedumpfile: Add parallel threads " Tao Liu
2021-09-10 10:33 ` [PATCH 09/11] makedumpfile: Add zstd help message Tao Liu
2021-09-10 10:33 ` [PATCH 10/11] makedumpfile: Add zstd manual description Tao Liu
2021-09-10 10:33 ` [PATCH 11/11] makedumpfile: Add zstd README description Tao Liu
2021-09-14 7:04 ` [PATCH 00/11] makedumpfile: Add zstd support for makedumpfile HAGIO KAZUHITO(萩尾 一仁)
2021-09-14 8:33 ` Tao Liu
2021-09-17 1:34 ` HAGIO KAZUHITO(萩尾 一仁)
2021-09-17 2:31 ` HAGIO KAZUHITO(萩尾 一仁)
2021-09-17 7:03 ` HAGIO KAZUHITO(萩尾 一仁)
2021-09-21 9:26 ` Tao Liu
2021-09-22 2:21 ` HAGIO KAZUHITO(萩尾 一仁)
2021-09-22 8:16 ` HAGIO KAZUHITO(萩尾 一仁)
Reply instructions:
You may reply publicly to this message via plain-text email
using any one of the following methods:
* Save the following mbox file, import it into your mail client,
and reply-to-all from there: mbox
Avoid top-posting and favor interleaved quoting:
https://en.wikipedia.org/wiki/Posting_style#Interleaved_style
* Reply using the --to, --cc, and --in-reply-to
switches of git-send-email(1):
git send-email \
--in-reply-to=20210910103318.292017-7-ltao@redhat.com \
--to=ltao@redhat.com \
--cc=k-hagio-ab@nec.com \
--cc=kexec@lists.infradead.org \
/path/to/YOUR_REPLY
https://kernel.org/pub/software/scm/git/docs/git-send-email.html
* If your mail client supports setting the In-Reply-To header
via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line
before the message body.
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox