[Libguestfs] [PATCH 2/2] Add export to RHEV
Matthew Booth
mbooth at redhat.com
Tue Mar 30 16:14:46 UTC 2010
Allow guests to be written to a RHEV NFS export storage domain.
Add 'rhev' output method and -osd command-line option.
Example command line:
virt-v2v -f virt-v2v.conf -ic 'esx://yellow.rhev.marston/' \
-o rhev -osd blue:/export/export RHEL3-32
This will connect to an ESX server and write the guest 'RHEL3-32' to
blue:/export/export, which is a pre-initialised RHEV export storage domain.
---
MANIFEST | 1 +
lib/Sys/VirtV2V/Target/RHEV.pm | 900 ++++++++++++++++++++++++++++++++++++++++
v2v/virt-v2v.conf | 12 +
v2v/virt-v2v.pl | 50 +++-
4 files changed, 961 insertions(+), 2 deletions(-)
create mode 100644 lib/Sys/VirtV2V/Target/RHEV.pm
diff --git a/MANIFEST b/MANIFEST
index d4dd140..1bc6018 100644
--- a/MANIFEST
+++ b/MANIFEST
@@ -13,6 +13,7 @@ lib/Sys/VirtV2V/Connection/LibVirt.pm
lib/Sys/VirtV2V/Connection/LibVirtXML.pm
lib/Sys/VirtV2V/UserMessage.pm
lib/Sys/VirtV2V/Target/LibVirt.pm
+lib/Sys/VirtV2V/Target/RHEV.pm
lib/Sys/VirtV2V/Transfer/ESX.pm
MANIFEST This list of files
MANIFEST.SKIP
diff --git a/lib/Sys/VirtV2V/Target/RHEV.pm b/lib/Sys/VirtV2V/Target/RHEV.pm
new file mode 100644
index 0000000..0251ab8
--- /dev/null
+++ b/lib/Sys/VirtV2V/Target/RHEV.pm
@@ -0,0 +1,900 @@
+# Sys::VirtV2V::Target::RHEV
+# Copyright (C) 2010 Red Hat Inc.
+#
+# This library is free software; you can redistribute it and/or
+# modify it under the terms of the GNU Lesser General Public
+# License as published by the Free Software Foundation; either
+# version 2 of the License, or (at your option) any later version.
+#
+# This library 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
+# Lesser General Public License for more details.
+#
+# You should have received a copy of the GNU Lesser General Public
+# License along with this library; if not, write to the Free Software
+# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
+
+use strict;
+use warnings;
+
+package Sys::VirtV2V::Target::RHEV::UUIDHelper;
+
+sub get_uuid
+{
+ my $uuidgen;
+ open($uuidgen, '<', '/proc/sys/kernel/random/uuid')
+ or die("Unable to open /proc/sys/kernel/random/uuid: $!");
+
+ my $uuid;
+ while(<$uuidgen>) {
+ chomp;
+ $uuid = $_;
+ }
+ close($uuidgen) or die("Error closing /proc/sys/kernel/random/uuid: $!");
+
+ return $uuid;
+}
+
+package Sys::VirtV2V::Target::RHEV::NFSHelper;
+
+use Carp;
+use File::Temp qw(tempfile);
+use POSIX qw(:sys_wait_h setuid setgid);
+
+use Sys::VirtV2V::UserMessage qw(user_message);
+
+use Locale::TextDomain 'virt-v2v';
+
+sub new
+{
+ my $class = shift;
+ my ($sub) = @_;
+
+ my $self = {};
+ bless($self, $class);
+
+ my ($tochild_read, $tochild_write);
+ my ($fromchild_read, $fromchild_write);
+
+ pipe($tochild_read, $tochild_write);
+ pipe($fromchild_read, $fromchild_write);
+
+ # Capture stderr to a file
+ my ($stderr, undef) = tempfile(UNLINK => 1, SUFFIX => '.virt-v2v');
+ $self->{stderr} = $stderr;
+
+ my $pid = fork();
+ if ($pid == 0) {
+ # Close the ends of the pipes we don't need
+ close($tochild_write);
+ close($fromchild_read);
+
+ # dup2() stdin and stdout with the communication pipes
+ open(STDIN, "<&".fileno($tochild_read))
+ or die("dup stdin failed: $!");
+ open(STDOUT, ">&".fileno($fromchild_write))
+ or die("dup stdout failed: $!");
+
+ # Write stderr to our temp file
+ open(STDERR, ">&".fileno($stderr))
+ or die("dup stderr failed: $!");
+
+ # Close the original file handles
+ close($tochild_read);
+ close($fromchild_write);
+
+ # Set EUID and EGID to RHEV magic values 36:36
+ # execute the wrapped function, trapping errors
+ eval {
+ setgid(36) or die("setgid failed: $!");
+ setuid(36) or die("setuid failed: $!");
+
+print STDERR "EUID: $>\n";
+print STDERR "EGID: $)\n";
+
+ &$sub();
+ };
+
+ # Don't exit, which would cause destructors to be called in the child.
+ # Instead exec /bin/true or /bin/false as appropriate
+ if ($@) {
+ print $stderr $@;
+ close($stderr);
+ exec('/bin/false');
+ }
+
+ exec('/bin/true');
+ } else {
+ close($tochild_read);
+ close($fromchild_write);
+ }
+
+ $self->{tochild} = $tochild_write;
+ $self->{fromchild} = $fromchild_read;
+
+ $self->{pid} = $pid;
+ return $self;
+}
+
+sub check_exit
+{
+ my $self = shift;
+
+ my $ret = waitpid($self->{pid}, 0);
+
+ # If the process terminated normally, check the exit status and stderr
+ if ($ret == $self->{pid}) {
+ delete($self->{pid});
+
+ # No error if the exit status was 0
+ return if ($? == 0);
+
+ # Otherwise return whatever went to stderr
+ my $stderr = $self->{stderr};
+ my $error = "";
+ seek($stderr, 0, 0);
+ while(<$stderr>) {
+ $error .= $_;
+ }
+ die($error);
+ }
+
+ confess("Error waiting for child process");
+}
+
+sub DESTROY
+{
+ my $self = shift;
+
+ # Make certain the child process dies with the object
+ if (defined($self->{pid})) {
+ kill(9, $self->{pid});
+ waitpid($self->{pid}, WNOHANG);
+ }
+}
+
+package Sys::VirtV2V::Target::RHEV::Vol;
+
+use POSIX;
+
+use Sys::VirtV2V::UserMessage qw(user_message);
+
+use Locale::TextDomain 'virt-v2v';
+
+our %vols_by_path;
+
+sub _new
+{
+ my $class = shift;
+ my ($mountdir, $domainuuid, $size) = @_;
+
+ my $self = {};
+ bless($self, $class);
+
+ $self->{size} = $size;
+
+ my $imageuuid = Sys::VirtV2V::Target::RHEV::UUIDHelper::get_uuid();
+ my $voluuid = Sys::VirtV2V::Target::RHEV::UUIDHelper::get_uuid();
+ $self->{imageuuid} = $imageuuid;
+ $self->{voluuid} = $voluuid;
+ $self->{domainuuid} = $domainuuid;
+
+ $self->{dir} = "$mountdir/$domainuuid/images/$imageuuid";
+ $self->{path} = $self->{dir}."/$voluuid";
+
+ $self->{creation} = time();
+
+ $vols_by_path{$self->{path}} = $self;
+
+ return $self;
+}
+
+sub _get_by_path
+{
+ my $class = shift;
+ my ($path) = @_;
+
+ return $vols_by_path{$path};
+}
+
+sub _get_size
+{
+ my $self = shift;
+
+ return $self->{size};
+}
+
+sub _get_imageuuid
+{
+ my $self = shift;
+
+ return $self->{imageuuid};
+}
+
+sub _get_voluuid
+{
+ my $self = shift;
+
+ return $self->{voluuid};
+}
+
+sub _get_creation
+{
+ my $self = shift;
+
+ return $self->{creation};
+}
+
+sub get_path
+{
+ my $self = shift;
+
+ return $self->{path};
+}
+
+sub get_format
+{
+ my $self = shift;
+
+ return "raw";
+}
+
+sub is_block
+{
+ my $self = shift;
+
+ return 0;
+}
+
+sub open
+{
+ my $self = shift;
+
+ my $now = $self->{creation};
+
+ $self->{writer} = Sys::VirtV2V::Target::RHEV::NFSHelper->new(sub {
+ my $dir = $self->{dir};
+ my $path = $self->{path};
+
+ mkdir($dir)
+ or die(user_message(__x("Failed to create directory {dir}: {error}",
+ dir => $dir,
+ error => $!)));
+
+ # Write out the .meta file
+ my $meta;
+ open($meta, '>', "$path.meta")
+ or die(__x("Unable to open {path} for writing: {error}",
+ path => "$path.meta",
+ error => $!));
+
+ print $meta "DOMAIN=".$self->{domainuuid}."\n";
+ print $meta "VOLTYPE=LEAF\n";
+ print $meta "CTIME=$now\n";
+ print $meta "FORMAT=RAW\n";
+ print $meta "IMAGE=".$self->{imageuuid}."\n";
+ print $meta "DISKTYPE=1\n";
+ print $meta "PUUID=00000000-0000-0000-0000-000000000000\n";
+ print $meta "LEGALITY=LEGAL\n";
+ print $meta "MTIME=$now\n";
+ print $meta "POOL_UUID=00000000-0000-0000-0000-000000000000\n";
+ print $meta "SIZE=".ceil($self->{size}/1024)."\n";
+ print $meta "TYPE=SPARSE\n";
+ print $meta "DESCRIPTION=Exported by virt-v2v\n";
+ print $meta "EOF\n";
+
+ close($meta)
+ or die(user_message(__x("Error closing {path}: {error}",
+ path => "$path.meta",
+ error => $!)));
+
+ # Open the data file for writing
+ my $data;
+ open($data, '>', $path)
+ or die(__x("Unable to open {path} for writing: {error}",
+ path => "$path",
+ error => $!));
+
+ # Write all data received to the data file
+ my $buffer;
+
+ for(;;) {
+ my $ret = sysread(STDIN, $buffer, 64*1024);
+ die("Error in NFSHelper reading from stdin: $!")
+ unless (defined($ret));
+ last if ($ret == 0);
+
+ print $data $buffer;
+ }
+
+ close($data)
+ or die(user_message(__x("Error closing {path}: {error}",
+ path => "$path",
+ error => $!)));
+ });
+}
+
+sub write
+{
+ my $self = shift;
+ my ($data) = @_;
+
+ defined($self->{writer}) or die("write called without open");
+
+ unless(print {$self->{writer}->{tochild}} $data) {
+ # This should only have failed if there was an error from the helper
+ $self->{writer}->check_exit();
+
+ # die() explicitly in case the above didn't
+ die("Error writing to helper: $!");
+ }
+}
+
+sub close
+{
+ my $self = shift;
+
+ # Close the writer pipe, which will cause the child to exit
+ close($self->{writer}->{tochild})
+ or die("Error closing tochild pipe");
+
+ # Wait for the child to exit
+ $self->{writer}->check_exit();
+
+ delete($self->{writer});
+}
+
+package Sys::VirtV2V::Target::RHEV;
+
+use File::Temp qw(tempdir);
+use Time::gmtime;
+
+use Sys::VirtV2V::ExecHelper;
+use Sys::VirtV2V::UserMessage qw(user_message);
+
+use Locale::TextDomain 'virt-v2v';
+
+=head1 NAME
+
+Sys::VirtV2V::Target::RHEV - Output to a RHEV Export storage domain
+
+=head1 SYNOPSIS
+
+ use Sys::VirtV2V::Target::RHEV;
+
+ my $target = new Sys::VirtV2V::Target::RHEV($domain_path);
+
+=head1 DESCRIPTION
+
+Sys::VirtV2V::Target::RHEV write the converted guest to a RHEV Export storage
+domain. This can later be imported to RHEV by the user.
+
+=head1 METHODS
+
+=over
+
+=item Sys::VirtV2V::Target::RHEV->new(domain_path)
+
+Create a new Sys::VirtV2V::Target::RHEV object.
+
+=over
+
+=item domain_path
+
+The NFS path to an initialised RHEV Export storage domain.
+
+=back
+
+=cut
+
+sub new
+{
+ my $class = shift;
+ my ($domain_path) = @_;
+
+ my $self = {};
+ bless($self, $class);
+
+ die(user_message(__"You must be root to output to RHEV"))
+ unless ($> == 0);
+
+ my $mountdir = tempdir();
+
+ # Needs to be read by 36:36
+ chown(36, 36, $mountdir)
+ or die(user_message(__x("Unable to change ownership of {mountdir} to ".
+ "36:36",
+ mountdir => $mountdir)));
+
+ $self->{mountdir} = $mountdir;
+ $self->{domain_path} = $domain_path;
+
+ my $eh = Sys::VirtV2V::ExecHelper->run('mount', $domain_path, $mountdir);
+ if ($eh->status() != 0) {
+ die(user_message(__x("Failed to mount {path}. Command exited with ".
+ "status {status}. Output was: {output}",
+ path => $domain_path,
+ status => $eh->status(),
+ output => $eh->output())));
+ }
+
+ my $nfs = Sys::VirtV2V::Target::RHEV::NFSHelper->new(sub {
+ opendir(my $dir, $mountdir)
+ or die(user_message(__x("Unable to open {mountdir}: {error}",
+ mountdir => $mountdir,
+ error => $!)));
+
+ foreach my $entry (readdir($dir)) {
+ # return entries which look like uuids
+ print "$entry\n"
+ if ($entry =~ /^[0-9a-z]{8}-(?:[0-9a-z]{4}-){3}[0-9a-z]{12}$/);
+ }
+ });
+
+ # Get the UUID of the storage domain
+ my $domainuuid;
+ my $fromchild = $nfs->{fromchild};
+ while (<$fromchild>) {
+ if (defined($domainuuid)) {
+ die(user_message(__x("{mountdir} contains multiple possible ".
+ "domains. It may only contain one.",
+ mountdir => $mountdir)));
+ }
+ chomp;
+ $domainuuid = $_;
+ }
+
+ $nfs->check_exit();
+
+ if (!defined($domainuuid)) {
+ die(user_message(__x("{mountdir} does not contain an initialised ".
+ "storage domain",
+ mountdir => $mountdir)));
+ }
+
+ $self->{domainuuid} = $domainuuid;
+
+ return $self;
+}
+
+sub DESTROY
+{
+ my $self = shift;
+
+ my $eh = Sys::VirtV2V::ExecHelper->run('umount', $self->{mountdir});
+ if ($eh->status() != 0) {
+ print STDERR user_message(__x("Failed to unmount {path}. Command ".
+ "exited with status {status}. Output ".
+ "was: {output}",
+ path => $self->{domain_path},
+ status => $eh->status(),
+ output => $eh->output()));
+ }
+
+ rmdir($self->{mountdir})
+ or print STDERR user_message(__x("Failed to remove mount directory ".
+ "{dir}: {error}",
+ dir => $self->{mountdir},
+ error => $!));
+}
+
+=item create_volume(name, size)
+
+Create a new volume in the export storage domain
+
+=over
+
+=item name
+
+The name of the volume which is being created.
+
+=item size
+
+The size of the volume which is being created in bytes.
+
+=back
+
+create_volume() returns a Sys::VirtV2V::Target::RHEV::Vol object.
+
+=cut
+
+sub create_volume
+{
+ my $self = shift;
+ my ($name, $size) = @_;
+
+ return Sys::VirtV2V::Target::RHEV::Vol->_new($self->{mountdir},
+ $self->{domainuuid},
+ $size);
+}
+
+=item volume_exists (name)
+
+Check if volume I<name> exists in the target storage domain.
+
+Always returns 0, as RHEV storage domains don't have names
+
+=cut
+
+sub volume_exists
+{
+ my $self = shift;
+ my ($name) = @_;
+
+ return 0;
+}
+
+=item get_volume (name)
+
+Not defined for RHEV output
+
+=cut
+
+sub get_volume
+{
+ my $self = shift;
+ my ($name) = @_;
+
+ die("Cannot retrieve an existing RHEV storage volume by name");
+}
+
+=item create_guest(dom)
+
+Create the guest in the target
+
+=cut
+
+sub create_guest
+{
+ my $self = shift;
+ my ($dom, $guestcaps) = @_;
+
+ # Get the name of the guest
+ my ($name) = $dom->findnodes('/domain/name/text()');
+ $name = $name->getNodeValue();
+
+ # Get the number of virtual cpus
+ my ($ncpus) = $dom->findnodes('/domain/vcpu/text()');
+ $ncpus = $ncpus->getNodeValue();
+
+ # Get the amount of memory in MB
+ my ($memsize) = $dom->findnodes('/domain/memory/text()');
+ $memsize = $memsize->getNodeValue();
+ $memsize = int($memsize / 1024);
+
+ # Generate a creation date
+ my $now = gmtime();
+ my $vmcreation = sprintf("%02d/%02d/%d %02d:%02d:%02d",
+ $now->mday(), $now->mon() + 1, $now->year() + 1900,
+ $now->hour(), $now->min(), $now->sec());
+
+ my $osuuid = Sys::VirtV2V::Target::RHEV::UUIDHelper::get_uuid();
+
+ my $ovf = new XML::DOM::Parser->parse(<<EOF);
+<ovf:Envelope
+ xmlns:rasd="http://schemas.dmtf.org/wbem/wscim/1/cim-schema/2/CIM_ResourceAllocationSettingData"
+ xmlns:vssd="http://schemas.dmtf.org/wbem/wscim/1/cim-schema/2/CIM_VirtualSystemSettingData"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xmlns:ovf="http://schemas.dmtf.org/ovf/envelope/1/"
+ ovf:version="0.9">
+
+ <References/>
+
+ <Section xsi:type="ovf:NetworkSection_Type">
+ <Info>List of networks</Info>
+ </Section>
+
+ <Section xsi:type="ovf:DiskSection_Type">
+ <Info>List of Virtual Disks</Info>
+ </Section>
+
+ <Content ovf:id="out" xsi:type="ovf:VirtualSystem_Type">
+ <Name>$name</Name>
+ <TemplateId>00000000-0000-0000-0000-000000000000</TemplateId>
+ <TemplateName>Blank</TemplateName>
+ <Description>Imported with virt-v2v</Description>
+ <Domain/>
+ <CreationDate>$vmcreation</CreationDate>
+ <IsInitilized>True</IsInitilized>
+ <IsAutoSuspend>False</IsAutoSuspend>
+ <TimeZone/>
+ <IsStateless>False</IsStateless>
+ <Origin>0</Origin>
+ <VmType>1</VmType>
+ <DefaultDisplayType>0</DefaultDisplayType>
+
+ <Section ovf:id="$osuuid" ovf:required="false" xsi:type="ovf:OperatingSystemSection_Type">
+ <Info>Guest Operating System</Info>
+ <Description>Unassigned</Description>
+ </Section>
+
+ <Section xsi:type="ovf:VirtualHardwareSection_Type">
+ <Info>$ncpus CPU, $memsize Memory</Info>
+ <Item>
+ <rasd:Caption>$ncpus virtual cpu</rasd:Caption>
+ <rasd:Description>Number of virtual CPU</rasd:Description>
+ <rasd:InstanceId>1</rasd:InstanceId>
+ <rasd:ResourceType>3</rasd:ResourceType>
+ <rasd:num_of_sockets>$ncpus</rasd:num_of_sockets>
+ <rasd:cpu_per_socket>1</rasd:cpu_per_socket>
+ </Item>
+ <Item>
+ <rasd:Caption>$memsize MB of memory</rasd:Caption>
+ <rasd:Description>Memory Size</rasd:Description>
+ <rasd:InstanceId>2</rasd:InstanceId>
+ <rasd:ResourceType>4</rasd:ResourceType>
+ <rasd:AllocationUnits>MegaBytes</rasd:AllocationUnits>
+ <rasd:VirtualQuantity>$memsize</rasd:VirtualQuantity>
+ </Item>
+ <Item>
+ <rasd:Caption>USB Controller</rasd:Caption>
+ <rasd:InstanceId>4</rasd:InstanceId>
+ <rasd:ResourceType>23</rasd:ResourceType>
+ <rasd:UsbPolicy>Disabled</rasd:UsbPolicy>
+ </Item>
+ <Item>
+ <rasd:Caption>Graphical Controller</rasd:Caption>
+ <rasd:InstanceId>5</rasd:InstanceId>
+ <rasd:ResourceType>20</rasd:ResourceType>
+ <rasd:VirtualQuantity>1</rasd:VirtualQuantity>
+ </Item>
+ </Section>
+ </Content>
+</ovf:Envelope>
+EOF
+
+ $self->_disks($ovf, $dom);
+ $self->_networks($ovf, $dom);
+
+ my $nfs = Sys::VirtV2V::Target::RHEV::NFSHelper->new(sub {
+ my $mountdir = $self->{mountdir};
+ my $domainuuid = $self->{domainuuid};
+
+ my $vmuuid = Sys::VirtV2V::Target::RHEV::UUIDHelper::get_uuid();
+
+ my $dir = $mountdir.'/'.$domainuuid.'/master/vms/'.$vmuuid;
+ mkdir($dir)
+ or die(user_message(__x("Failed to create directory {dir}: {error}",
+ dir => $dir,
+ error => $!)));
+
+ my $vm;
+ my $ovfpath = $dir.'/'.$vmuuid.'.ovf';
+ open($vm, '>', $ovfpath)
+ or die(user_message(__x("Unable to open {path} for writing: ".
+ "{error}",
+ path => $ovfpath,
+ error => $!)));
+
+ print $vm $ovf->toString();
+ });
+ $nfs->check_exit();
+}
+
+sub _disks
+{
+ my $self = shift;
+ my ($ovf, $dom) = @_;
+
+ my ($references) = $ovf->findnodes('/ovf:Envelope/References');
+ die("no references") unless (defined($references));
+
+ my ($disksection) = $ovf->findnodes("/ovf:Envelope/Section".
+ "[\@xsi:type = 'ovf:DiskSection_Type']");
+ die("no disksection") unless (defined($disksection));
+
+ my ($virtualhardware) =
+ $ovf->findnodes("/ovf:Envelope/Content/Section".
+ "[\@xsi:type = 'ovf:VirtualHardwareSection_Type'");
+ die("no virtualhardware") unless (defined($virtualhardware));
+
+ my $driveno = 1;
+
+ foreach my $disk
+ ($dom->findnodes("/domain/devices/disk[\@device='disk']"))
+ {
+ my ($path) = $disk->findnodes('source/@file');
+ $path = $path->getNodeValue();
+
+ my $vol = Sys::VirtV2V::Target::RHEV::Vol->_get_by_path($path);
+
+ die("dom contains path not written by virt-v2v: $path\n".
+ $dom->toString()) unless (defined($vol));
+
+ my $fileref = $vol->_get_imageuuid().'/'.$vol->_get_voluuid();
+ my $size_gb = int($vol->_get_size()/1024/1024/1024);
+
+ # Add disk to References
+ my $file = $ovf->createElement("File");
+ $references->appendChild($file);
+
+ $file->setAttribute('ovf:href', $fileref);
+ $file->setAttribute('ovf:id', $vol->_get_voluuid());
+ $file->setAttribute('ovf:size', $vol->_get_size());
+ $file->setAttribute('ovf:description', 'imported by virt-v2v');
+
+ # Add disk to DiskSection
+ my $diske = $ovf->createElement("Disk");
+ $disksection->appendChild($diske);
+
+ $diske->setAttribute('ovf:diskId', $vol->_get_voluuid());
+ $diske->setAttribute('ovf:size', $size_gb);
+ $diske->setAttribute('ovf:actual_size', $size_gb);
+ $diske->setAttribute('ovf:fileRef', $fileref);
+ $diske->setAttribute('ovf:parentRef', '');
+ $diske->setAttribute('ovf:vm_snapshot_id',
+ '00000000-0000-0000-0000-000000000000');
+ $diske->setAttribute('ovf:volume-format', 'RAW');
+ $diske->setAttribute('ovf:volume-type', 'Sparse');
+ $diske->setAttribute('ovf:format', 'http://en.wikipedia.org/wiki/Byte');
+
+ # Add disk to VirtualHardware
+ my $item = $ovf->createElement('Item');
+ $virtualhardware->appendChild($item);
+
+ my $e;
+ $e = $ovf->createElement('rasd:Caption');
+ $e->addText("Drive $driveno"); # This text MUST begin with the string
+ # 'Drive ' or the file will not parse
+ $item->appendChild($e);
+
+ $e = $ovf->createElement('rasd:InstanceId');
+ $e->addText($vol->_get_voluuid());
+ $item->appendChild($e);
+
+ $e = $ovf->createElement('rasd:ResourceType');
+ $e->addText('17');
+ $item->appendChild($e);
+
+ $e = $ovf->createElement('rasd:HostResource');
+ $e->addText($fileref);
+ $item->appendChild($e);
+
+ $e = $ovf->createElement('rasd:Parent');
+ $e->addText('00000000-0000-0000-0000-000000000000');
+ $item->appendChild($e);
+
+ $e = $ovf->createElement('rasd:Template');
+ $e->addText('00000000-0000-0000-0000-000000000000');
+ $item->appendChild($e);
+
+ $e = $ovf->createElement('rasd:ApplicationList');
+ $item->appendChild($e);
+
+ $e = $ovf->createElement('rasd:StorageId');
+ $e->addText($self->{domainuuid});
+ $item->appendChild($e);
+
+ $e = $ovf->createElement('rasd:StoragePoolId');
+ $e->addText('00000000-0000-0000-0000-000000000000');
+ $item->appendChild($e);
+
+ my $volcreation = gmtime($vol->_get_creation());
+ my $voldate = sprintf("%02d/%02d/%d %02d:%02d:%02d",
+ $volcreation->mday(), $volcreation->mon() + 1,
+ $volcreation->year() + 1900, $volcreation->hour(),
+ $volcreation->min(), $volcreation->sec());
+
+ $e = $ovf->createElement('rasd:CreationDate');
+ $e->addText($voldate);
+ $item->appendChild($e);
+
+ $e = $ovf->createElement('rasd:LastModified');
+ $e->addText($voldate);
+ $item->appendChild($e);
+
+ $e = $ovf->createElement('rasd:last_modified_date');
+ $e->addText($voldate);
+ $item->appendChild($e);
+
+ $driveno++;
+ }
+}
+
+sub _networks
+{
+ my $self = shift;
+ my ($ovf, $dom) = @_;
+
+ my ($networksection) = $ovf->findnodes("/ovf:Envelope/Section".
+ "[\@xsi:type = 'ovf:NetworkSection_Type']");
+
+ my ($virtualhardware) =
+ $ovf->findnodes("/ovf:Envelope/Content/Section".
+ "[\@xsi:type = 'ovf:VirtualHardwareSection_Type'");
+ die("no virtualhardware") unless (defined($virtualhardware));
+
+ my $i = 0;
+
+ foreach my $if
+ ($dom->findnodes('/domain/devices/interface'))
+ {
+ # Extract relevant info about this NIC
+ my $type = $if->getAttribute('type');
+
+ my $name;
+ if ($type eq 'bridge') {
+ ($name) = $if->findnodes('source/@bridge');
+ } elsif ($type eq 'network') {
+ ($name) = $if->findnodes('source/@network');
+ } else {
+ # Should have been picked up in Converter
+ die("Unknown interface type");
+ }
+ $name = $name->getNodeValue();
+
+ my ($driver) = $if->findnodes('model/@type');
+ $driver &&= $driver->getNodeValue();
+
+ my ($mac) = $if->findnodes('mac/@address');
+ $mac &&= $mac->getNodeValue();
+
+ my $dev = "eth$i";
+
+ my $e = $ovf->createElement("Network");
+ $e->setAttribute('ovf:name', $name);
+ $networksection->appendChild($e);
+
+ my $item = $ovf->createElement('Item');
+ $virtualhardware->appendChild($item);
+
+ $e = $ovf->createElement('rasd:Caption');
+ $e->addText("Ethernet adapter on $name");
+ $item->appendChild($e);
+
+ $e = $ovf->createElement('rasd:InstanceId');
+ $e->addText('3');
+ $item->appendChild($e);
+
+ $e = $ovf->createElement('rasd:ResourceType');
+ $e->addText('10');
+ $item->appendChild($e);
+
+ $e = $ovf->createElement('rasd:ResourceSubType');
+ if ($driver eq 'rtl8139') {
+ $e->addText('1');
+ } elsif ($driver eq 'e1000') {
+ $e->addText('2');
+ } elsif ($driver eq 'virtio') {
+ $e->addText('3');
+ } else {
+ print STDERR (user_message(__x("Unknown NIC model {driver} for ".
+ "{dev}. NIC will be {default} ".
+ "when imported",
+ driver => $driver,
+ dev => $dev,
+ default => 'e1000')));
+ $e->addText('1');
+ }
+ $item->appendChild($e);
+
+ $e = $ovf->createElement('rasd:Connection');
+ $e->addText($name);
+ $item->appendChild($e);
+
+ $e = $ovf->createElement('rasd:Name');
+ $e->addText($dev);
+ $item->appendChild($e);
+
+ $e = $ovf->createElement('rasd:MACAddress');
+ $e->addText($mac) if (defined($mac));
+ $item->appendChild($e);
+
+ $i++;
+ }
+}
+
+=back
+
+=head1 COPYRIGHT
+
+Copyright (C) 2010 Red Hat Inc.
+
+=head1 LICENSE
+
+Please see the file COPYING for the full license.
+
+=cut
+
+1;
diff --git a/v2v/virt-v2v.conf b/v2v/virt-v2v.conf
index 7101e1e..4597adc 100644
--- a/v2v/virt-v2v.conf
+++ b/v2v/virt-v2v.conf
@@ -59,4 +59,16 @@
<network type='bridge' name='VM Network'>
<network type='network' name='default'/>
</network>
+
+ <!-- If importing to RHEV, you may want to use the default network name
+ 'rhevm' instead -->
+ <!--
+ <network type='bridge' name='xenbr1'>
+ <network type='network' name='rhevm'/>
+ </network>
+
+ <network type='bridge' name='VM Network'>
+ <network type='network' name='rhevm'/>
+ </network>
+ -->
</virt-v2v>
diff --git a/v2v/virt-v2v.pl b/v2v/virt-v2v.pl
index a9e834f..351caf1 100755
--- a/v2v/virt-v2v.pl
+++ b/v2v/virt-v2v.pl
@@ -37,6 +37,7 @@ use Sys::VirtV2V::Converter;
use Sys::VirtV2V::Connection::LibVirt;
use Sys::VirtV2V::Connection::LibVirtXML;
use Sys::VirtV2V::Target::LibVirt;
+use Sys::VirtV2V::Target::RHEV;
use Sys::VirtV2V::ExecHelper;
use Sys::VirtV2V::GuestOS;
use Sys::VirtV2V::UserMessage qw(user_message);
@@ -145,6 +146,21 @@ guest.
=cut
+my $output_storage_domain;
+
+=item B<-osd domain>
+
+Specifies the NFS path to a RHEV Export storage domain. Note that the storage
+domain must have been previously initialised by RHEV.
+
+The domain must be in the format <host>:<path>, eg:
+
+ rhev-storage.example.com:/rhev/export
+
+The nfs export must be mountable and writable by the machine running virt-v2v.
+
+=cut
+
my $config_file;
=item B<-f file> | B<--config file>
@@ -182,8 +198,10 @@ GetOptions ("help|?" => sub {
},
"i=s" => \$input_method,
"ic=s" => \$input_uri,
+ "o=s" => \$output_method,
"oc=s" => \$output_uri,
"op=s" => \$output_pool,
+ "osd=s" => \$output_storage_domain,
"f|config=s" => \$config_file
) or pod2usage(2);
@@ -208,7 +226,18 @@ if(defined($config_file)) {
my $target;
if ($output_method eq "libvirt") {
$target = new Sys::VirtV2V::Target::LibVirt($output_uri, $output_pool);
-} else {
+}
+
+elsif ($output_method eq "rhev") {
+ pod2usage({ -message => __("You must specify an output storage domain ".
+ "when using the rhev output method"),
+ -exitval => 1 })
+ unless (defined($output_storage_domain));
+
+ $target = new Sys::VirtV2V::Target::RHEV($output_storage_domain);
+}
+
+else {
die(user_message(__x("{output} is not a valid output method",
output => $output_method)));
}
@@ -272,9 +301,19 @@ my $storage = $conn->get_storage_paths();
# Create the transfer iso if required
my $transferiso = get_transfer_iso($config, $config_file);
+if ($output_method eq 'rhev') {
+ $) = "36 36";
+ $> = "36";
+}
+
# Open a libguestfs handle on the guest's storage devices
my $g = get_guestfs_handle($storage, $transferiso);
+if ($output_method eq 'rhev') {
+ $) = "0";
+ $> = "0";
+}
+
$SIG{'INT'} = \&close_guest_handle;
$SIG{'QUIT'} = \&close_guest_handle;
@@ -284,10 +323,12 @@ my $os = inspect_guest($g);
# Instantiate a GuestOS instance to manipulate the guest
my $guestos = Sys::VirtV2V::GuestOS->new($g, $os, $dom, $config);
-# Modify the guest and its metadata for the target hypervisor
+# Modify the guest and its metadata
my $guestcaps = Sys::VirtV2V::Converter->convert($guestos, $config, $dom, $os,
$conn->get_storage_devices());
+close_guest_handle();
+
$target->create_guest($dom, $guestcaps);
my ($name) = $dom->findnodes('/domain/name/text()');
@@ -315,6 +356,11 @@ sub close_guest_handle
if (defined($g)) {
$g->umount_all();
$g->sync();
+
+ # Note that this undef is what actually causes the underlying handle to
+ # be closed. This is required to allow the RHEV target's temporary mount
+ # directory to be unmounted and deleted prior to exit.
+ $g = undef;
}
}
--
1.6.6.1
More information about the Libguestfs
mailing list