[pve-devel] r5066 - in qemu-server/pve2: . PVE PVE/VZDump
svn-commits at proxmox.com
svn-commits at proxmox.com
Thu Aug 26 13:40:29 CEST 2010
Author: dietmar
Date: 2010-08-26 11:40:29 +0000 (Thu, 26 Aug 2010)
New Revision: 5066
Added:
qemu-server/pve2/PVE/
qemu-server/pve2/PVE/Makefile
qemu-server/pve2/PVE/VZDump/
qemu-server/pve2/PVE/VZDump/Makefile
qemu-server/pve2/PVE/VZDump/QemuServer.pm
Removed:
qemu-server/pve2/VZDump::QemuServer.pm
Modified:
qemu-server/pve2/Makefile
Log:
* PVE/*: created directory hierachy for library compoments
Modified: qemu-server/pve2/Makefile
===================================================================
--- qemu-server/pve2/Makefile 2010-08-26 11:13:31 UTC (rev 5065)
+++ qemu-server/pve2/Makefile 2010-08-26 11:40:29 UTC (rev 5066)
@@ -14,7 +14,7 @@
MANDIR=${PREFIX}/share/man
DOCDIR=${PREFIX}/share/doc
MAN1DIR=${MANDIR}/man1/
-PERLDIR=${PREFIX}/share/perl5
+export PERLDIR=${PREFIX}/share/perl5
PERLINCDIR=${PERLDIR}/asm-x86_64
ARCH:=$(shell dpkg-architecture -qDEB_BUILD_ARCH)
@@ -58,7 +58,7 @@
install -d ${DESTDIR}/var/run/qemu-server
install -d ${DESTDIR}/var/lock/qemu-server
install -D -m 0644 QemuServer.pm ${DESTDIR}${PERLDIR}/PVE/QemuServer.pm
- install -D -m 0644 VZDump::QemuServer.pm ${DESTDIR}${PERLDIR}/PVE/VZDump/QemuServer.pm
+ make -C PVE install
install -m 0755 qm ${DESTDIR}${SBINDIR}
install -m 0755 qmigrate ${DESTDIR}${SBINDIR}
install -m 0755 qmrestore ${DESTDIR}${SBINDIR}
@@ -76,7 +76,7 @@
deb ${DEB}: ${PKGSOURCES}
rm -rf debian
mkdir debian
- make DESTDIR=debian install
+ make DESTDIR=${CURDIR}/debian install
install -d -m 0755 debian/DEBIAN
install -m 0644 control debian/DEBIAN
install -m 0755 postinst debian/DEBIAN
@@ -102,8 +102,10 @@
.PHONY: clean
clean:
- rm -rf debian *~ *.deb control vzsyscalls.ph _h2ph_pre.ph ${PACKAGE}-*.tar.gz dist
+ rm -rf debian *.deb control vzsyscalls.ph _h2ph_pre.ph ${PACKAGE}-*.tar.gz dist
+ find . -name '*~' -exec rm {} ';'
+
.PHONY: distclean
distclean: clean
Added: qemu-server/pve2/PVE/Makefile
===================================================================
--- qemu-server/pve2/PVE/Makefile (rev 0)
+++ qemu-server/pve2/PVE/Makefile 2010-08-26 11:40:29 UTC (rev 5066)
@@ -0,0 +1,4 @@
+
+.PHONY: install
+install:
+ make -C VZDump install
\ No newline at end of file
Added: qemu-server/pve2/PVE/VZDump/Makefile
===================================================================
--- qemu-server/pve2/PVE/VZDump/Makefile (rev 0)
+++ qemu-server/pve2/PVE/VZDump/Makefile 2010-08-26 11:40:29 UTC (rev 5066)
@@ -0,0 +1,4 @@
+
+.PHONY: install
+install:
+ install -D -m 0644 QemuServer.pm ${DESTDIR}${PERLDIR}/PVE/VZDump/QemuServer.pm
Added: qemu-server/pve2/PVE/VZDump/QemuServer.pm
===================================================================
--- qemu-server/pve2/PVE/VZDump/QemuServer.pm (rev 0)
+++ qemu-server/pve2/PVE/VZDump/QemuServer.pm 2010-08-26 11:40:29 UTC (rev 5066)
@@ -0,0 +1,454 @@
+package PVE::VZDump::QemuServer;
+
+# Copyright (C) 2007-2009 Proxmox Server Solutions GmbH
+#
+# Copyright: vzdump is under GNU GPL, the GNU General Public License.
+#
+# 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; version 2 dated June, 1991.
+#
+# 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, write to the
+# Free Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston,
+# MA 02110-1301, USA.
+#
+# Author: Dietmar Maurer <dietmar at proxmox.com>
+
+use strict;
+use warnings;
+use File::Path;
+use File::Basename;
+use PVE::VZDump;
+use PVE::Storage;
+use PVE::QemuServer;
+use Sys::Hostname;
+use IO::File;
+
+use base qw (PVE::VZDump::Plugin);
+
+sub new {
+ my ($class, $vzdump) = @_;
+
+ PVE::VZDump::check_bin ('qm');
+
+ my $self = bless { vzdump => $vzdump };
+
+ $self->{qm} = PVE::QemuServer->new();
+
+ $self->{vmlist} = PVE::QemuServer::vzlist();
+
+ return $self;
+};
+
+
+sub type {
+ return 'qemu';
+}
+
+sub vmlist {
+ my ($self) = @_;
+
+ return [ keys %{$self->{vmlist}} ];
+}
+
+sub prepare {
+ my ($self, $task, $vmid, $mode) = @_;
+
+ $task->{disks} = [];
+
+ my $conf = $self->{vmlist}->{$vmid} = $self->{qm}->load_config ($vmid);
+
+ $task->{hostname} = $conf->{name};
+
+ my $di = $conf->{diskinfo};
+
+ my $lvmmap = PVE::VZDump::get_lvm_mapping();
+
+ my $hostname = hostname();
+
+ my $ind = {};
+ my $mountinfo = {};
+ my $mountind = 0;
+
+ my $snapshot_count = 0;
+
+ foreach my $ds (sort keys %$di) {
+ next if PVE::QemuServer::drive_is_cdrom ($di->{$ds});
+
+ my $volid = $di->{$ds}->{file};
+
+ my $path;
+
+ my ($storeid, $volname) = PVE::Storage::parse_volume_id ($volid, 1);
+ if ($storeid) {
+ $path = PVE::Storage::path ($self->{qm}->{storecfg}, $volid);
+ } else {
+ $path = $volid;
+ }
+
+ $self->{qm}->activate_volumes ($conf);
+
+ die "no such volume '$volid'\n" if ! -e $path;
+
+ my $diskinfo = { path => $path , volid => $volid, storeid => $storeid,
+ snappath => $path, virtdev => $ds };
+
+ if (-b $path) {
+
+ $diskinfo->{type} = 'block';
+
+ $diskinfo->{filename} = "vm-disk-$ds.raw";
+
+ if ($mode eq 'snapshot') {
+ my ($lvmvg, $lvmlv) = @{$lvmmap->{$path}} if defined ($lvmmap->{$path});
+ die ("mode failure - unable to detect lvm volume group\n") if !$lvmvg;
+
+ $ind->{$lvmvg} = 0 if !defined $ind->{$lvmvg};
+ $diskinfo->{snapname} = "vzsnap-$hostname-$ind->{$lvmvg}";
+ $diskinfo->{snapdev} = "/dev/$lvmvg/$diskinfo->{snapname}";
+ $diskinfo->{lvmvg} = $lvmvg;
+ $diskinfo->{lvmlv} = $lvmlv;
+ $diskinfo->{snappath} = $diskinfo->{snapdev};
+ $ind->{$lvmvg}++;
+
+ $snapshot_count++;
+ }
+
+ } else {
+
+ $diskinfo->{type} = 'file';
+
+ my (undef, $dir, $ext) = fileparse ($path, qr/\.[^.]*/);
+
+ $diskinfo->{filename} = "vm-disk-$ds$ext";
+
+ if ($mode eq 'snapshot') {
+
+ my ($srcdev, $lvmpath, $lvmvg, $lvmlv, $fstype) =
+ PVE::VZDump::get_lvm_device ($dir, $lvmmap);
+
+ my $targetdev = PVE::VZDump::get_lvm_device ($task->{dumpdir}, $lvmmap);
+
+ die ("mode failure - unable to detect lvm volume group\n") if !$lvmvg;
+ die ("mode failure - wrong lvm mount point '$lvmpath'\n") if $dir !~ m|/?$lvmpath/?|;
+ die ("mode failure - unable to dump into snapshot (use option --dumpdir)\n")
+ if $targetdev eq $srcdev;
+
+ $ind->{$lvmvg} = 0 if !defined $ind->{$lvmvg};
+
+ my $info = $mountinfo->{$lvmpath};
+ if (!$info) {
+ my $snapname = "vzsnap-$hostname-$ind->{$lvmvg}";
+ my $snapdev = "/dev/$lvmvg/$snapname";
+ $mountinfo->{$lvmpath} = $info = {
+ snapdev => $snapdev,
+ snapname => $snapname,
+ mountpoint => "/mnt/vzsnap$mountind",
+ };
+ $ind->{$lvmvg}++;
+ $mountind++;
+
+ $snapshot_count++;
+ }
+
+ $diskinfo->{snapdev} = $info->{snapdev};
+ $diskinfo->{snapname} = $info->{snapname};
+ $diskinfo->{mountpoint} = $info->{mountpoint};
+
+ $diskinfo->{lvmvg} = $lvmvg;
+ $diskinfo->{lvmlv} = $lvmlv;
+
+ $diskinfo->{fstype} = $fstype;
+ $diskinfo->{lvmpath} = $lvmpath;
+
+ $diskinfo->{snappath} = $path;
+ $diskinfo->{snappath} =~ s|/?$lvmpath/?|$diskinfo->{mountpoint}/|;
+ }
+ }
+
+ push @{$task->{disks}}, $diskinfo;
+
+ }
+
+ $task->{snapshot_count} = $snapshot_count;
+}
+
+sub vm_status {
+ my ($self, $vmid) = @_;
+
+ my $status_text = $self->cmd ("qm status $vmid");
+ chomp $status_text;
+
+ my $running = $status_text =~ m/running/ ? 1 : 0;
+
+ return wantarray ? ($running, $status_text) : $running;
+}
+
+sub lock_vm {
+ my ($self, $vmid) = @_;
+
+ $self->cmd ("qm set $vmid --lock backup");
+}
+
+sub unlock_vm {
+ my ($self, $vmid) = @_;
+
+ $self->cmd ("qm --skiplock set $vmid --lock ''");
+}
+
+sub stop_vm {
+ my ($self, $task, $vmid) = @_;
+
+ my $opts = $self->{vzdump}->{opts};
+
+ my $wait = $opts->{stopwait} * 60;
+ # send shutdown and wait
+ $self->cmd ("qm --skiplock shutdown $vmid && qm wait $vmid $wait");
+}
+
+sub start_vm {
+ my ($self, $task, $vmid) = @_;
+
+ $self->cmd ("qm --skiplock start $vmid");
+}
+
+sub suspend_vm {
+ my ($self, $task, $vmid) = @_;
+
+ $self->cmd ("qm --skiplock suspend $vmid");
+}
+
+sub resume_vm {
+ my ($self, $task, $vmid) = @_;
+
+ $self->cmd ("qm --skiplock resume $vmid");
+}
+
+sub snapshot_alloc {
+ my ($self, $volid, $name, $size, $srcdev) = @_;
+
+ my $cmd = "lvcreate --size ${size}M --snapshot --name '$name' '$srcdev'";
+
+ my ($storeid, $volname) = PVE::Storage::parse_volume_id ($volid, 1);
+ if ($storeid) {
+
+ my $scfg = PVE::Storage::storage_config ($self->{qm}->{storecfg}, $storeid);
+
+ # lock shared storage
+ return PVE::Storage::cluster_lock_storage ($storeid, $scfg->{shared}, undef, sub {
+
+ if ($scfg->{type} eq 'lvm') {
+ my $vg = $scfg->{vgname};
+
+ $self->cmd ($cmd);
+
+ } else {
+ die "can't allocate snapshot on storage type '$scfg->{type}'\n";
+ }
+ });
+ } else {
+ $self->cmd ($cmd);
+ }
+}
+
+sub snapshot_free {
+ my ($self, $volid, $name, $snapdev, $noerr) = @_;
+
+ my $cmd = "lvremove -f '$snapdev'";
+
+ eval {
+ my ($storeid, $volname) = PVE::Storage::parse_volume_id ($volid, 1);
+ if ($storeid) {
+
+ my $scfg = PVE::Storage::storage_config ($self->{qm}->{storecfg}, $storeid);
+
+ # lock shared storage
+ return PVE::Storage::cluster_lock_storage ($storeid, $scfg->{shared}, undef, sub {
+
+ if ($scfg->{type} eq 'lvm') {
+ my $vg = $scfg->{vgname};
+
+ $self->cmd ($cmd);
+
+ } else {
+ die "can't allocate snapshot on storage type '$scfg->{type}'\n";
+ }
+ });
+ } else {
+ $self->cmd ($cmd);
+ }
+ };
+ die $@ if !$noerr;
+ $self->logerr ($@) if $@;
+}
+
+sub snapshot {
+ my ($self, $task, $vmid) = @_;
+
+ my $opts = $self->{vzdump}->{opts};
+
+ my $mounts = {};
+
+ foreach my $di (@{$task->{disks}}) {
+ if ($di->{type} eq 'block') {
+
+ if (-b $di->{snapdev}) {
+ $self->loginfo ("trying to remove stale snapshot '$di->{snapdev}'");
+ $self->snapshot_free ($di->{volid}, $di->{snapname}, $di->{snapdev}, 1);
+ }
+
+ $di->{cleanup_lvm} = 1;
+ $self->snapshot_alloc ($di->{volid}, $di->{snapname}, $opts->{size},
+ "/dev/$di->{lvmvg}/$di->{lvmlv}");
+
+ } elsif ($di->{type} eq 'file') {
+
+ next if defined ($mounts->{$di->{mountpoint}}); # already mounted
+
+ # note: files are never on shared storage, so we use $di->{path} instead
+ # of $di->{volid} (avoid PVE:Storage calls because path start with /)
+
+ if (-b $di->{snapdev}) {
+ $self->loginfo ("trying to remove stale snapshot '$di->{snapdev}'");
+
+ $self->cmd_noerr ("umount $di->{mountpoint}");
+
+ $self->snapshot_free ($di->{path}, $di->{snapname}, $di->{snapdev}, 1);
+ }
+
+ mkpath $di->{mountpoint}; # create mount point for lvm snapshot
+
+ $di->{cleanup_lvm} = 1;
+
+ $self->snapshot_alloc ($di->{path}, $di->{snapname}, $opts->{size},
+ "/dev/$di->{lvmvg}/$di->{lvmlv}");
+
+ my $mopts = $di->{fstype} eq 'xfs' ? "-o nouuid" : '';
+
+ $di->{snapshot_mount} = 1;
+
+ $self->cmd ("mount -t $di->{fstype} $mopts $di->{snapdev} $di->{mountpoint}");
+
+ $mounts->{$di->{mountpoint}} = 1;
+
+ } else {
+ die "implement me";
+ }
+ }
+}
+
+sub get_size {
+ my $path = shift;
+
+ if (-f $path) {
+ return -s $path;
+ } elsif (-b $path) {
+ my $fh = IO::File->new ($path, "r");
+ die "unable to open '$path' to detect device size\n" if !$fh;
+ my $size = sysseek $fh, 0, 2;
+ $fh->close();
+ die "unable to detect device size for '$path'\n" if !$size;
+ return $size;
+ }
+}
+
+sub assemble {
+ my ($self, $task, $vmid) = @_;
+
+ my $conffile = PVE::QemuServer::config_file ($vmid);
+
+ my $outfile = "$task->{tmpdir}/qemu-server.conf";
+
+ my $outfd;
+ my $conffd;
+
+ eval {
+
+ $outfd = IO::File->new (">$outfile") ||
+ die "unable to open '$outfile'";
+ $conffd = IO::File->new ($conffile, 'r') ||
+ die "unable open '$conffile'";
+
+ while (defined (my $line = <$conffd>)) {
+ next if $line =~ m/^\#vzdump\#/; # just to be sure
+ print $outfd $line;
+ }
+
+ foreach my $di (@{$task->{disks}}) {
+ if ($di->{type} eq 'block' || $di->{type} eq 'file') {
+ my $size = get_size ($di->{snappath});
+ my $storeid = $di->{storeid} || '';
+ print $outfd "#vzdump#map:$di->{virtdev}:$di->{filename}:$size:$storeid:\n";
+ } else {
+ die "internal error";
+ }
+ }
+ };
+ my $err = $@;
+
+ close ($outfd) if $outfd;
+ close ($conffd) if $conffd;
+
+ die $err if $err;
+}
+
+sub archive {
+ my ($self, $task, $vmid, $filename) = @_;
+
+ my $conffile = "$task->{tmpdir}/qemu-server.conf";
+
+ my $opts = $self->{vzdump}->{opts};
+
+ my $starttime = time ();
+
+ my $fh;
+
+ my $bwl = $opts->{bwlimit}*1024; # bandwidth limit for cstream
+
+ my @filea = ($conffile, 'qemu-server.conf'); # always first file in tar
+ foreach my $di (@{$task->{disks}}) {
+ if ($di->{type} eq 'block' || $di->{type} eq 'file') {
+ push @filea, $di->{snappath}, $di->{filename};
+ } else {
+ die "implement me";
+ }
+ }
+
+ my $out = ">$filename";
+ $out = "|cstream -t $bwl $out" if $opts->{bwlimit};
+ $out = "|gzip $out" if $opts->{compress};
+
+ my $files = join (' ', map { "'$_'" } @filea);
+
+ $self->cmd("/usr/lib/qemu-server/vmtar $files $out");
+}
+
+sub cleanup {
+ my ($self, $task, $vmid) = @_;
+
+ foreach my $di (@{$task->{disks}}) {
+
+ if ($di->{snapshot_mount}) {
+ $self->cmd_noerr ("umount $di->{mountpoint}");
+ }
+
+ if ($di->{cleanup_lvm}) {
+ if (-b $di->{snapdev}) {
+ if ($di->{type} eq 'block') {
+ $self->snapshot_free ($di->{volid}, $di->{snapname}, $di->{snapdev}, 1);
+ } elsif ($di->{type} eq 'file') {
+ $self->snapshot_free ($di->{path}, $di->{snapname}, $di->{snapdev}, 1);
+ }
+ }
+ }
+ }
+
+}
+
+1;
Deleted: qemu-server/pve2/VZDump::QemuServer.pm
===================================================================
--- qemu-server/pve2/VZDump::QemuServer.pm 2010-08-26 11:13:31 UTC (rev 5065)
+++ qemu-server/pve2/VZDump::QemuServer.pm 2010-08-26 11:40:29 UTC (rev 5066)
@@ -1,454 +0,0 @@
-package PVE::VZDump::QemuServer;
-
-# Copyright (C) 2007-2009 Proxmox Server Solutions GmbH
-#
-# Copyright: vzdump is under GNU GPL, the GNU General Public License.
-#
-# 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; version 2 dated June, 1991.
-#
-# 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, write to the
-# Free Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston,
-# MA 02110-1301, USA.
-#
-# Author: Dietmar Maurer <dietmar at proxmox.com>
-
-use strict;
-use warnings;
-use File::Path;
-use File::Basename;
-use PVE::VZDump;
-use PVE::Storage;
-use PVE::QemuServer;
-use Sys::Hostname;
-use IO::File;
-
-use base qw (PVE::VZDump::Plugin);
-
-sub new {
- my ($class, $vzdump) = @_;
-
- PVE::VZDump::check_bin ('qm');
-
- my $self = bless { vzdump => $vzdump };
-
- $self->{qm} = PVE::QemuServer->new();
-
- $self->{vmlist} = PVE::QemuServer::vzlist();
-
- return $self;
-};
-
-
-sub type {
- return 'qemu';
-}
-
-sub vmlist {
- my ($self) = @_;
-
- return [ keys %{$self->{vmlist}} ];
-}
-
-sub prepare {
- my ($self, $task, $vmid, $mode) = @_;
-
- $task->{disks} = [];
-
- my $conf = $self->{vmlist}->{$vmid} = $self->{qm}->load_config ($vmid);
-
- $task->{hostname} = $conf->{name};
-
- my $di = $conf->{diskinfo};
-
- my $lvmmap = PVE::VZDump::get_lvm_mapping();
-
- my $hostname = hostname();
-
- my $ind = {};
- my $mountinfo = {};
- my $mountind = 0;
-
- my $snapshot_count = 0;
-
- foreach my $ds (sort keys %$di) {
- next if PVE::QemuServer::drive_is_cdrom ($di->{$ds});
-
- my $volid = $di->{$ds}->{file};
-
- my $path;
-
- my ($storeid, $volname) = PVE::Storage::parse_volume_id ($volid, 1);
- if ($storeid) {
- $path = PVE::Storage::path ($self->{qm}->{storecfg}, $volid);
- } else {
- $path = $volid;
- }
-
- $self->{qm}->activate_volumes ($conf);
-
- die "no such volume '$volid'\n" if ! -e $path;
-
- my $diskinfo = { path => $path , volid => $volid, storeid => $storeid,
- snappath => $path, virtdev => $ds };
-
- if (-b $path) {
-
- $diskinfo->{type} = 'block';
-
- $diskinfo->{filename} = "vm-disk-$ds.raw";
-
- if ($mode eq 'snapshot') {
- my ($lvmvg, $lvmlv) = @{$lvmmap->{$path}} if defined ($lvmmap->{$path});
- die ("mode failure - unable to detect lvm volume group\n") if !$lvmvg;
-
- $ind->{$lvmvg} = 0 if !defined $ind->{$lvmvg};
- $diskinfo->{snapname} = "vzsnap-$hostname-$ind->{$lvmvg}";
- $diskinfo->{snapdev} = "/dev/$lvmvg/$diskinfo->{snapname}";
- $diskinfo->{lvmvg} = $lvmvg;
- $diskinfo->{lvmlv} = $lvmlv;
- $diskinfo->{snappath} = $diskinfo->{snapdev};
- $ind->{$lvmvg}++;
-
- $snapshot_count++;
- }
-
- } else {
-
- $diskinfo->{type} = 'file';
-
- my (undef, $dir, $ext) = fileparse ($path, qr/\.[^.]*/);
-
- $diskinfo->{filename} = "vm-disk-$ds$ext";
-
- if ($mode eq 'snapshot') {
-
- my ($srcdev, $lvmpath, $lvmvg, $lvmlv, $fstype) =
- PVE::VZDump::get_lvm_device ($dir, $lvmmap);
-
- my $targetdev = PVE::VZDump::get_lvm_device ($task->{dumpdir}, $lvmmap);
-
- die ("mode failure - unable to detect lvm volume group\n") if !$lvmvg;
- die ("mode failure - wrong lvm mount point '$lvmpath'\n") if $dir !~ m|/?$lvmpath/?|;
- die ("mode failure - unable to dump into snapshot (use option --dumpdir)\n")
- if $targetdev eq $srcdev;
-
- $ind->{$lvmvg} = 0 if !defined $ind->{$lvmvg};
-
- my $info = $mountinfo->{$lvmpath};
- if (!$info) {
- my $snapname = "vzsnap-$hostname-$ind->{$lvmvg}";
- my $snapdev = "/dev/$lvmvg/$snapname";
- $mountinfo->{$lvmpath} = $info = {
- snapdev => $snapdev,
- snapname => $snapname,
- mountpoint => "/mnt/vzsnap$mountind",
- };
- $ind->{$lvmvg}++;
- $mountind++;
-
- $snapshot_count++;
- }
-
- $diskinfo->{snapdev} = $info->{snapdev};
- $diskinfo->{snapname} = $info->{snapname};
- $diskinfo->{mountpoint} = $info->{mountpoint};
-
- $diskinfo->{lvmvg} = $lvmvg;
- $diskinfo->{lvmlv} = $lvmlv;
-
- $diskinfo->{fstype} = $fstype;
- $diskinfo->{lvmpath} = $lvmpath;
-
- $diskinfo->{snappath} = $path;
- $diskinfo->{snappath} =~ s|/?$lvmpath/?|$diskinfo->{mountpoint}/|;
- }
- }
-
- push @{$task->{disks}}, $diskinfo;
-
- }
-
- $task->{snapshot_count} = $snapshot_count;
-}
-
-sub vm_status {
- my ($self, $vmid) = @_;
-
- my $status_text = $self->cmd ("qm status $vmid");
- chomp $status_text;
-
- my $running = $status_text =~ m/running/ ? 1 : 0;
-
- return wantarray ? ($running, $status_text) : $running;
-}
-
-sub lock_vm {
- my ($self, $vmid) = @_;
-
- $self->cmd ("qm set $vmid --lock backup");
-}
-
-sub unlock_vm {
- my ($self, $vmid) = @_;
-
- $self->cmd ("qm --skiplock set $vmid --lock ''");
-}
-
-sub stop_vm {
- my ($self, $task, $vmid) = @_;
-
- my $opts = $self->{vzdump}->{opts};
-
- my $wait = $opts->{stopwait} * 60;
- # send shutdown and wait
- $self->cmd ("qm --skiplock shutdown $vmid && qm wait $vmid $wait");
-}
-
-sub start_vm {
- my ($self, $task, $vmid) = @_;
-
- $self->cmd ("qm --skiplock start $vmid");
-}
-
-sub suspend_vm {
- my ($self, $task, $vmid) = @_;
-
- $self->cmd ("qm --skiplock suspend $vmid");
-}
-
-sub resume_vm {
- my ($self, $task, $vmid) = @_;
-
- $self->cmd ("qm --skiplock resume $vmid");
-}
-
-sub snapshot_alloc {
- my ($self, $volid, $name, $size, $srcdev) = @_;
-
- my $cmd = "lvcreate --size ${size}M --snapshot --name '$name' '$srcdev'";
-
- my ($storeid, $volname) = PVE::Storage::parse_volume_id ($volid, 1);
- if ($storeid) {
-
- my $scfg = PVE::Storage::storage_config ($self->{qm}->{storecfg}, $storeid);
-
- # lock shared storage
- return PVE::Storage::cluster_lock_storage ($storeid, $scfg->{shared}, undef, sub {
-
- if ($scfg->{type} eq 'lvm') {
- my $vg = $scfg->{vgname};
-
- $self->cmd ($cmd);
-
- } else {
- die "can't allocate snapshot on storage type '$scfg->{type}'\n";
- }
- });
- } else {
- $self->cmd ($cmd);
- }
-}
-
-sub snapshot_free {
- my ($self, $volid, $name, $snapdev, $noerr) = @_;
-
- my $cmd = "lvremove -f '$snapdev'";
-
- eval {
- my ($storeid, $volname) = PVE::Storage::parse_volume_id ($volid, 1);
- if ($storeid) {
-
- my $scfg = PVE::Storage::storage_config ($self->{qm}->{storecfg}, $storeid);
-
- # lock shared storage
- return PVE::Storage::cluster_lock_storage ($storeid, $scfg->{shared}, undef, sub {
-
- if ($scfg->{type} eq 'lvm') {
- my $vg = $scfg->{vgname};
-
- $self->cmd ($cmd);
-
- } else {
- die "can't allocate snapshot on storage type '$scfg->{type}'\n";
- }
- });
- } else {
- $self->cmd ($cmd);
- }
- };
- die $@ if !$noerr;
- $self->logerr ($@) if $@;
-}
-
-sub snapshot {
- my ($self, $task, $vmid) = @_;
-
- my $opts = $self->{vzdump}->{opts};
-
- my $mounts = {};
-
- foreach my $di (@{$task->{disks}}) {
- if ($di->{type} eq 'block') {
-
- if (-b $di->{snapdev}) {
- $self->loginfo ("trying to remove stale snapshot '$di->{snapdev}'");
- $self->snapshot_free ($di->{volid}, $di->{snapname}, $di->{snapdev}, 1);
- }
-
- $di->{cleanup_lvm} = 1;
- $self->snapshot_alloc ($di->{volid}, $di->{snapname}, $opts->{size},
- "/dev/$di->{lvmvg}/$di->{lvmlv}");
-
- } elsif ($di->{type} eq 'file') {
-
- next if defined ($mounts->{$di->{mountpoint}}); # already mounted
-
- # note: files are never on shared storage, so we use $di->{path} instead
- # of $di->{volid} (avoid PVE:Storage calls because path start with /)
-
- if (-b $di->{snapdev}) {
- $self->loginfo ("trying to remove stale snapshot '$di->{snapdev}'");
-
- $self->cmd_noerr ("umount $di->{mountpoint}");
-
- $self->snapshot_free ($di->{path}, $di->{snapname}, $di->{snapdev}, 1);
- }
-
- mkpath $di->{mountpoint}; # create mount point for lvm snapshot
-
- $di->{cleanup_lvm} = 1;
-
- $self->snapshot_alloc ($di->{path}, $di->{snapname}, $opts->{size},
- "/dev/$di->{lvmvg}/$di->{lvmlv}");
-
- my $mopts = $di->{fstype} eq 'xfs' ? "-o nouuid" : '';
-
- $di->{snapshot_mount} = 1;
-
- $self->cmd ("mount -t $di->{fstype} $mopts $di->{snapdev} $di->{mountpoint}");
-
- $mounts->{$di->{mountpoint}} = 1;
-
- } else {
- die "implement me";
- }
- }
-}
-
-sub get_size {
- my $path = shift;
-
- if (-f $path) {
- return -s $path;
- } elsif (-b $path) {
- my $fh = IO::File->new ($path, "r");
- die "unable to open '$path' to detect device size\n" if !$fh;
- my $size = sysseek $fh, 0, 2;
- $fh->close();
- die "unable to detect device size for '$path'\n" if !$size;
- return $size;
- }
-}
-
-sub assemble {
- my ($self, $task, $vmid) = @_;
-
- my $conffile = PVE::QemuServer::config_file ($vmid);
-
- my $outfile = "$task->{tmpdir}/qemu-server.conf";
-
- my $outfd;
- my $conffd;
-
- eval {
-
- $outfd = IO::File->new (">$outfile") ||
- die "unable to open '$outfile'";
- $conffd = IO::File->new ($conffile, 'r') ||
- die "unable open '$conffile'";
-
- while (defined (my $line = <$conffd>)) {
- next if $line =~ m/^\#vzdump\#/; # just to be sure
- print $outfd $line;
- }
-
- foreach my $di (@{$task->{disks}}) {
- if ($di->{type} eq 'block' || $di->{type} eq 'file') {
- my $size = get_size ($di->{snappath});
- my $storeid = $di->{storeid} || '';
- print $outfd "#vzdump#map:$di->{virtdev}:$di->{filename}:$size:$storeid:\n";
- } else {
- die "internal error";
- }
- }
- };
- my $err = $@;
-
- close ($outfd) if $outfd;
- close ($conffd) if $conffd;
-
- die $err if $err;
-}
-
-sub archive {
- my ($self, $task, $vmid, $filename) = @_;
-
- my $conffile = "$task->{tmpdir}/qemu-server.conf";
-
- my $opts = $self->{vzdump}->{opts};
-
- my $starttime = time ();
-
- my $fh;
-
- my $bwl = $opts->{bwlimit}*1024; # bandwidth limit for cstream
-
- my @filea = ($conffile, 'qemu-server.conf'); # always first file in tar
- foreach my $di (@{$task->{disks}}) {
- if ($di->{type} eq 'block' || $di->{type} eq 'file') {
- push @filea, $di->{snappath}, $di->{filename};
- } else {
- die "implement me";
- }
- }
-
- my $out = ">$filename";
- $out = "|cstream -t $bwl $out" if $opts->{bwlimit};
- $out = "|gzip $out" if $opts->{compress};
-
- my $files = join (' ', map { "'$_'" } @filea);
-
- $self->cmd("/usr/lib/qemu-server/vmtar $files $out");
-}
-
-sub cleanup {
- my ($self, $task, $vmid) = @_;
-
- foreach my $di (@{$task->{disks}}) {
-
- if ($di->{snapshot_mount}) {
- $self->cmd_noerr ("umount $di->{mountpoint}");
- }
-
- if ($di->{cleanup_lvm}) {
- if (-b $di->{snapdev}) {
- if ($di->{type} eq 'block') {
- $self->snapshot_free ($di->{volid}, $di->{snapname}, $di->{snapdev}, 1);
- } elsif ($di->{type} eq 'file') {
- $self->snapshot_free ($di->{path}, $di->{snapname}, $di->{snapdev}, 1);
- }
- }
- }
- }
-
-}
-
-1;
More information about the pve-devel
mailing list