feffe/sau
1
0
Fork 0
Code Issues Pull Requests Projects Releases 24 Wiki Activity

add support for cleaning zfs system snapshots

Browse Source
This commit is contained in:
Fredrik Eriksson
2025-09-20 11:45:08 +02:00
parent d8f096ebe3
commit a176ee3c26
1 changed files with 22 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
sau/freebsd.py
View File

@ -10,11 +10,14 @@ import sau.helpers
PKG_PATH='/usr/sbin/pkg' PKG_PATH='/usr/sbin/pkg'
SERVICE_PATH='/usr/sbin/service' SERVICE_PATH='/usr/sbin/service'
FREEBSD_UPDATE_PATH='/usr/sbin/freebsd-update' FREEBSD_UPDATE_PATH='/usr/sbin/freebsd-update'
ZFS='/sbin/zfs'
# regex to identify rc.d-files # regex to identify rc.d-files
rc_script_re = re.compile(r'^(?:/usr/local)?/etc/rc\.d/(.*)$') rc_script_re = re.compile(r'^(?:/usr/local)?/etc/rc\.d/(.*)$')
# regex to parse packages # regex to parse packages
pkg_upgrade_re = re.compile(r'^\s([^\s]*): ([^\s]*) -> ([^\s]*).*$') pkg_upgrade_re = re.compile(r'^\s([^\s]*): ([^\s]*) -> ([^\s]*).*$')
# regex for system zfs snapshots
system_snaps_re=re.compile(r'^zroot/ROOT/default@\d{4}-\d\d-\d\d-\d\d:\d\d:\d\d-\d+(?:\s|$)')
def identify_service_from_bin(exe): def identify_service_from_bin(exe):
@ -55,7 +58,24 @@ def restart_service(service):
else: else:
log.info("restarted service {}".format(service)) log.info("restarted service {}".format(service))
def clean_zfs(to_keep=5):
log = logging.getLogger(sau.LOGNAME)
cmd = [ ZFS, 'list', '-t', 'snapshot', '-H' ]
ret, out, err = sau.helpers.exec_cmd(cmd, timeout=300)
snapshots = sorted([l.split()[0] for l in out.splitlines() if re.match(system_snaps_re, l)], reverse=True)
if to_keep < 1:
log.warning(f'set to save {to_keep} snapshots; NO WAY!, will keep one anyway')
to_keep = 1
for s in snapshots[to_keep:]:
log.info(f'Removing old system snapshot "{s}"')
cmd = [ ZFS, 'destroy', '-R', s ]
ret, out, err = sau.helpers.exec_cmd(cmd, timeout=600)
def system_upgrade(): def system_upgrade():
conf = sau.config
log = logging.getLogger(sau.LOGNAME) log = logging.getLogger(sau.LOGNAME)
# this is how freebsd wants it... # this is how freebsd wants it...
time.sleep(random.randint(0, 3600)) time.sleep(random.randint(0, 3600))
@ -70,6 +90,8 @@ def system_upgrade():
log.info('System updates installed:') log.info('System updates installed:')
for line in out.splitlines(): for line in out.splitlines():
log.info(line) log.info(line)
keep_snapshots = conf.getint('default', 'keep_snapshots', fallback=4)
clean_zfs(keep_snapshots)
return True return True
else: else:
log.warning('System upgrade failed (return code {}):'.format(ret)) log.warning('System upgrade failed (return code {}):'.format(ret))