norohind/zfs_autobackup
1
0
Fork 0
forked from third-party-mirrors/zfs_autobackup
Code Pull Requests Activity

added bandwidth throttling. fixes #51

Browse Source
This commit is contained in:
Edwin Eefting 2021-05-18 19:56:33 +02:00
parent 9264e8de6d
commit 97e3c110b3
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
zfs_autobackup/ZfsAutobackup.py
View File

@ -280,6 +280,11 @@ class ZfsAutobackup:
ret=[] ret=[]
# IO buffer
if self.args.buffer:
logger("zfs send buffer : {}".format(self.args.buffer))
ret.extend([ ExecuteNode.PIPE, "mbuffer", "-q", "-s128k", "-m"+self.args.buffer ])
# custom pipes # custom pipes
for send_pipe in self.args.send_pipe: for send_pipe in self.args.send_pipe:
ret.append(ExecuteNode.PIPE) ret.append(ExecuteNode.PIPE)
@ -293,6 +298,11 @@ class ZfsAutobackup:
ret.extend(cmd) ret.extend(cmd)
logger("zfs send compression : {}".format(" ".join(cmd))) logger("zfs send compression : {}".format(" ".join(cmd)))
# transfer rate
if self.args.rate:
logger("zfs send transfer rate : {}".format(self.args.rate))
ret.extend([ ExecuteNode.PIPE, "mbuffer", "-q", "-s128k", "-m16M", "-R"+self.args.rate ])
return ret return ret