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

wip

Browse Source
This commit is contained in:
Edwin Eefting 2019-10-20 14:56:45 +02:00
parent fb1f0d90ad
commit 57874e8e3e
1 changed files with 18 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
zfs_autobackup
View File

@ -43,9 +43,9 @@ class Log:
if self.show_verbose: if self.show_verbose:
print(self.titled_str(txt, titles)) print(self.titled_str(txt, titles))
def debug(self, txt): def debug(self, txt, titles=[]):
if self.show_debug: if self.show_debug:
print(txt) print(self.titled_str(txt, titles))
@ -224,6 +224,7 @@ class ZfsDataset():
@cached_property @cached_property
def exists(self): def exists(self):
"""check if dataset exists""" """check if dataset exists"""
self.debug("Checking if filesystem exists")
return(self.zfs_node.run(tab_split=True, cmd=[ "zfs", "list", self.name], readonly=True, valid_exitcodes=[ 0,1 ])!="") return(self.zfs_node.run(tab_split=True, cmd=[ "zfs", "list", self.name], readonly=True, valid_exitcodes=[ 0,1 ])!="")
@ -347,23 +348,26 @@ class ZfsDataset():
def transfer_snapshot(self, target_dataset, prev_snapshot=None): def transfer_snapshot(self, target_dataset, prev_snapshot=None):
"""transfer this snapshot to target_dataset. specify prev_snapshot for incremental transfer""" """transfer this snapshot to target_dataset. specify prev_snapshot for incremental transfer"""
receive_resume_token=getattr(target_dataset.properties, 'receive_resume_token', None) if target_dataset.exists:
receive_resume_token=getattr(target_dataset.properties, 'receive_resume_token', None)
else:
receive_resume_token=False
if receive_resume_token: if receive_resume_token:
resumed="[RESUMED]" resumed="[RESUMED]"
else: else:
resumed="" resumed=""
if (prev_snapshot): if (prev_snapshot):
self.verbose("incremental @{}...@{} {}".format(prev_snapshot.snapshot_name, self.snapshot_name, resumed)) target_dataset.verbose("receiving @{}...@{} {}".format(prev_snapshot.snapshot_name, self.snapshot_name, resumed))
else: else:
self.verbose("initial @{} {}".format(snapshot.snapshot_name, resumed)) target_dataset.verbose("receiving @{} {}".format(snapshot.snapshot_name, resumed))
target_dataset.invalidate() target_dataset.invalidate()
def sync_snapshots(self, target_dataset): def sync_snapshots(self, target_dataset):
"""sync our snapshots to target_dataset""" """sync our snapshots to target_dataset"""
# inital transfer # inital transfer
if not target_dataset.exists: if not target_dataset.exists:
self.our_snapshots[0].transfer_snapshot(target_dataset) self.our_snapshots[0].transfer_snapshot(target_dataset)
@ -381,7 +385,7 @@ class ZfsDataset():
latest_common_snapshot=source_snapshot latest_common_snapshot=source_snapshot
if not latest_common_snapshot: if not latest_common_snapshot:
raise(Exception("Cant find a common snapshot. (hint: on target zfs destroy {})".format(target_dataset))) raise(Exception("Cant find a common snapshot. (hint: zfs destroy {})".format(target_dataset)))
@ -407,8 +411,9 @@ class ZfsNode(ExecuteNode):
titles.insert(0,self.description) titles.insert(0,self.description)
self.zfs_autobackup.error(txt, titles) self.zfs_autobackup.error(txt, titles)
def debug(self,txt): def debug(self,txt, titles=[]):
self.zfs_autobackup.debug(txt) titles.insert(0,self.description)
self.zfs_autobackup.debug(txt, titles)
def new_snapshotname(self): def new_snapshotname(self):
"""determine uniq new snapshotname""" """determine uniq new snapshotname"""
@ -542,8 +547,9 @@ class ZfsAutobackup:
titles.insert(0,self.title) titles.insert(0,self.title)
self.log.error(txt, titles) self.log.error(txt, titles)
def debug(self,txt): def debug(self,txt, titles=[]):
self.log.debug(txt) titles.insert(0,self.title)
self.log.debug(txt, titles)
def set_title(self, title): def set_title(self, title):
self.title=title self.title=title
@ -580,7 +586,7 @@ class ZfsAutobackup:
target_dataset=ZfsDataset(target_node, target_name) target_dataset=ZfsDataset(target_node, target_name)
source_dataset.sync_snapshots(target_dataset) source_dataset.sync_snapshots(target_dataset)
except Exception as e: except Exception as e:
source_dataset.error(str(e)) target_dataset.error(str(e))
if self.args.debug: if self.args.debug:
raise raise