third-party-mirrors/zfs_autobackup
1
0
Fork 1
mirror of https://github.com/psy0rz/zfs_autobackup.git synced 2025-04-11 22:40:01 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

Rename chunk-size to buffer-chunk-size

Browse Source
This commit is contained in:
Pierre-Elliott Bécue 2023-10-04 00:02:59 +02:00 committed by DatuX
parent 7feae675a6
commit 843b87f319
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
zfs_autobackup/ZfsAutobackup.py
View File

@ -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