1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64
|
#!/usr/bin/python3
"""
Copyright (C) 2023 Michael Ablassmeier <abi@grinser.de>
This program is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program. If not, see <https://www.gnu.org/licenses/>.
"""
import logging
from argparse import Namespace
from typing import List
from libvirt import virDomain, libvirtError
from libvirtnbdbackup import virt
from libvirtnbdbackup.virt.client import DomainDisk
from libvirtnbdbackup.virt.exceptions import startBackupFailed
def start(
args: Namespace,
virtClient: virt.client,
domObj: virDomain,
disks: List[DomainDisk],
) -> bool:
"""Start backup job via libvirt API"""
paused: bool = False
if args.pause is True and args.start_domain is False:
try:
domObj.suspend()
paused = True
logging.info("Paused virtual machine.")
except libvirtError as e:
logging.warning("Attempting to pause VM failed: [%s]", e)
try:
logging.info("Starting backup job.")
virtClient.startBackup(
args,
domObj,
disks,
)
logging.debug("Backup job started.")
return True
except startBackupFailed as e:
logging.error(e)
finally:
if paused is True:
try:
domObj.resume()
logging.info("Resumed virtual machine.")
except libvirtError as e:
logging.warning("Attempting to resume VM failed: [%s]", e)
return False
|