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

wip

Browse Source
This commit is contained in:
Edwin Eefting 2019-10-19 19:04:13 +02:00
parent b97eed404a
commit b98ffec10c
1 changed files with 36 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
zfs_autobackup
View File

@ -191,10 +191,11 @@ class ZfsDataset():
def __str__(self): def __str__(self):
return(self.name) return(self.name)
# def invalidate(self): def verbose(self,txt):
# """invalidate cached data""" self.zfs_node.verbose("{}: {}".format(self.name, txt))
# for d in self.__dict__:
# if (self.__getattribute__) def debug(self,txt):
self.zfs_node.debug("{}: {}".format(self.name, txt))
def invalidate(self): def invalidate(self):
@ -273,10 +274,13 @@ class ZfsDataset():
def is_changed_ours(self): def is_changed_ours(self):
"""dataset is changed since OUR latest snapshot?""" """dataset is changed since OUR latest snapshot?"""
latest_snapshot=self.snapshots[:-1] if not self.our_snapshots:
cmd=[ "zfs", "get","-H" ,"-ovalue", "written@"+latest_snapshot, self.name ] return(True)
output=self.zfs_node.run(tab_split=False, cmd=cmd, valid_exitcodes=[ 0 ])
latest_snapshot=self.snapshots[-1]
cmd=[ "zfs", "get","-H" ,"-ovalue", "written@"+str(latest_snapshot), self.name ]
output=self.zfs_node.run(readonly=True, tab_split=False, cmd=cmd, valid_exitcodes=[ 0 ])
if output[0]=="0B" or output[0]=="0": if output[0]=="0B" or output[0]=="0":
return(False) return(False)
@ -296,10 +300,19 @@ class ZfsDataset():
class ZfsNode(ExecuteNode): class ZfsNode(ExecuteNode):
"""a node that contains zfs datasets. implements global lowlevel zfs commands""" """a node that contains zfs datasets. implements global lowlevel zfs commands"""
def __init__(self, backup_name, ssh_to=None, readonly=False): def __init__(self, backup_name, ssh_to=None, readonly=False, description=""):
self.backup_name=backup_name self.backup_name=backup_name
if not description:
self.description=ssh_to
ExecuteNode.__init__(self, ssh_to=ssh_to, readonly=readonly) ExecuteNode.__init__(self, ssh_to=ssh_to, readonly=readonly)
def verbose(self,txt):
verbose("{}: {}".format(self.description, txt))
def debug(self,txt):
debug("{}: {}".format(self.description, txt))
def new_snapshotname(self): def new_snapshotname(self):
"""determine uniq new snapshotname""" """determine uniq new snapshotname"""
return(self.backup_name+"-"+time.strftime("%Y%m%d%H%M%S")) return(self.backup_name+"-"+time.strftime("%Y%m%d%H%M%S"))
@ -315,12 +328,19 @@ class ZfsNode(ExecuteNode):
noop=True noop=True
for dataset in datasets: for dataset in datasets:
if allow_empty or dataset.is_changed_ours(): if not allow_empty:
cmd.append(str(dataset)+"@"+snapshot_name) if not dataset.is_changed_ours:
dataset.invalidate() dataset.verbose("No changes, not snapshotting")
noop=False continue
if not noop: cmd.append(str(dataset)+"@"+snapshot_name)
dataset.invalidate()
noop=False
if noop:
self.verbose("No changes, not creating snapshot.")
else:
self.verbose("Creating snapshot {}".format(snapshot_name))
self.run(cmd, readonly=False) self.run(cmd, readonly=False)
@ -340,8 +360,10 @@ class ZfsNode(ExecuteNode):
direct_filesystems=[] direct_filesystems=[]
for line in lines: for line in lines:
(name,value,source)=line (name,value,source)=line
dataset=ZfsDataset(self, name)
if value=="false": if value=="false":
verbose("* Ignored : {0} (disabled)".format(name)) dataset.verbose("Ignored (disabled)")
else: else:
if source=="local" and ( value=="true" or value=="child"): if source=="local" and ( value=="true" or value=="child"):