From 843b87f319bcda926ebb2868d5f13c7846e43531 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Pierre-Elliott=20B=C3=A9cue?= Date: Wed, 4 Oct 2023 00:02:59 +0200 Subject: [PATCH] Rename chunk-size to buffer-chunk-size --- zfs_autobackup/ZfsAutobackup.py | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/zfs_autobackup/ZfsAutobackup.py b/zfs_autobackup/ZfsAutobackup.py index 4343419..0f44dbf 100644 --- a/zfs_autobackup/ZfsAutobackup.py +++ b/zfs_autobackup/ZfsAutobackup.py @@ -119,7 +119,7 @@ class ZfsAutobackup(ZfsAuto): help='Limit data transfer rate in Bytes/sec (e.g. 128K. requires mbuffer.)') group.add_argument('--buffer', metavar='SIZE', default=None, help='Add zfs send and recv buffers to smooth out IO bursts. (e.g. 128M. requires mbuffer)') - parser.add_argument('--chunk-size', metavar="CHUNKSIZE", default=None, + parser.add_argument('--buffer-chunk-size', metavar="BUFFERCHUNKSIZE", default=None, help='Tune chunk size when mbuffer is used. (requires mbuffer.)') group.add_argument('--send-pipe', metavar="COMMAND", default=[], action='append', help='pipe zfs send output through COMMAND (can be used multiple times)') @@ -256,10 +256,10 @@ class ZfsAutobackup(ZfsAuto): _buffer = self.args.buffer # IO chunk size - if self.args.chunk_size: - logger("zfs send chunk size : {}".format(self.args.chunk_size)) + if self.args.buffer_chunk_size: + logger("zfs send chunk size : {}".format(self.args.buffer_chunk_size)) _mbuffer = True - _cs = self.args.chunk_size + _cs = self.args.buffer_chunk_size # custom pipes for send_pipe in self.args.send_pipe: @@ -306,15 +306,15 @@ class ZfsAutobackup(ZfsAuto): logger("zfs recv custom pipe : {}".format(recv_pipe)) # IO buffer - if self.args.buffer or self.args.chunk_size: + if self.args.buffer or self.args.buffer_chunk_size: _cs = "128k" _buffer = "16M" # only add second buffer if its usefull. (e.g. non local transfer or other pipes active) if self.args.ssh_source != None or self.args.ssh_target != None or self.args.recv_pipe or self.args.send_pipe or self.args.compress != None: logger("zfs recv buffer : {}".format(self.args.buffer)) - if self.args.chunk_size: - _cs = self.args.chunk_size + if self.args.buffer_chunk_size: + _cs = self.args.buffer_chunk_size if self.args.buffer: _buffer = self.args.buffer