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

working on thinning obsolete datasets

Browse Source
This commit is contained in:
Edwin Eefting 2020-04-01 01:48:28 +02:00
parent 002aa6a731
commit 8f0472e8f5
1 changed files with 29 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
bin/zfs-autobackup
View File

@ -1432,6 +1432,24 @@ class ZfsNode(ExecuteNode):
return(selected_filesystems) return(selected_filesystems)
def received_datasets(self, target_path):
"""determine already received datasets for this backup
returns: list of ZfsDataset
"""
#get all source filesystems that have the backup property
lines=self.run(tab_split=True, readonly=True, cmd=[
"zfs", "get", "-t", "volume,filesystem", "-o", "name,value,source", "-s", "local,inherited", "-H", "-r", "autobackup:"+self.backup_name, target_path
])
#consider all datasets in target_path with the correct autobackup property, as a received dataset
ret=[]
for line in lines:
(name,value,source)=line
dataset=ZfsDataset(self, name)
return(ret)
@ -1528,6 +1546,7 @@ class ZfsAutobackup:
if self.args.test: if self.args.test:
self.verbose("TEST MODE - SIMULATING WITHOUT MAKING ANY CHANGES") self.verbose("TEST MODE - SIMULATING WITHOUT MAKING ANY CHANGES")
self.set_title("Settings summary") self.set_title("Settings summary")
description="[Source]" description="[Source]"
@ -1542,6 +1561,7 @@ class ZfsAutobackup:
target_node=ZfsNode(self.args.backup_name, self, ssh_config=self.args.ssh_config, ssh_to=self.args.ssh_target, readonly=self.args.test, debug_output=self.args.debug_output, description=description, thinner=target_thinner) target_node=ZfsNode(self.args.backup_name, self, ssh_config=self.args.ssh_config, ssh_to=self.args.ssh_target, readonly=self.args.test, debug_output=self.args.debug_output, description=description, thinner=target_thinner)
target_node.verbose("Receive datasets under: {}".format(self.args.target_path)) target_node.verbose("Receive datasets under: {}".format(self.args.target_path))
self.set_title("Selecting") self.set_title("Selecting")
selected_source_datasets=source_node.selected_datasets selected_source_datasets=source_node.selected_datasets
if not selected_source_datasets: if not selected_source_datasets:
@ -1550,6 +1570,7 @@ class ZfsAutobackup:
source_datasets=[] source_datasets=[]
#filter out already replicated stuff? #filter out already replicated stuff?
if not self.args.ignore_replicated: if not self.args.ignore_replicated:
source_datasets=selected_source_datasets source_datasets=selected_source_datasets
@ -1567,7 +1588,6 @@ class ZfsAutobackup:
source_node.consistent_snapshot(source_datasets, source_node.new_snapshotname(), min_changed_bytes=self.args.min_change) source_node.consistent_snapshot(source_datasets, source_node.new_snapshotname(), min_changed_bytes=self.args.min_change)
if self.args.no_send: if self.args.no_send:
self.set_title("Thinning") self.set_title("Thinning")
else: else:
@ -1589,6 +1609,14 @@ class ZfsAutobackup:
if self.args.clear_mountpoint: if self.args.clear_mountpoint:
set_properties.append("canmount=noauto") set_properties.append("canmount=noauto")
#thin/destroy obsolete datasets on target
for dataset in target_node.received_datasets(self.args.target_path):
if dataset not in source_datasets:
dataset.verbose("Obsolete")
#sync datasets
fail_count=0 fail_count=0
for source_dataset in source_datasets: for source_dataset in source_datasets: