From 97cb8d63dc2474e4444f90fb218cc83b462f1e19 Mon Sep 17 00:00:00 2001
From: Edwin Eefting <edwin@datux.nl>
Date: Sat, 21 Nov 2015 10:33:03 +0100
Subject: [PATCH] working on it

---
 zfs_autobackup | 21 +++++++++++++++++++--
 1 file changed, 19 insertions(+), 2 deletions(-)

diff --git a/zfs_autobackup b/zfs_autobackup
index 0c31388..3356d7f 100755
--- a/zfs_autobackup
+++ b/zfs_autobackup
@@ -204,9 +204,22 @@ def zfs_get_snapshots(ssh_to, filesystems, backup_name):
 
 
 
-"""transfer a zfs snapshot from source to target. both can be either local or via ssh."""
+"""transfer a zfs snapshot from source to target. both can be either local or via ssh.
+
+specify buffer_size to use mbuffer (or alike) to apply buffering where neccesary
+
+local to local:
+local send -> local buffer -> local receive
+
+local to remote and remote to local: 
+local send -> local buffer -> ssh -> remote buffer -> remote receive
+remote send -> remote buffer -> ssh -> local buffer -> local receive
+
+remote to remote:
+remote send -> remote buffer -> ssh -> local buffer -> ssh -> remote buffer -> remote receive
+"""
 def zfs_transfer(ssh_source, source_filesystem, first_snapshot, second_snapshot,
-                 ssh_target, target_filesystem):
+                 ssh_target, target_filesystem, buffer_size=None):
 
     #### build source command
     source_cmd=[]
@@ -229,6 +242,10 @@ def zfs_transfer(ssh_source, source_filesystem, first_snapshot, second_snapshot,
 
     source_cmd.append(source_filesystem + "@" + second_snapshot)
 
+    # if ssh_source != "local":
+    #     #add buffer
+    #     source_cmd.append("|dd")
+
 
     #### build target command
     target_cmd=[]