verified that only tabs were removed by running "git diff -w". Signed-off-by: Laine Stump <laine@xxxxxxxxx> --- lib/Sys/Virt/TCK.pm | 544 +++++++++++------------ lib/Sys/Virt/TCK/Capabilities.pm | 84 ++-- lib/Sys/Virt/TCK/DomainBuilder.pm | 312 ++++++------- lib/Sys/Virt/TCK/NetworkBuilder.pm | 44 +- lib/Sys/Virt/TCK/NetworkHelpers.pm | 6 +- lib/Sys/Virt/TCK/SELinux.pm | 6 +- lib/Sys/Virt/TCK/StoragePoolBuilder.pm | 40 +- lib/Sys/Virt/TCK/StorageVolBuilder.pm | 48 +- lib/Sys/Virt/TCK/TAP/XMLFormatter.pm | 18 +- lib/Sys/Virt/TCK/TAP/XMLFormatterSession.pm | 66 +-- scripts/nwfilter/300-vsitype.t | 2 +- scripts/nwfilter/concurrency/chg-vm-filter.sh | 18 +- scripts/nwfilter/concurrency/start-destroy-vm.sh | 20 +- scripts/nwfilter/nwfilter2vmtest.sh | 42 +- 14 files changed, 625 insertions(+), 625 deletions(-) diff --git a/lib/Sys/Virt/TCK.pm b/lib/Sys/Virt/TCK.pm index 2259042..3f650a8 100644 --- a/lib/Sys/Virt/TCK.pm +++ b/lib/Sys/Virt/TCK.pm @@ -52,14 +52,14 @@ sub new { my %params = @_; $self->{config} = $params{config} ? $params{config} : - Config::Record->new(file => ($ENV{LIBVIRT_TCK_CONFIG} || "/etc/tck.conf")); + Config::Record->new(file => ($ENV{LIBVIRT_TCK_CONFIG} || "/etc/tck.conf")); $self->{autoclean} = $params{autoclean} ? $params{autoclean} : - ($ENV{LIBVIRT_TCK_AUTOCLEAN} || 0); + ($ENV{LIBVIRT_TCK_AUTOCLEAN} || 0); if ($ENV{LIBVIRT_TCK_DEBUG}) { - $SIG{__WARN__} = sub { Carp::cluck $_[0]; }; - $SIG{__DIE__} = sub { Carp::confess $_[0]; }; + $SIG{__WARN__} = sub { Carp::cluck $_[0]; }; + $SIG{__DIE__} = sub { Carp::confess $_[0]; }; } bless $self, $class; @@ -112,32 +112,32 @@ sub sanity_check { my @doms = grep { $_->get_name =~ /^tck/ } $conn->list_domains; if (@doms) { - die "there is/are " . int(@doms) . " pre-existing active domain(s) in this driver"; + die "there is/are " . int(@doms) . " pre-existing active domain(s) in this driver"; } @doms = grep { $_->get_name =~ /^tck/ } $conn->list_defined_domains; if (@doms) { - die "there is/are " . int(@doms) . " pre-existing inactive domain(s) in this driver"; + die "there is/are " . int(@doms) . " pre-existing inactive domain(s) in this driver"; } my @nets = grep { $_->get_name =~ /^tck/ } $conn->list_networks; if (@nets) { - die "there is/are " . int(@nets) . " pre-existing active network(s) in this driver"; + die "there is/are " . int(@nets) . " pre-existing active network(s) in this driver"; } @nets = grep { $_->get_name =~ /^tck/ } $conn->list_defined_networks; if (@nets) { - die "there is/are " . int(@nets) . " pre-existing inactive network(s) in this driver"; + die "there is/are " . int(@nets) . " pre-existing inactive network(s) in this driver"; } my @pools = grep { $_->get_name =~ /^tck/ } $conn->list_storage_pools; if (@pools) { - die "there is/are " . int(@pools) . " pre-existing active storage_pool(s) in this driver"; + die "there is/are " . int(@pools) . " pre-existing active storage_pool(s) in this driver"; } @pools = grep { $_->get_name =~ /^tck/ } $conn->list_defined_storage_pools; if (@pools) { - die "there is/are " . int(@pools) . " pre-existing inactive storage_pool(s) in this driver"; + die "there is/are " . int(@pools) . " pre-existing inactive storage_pool(s) in this driver"; } } @@ -148,7 +148,7 @@ sub reset_snapshots { # Use eval as not all drivers support snapshots my @domss = eval { $dom->list_snapshots }; foreach my $domss (@domss) { - $domss->delete; + $domss->delete; } } @@ -158,16 +158,16 @@ sub reset_domains { my @doms = grep { $_->get_name =~ /^tck/ } $conn->list_domains; foreach my $dom (@doms) { - $self->reset_snapshots($dom); - if ($dom->get_id != 0) { - $dom->destroy; - } + $self->reset_snapshots($dom); + if ($dom->get_id != 0) { + $dom->destroy; + } } @doms = grep { $_->get_name =~ /^tck/ } $conn->list_defined_domains(); foreach my $dom (@doms) { - $self->reset_snapshots($dom); - $dom->undefine; + $self->reset_snapshots($dom); + $dom->undefine; } } @@ -177,14 +177,14 @@ sub reset_networks { my @nets = grep { $_->get_name =~ /^tck/ } $conn->list_networks; foreach my $net (@nets) { - if ($net->is_active()) { - $net->destroy; - } + if ($net->is_active()) { + $net->destroy; + } } @nets = grep { $_->get_name =~ /^tck/ } $conn->list_defined_networks(); foreach my $net (@nets) { - $net->undefine; + $net->undefine; } } @@ -194,19 +194,19 @@ sub reset_storage_pools { my @pools = grep { $_->get_name =~ /^tck/ } $conn->list_storage_pools; foreach my $pool (@pools) { - my @vols = $pool->list_volumes; - foreach my $vol (@vols) { - eval { $vol->delete(0) }; - } - $pool->destroy; + my @vols = $pool->list_volumes; + foreach my $vol (@vols) { + eval { $vol->delete(0) }; + } + $pool->destroy; } @pools = grep { $_->get_name =~ /^tck/ } $conn->list_defined_storage_pools(); foreach my $pool (@pools) { - eval { - $pool->delete(0); - }; - $pool->undefine; + eval { + $pool->delete(0); + }; + $pool->undefine; } } @@ -224,7 +224,7 @@ sub cleanup { my $self = shift; foreach my $conn (@{$self->{conns}}) { - $self->reset($conn); + $self->reset($conn); } delete $self->{conns}; @@ -234,10 +234,10 @@ sub config { my $self = shift; my $key = shift; if (@_) { - my $default = shift; - return $self->{config}->get($key, $default); + my $default = shift; + return $self->{config}->get($key, $default); } else { - return $self->{config}->get($key); + return $self->{config}->get($key); } } @@ -253,8 +253,8 @@ sub scratch_dir { my $self = shift; my $scratch = $self->config("scratch_dir", $< > 0 ? - catdir(cwd(), "libvirt-tck") : - catdir(rootdir(), "var", "cache", "libvirt-tck")); + catdir(cwd(), "libvirt-tck") : + catdir(rootdir(), "var", "cache", "libvirt-tck")); mkpath($scratch) unless -e $scratch; @@ -286,14 +286,14 @@ sub get_scratch_resource { my $uncompress = undef; if (ref($source)) { - $uncompress = $source->{uncompress}; - $source = $source->{source}; + $uncompress = $source->{uncompress}; + $source = $source->{source}; } if ($source =~ m,^/,) { - $self->copy_scratch($source, $target, $uncompress); + $self->copy_scratch($source, $target, $uncompress); } else { - $self->download_scratch($source, $target, $uncompress); + $self->download_scratch($source, $target, $uncompress); } return $target; @@ -314,22 +314,22 @@ sub download_scratch { my $response = $ua->get($source); if ($response->is_success) { - open TGT, ">$target" or die "cannot create $target: $!"; - if (defined $uncompress) { - my $data = $response->content; - if ($uncompress eq "gzip") { - gunzip \$data => \*TGT; - } elsif ($uncompress eq "bzip2") { - bunzip2 \$data => \*TGT; - } else { - die "unknown compression method '$uncompress'"; - } - } else { - print TGT $response->content or die "cannot write $target: $!"; - } - close TGT or die "cannot save $target: $!"; + open TGT, ">$target" or die "cannot create $target: $!"; + if (defined $uncompress) { + my $data = $response->content; + if ($uncompress eq "gzip") { + gunzip \$data => \*TGT; + } elsif ($uncompress eq "bzip2") { + bunzip2 \$data => \*TGT; + } else { + die "unknown compression method '$uncompress'"; + } + } else { + print TGT $response->content or die "cannot write $target: $!"; + } + close TGT or die "cannot save $target: $!"; } else { - die "cannot download $source: " . $response->status_line; + die "cannot download $source: " . $response->status_line; } } @@ -342,15 +342,15 @@ sub copy_scratch { print "# copying $source\n"; if (defined $uncompress) { - if ($uncompress eq "gzip") { - gunzip $source => $target; - } elsif ($uncompress eq "bzip2") { - bunzip2 $source => $target; - } else { - die "unknown compression method '$uncompress'"; - } + if ($uncompress eq "gzip") { + gunzip $source => $target; + } elsif ($uncompress eq "bzip2") { + bunzip2 $source => $target; + } else { + die "unknown compression method '$uncompress'"; + } } else { - copy ($source, $target) or die "cannot copy $source to $target: $!"; + copy ($source, $target) or die "cannot copy $source to $target: $!"; } } @@ -401,7 +401,7 @@ sub create_virt_builder_disk { my $password = $self->root_password; if ($self->has_disk_image($bucket, $name, $osname)) { - return $target; + return $target; } print "# running virt-builder $osname\n"; @@ -448,9 +448,9 @@ sub create_minimal_vroot { my @dirs = qw(sbin bin dev proc sys tmp); foreach my $dir (@dirs) { - my $fulldir = catdir($target, $dir); - next if -e $fulldir; - mkpath($fulldir); + my $fulldir = catdir($target, $dir); + next if -e $fulldir; + mkpath($fulldir); } my $dst = catfile($target, "sbin", "busybox"); @@ -514,10 +514,10 @@ dumpleases iptunnel pidof sum echo kbd_mode ping sv); foreach my $file (@links) { - my $fullfile = catfile($target, "bin", $file); - next if -e $fullfile; - symlink "../sbin/busybox", $fullfile - or die "cannot symlink $fullfile to ../sbin/busybox: $!"; + my $fullfile = catfile($target, "bin", $file); + next if -e $fullfile; + symlink "../sbin/busybox", $fullfile + or die "cannot symlink $fullfile to ../sbin/busybox: $!"; } my $init = catfile($target, "sbin", "init"); @@ -541,18 +541,18 @@ sub best_domain { my $ostype = shift; for (my $i = 0 ; $i < $caps->num_guests ; $i++) { - if ($caps->guest_os_type($i) eq $ostype && - $caps->guest_arch_name($i) eq $caps->host_cpu_arch()) { + if ($caps->guest_os_type($i) eq $ostype && + $caps->guest_arch_name($i) eq $caps->host_cpu_arch()) { - my @domains = $caps->guest_domain_types($i); - next unless int(@domains); + my @domains = $caps->guest_domain_types($i); + next unless int(@domains); - # Prefer kvm if multiple domain types are returned - my $domain = (grep /^kvm$/, @domains) ? "kvm" : $domains[0]; + # Prefer kvm if multiple domain types are returned + my $domain = (grep /^kvm$/, @domains) ? "kvm" : $domains[0]; - return ($domain, - $caps->host_cpu_arch()); - } + return ($domain, + $caps->host_cpu_arch()); + } } return (); @@ -566,19 +566,19 @@ sub match_guest_domain { my $ostype = shift; for (my $i = 0 ; $i < $caps->num_guests ; $i++) { - if ($caps->guest_os_type($i) eq $ostype && - $caps->guest_arch_name($i) eq $arch) { + if ($caps->guest_os_type($i) eq $ostype && + $caps->guest_arch_name($i) eq $arch) { - my @domains = $caps->guest_domain_types($i); - next unless int(@domains); + my @domains = $caps->guest_domain_types($i); + next unless int(@domains); - # Prefer kvm if multiple domain types are returned - my $domain = (grep /^kvm$/, @domains) ? "kvm" : $domains[0]; + # Prefer kvm if multiple domain types are returned + my $domain = (grep /^kvm$/, @domains) ? "kvm" : $domains[0]; - return ($domain, - $caps->guest_domain_emulator($i, $domain), - $caps->guest_domain_loader($i, $domain)); - } + return ($domain, + $caps->guest_domain_emulator($i, $domain), + $caps->guest_domain_loader($i, $domain)); + } } return (); @@ -594,25 +594,25 @@ sub best_kernel { my $hostarch = $caps->host_cpu_arch(); for (my $i = 0 ; $i <= $#{$kernels} ; $i++) { - my $arch = $kernels->[$i]->{arch}; - my $ostype = $kernels->[$i]->{ostype}; - my @ostype = ref($ostype) ? @{$ostype} : ($ostype); + my $arch = $kernels->[$i]->{arch}; + my $ostype = $kernels->[$i]->{ostype}; + my @ostype = ref($ostype) ? @{$ostype} : ($ostype); - next unless $arch eq $hostarch; + next unless $arch eq $hostarch; - foreach $ostype (@ostype) { - if ((defined $wantostype) && - ($wantostype ne $ostype)) { - next; - } + foreach $ostype (@ostype) { + if ((defined $wantostype) && + ($wantostype ne $ostype)) { + next; + } - my ($domain, $emulator, $loader) = - $self->match_guest_domain($caps, $arch, $ostype); + my ($domain, $emulator, $loader) = + $self->match_guest_domain($caps, $arch, $ostype); - if (defined $domain) { - return ($i, $domain, $arch, $ostype, $emulator, $loader) - } - } + if (defined $domain) { + return ($i, $domain, $arch, $ostype, $emulator, $loader) + } + } } return (); @@ -629,25 +629,25 @@ sub best_image { my $hostarch = $caps->host_cpu_arch(); for (my $i = 0 ; $i <= $#{$images} ; $i++) { - my $arch = $images->[$i]->{arch}; - my $ostype = $images->[$i]->{ostype}; - my @ostype = ref($ostype) ? @{$ostype} : ($ostype); + my $arch = $images->[$i]->{arch}; + my $ostype = $images->[$i]->{ostype}; + my @ostype = ref($ostype) ? @{$ostype} : ($ostype); - next unless $arch eq $hostarch; + next unless $arch eq $hostarch; - foreach $ostype (@ostype) { - if ((defined $wantostype) && - ($wantostype ne $ostype)) { - next; - } + foreach $ostype (@ostype) { + if ((defined $wantostype) && + ($wantostype ne $ostype)) { + next; + } - my ($domain, $emulator, $loader) = - $self->match_guest_domain($caps, $arch, $ostype); + my ($domain, $emulator, $loader) = + $self->match_guest_domain($caps, $arch, $ostype); - if (defined $domain) { - return ($i, $domain, $arch, $ostype, $emulator, $loader) - } - } + if (defined $domain) { + return ($i, $domain, $arch, $ostype, $emulator, $loader) + } + } } return (); @@ -660,17 +660,17 @@ sub get_disk_dev { my $dev; if ($ostype eq "xen") { - $dev = "xvda"; + $dev = "xvda"; } elsif ($ostype eq "uml") { - $dev = "ubda"; + $dev = "ubda"; } elsif ($ostype eq "hvm") { - if ($domain eq "kvm" || - $domain eq "qemu" || - $domain eq "kqemu") { - $dev = "vda"; - } else { - $dev = "hda"; - } + if ($domain eq "kvm" || + $domain eq "qemu" || + $domain eq "kqemu") { + $dev = "vda"; + } else { + $dev = "hda"; + } } return $dev; } @@ -682,10 +682,10 @@ sub get_kernel { my $wantostype = shift; my ($cfgindex, $domain, $arch, $ostype, $emulator, $loader) = - $self->best_kernel($caps, $wantostype); + $self->best_kernel($caps, $wantostype); if (!defined $cfgindex) { - die "cannot find any supported kernel configuration"; + die "cannot find any supported kernel configuration"; } my $kernels = $self->config("kernels", []); @@ -701,7 +701,7 @@ sub get_kernel { my $dfile = $disk ? $self->get_scratch_resource($disk, $bucket, "disk.img") : undef; unless (defined $dfile) { - $dfile = $self->create_sparse_disk($bucket, "disk.img", 100); + $dfile = $self->create_sparse_disk($bucket, "disk.img", 100); } chmod 0755, $kfile; @@ -709,15 +709,15 @@ sub get_kernel { my $dev = $self->get_disk_dev($ostype, $domain); return ( - domain => $domain, - arch => $arch, - ostype => $ostype, - emulator => $emulator, - loader => $loader, - kernel => $kfile, - initrd => $ifile, - root => $dfile, - dev => $dev, + domain => $domain, + arch => $arch, + ostype => $ostype, + emulator => $emulator, + loader => $loader, + kernel => $kfile, + initrd => $ifile, + root => $dfile, + dev => $dev, ); } @@ -728,10 +728,10 @@ sub get_image { my $wantostype = shift; my ($cfgindex, $domain, $arch, $ostype, $emulator, $loader) = - $self->best_image($caps, $wantostype); + $self->best_image($caps, $wantostype); if (!defined $cfgindex) { - die "cannot find any supported image configuration"; + die "cannot find any supported image configuration"; } my $kernels = $self->config("images", []); @@ -746,13 +746,13 @@ sub get_image { my $dev = $self->get_disk_dev($ostype, $domain); return ( - domain => $domain, - arch => $arch, - ostype => $ostype, - emulator => $emulator, - loader => $loader, - root => $dfile, - dev => $dev, + domain => $domain, + arch => $arch, + ostype => $ostype, + emulator => $emulator, + loader => $loader, + root => $dfile, + dev => $dev, firstboot => $needs_firstboot, ); } @@ -769,78 +769,78 @@ sub generic_machine_domain { my $filterref = exists $params{filterref} ? $params{filterref} : undef; if ($fullos) { - my %config = $self->get_image($caps, $ostype); + my %config = $self->get_image($caps, $ostype); my $b = Sys::Virt::TCK::DomainBuilder->new(conn => $self->conn, - name => $name, - arch => $config{arch}, - domain => $config{domain}, - ostype => $config{ostype}); - $b->memory(1024 * 1024); - $b->with_acpi(); - $b->with_apic(); + name => $name, + arch => $config{arch}, + domain => $config{domain}, + ostype => $config{ostype}); + $b->memory(1024 * 1024); + $b->with_acpi(); + $b->with_apic(); - $b->boot_disk(); + $b->boot_disk(); - $b->disk(src => $config{root}, - dst => $config{dev}, - type => "file"); + $b->disk(src => $config{root}, + dst => $config{dev}, + type => "file"); - if ($config{firstboot}) { - print "# Running the first boot\n"; + if ($config{firstboot}) { + print "# Running the first boot\n"; - $b->interface(type => "network", - source => "default", + $b->interface(type => "network", + source => "default", model => "virtio", - mac => "52:54:00:11:11:11", - filterref => $filterref); - my $xml = $b->as_xml(); - # Cleanup the temporary interface - $b->rminterface(); - - my $dom = $self->conn->define_domain($xml); - $dom->create(); - - # Wait for the first boot to reach network setting - my $stats; - my $tries = 0; - do { - sleep(10); - $stats = $dom->interface_stats("vnet0"); - $tries++; - } while ($stats->{"tx_packets"} < 10 && $tries < 10); - - # Safe to shutdown domain now - my $target = time() + 30; - $dom->shutdown; - while ($dom->is_active()) { - sleep(1); - $dom->destroy() if time() > $target; - } - sleep(1); - $dom->undefine(); - } - - return $b; + mac => "52:54:00:11:11:11", + filterref => $filterref); + my $xml = $b->as_xml(); + # Cleanup the temporary interface + $b->rminterface(); + + my $dom = $self->conn->define_domain($xml); + $dom->create(); + + # Wait for the first boot to reach network setting + my $stats; + my $tries = 0; + do { + sleep(10); + $stats = $dom->interface_stats("vnet0"); + $tries++; + } while ($stats->{"tx_packets"} < 10 && $tries < 10); + + # Safe to shutdown domain now + my $target = time() + 30; + $dom->shutdown; + while ($dom->is_active()) { + sleep(1); + $dom->destroy() if time() > $target; + } + sleep(1); + $dom->undefine(); + } + + return $b; } else { - my %config = $self->get_kernel($caps, $ostype); - - my $b = Sys::Virt::TCK::DomainBuilder->new(conn => $self->conn, - name => $name, - arch => $config{arch}, - domain => $config{domain}, - ostype => $config{ostype}); - $b->memory(1024 * 1024); - $b->with_acpi(); - $b->with_apic(); - - # XXX boot CDROM or vroot for other HVs - $b->boot_kernel($config{kernel}, $config{initrd}); - - $b->disk(src => $config{root}, - dst => $config{dev}, - type => "file"); - return $b; + my %config = $self->get_kernel($caps, $ostype); + + my $b = Sys::Virt::TCK::DomainBuilder->new(conn => $self->conn, + name => $name, + arch => $config{arch}, + domain => $config{domain}, + ostype => $config{ostype}); + $b->memory(1024 * 1024); + $b->with_acpi(); + $b->with_apic(); + + # XXX boot CDROM or vroot for other HVs + $b->boot_kernel($config{kernel}, $config{initrd}); + + $b->disk(src => $config{root}, + dst => $config{dev}, + type => "file"); + return $b; } } @@ -850,12 +850,12 @@ sub best_container_domain { my $caps = shift; for (my $i = 0 ; $i < $caps->num_guests ; $i++) { - if ($caps->guest_os_type($i) eq "exe") { - my @domains = $caps->guest_domain_types($i); - next unless int(@domains); + if ($caps->guest_os_type($i) eq "exe") { + my @domains = $caps->guest_domain_types($i); + next unless int(@domains); - return $domains[0]; - } + return $domains[0]; + } } return undef; @@ -872,9 +872,9 @@ sub generic_container_domain { my $bucket = "os-exe"; my $b = Sys::Virt::TCK::DomainBuilder->new(conn => $self->conn, - name => $name, - domain => $domain, - ostype => "exe"); + name => $name, + domain => $domain, + ostype => "exe"); $b->memory(64 * 1024); my ($root, $init) = $self->create_minimal_vroot($bucket, $name); @@ -882,8 +882,8 @@ sub generic_container_domain { $b->boot_init($init); $b->filesystem(src => $root, - dst => "/", - type => "mount"); + dst => "/", + type => "mount"); return $b; } @@ -904,38 +904,38 @@ sub generic_domain { my $container; $container = $self->best_container_domain($caps) - unless $ostype && $ostype ne "exe"; + unless $ostype && $ostype ne "exe"; my $b; if ($container) { - die "Full provisioned OS not supported with containers yet" if $fullos; + die "Full provisioned OS not supported with containers yet" if $fullos; - $b = $self->generic_container_domain(name => $name, - caps => $caps, - domain => $container); + $b = $self->generic_container_domain(name => $name, + caps => $caps, + domain => $container); } else { - $b = $self->generic_machine_domain(name => $name, - caps => $caps, - ostype => $ostype, + $b = $self->generic_machine_domain(name => $name, + caps => $caps, + ostype => $ostype, fullos => $fullos, filterref => $filterref); } if ($netmode) { - if ($netmode eq "vepa") { - $b->interface(type => "direct", - source => "default", + if ($netmode eq "vepa") { + $b->interface(type => "direct", + source => "default", model => "virtio", - mac => "52:54:00:11:11:11", - dev => $self->get_host_network_device(), - mode => "vepa", - virtualport => "802.1Qbg"); - } else { - $b->interface(type => "network", - source => "default", + mac => "52:54:00:11:11:11", + dev => $self->get_host_network_device(), + mode => "vepa", + virtualport => "802.1Qbg"); + } else { + $b->interface(type => "network", + source => "default", model => "virtio", - mac => "52:54:00:11:11:11", - filterref => $filterref); - } + mac => "52:54:00:11:11:11", + filterref => $filterref); + } } return $b; } @@ -948,7 +948,7 @@ sub generic_pool { my $bucket = $self->bucket_dir("storage-fs"); my $b = Sys::Virt::TCK::StoragePoolBuilder->new(name => $name, - type => $type); + type => $type); $b->target(catdir($bucket, $name)); @@ -994,7 +994,7 @@ sub _quiet_caller (;$) { ## no critic Prototypes else { return CORE::caller($height); } - } + } sub _try_as_caller { my $coderef = shift; @@ -1018,26 +1018,26 @@ sub ok_object($$$;$) { my $name = shift; die "must pass coderef, class, description and (optional) expected name" - unless defined $description; + unless defined $description; my ($ret, $exception) = _try_as_caller($coderef, 4); my $ok = "$exception" eq "" && - $ret && ref($ret) && $ret->isa($class) && - (!defined $name || ($ret->get_name() eq $name)); + $ret && ref($ret) && $ret->isa($class) && + (!defined $name || ($ret->get_name() eq $name)); $Tester->ok($ok, $description); unless ($ok) { - $Tester->diag("expected $class object" . ($name ? " with name $name" : "")); - if ($exception) { - $Tester->diag("found '$exception'"); - } else { - if ($ret && ref($ret) && $ret->isa($class)) { - $Tester->diag("found $class object with name " . $ret->get_name); - } else { - $Tester->diag("found '$ret'"); - } - } + $Tester->diag("expected $class object" . ($name ? " with name $name" : "")); + if ($exception) { + $Tester->diag("found '$exception'"); + } else { + if ($ret && ref($ret) && $ret->isa($class)) { + $Tester->diag("found $class object with name " . $ret->get_name); + } else { + $Tester->diag("found '$ret'"); + } + } } } @@ -1104,17 +1104,17 @@ sub ok_error(&$;$) { my $code = shift; die "must pass coderef, description and (optional) expected error code" - unless defined $description; + unless defined $description; my ($ret, $exception) = _try_as_caller($coderef, 3); my $ok = ref($exception) && $exception->isa("Sys::Virt::Error") && - (!defined $code || ($exception->code() == $code)); + (!defined $code || ($exception->code() == $code)); $Tester->ok($ok, $description); unless ($ok) { - $Tester->diag("expecting Sys::Virt::Error object" . ($code ? " with code $code" : "")); - $Tester->diag("found '$exception'"); + $Tester->diag("expecting Sys::Virt::Error object" . ($code ? " with code $code" : "")); + $Tester->diag("found '$exception'"); } $@ = $exception; return $ok; @@ -1125,10 +1125,10 @@ sub err_not_implemented { my $exception = shift; if ($exception && - ref($exception) && - $exception->isa("Sys::Virt::Error") && - $exception->code() == 3) { - return 1; + ref($exception) && + $exception->isa("Sys::Virt::Error") && + $exception->code() == 3) { + return 1; } return 0; } @@ -1151,7 +1151,7 @@ sub get_host_usb_device { my $devs = $self->config("host_usb_devices", []); if ($devindex > $#{$devs}) { - return (); + return (); } my $bus = $self->config("host_usb_devices/[$devindex]/bus", undef); @@ -1169,7 +1169,7 @@ sub get_host_pci_device { my $devs = $self->config("host_pci_devices", []); if ($devindex > $#{$devs}) { - return (); + return (); } my $domain = $self->config("host_pci_devices/[$devindex]/domain", 0); @@ -1185,7 +1185,7 @@ sub get_host_block_device { my $devindex = @_ ? shift : 0; my $device = ($self->config("host_block_devices/[$devindex]/path", undef) - || $self->config("host_block_devices/[$devindex]", undef)); + || $self->config("host_block_devices/[$devindex]", undef)); return undef unless $device; my $kb_blocks = $self->config("host_block_devices/[$devindex]/size", 0); @@ -1193,7 +1193,7 @@ sub get_host_block_device { # Filter out devices that the current user can't open. sysopen(BLK, $device, O_RDONLY) or return undef; my $match = ($kb_blocks ? sysseek(BLK, 0, SEEK_END) == $kb_blocks * 1024 - : 1); + : 1); close BLK; return $match ? $device : undef; diff --git a/lib/Sys/Virt/TCK/Capabilities.pm b/lib/Sys/Virt/TCK/Capabilities.pm index 281f41e..ef2c87a 100644 --- a/lib/Sys/Virt/TCK/Capabilities.pm +++ b/lib/Sys/Virt/TCK/Capabilities.pm @@ -59,7 +59,7 @@ sub _parse_capabilities { $self->_parse_host($host) if $host; foreach my $child ($node->children("guest")) { - $self->_parse_guest($child); + $self->_parse_guest($child); } } @@ -92,11 +92,11 @@ sub _parse_host_cpu { my $feat = $node->first_child("features"); if (defined $feat) { - $cpu->{features} = {}; - foreach my $child ($feat->children()) { - my $name = $child->name; - $cpu->{features}->{$name} = 1; - } + $cpu->{features} = {}; + foreach my $child ($feat->children()) { + my $name = $child->name; + $cpu->{features}->{$name} = 1; + } } $self->{host}->{cpu} = $cpu; @@ -116,9 +116,9 @@ sub _parse_host_migration { $mig->{transports} = []; my $trans = $node->first_child("uri_transports"); if (defined $trans) { - foreach my $child ($trans->children("uri_transport")) { - push @{$mig->{transports}}, $child->text; - } + foreach my $child ($trans->children("uri_transport")) { + push @{$mig->{transports}}, $child->text; + } } $self->{host}->{migration} = $mig; @@ -136,16 +136,16 @@ sub _parse_host_topology { my @cells; foreach my $cell ($cells->children("cell")) { - my $topcell = []; - push @{$top}, $topcell; + my $topcell = []; + push @{$top}, $topcell; - my $cpus = $cell->first_child("cpus"); - next unless $cpus; + my $cpus = $cell->first_child("cpus"); + next unless $cpus; - foreach my $cpu ($cpus->children("cpu")) { - my $id = $cpu->att("id"); - push @{$topcell}, $id; - } + foreach my $cpu ($cpus->children("cpu")) { + my $id = $cpu->att("id"); + push @{$topcell}, $id; + } } $self->{host}->{topology} = $top; @@ -156,8 +156,8 @@ sub _parse_host_secmodel { my $node = shift; my $sec = { - model => $node->first_child_text("model"), - doi => $node->first_child_text("doi"), + model => $node->first_child_text("model"), + doi => $node->first_child_text("doi"), }; $self->{host}->{secmodel} = $sec; @@ -175,44 +175,44 @@ sub _parse_guest { my $wordsize = $arch->first_child_text("wordsize"); $guest->{arch} = { - name => $arch->att("name"), - wordsize => $wordsize, - domains => {}, + name => $arch->att("name"), + wordsize => $wordsize, + domains => {}, }; my $defemu = $arch->first_child("emulator") ? $arch->first_child_text("emulator") : undef; my $defload = $arch->first_child("loader") ? $arch->first_child_text("loader") : undef; my @defmachines = (); foreach my $child ($arch->children("machine")) { - push @defmachines, $child->text; + push @defmachines, $child->text; } foreach my $dom ($arch->children("domain")) { - my $emu = $dom->first_child("emulator") ? $dom->first_child_text("emulator") : undef; - my $load = $dom->first_child("loader") ? $dom->first_child_text("loader") : undef; - my @machines = (); - foreach my $child ($dom->children("machine")) { - push @machines, $child->text; - } - $emu = $defemu unless $emu; - $load = $defload unless $load; - @machines = @defmachines unless @machines; - - my $type = $dom->att("type"); - $guest->{arch}->{domains}->{$type} = { - emulator => $emu, - loader => $load, - machines => \@machines, - }; + my $emu = $dom->first_child("emulator") ? $dom->first_child_text("emulator") : undef; + my $load = $dom->first_child("loader") ? $dom->first_child_text("loader") : undef; + my @machines = (); + foreach my $child ($dom->children("machine")) { + push @machines, $child->text; + } + $emu = $defemu unless $emu; + $load = $defload unless $load; + @machines = @defmachines unless @machines; + + my $type = $dom->att("type"); + $guest->{arch}->{domains}->{$type} = { + emulator => $emu, + loader => $load, + machines => \@machines, + }; } $guest->{features} = {}; my $features = $node->first_child("features"); if ($features) { - foreach my $child ($features->children) { - $guest->{features}->{$child->name} = 1; - } + foreach my $child ($features->children) { + $guest->{features}->{$child->name} = 1; + } } push @{$self->{guests}}, $guest; diff --git a/lib/Sys/Virt/TCK/DomainBuilder.pm b/lib/Sys/Virt/TCK/DomainBuilder.pm index e9453ee..fb9a31f 100644 --- a/lib/Sys/Virt/TCK/DomainBuilder.pm +++ b/lib/Sys/Virt/TCK/DomainBuilder.pm @@ -31,24 +31,24 @@ sub new { my $ostype = $params{ostype} ? $params{ostype} : die "ostype parameter is required"; my $self = { - name => $params{name} ? $params{name} : "tck" , - type => $domain, - ostype => $ostype, - boot => { type => "disk" }, - arch => $params{arch} ? $params{arch} : undef, - emulator => undef, - lifecycle => {}, - features => {}, - disks => [], - filesystems => [], - interfaces => [], - serials => [], - parallels => [], - consoles => [], - inputs => [], - graphics => [], - hostdevs => [], - seclabel => {}, + name => $params{name} ? $params{name} : "tck" , + type => $domain, + ostype => $ostype, + boot => { type => "disk" }, + arch => $params{arch} ? $params{arch} : undef, + emulator => undef, + lifecycle => {}, + features => {}, + disks => [], + filesystems => [], + interfaces => [], + serials => [], + parallels => [], + consoles => [], + inputs => [], + graphics => [], + hostdevs => [], + seclabel => {}, }; bless $self, $class; @@ -61,7 +61,7 @@ sub memory { my $mem = shift; $self->{memory} = $mem - unless defined $self->{memory}; + unless defined $self->{memory}; $self->{currentMemory} = $mem; return $self; @@ -95,7 +95,7 @@ sub boot_network { my $self = shift; $self->{boot} = { - type => "network" + type => "network" }; return $self; @@ -105,7 +105,7 @@ sub boot_disk { my $self = shift; $self->{boot} = { - type => "disk" + type => "disk" }; return $self; @@ -115,7 +115,7 @@ sub boot_cdrom { my $self = shift; $self->{boot} = { - type => "cdrom" + type => "cdrom" }; return $self; @@ -125,7 +125,7 @@ sub boot_floppy { my $self = shift; $self->{boot} = { - type => "floppy" + type => "floppy" }; return $self; @@ -140,10 +140,10 @@ sub boot_kernel { die "kernel parameter is required" unless $kernel; $self->{boot} = { - type => "kernel", - kernel => $kernel, - ($initrd ? (initrd => $initrd) : ()), - ($cmdline ? (cmdline => $cmdline) : ()), + type => "kernel", + kernel => $kernel, + ($initrd ? (initrd => $initrd) : ()), + ($cmdline ? (cmdline => $cmdline) : ()), }; return $self; @@ -154,8 +154,8 @@ sub boot_bootloader { my $path = shift; $self->{boot} = { - type => "bootloader", - bootloader => $path + type => "bootloader", + bootloader => $path }; return $self; @@ -167,8 +167,8 @@ sub boot_init { my $path = shift; $self->{boot} = { - type => "init", - init => $path + type => "init", + init => $path }; return $self; @@ -182,10 +182,10 @@ sub boot_cmdline { my $initrd = $self->{boot}->{initrd}; $self->{boot} = { - type => "kernel", - kernel => $kernel, - initrd => $initrd, - cmdline => $cmdline + type => "kernel", + kernel => $kernel, + initrd => $initrd, + cmdline => $cmdline }; return $self; @@ -195,10 +195,10 @@ sub clear_kernel_initrd_cmdline { my $self = shift; $self->{boot} = { - type => "kernel", - kernel => "", - initrd => "", - cmdline => "" + type => "kernel", + kernel => "", + initrd => "", + cmdline => "" }; return $self; } @@ -334,168 +334,168 @@ sub as_xml { my $data; my $fh = IO::String->new(\$data); my $w = XML::Writer->new(OUTPUT => $fh, - DATA_MODE => 1, - DATA_INDENT => 2); + DATA_MODE => 1, + DATA_INDENT => 2); $w->startTag("domain", - "type" => $self->{type}); + "type" => $self->{type}); foreach (qw(name uuid memory currentMemory vcpu)) { - $w->dataElement("$_" => $self->{$_}) if $self->{$_}; + $w->dataElement("$_" => $self->{$_}) if $self->{$_}; } $w->startTag("os"); if ($self->{arch}) { - $w->dataElement("type", $self->{ostype}, arch => $self->{arch}); + $w->dataElement("type", $self->{ostype}, arch => $self->{arch}); } else { - $w->dataElement("type", $self->{ostype}); + $w->dataElement("type", $self->{ostype}); } if ($self->{boot}->{type} eq "disk") { - $w->emptyTag("boot", dev => "hd"); + $w->emptyTag("boot", dev => "hd"); } elsif ($self->{boot}->{type} eq "floppy") { - $w->emptyTag("boot", dev => "fd"); + $w->emptyTag("boot", dev => "fd"); } elsif ($self->{boot}->{type} eq "cdrom") { - $w->emptyTag("boot", dev => "cdrom"); + $w->emptyTag("boot", dev => "cdrom"); } elsif ($self->{boot}->{type} eq "network") { - $w->emptyTag("boot", dev => "network"); + $w->emptyTag("boot", dev => "network"); } elsif ($self->{boot}->{type} eq "kernel") { - foreach (qw(kernel initrd cmdline)) { - $w->dataElement($_, $self->{boot}->{$_}) if $self->{boot}->{$_}; - } + foreach (qw(kernel initrd cmdline)) { + $w->dataElement($_, $self->{boot}->{$_}) if $self->{boot}->{$_}; + } } elsif ($self->{boot}->{type} eq "init") { - $w->dataElement("init", $self->{boot}->{init}); + $w->dataElement("init", $self->{boot}->{init}); } if (exists $self->{boot}->{loader}) { - $w->dataElement("loader" => $self->{boot}->{loader}); + $w->dataElement("loader" => $self->{boot}->{loader}); } $w->endTag("os"); if ($self->{boot}->{type} eq "bootloader") { - $w->dataElement("bootloader" => $self->{boot}->{bootloader}); + $w->dataElement("bootloader" => $self->{boot}->{bootloader}); } foreach (qw(on_reboot on_poweroff on_crash)) { - $w->dataElement($_ => $self->{lifecycle}->{$_}) if $self->{lifecycle}->{$_}; + $w->dataElement($_ => $self->{lifecycle}->{$_}) if $self->{lifecycle}->{$_}; } if (%{$self->{features}}) { - $w->startTag("features"); - foreach (qw(pae acpi apic)) { - $w->emptyTag($_) if $self->{features}->{$_}; - } - $w->endTag("features"); + $w->startTag("features"); + foreach (qw(pae acpi apic)) { + $w->emptyTag($_) if $self->{features}->{$_}; + } + $w->endTag("features"); } $w->startTag("devices"); if ($self->{emulator}) { - $w->dataElement("emulator" => $self->{emulator}); + $w->dataElement("emulator" => $self->{emulator}); } foreach my $disk (@{$self->{disks}}) { - $w->startTag("disk", - type => $disk->{type}, - $disk->{device} ? (device => $disk->{device}) : ()); - - if ($disk->{format}) { - $w->emptyTag("driver", - name => $disk->{format}->{name}, - type => $disk->{format}->{type}); - } - - if ($disk->{type} eq "block") { - $w->emptyTag("source", - dev => $disk->{src}); - } else { - $w->emptyTag("source", - file => $disk->{src}); - } - $w->emptyTag("target", - dev => $disk->{dst}, - $disk->{bus} ? (bus => $disk->{bus}) : ()); - if ($disk->{secret}) { - $w->startTag("encryption", format => "qcow"); - $w->emptyTag("secret", type => "passphrase", uuid => $disk->{secret}); - $w->endTag("encryption"); - } - $w->endTag("disk"); + $w->startTag("disk", + type => $disk->{type}, + $disk->{device} ? (device => $disk->{device}) : ()); + + if ($disk->{format}) { + $w->emptyTag("driver", + name => $disk->{format}->{name}, + type => $disk->{format}->{type}); + } + + if ($disk->{type} eq "block") { + $w->emptyTag("source", + dev => $disk->{src}); + } else { + $w->emptyTag("source", + file => $disk->{src}); + } + $w->emptyTag("target", + dev => $disk->{dst}, + $disk->{bus} ? (bus => $disk->{bus}) : ()); + if ($disk->{secret}) { + $w->startTag("encryption", format => "qcow"); + $w->emptyTag("secret", type => "passphrase", uuid => $disk->{secret}); + $w->endTag("encryption"); + } + $w->endTag("disk"); } foreach my $fs (@{$self->{filesystems}}) { - $w->startTag("filesystem", - type => $fs->{type}); - - $w->emptyTag("source", - dir => $fs->{src}); - $w->emptyTag("target", - dir => $fs->{dst}); - $w->endTag("filesystem"); + $w->startTag("filesystem", + type => $fs->{type}); + + $w->emptyTag("source", + dir => $fs->{src}); + $w->emptyTag("target", + dir => $fs->{dst}); + $w->endTag("filesystem"); } foreach my $interface (@{$self->{interfaces}}) { - $w->startTag("interface", - type => $interface->{type}); - - $w->emptyTag("mac", - address => $interface->{mac}); - - if ($interface->{dev}) { - $w->emptyTag("source", - dev => $interface->{dev}, - mode => $interface->{mode}); - } else { - $w->emptyTag("source", - network => $interface->{source}); - } - if ($interface->{virtualport}) { - $w->startTag("virtualport", - type => $interface->{virtualport}); - $w->emptyTag("parameters", - managerid => '1', - typeid => '2', - typeidversion => '3', - instanceid => '40000000-0000-0000-0000-000000000000'); - $w->endTag("virtualport"); - } - if ($interface->{model}) { - $w->emptyTag("model", - type => $interface->{model}); - } - if ($interface->{filterref}) { - $w->emptyTag("filterref", - filter => $interface->{filterref}); - } - $w->endTag("interface"); + $w->startTag("interface", + type => $interface->{type}); + + $w->emptyTag("mac", + address => $interface->{mac}); + + if ($interface->{dev}) { + $w->emptyTag("source", + dev => $interface->{dev}, + mode => $interface->{mode}); + } else { + $w->emptyTag("source", + network => $interface->{source}); + } + if ($interface->{virtualport}) { + $w->startTag("virtualport", + type => $interface->{virtualport}); + $w->emptyTag("parameters", + managerid => '1', + typeid => '2', + typeidversion => '3', + instanceid => '40000000-0000-0000-0000-000000000000'); + $w->endTag("virtualport"); + } + if ($interface->{model}) { + $w->emptyTag("model", + type => $interface->{model}); + } + if ($interface->{filterref}) { + $w->emptyTag("filterref", + filter => $interface->{filterref}); + } + $w->endTag("interface"); } foreach my $graphic (@{$self->{graphics}}) { - $w->startTag("graphics", - type => $graphic->{type}); - - $w->emptyTag("port", - port => $graphic->{port}); - $w->emptyTag("autoport", - autoport => $graphic->{autoport}); - $w->emptyTag("listen", - listen => $graphic->{listen}, - $graphic->{listen_type} ? (type => $graphic->{listen_type}) : type => "address"); - $w->emptyTag("keymap", - keymap => $graphic->{keymap}); - $w->endTag("graphics"); + $w->startTag("graphics", + type => $graphic->{type}); + + $w->emptyTag("port", + port => $graphic->{port}); + $w->emptyTag("autoport", + autoport => $graphic->{autoport}); + $w->emptyTag("listen", + listen => $graphic->{listen}, + $graphic->{listen_type} ? (type => $graphic->{listen_type}) : type => "address"); + $w->emptyTag("keymap", + keymap => $graphic->{keymap}); + $w->endTag("graphics"); } $w->emptyTag("console", type => "pty"); $w->endTag("devices"); if ($self->{seclabel}->{model}) { - $w->startTag("seclabel", - model => $self->{seclabel}->{model}, - type => $self->{seclabel}->{type}, - relabel => $self->{seclabel}->{relabel}); - if ($self->{seclabel}->{label}) { - $w->dataElement("label", $self->{seclabel}->{label}); - } - if ($self->{seclabel}->{imagelabel}) { - $w->dataElement("imagelabel", $self->{seclabel}->{imagelabel}); - } - if ($self->{seclabel}->{baselabel}) { - $w->dataElement("baselabel", $self->{seclabel}->{baselabel}); - } - $w->endTag("seclabel"); + $w->startTag("seclabel", + model => $self->{seclabel}->{model}, + type => $self->{seclabel}->{type}, + relabel => $self->{seclabel}->{relabel}); + if ($self->{seclabel}->{label}) { + $w->dataElement("label", $self->{seclabel}->{label}); + } + if ($self->{seclabel}->{imagelabel}) { + $w->dataElement("imagelabel", $self->{seclabel}->{imagelabel}); + } + if ($self->{seclabel}->{baselabel}) { + $w->dataElement("baselabel", $self->{seclabel}->{baselabel}); + } + $w->endTag("seclabel"); } $w->endTag("domain"); diff --git a/lib/Sys/Virt/TCK/NetworkBuilder.pm b/lib/Sys/Virt/TCK/NetworkBuilder.pm index 2e6d8a1..09ca6b7 100644 --- a/lib/Sys/Virt/TCK/NetworkBuilder.pm +++ b/lib/Sys/Virt/TCK/NetworkBuilder.pm @@ -26,7 +26,7 @@ sub new { my %params = @_; my $self = { - name => $params{name} ? $params{name} : "tck" , + name => $params{name} ? $params{name} : "tck" , }; bless $self, $class; @@ -47,7 +47,7 @@ sub bridge { my $name = shift; $self->{bridge} = { name => $name, - @_ }; + @_ }; return $self; } @@ -88,35 +88,35 @@ sub as_xml { my $data; my $fh = IO::String->new(\$data); my $w = XML::Writer->new(OUTPUT => $fh, - DATA_MODE => 1, - DATA_INDENT => 2); + DATA_MODE => 1, + DATA_INDENT => 2); $w->startTag("network"); foreach (qw(name uuid)) { - $w->dataElement("$_" => $self->{$_}) if $self->{$_}; + $w->dataElement("$_" => $self->{$_}) if $self->{$_}; } $w->emptyTag("bridge", %{$self->{bridge}}) - if $self->{bridge}; + if $self->{bridge}; $w->emptyTag("forward", %{$self->{forward}}) - if exists $self->{forward}; + if exists $self->{forward}; if ($self->{ipaddr}) { - $w->startTag("ip", - address => $self->{ipaddr}->[0], - netmask => $self->{ipaddr}->[1]); - - if ($self->{dhcp}) { - $w->startTag("dhcp"); - foreach my $range (@{$self->{dhcp}}) { - $w->emptyTag("range", - start => $range->[0], - end => $range->[1]); - } - $w->endTag("dhcp"); - } - - $w->endTag("ip"); + $w->startTag("ip", + address => $self->{ipaddr}->[0], + netmask => $self->{ipaddr}->[1]); + + if ($self->{dhcp}) { + $w->startTag("dhcp"); + foreach my $range (@{$self->{dhcp}}) { + $w->emptyTag("range", + start => $range->[0], + end => $range->[1]); + } + $w->endTag("dhcp"); + } + + $w->endTag("ip"); } $w->endTag("network"); diff --git a/lib/Sys/Virt/TCK/NetworkHelpers.pm b/lib/Sys/Virt/TCK/NetworkHelpers.pm index f6bf8f9..5f563e5 100644 --- a/lib/Sys/Virt/TCK/NetworkHelpers.pm +++ b/lib/Sys/Virt/TCK/NetworkHelpers.pm @@ -33,9 +33,9 @@ sub shutdown_vm_gracefully { my $target = time() + 30; $dom->shutdown; while ($dom->is_active()) { - sleep(1); - diag ".. waiting for virtual machine to shutdown.. "; - $dom->destroy() if time() > $target; + sleep(1); + diag ".. waiting for virtual machine to shutdown.. "; + $dom->destroy() if time() > $target; } sleep(1); diag ".. shutdown complete.. "; diff --git a/lib/Sys/Virt/TCK/SELinux.pm b/lib/Sys/Virt/TCK/SELinux.pm index c117fca..9f378a8 100644 --- a/lib/Sys/Virt/TCK/SELinux.pm +++ b/lib/Sys/Virt/TCK/SELinux.pm @@ -61,9 +61,9 @@ sub selinux_get_file_context { my @attr = split /\n/, `getfattr -n security.selinux $path 2>/dev/null`; foreach (@attr) { - if (/security.selinux=\"(.*)\"/) { - return $1; - } + if (/security.selinux=\"(.*)\"/) { + return $1; + } } return undef; } diff --git a/lib/Sys/Virt/TCK/StoragePoolBuilder.pm b/lib/Sys/Virt/TCK/StoragePoolBuilder.pm index 3973cd1..99b36ae 100644 --- a/lib/Sys/Virt/TCK/StoragePoolBuilder.pm +++ b/lib/Sys/Virt/TCK/StoragePoolBuilder.pm @@ -26,10 +26,10 @@ sub new { my %params = @_; my $self = { - name => $params{name} ? $params{name} : "tck" , - type => $params{type} ? $params{type} : "dir", - source => {}, - perms => {}, + name => $params{name} ? $params{name} : "tck" , + type => $params{type} ? $params{type} : "dir", + source => {}, + perms => {}, }; bless $self, $class; @@ -138,44 +138,44 @@ sub as_xml { my $data; my $fh = IO::String->new(\$data); my $w = XML::Writer->new(OUTPUT => $fh, - DATA_MODE => 1, - DATA_INDENT => 2); + DATA_MODE => 1, + DATA_INDENT => 2); $w->startTag("pool", type => $self->{type}); foreach (qw(name uuid)) { - $w->dataElement("$_" => $self->{$_}) if $self->{$_}; + $w->dataElement("$_" => $self->{$_}) if $self->{$_}; } $w->startTag("source"); if ($self->{source}->{host}) { - $w->emptyTag("host", name => $self->{source}->{host}); + $w->emptyTag("host", name => $self->{source}->{host}); } if ($self->{source}->{dir}) { - $w->emptyTag("dir", path => $self->{source}->{dir}); + $w->emptyTag("dir", path => $self->{source}->{dir}); } if ($self->{source}->{device}) { - foreach my $dev (@{$self->{source}->{device}}) { - $w->emptyTag("device", path => $dev); - } + foreach my $dev (@{$self->{source}->{device}}) { + $w->emptyTag("device", path => $dev); + } } if ($self->{source}->{adapter}) { - $w->emptyTag("adapter", name => $self->{source}->{adapter}); + $w->emptyTag("adapter", name => $self->{source}->{adapter}); } if ($self->{source}->{name}) { - $w->dataElement("name", $self->{source}->{name}); + $w->dataElement("name", $self->{source}->{name}); } if ($self->{format}) { - $w->emptyTag("format", type => $self->{format}); + $w->emptyTag("format", type => $self->{format}); } $w->endTag("source"); $w->startTag("target"); $w->dataElement("path", $self->{target}); if (int(keys %{$self->{perms}})) { - $w->startTag("permissions"); - foreach (qw(mode user group)) { - $w->dataElement("$_" => $self->{perms}->{$_}) if $self->{perms}->{$_}; - } - $w->endTag("permissions"); + $w->startTag("permissions"); + foreach (qw(mode user group)) { + $w->dataElement("$_" => $self->{perms}->{$_}) if $self->{perms}->{$_}; + } + $w->endTag("permissions"); } $w->endTag("target"); diff --git a/lib/Sys/Virt/TCK/StorageVolBuilder.pm b/lib/Sys/Virt/TCK/StorageVolBuilder.pm index da90788..7208f75 100644 --- a/lib/Sys/Virt/TCK/StorageVolBuilder.pm +++ b/lib/Sys/Virt/TCK/StorageVolBuilder.pm @@ -26,7 +26,7 @@ sub new { my %params = @_; my $self = { - name => $params{name} ? $params{name} : "tck" , + name => $params{name} ? $params{name} : "tck" , }; bless $self, $class; @@ -87,8 +87,8 @@ sub as_xml { my $data; my $fh = IO::String->new(\$data); my $w = XML::Writer->new(OUTPUT => $fh, - DATA_MODE => 1, - DATA_INDENT => 2); + DATA_MODE => 1, + DATA_INDENT => 2); $w->startTag("volume"); $w->dataElement("name" => $self->{name}); @@ -96,30 +96,30 @@ sub as_xml { $w->dataElement("allocation", $self->{allocation}); if ($self->{format} || $self->{secret}) { - $w->startTag("target"); - if ($self->{format}) { - $w->emptyTag("format", type => $self->{format}); - } - if ($self->{secret}) { - $w->startTag("encryption", format => "qcow"); - $w->emptyTag("secret", type => "passphrase", uuid => $self->{secret}); - $w->endTag("encryption"); - } - $w->endTag("target"); + $w->startTag("target"); + if ($self->{format}) { + $w->emptyTag("format", type => $self->{format}); + } + if ($self->{secret}) { + $w->startTag("encryption", format => "qcow"); + $w->emptyTag("secret", type => "passphrase", uuid => $self->{secret}); + $w->endTag("encryption"); + } + $w->endTag("target"); } if ($self->{backingFile}) { - $w->startTag("backingStore"); - $w->dataElement("path", $self->{backingFile}); - if ($self->{backingFormat}) { - $w->emptyTag("format", type => $self->{backingFormat}); - } - if ($self->{secret}) { - $w->startTag("encryption", format => "qcow"); - $w->emptyTag("secret", type => "passphrase", uuid => $self->{secret}); - $w->endTag("encryption"); - } - $w->endTag("backingStore"); + $w->startTag("backingStore"); + $w->dataElement("path", $self->{backingFile}); + if ($self->{backingFormat}) { + $w->emptyTag("format", type => $self->{backingFormat}); + } + if ($self->{secret}) { + $w->startTag("encryption", format => "qcow"); + $w->emptyTag("secret", type => "passphrase", uuid => $self->{secret}); + $w->endTag("encryption"); + } + $w->endTag("backingStore"); } $w->endTag("volume"); diff --git a/lib/Sys/Virt/TCK/TAP/XMLFormatter.pm b/lib/Sys/Virt/TCK/TAP/XMLFormatter.pm index b4514fd..a8fdf93 100644 --- a/lib/Sys/Virt/TCK/TAP/XMLFormatter.pm +++ b/lib/Sys/Virt/TCK/TAP/XMLFormatter.pm @@ -35,8 +35,8 @@ sub _initialize { $self->verbosity(0); my $w = XML::Writer->new(OUTPUT => \*STDOUT, - DATA_MODE => 1, - DATA_INDENT => 2); + DATA_MODE => 1, + DATA_INDENT => 2); $self->xml($w); return $self; @@ -64,13 +64,13 @@ sub summary { my $agg = shift; $self->xml->startTag("summary", - total => int($agg->total), - passed => int($agg->passed), - failed => int($agg->failed), - todo => int($agg->todo), - unexpected => int($agg->todo_passed), - skipped => int($agg->skipped), - errors => int($agg->parse_errors)); + total => int($agg->total), + passed => int($agg->passed), + failed => int($agg->failed), + todo => int($agg->todo), + unexpected => int($agg->todo_passed), + skipped => int($agg->skipped), + errors => int($agg->parse_errors)); $self->xml->endTag("summary"); diff --git a/lib/Sys/Virt/TCK/TAP/XMLFormatterSession.pm b/lib/Sys/Virt/TCK/TAP/XMLFormatterSession.pm index ca2a298..cd4ba1b 100644 --- a/lib/Sys/Virt/TCK/TAP/XMLFormatterSession.pm +++ b/lib/Sys/Virt/TCK/TAP/XMLFormatterSession.pm @@ -32,7 +32,7 @@ sub _initialize { $self->parser($args->{parser}); $self->xml->startTag("test", - name => $args->{test}); + name => $args->{test}); return $self; } @@ -45,7 +45,7 @@ sub result { my $meth = "result_" . $result->type; if ($self->can($meth)) { - $self->$meth($result); + $self->$meth($result); } } @@ -54,13 +54,13 @@ sub result_plan { my $result = shift; if ($result->has_skip) { - $self->xml->startTag("plan", - count => $result->tests_planned); - $self->xml->dataElement("skip", $result->explanation); - $self->xml->endTag("plan"); + $self->xml->startTag("plan", + count => $result->tests_planned); + $self->xml->dataElement("skip", $result->explanation); + $self->xml->endTag("plan"); } else { - $self->xml->emptyTag("plan", - count => $result->tests_planned); + $self->xml->emptyTag("plan", + count => $result->tests_planned); } } @@ -69,7 +69,7 @@ sub result_pragma { my $result = shift; foreach ($result->pragmas) { - $self->dataElement("pragma", $_); + $self->dataElement("pragma", $_); } } @@ -78,23 +78,23 @@ sub result_test { my $result = shift; $self->xml->startTag("test", - id => $result->number); + id => $result->number); if ($result->is_ok) { - $self->xml->emptyTag("pass"); + $self->xml->emptyTag("pass"); } else { - $self->xml->emptyTag("fail"); + $self->xml->emptyTag("fail"); } $self->xml->emptyTag("unplanned") if $result->is_unplanned; $self->xml->cdataElement("desc", $result->description); if ($result->has_todo) { - $self->xml->cdataElement("todo", $result->explanation, - pass => $result->todo_passed ? "yes" : "no"); + $self->xml->cdataElement("todo", $result->explanation, + pass => $result->todo_passed ? "yes" : "no"); } if ($result->has_skip) { - $self->xml->cdataElement("skip", $result->explanation); + $self->xml->cdataElement("skip", $result->explanation); } $self->xml->endTag("test"); @@ -105,7 +105,7 @@ sub result_bailout { my $result = shift; $self->xml->cdataElement("bailout", - $result->explanation); + $result->explanation); } sub result_version { @@ -144,31 +144,31 @@ sub close_test { my $self = shift; $self->xml->startTag("summary", - passed => int($self->parser->passed), - failed => int($self->parser->failed), - todo => int($self->parser->todo), - unexpected => int($self->parser->todo_passed), - skipped => int($self->parser->skipped)); + passed => int($self->parser->passed), + failed => int($self->parser->failed), + todo => int($self->parser->todo), + unexpected => int($self->parser->todo_passed), + skipped => int($self->parser->skipped)); if ($self->parser->skip_all) { - $self->xml->startTag("plan", - expected => int($self->parser->tests_planned), - actual => int($self->parser->tests_run)); - $self->xml->cdataElement("skip", $self->parser->skip_all); - $self->xml->endTag("plan"); + $self->xml->startTag("plan", + expected => int($self->parser->tests_planned), + actual => int($self->parser->tests_run)); + $self->xml->cdataElement("skip", $self->parser->skip_all); + $self->xml->endTag("plan"); } else { - $self->xml->emptyTag("plan", - expected => int($self->parser->tests_planned), - actual => int($self->parser->tests_run)); + $self->xml->emptyTag("plan", + expected => int($self->parser->tests_planned), + actual => int($self->parser->tests_run)); } $self->xml->emptyTag("status", - wait => $self->parser->wait, - exit => $self->parser->exit); + wait => $self->parser->wait, + exit => $self->parser->exit); $self->xml->emptyTag("timing", - start => $self->parser->start_time, - end => $self->parser->end_time); + start => $self->parser->start_time, + end => $self->parser->end_time); $self->xml->endTag("summary"); diff --git a/scripts/nwfilter/300-vsitype.t b/scripts/nwfilter/300-vsitype.t index d169339..90d237f 100644 --- a/scripts/nwfilter/300-vsitype.t +++ b/scripts/nwfilter/300-vsitype.t @@ -52,7 +52,7 @@ if ( ! -e '/usr/sbin/lldptool' ) { # create first domain and start it my $xml = $tck->generic_domain(name => "tck", fullos => 1, - netmode => "vepa")->as_xml(); + netmode => "vepa")->as_xml(); my $dom; ok_domain(sub { $dom = $conn->define_domain($xml) }, "created persistent domain object"); diff --git a/scripts/nwfilter/concurrency/chg-vm-filter.sh b/scripts/nwfilter/concurrency/chg-vm-filter.sh index 3cf26ee..3066f59 100644 --- a/scripts/nwfilter/concurrency/chg-vm-filter.sh +++ b/scripts/nwfilter/concurrency/chg-vm-filter.sh @@ -1,7 +1,7 @@ #!/bin/sh cleanup() { - virsh nwfilter-undefine tck-vm${idx}-filter 2>/dev/null + virsh nwfilter-undefine tck-vm${idx}-filter 2>/dev/null } cd $(dirname "$0") @@ -16,14 +16,14 @@ trap cleanup 2 while :; do - virsh nwfilter-define tck-vm${idx}-filter1.xml - [ $? -ne 0 ] && break - [ ! -w "${logfile}" ] && break - virsh nwfilter-define tck-vm${idx}-filter2.xml - [ $? -ne 0 ] && break - ctr=$(($ctr + 1)) - [ ! -w "${logfile}" ] && break - echo "${ctr}" >> "${logfile}" + virsh nwfilter-define tck-vm${idx}-filter1.xml + [ $? -ne 0 ] && break + [ ! -w "${logfile}" ] && break + virsh nwfilter-define tck-vm${idx}-filter2.xml + [ $? -ne 0 ] && break + ctr=$(($ctr + 1)) + [ ! -w "${logfile}" ] && break + echo "${ctr}" >> "${logfile}" done cleanup diff --git a/scripts/nwfilter/concurrency/start-destroy-vm.sh b/scripts/nwfilter/concurrency/start-destroy-vm.sh index 9e94708..0662997 100644 --- a/scripts/nwfilter/concurrency/start-destroy-vm.sh +++ b/scripts/nwfilter/concurrency/start-destroy-vm.sh @@ -2,8 +2,8 @@ cleanup() { - virsh destroy tck-vm${idx} 2>/dev/null - virsh nwfilter-undefine tck-vm${idx}-filter 2>/dev/null + virsh destroy tck-vm${idx} 2>/dev/null + virsh nwfilter-undefine tck-vm${idx}-filter 2>/dev/null } cd $(dirname "$0") @@ -18,14 +18,14 @@ trap cleanup 2 while :; do - virsh create tck-vm${idx}.xml - [ $? -ne 0 ] && break - sleep 2 - virsh destroy tck-vm${idx} - [ $? -ne 0 ] && break - ctr=$(($ctr + 1)) - [ ! -w "${logfile}" ] && break - echo "${ctr}" >> "${logfile}" + virsh create tck-vm${idx}.xml + [ $? -ne 0 ] && break + sleep 2 + virsh destroy tck-vm${idx} + [ $? -ne 0 ] && break + ctr=$(($ctr + 1)) + [ ! -w "${logfile}" ] && break + echo "${ctr}" >> "${logfile}" done cleanup diff --git a/scripts/nwfilter/nwfilter2vmtest.sh b/scripts/nwfilter/nwfilter2vmtest.sh index 4cf63b2..90a5255 100644 --- a/scripts/nwfilter/nwfilter2vmtest.sh +++ b/scripts/nwfilter/nwfilter2vmtest.sh @@ -139,7 +139,7 @@ checkExpectedOutput() { skip=0 if [ "x${skipregex}x" != "xx" ]; then - skip=$(printf %s\\n ${cmd} | grep -c -E ${skipregex}) + skip=$(printf %s\\n ${cmd} | grep -c -E ${skipregex}) fi eval ${cmd} 2>&1 | tee ${tmpfile} 1>/dev/null @@ -157,12 +157,12 @@ checkExpectedOutput() { if [ "x${letter}x" = "x#x" ] || [ "x${line}x" = "xx" ]; then - if [ ${skip} -ne 0 ]; then - break - fi + if [ ${skip} -ne 0 ]; then + break + fi - if [ -n "${skiptest}" ]; then - # treat all skips as passes + if [ -n "${skiptest}" ]; then + # treat all skips as passes passctr=$(($passctr + 1)) [ $(($flags & $FLAG_VERBOSE)) -ne 0 ] && \ echo "SKIP ${xmlfile} : ${cmd}" @@ -171,7 +171,7 @@ checkExpectedOutput() { [ $(($flags & $FLAG_TAP_TEST)) -ne 0 ] && \ tap_pass $(($passctr + $failctr)) "SKIP: ${xmlfile} : ${skiptest}" break - fi + fi if [ $IPTABLES_CTDIR_CORRECTED -ne 0 ]; then #change --ctdir ORIGINAL to --ctdir REPLY @@ -196,8 +196,8 @@ checkExpectedOutput() { failctr=$(($failctr + 1)) if [ $(($flags & $FLAG_WAIT)) -ne 0 ]; then echo "tmp files: $tmpfile, $tmpfile2" - echo "Press enter" - read enter + echo "Press enter" + read enter fi [ $(($flags & $FLAG_LIBVIRT_TEST)) -ne 0 ] && \ test_result $(($passctr + $failctr)) "" 1 @@ -239,15 +239,15 @@ doTest() { skiptest="" if [ ! -r "${xmlfile}" ]; then - echo "FAIL : Cannot access filter XML file ${xmlfile}." - return 1 + echo "FAIL : Cannot access filter XML file ${xmlfile}." + return 1 fi # Check whether we can run this test at all cmd=$(sed -n '1 s/^<\!--[ ]*#\(.*\)#[ ]*-->/\1/p' "${xmlfile}") if [ -n "${cmd}" ]; then - eval "${cmd}" 2>/dev/null 1>/dev/null - [ $? -ne 0 ] && skiptest="${cmd}" + eval "${cmd}" 2>/dev/null 1>/dev/null + [ $? -ne 0 ] && skiptest="${cmd}" fi [ -z "${skiptest}" ] && ${VIRSH} nwfilter-define "${xmlfile}" > /dev/null @@ -643,23 +643,23 @@ main() { createTestFilters "${flags}" if [ $? -ne 0 ]; then - exit 1; + exit 1; fi createVM "${vm1}" "tck-testcase" "10.2.2.2" "52:54:0:0:0:1" "${flags}" if [ $? -ne 0 ]; then - echo "Could not create VM ${vm1}. Exiting." - deleteTestFilter "${flags}" - exit 1 + echo "Could not create VM ${vm1}. Exiting." + deleteTestFilter "${flags}" + exit 1 fi createVM "${vm2}" "${TESTFILTERNAME}" "10.1.1.1" "52:54:0:9f:33:da" \ "${flags}" if [ $? -ne 0 ]; then - echo "Could not create VM ${vm2}. Exiting." - destroyVM "${vm1}" "${flags}" - deleteTestFilter "${flags}" - exit 1 + echo "Could not create VM ${vm2}. Exiting." + destroyVM "${vm1}" "${flags}" + deleteTestFilter "${flags}" + exit 1 fi runTests "${vm1}" "${vm2}" "${xmldir}" "${fwalldir}" "${flags}" -- 2.14.3 -- libvir-list mailing list libvir-list@xxxxxxxxxx https://www.redhat.com/mailman/listinfo/libvir-list