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

wip

Browse Source
This commit is contained in:
Edwin Eefting 2019-10-20 01:47:00 +02:00
parent 5e8c7fa968
commit 62b9d0ba39
1 changed files with 51 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

67
zfs_autobackup
View File

@ -242,7 +242,7 @@ class ZfsDataset():
@cached_property
def snapshots(self):
"""get all snaphots of this dataset"""
"""get all snapshots of this dataset"""
cmd=[
"zfs", "list", "-d", "1", "-r", "-t" ,"snapshot", "-H", "-o", "name", self.name
@ -261,14 +261,22 @@ class ZfsDataset():
return(ret)
def find_in_our_snapshots(self, snapshot_name):
"""finds the snapshot and returns an iterator to our_snapshots. Returns None if not found"""
snapshot_iter=iter(self.our_snapshots)
for snapshot in snapshot_iter:
if snapshot.snapshot_name==snapshot_name:
return (snapshot_iter)
def find_sends(self, snapshot_name):
"""find the snapshot sendlist, starting from snapshot_name.
returns: ( start_snapshot, send_snapshots )
"""
return(None)
start_snapshot=None
send_snapshots=[]
for snapshot in self.our_snapshots:
if start_snapshot:
send_snapshots.append(snapshot)
elif snapshot.snapshot_name==snapshot_name:
start_snapshot=snapshot
return( (start_snapshot, send_snapshots) )
@cached_property
def is_changed_ours(self):
@ -296,6 +304,26 @@ class ZfsDataset():
return(self.from_names(names[1:]))
def transfer_snapshots(self, source_dataset, source_start_snapshot, source_sends):
"""transfer bunch snapshots to this target"""
receive_resume_token=getattr(source_dataset.properties, 'receive_resume_token', None)
last_snapshot=source_start_snapshot
for snapshot in source_sends:
if receive_resume_token:
resumed="[RESUMED]"
else:
resumed=""
if (last_snapshot):
source_dataset.verbose("incremental @{}...@{} {}".format(last_snapshot.snapshot_name, snapshot.snapshot_name, resumed))
else:
source_dataset.verbose("initial @{} {}".format(snapshot.snapshot_name, resumed))
last_snapshot=snapshot
receive_resume_token=None
class ZfsNode(ExecuteNode):
"""a node that contains zfs datasets. implements global lowlevel zfs commands"""
@ -394,7 +422,10 @@ class ZfsNode(ExecuteNode):
return(selected_filesystems)
def transfer_snapshots(self, target_root, start_snapshots, iter_s)
class ZfsAutobackup:
"""main class"""
@ -482,15 +513,19 @@ class ZfsAutobackup:
#find latest target snapshot and find it on source
latest_target_snapshot=target_dataset.our_snapshots[-1]
source_snapshot_iter=source_dataset.find_in_our_snapshots(latest_target_snapshot.snapshot_name)
# print("finding {}".format(latest_target_snapshot))
if source_snapshot_iter:
for source_snapshot in source_snapshot_iter:
source_snapshot.verbose("incremental from {}".format(latest_target_snapshot.snapshot_name))
else:
# abort("cant find source ")
( source_start_snapshot, source_sends )=source_dataset.find_sends(latest_target_snapshot.snapshot_name)
if not source_start_snapshot:
print("cant find source snap")
pass
else:
if source_sends:
target_root.transfer_snapshots(source_dataset, source_start_snapshot, source_sends)
else:
print("nothgin to do")
# if latest_target_snapshot not in source_dataset.snapshots:
# #cant find latest target anymore. find first common snapshot and inform user