From 97e3c110b383e2101eaef6d08248147d992e9630 Mon Sep 17 00:00:00 2001
From: Edwin Eefting <edwin@datux.nl>
Date: Tue, 18 May 2021 19:56:33 +0200
Subject: [PATCH] added bandwidth throttling. fixes #51

---
 zfs_autobackup/ZfsAutobackup.py | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/zfs_autobackup/ZfsAutobackup.py b/zfs_autobackup/ZfsAutobackup.py
index d0d04d0..1f75cff 100644
--- a/zfs_autobackup/ZfsAutobackup.py
+++ b/zfs_autobackup/ZfsAutobackup.py
@@ -280,6 +280,11 @@ class ZfsAutobackup:
 
         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
         for send_pipe in self.args.send_pipe:
             ret.append(ExecuteNode.PIPE)
@@ -293,6 +298,11 @@ class ZfsAutobackup:
             ret.extend(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