| /* |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| */ |
| |
| package com.cloud.hypervisor.kvm.resource; |
| |
| import java.io.File; |
| import java.util.Arrays; |
| import java.util.List; |
| import java.util.UUID; |
| |
| import junit.framework.TestCase; |
| |
| import com.cloud.hypervisor.kvm.resource.LibvirtVMDef.ChannelDef; |
| import com.cloud.hypervisor.kvm.resource.LibvirtVMDef.DiskDef; |
| import com.cloud.hypervisor.kvm.resource.LibvirtVMDef.MemBalloonDef; |
| import com.cloud.hypervisor.kvm.resource.LibvirtVMDef.SCSIDef; |
| import org.apache.cloudstack.utils.qemu.QemuObject; |
| import org.junit.Test; |
| import org.junit.runner.RunWith; |
| import org.mockito.junit.MockitoJUnitRunner; |
| |
| |
| @RunWith(MockitoJUnitRunner.class) |
| public class LibvirtVMDefTest extends TestCase { |
| |
| final String memInfo = "MemTotal: 5830236 kB\n" + |
| "MemFree: 156752 kB\n" + |
| "Buffers: 326836 kB\n" + |
| "Cached: 2606764 kB\n" + |
| "SwapCached: 0 kB\n" + |
| "Active: 4260808 kB\n" + |
| "Inactive: 949392 kB\n"; |
| |
| @Test |
| public void testInterfaceTypeUserWithNetwork() { |
| LibvirtVMDef.InterfaceDef interfaceDef = new LibvirtVMDef.InterfaceDef(); |
| interfaceDef.defUserNet(LibvirtVMDef.InterfaceDef.NicModel.VIRTIO, "00:11:22:aa:bb:dd", "192.168.100.0", 24); |
| |
| String expected = "<interface type='user'>\n" + |
| "<mac address='00:11:22:aa:bb:dd'/>\n" + |
| "<model type='virtio'/>\n" + |
| "<ip family='ipv4' address='192.168.100.0' prefix='24'/>\n" + |
| "</interface>\n"; |
| |
| assertEquals(expected, interfaceDef.toString()); |
| } |
| |
| @Test |
| public void testInterfaceTypeUserWithoutNetwork() { |
| LibvirtVMDef.InterfaceDef interfaceDef = new LibvirtVMDef.InterfaceDef(); |
| interfaceDef.defUserNet(LibvirtVMDef.InterfaceDef.NicModel.VIRTIO, "00:11:22:aa:bb:dd"); |
| |
| String expected = "<interface type='user'>\n" + |
| "<mac address='00:11:22:aa:bb:dd'/>\n" + |
| "<model type='virtio'/>\n" + |
| "</interface>\n"; |
| |
| assertEquals(expected, interfaceDef.toString()); |
| } |
| |
| @Test |
| public void testInterfaceEthernet() { |
| LibvirtVMDef.InterfaceDef ifDef = new LibvirtVMDef.InterfaceDef(); |
| ifDef.defEthernet("targetDeviceName", "00:11:22:aa:bb:dd", LibvirtVMDef.InterfaceDef.NicModel.VIRTIO); |
| |
| String expected = |
| "<interface type='ethernet'>\n" |
| + "<target dev='targetDeviceName'/>\n" |
| + "<mac address='00:11:22:aa:bb:dd'/>\n" |
| + "<model type='virtio'/>\n" |
| + "<link state='up'/>\n" |
| + "</interface>\n"; |
| |
| assertEquals(expected, ifDef.toString()); |
| } |
| |
| @Test |
| public void testInterfaceDirectNet() { |
| LibvirtVMDef.InterfaceDef ifDef = new LibvirtVMDef.InterfaceDef(); |
| ifDef.defDirectNet("targetDeviceName", null, "00:11:22:aa:bb:dd", LibvirtVMDef.InterfaceDef.NicModel.VIRTIO, "private"); |
| |
| String expected = |
| "<interface type='" + LibvirtVMDef.InterfaceDef.GuestNetType.DIRECT + "'>\n" |
| + "<source dev='targetDeviceName' mode='private'/>\n" |
| + "<mac address='00:11:22:aa:bb:dd'/>\n" |
| + "<model type='virtio'/>\n" |
| + "<link state='up'/>\n" |
| + "</interface>\n"; |
| |
| assertEquals(expected, ifDef.toString()); |
| } |
| |
| @Test |
| public void testInterfaceBridgeSlot() { |
| LibvirtVMDef.InterfaceDef ifDef = new LibvirtVMDef.InterfaceDef(); |
| ifDef.defBridgeNet("targetDeviceName", null, "00:11:22:aa:bb:dd", LibvirtVMDef.InterfaceDef.NicModel.VIRTIO); |
| ifDef.setSlot(16); |
| |
| String expected = |
| "<interface type='" + LibvirtVMDef.InterfaceDef.GuestNetType.BRIDGE + "'>\n" |
| + "<source bridge='targetDeviceName'/>\n" |
| + "<mac address='00:11:22:aa:bb:dd'/>\n" |
| + "<model type='virtio'/>\n" |
| + "<link state='up'/>\n" |
| + "<address type='pci' domain='0x0000' bus='0x00' slot='0x10' function='0x0'/>\n" |
| + "</interface>\n"; |
| |
| assertEquals(expected, ifDef.toString()); |
| |
| ifDef.setLinkStateUp(false); |
| ifDef.setDevName("vnet11"); |
| |
| expected = |
| "<interface type='" + LibvirtVMDef.InterfaceDef.GuestNetType.BRIDGE + "'>\n" |
| + "<source bridge='targetDeviceName'/>\n" |
| + "<target dev='vnet11'/>\n" |
| + "<mac address='00:11:22:aa:bb:dd'/>\n" |
| + "<model type='virtio'/>\n" |
| + "<link state='down'/>\n" |
| + "<address type='pci' domain='0x0000' bus='0x00' slot='0x10' function='0x0'/>\n" |
| + "</interface>\n"; |
| |
| assertEquals(expected, ifDef.toString()); |
| } |
| |
| @Test |
| public void testInterfaceWithMultiQueueAndPacked() { |
| LibvirtVMDef.InterfaceDef ifDef = new LibvirtVMDef.InterfaceDef(); |
| ifDef.defBridgeNet("targetDeviceName", null, "00:11:22:aa:bb:dd", LibvirtVMDef.InterfaceDef.NicModel.VIRTIO); |
| ifDef.setMultiQueueNumber(6); |
| |
| LibvirtVMDef.setGlobalQemuVersion(5000000L); |
| LibvirtVMDef.setGlobalLibvirtVersion(6400000L); |
| |
| String expected = |
| "<interface type='" + LibvirtVMDef.InterfaceDef.GuestNetType.BRIDGE + "'>\n" |
| + "<source bridge='targetDeviceName'/>\n" |
| + "<mac address='00:11:22:aa:bb:dd'/>\n" |
| + "<model type='virtio'/>\n" |
| + "<driver queues='6'/>\n" |
| + "<link state='up'/>\n" |
| + "</interface>\n"; |
| assertEquals(expected, ifDef.toString()); |
| |
| ifDef.setPackedVirtQueues(true); |
| expected = |
| "<interface type='" + LibvirtVMDef.InterfaceDef.GuestNetType.BRIDGE + "'>\n" |
| + "<source bridge='targetDeviceName'/>\n" |
| + "<mac address='00:11:22:aa:bb:dd'/>\n" |
| + "<model type='virtio'/>\n" |
| + "<driver queues='6' packed='on'/>\n" |
| + "<link state='up'/>\n" |
| + "</interface>\n"; |
| assertEquals(expected, ifDef.toString()); |
| |
| ifDef.setMultiQueueNumber(null); |
| expected = |
| "<interface type='" + LibvirtVMDef.InterfaceDef.GuestNetType.BRIDGE + "'>\n" |
| + "<source bridge='targetDeviceName'/>\n" |
| + "<mac address='00:11:22:aa:bb:dd'/>\n" |
| + "<model type='virtio'/>\n" |
| + "<driver packed='on'/>\n" |
| + "<link state='up'/>\n" |
| + "</interface>\n"; |
| assertEquals(expected, ifDef.toString()); |
| |
| LibvirtVMDef.setGlobalLibvirtVersion(300000L); |
| expected = |
| "<interface type='" + LibvirtVMDef.InterfaceDef.GuestNetType.BRIDGE + "'>\n" |
| + "<source bridge='targetDeviceName'/>\n" |
| + "<mac address='00:11:22:aa:bb:dd'/>\n" |
| + "<model type='virtio'/>\n" |
| + "<link state='up'/>\n" |
| + "</interface>\n"; |
| assertEquals(expected, ifDef.toString()); |
| } |
| |
| @Test |
| public void testCpuModeDef() { |
| LibvirtVMDef.CpuModeDef cpuModeDef = new LibvirtVMDef.CpuModeDef(); |
| cpuModeDef.setMode("custom"); |
| cpuModeDef.setModel("Nehalem"); |
| |
| String expected1 = "<cpu mode='custom' match='exact'><model fallback='allow'>Nehalem</model></cpu>"; |
| |
| assertEquals(expected1, cpuModeDef.toString()); |
| |
| cpuModeDef.setMode("host-model"); |
| String expected2 = "<cpu mode='host-model'><model fallback='allow'></model></cpu>"; |
| |
| assertEquals(expected2, cpuModeDef.toString()); |
| |
| cpuModeDef.setMode("host-passthrough"); |
| String expected3 = "<cpu mode='host-passthrough'></cpu>"; |
| assertEquals(expected3, cpuModeDef.toString()); |
| |
| } |
| |
| @Test |
| public void testCpuModeDefCpuFeatures() { |
| LibvirtVMDef.CpuModeDef cpuModeDef = new LibvirtVMDef.CpuModeDef(); |
| cpuModeDef.setMode("custom"); |
| cpuModeDef.setModel("Nehalem"); |
| |
| String expected_start = "<cpu mode='custom' match='exact'><model fallback='allow'>Nehalem</model>"; |
| String expected_end = "</cpu>"; |
| |
| List<String> features1 = Arrays.asList("feature1", "feature2"); |
| cpuModeDef.setFeatures(features1); |
| String expected1 = "<feature policy='require' name='feature1'/><feature policy='require' name='feature2'/>"; |
| assertEquals(expected_start + expected1 + expected_end, cpuModeDef.toString()); |
| |
| List<String> features2 = Arrays.asList("-feature1", "-feature2"); |
| cpuModeDef.setFeatures(features2); |
| String expected2 = "<feature policy='disable' name='feature1'/><feature policy='disable' name='feature2'/>"; |
| assertEquals(expected_start + expected2 + expected_end, cpuModeDef.toString()); |
| |
| List<String> features3 = Arrays.asList("-feature1", "feature2"); |
| cpuModeDef.setFeatures(features3); |
| String expected3 = "<feature policy='disable' name='feature1'/><feature policy='require' name='feature2'/>"; |
| assertEquals(expected_start + expected3 + expected_end, cpuModeDef.toString()); |
| } |
| |
| @Test |
| public void testDiskDef() { |
| String filePath = "/var/lib/libvirt/images/disk.qcow2"; |
| String diskLabel = "vda"; |
| |
| DiskDef disk = new DiskDef(); |
| DiskDef.DiskBus bus = DiskDef.DiskBus.VIRTIO; |
| DiskDef.DiskFmtType type = DiskDef.DiskFmtType.QCOW2; |
| DiskDef.DiskCacheMode cacheMode = DiskDef.DiskCacheMode.WRITEBACK; |
| |
| disk.defFileBasedDisk(filePath, diskLabel, bus, type); |
| disk.setCacheMode(cacheMode); |
| |
| assertEquals(filePath, disk.getDiskPath()); |
| assertEquals(diskLabel, disk.getDiskLabel()); |
| assertEquals(bus, disk.getBusType()); |
| assertEquals(DiskDef.DeviceType.DISK, disk.getDeviceType()); |
| |
| String xmlDef = disk.toString(); |
| String expectedXml = "<disk device='disk' type='file'>\n<driver name='qemu' type='" + type.toString() + "' cache='" + cacheMode.toString() + "' />\n" + |
| "<source file='" + filePath + "'/>\n<target dev='" + diskLabel + "' bus='" + bus.toString() + "'/>\n</disk>\n"; |
| |
| assertEquals(expectedXml, xmlDef); |
| } |
| |
| @Test |
| public void testDiskDefWithEncryption() { |
| String passphraseUuid = UUID.randomUUID().toString(); |
| DiskDef disk = new DiskDef(); |
| DiskDef.LibvirtDiskEncryptDetails encryptDetails = new DiskDef.LibvirtDiskEncryptDetails(passphraseUuid, QemuObject.EncryptFormat.LUKS); |
| disk.defBlockBasedDisk("disk1", 1, DiskDef.DiskBus.VIRTIO); |
| disk.setLibvirtDiskEncryptDetails(encryptDetails); |
| String expectedXML = "<disk device='disk' type='block'>\n" + |
| "<driver name='qemu' type='raw' cache='none' />\n" + |
| "<source dev='disk1'/>\n" + |
| "<target dev='vdb' bus='virtio'/>\n" + |
| "<encryption format='luks'>\n" + |
| "<secret type='passphrase' uuid='" + passphraseUuid + "' />\n" + |
| "</encryption>\n" + |
| "</disk>\n"; |
| assertEquals(expectedXML, disk.toString()); |
| } |
| |
| @Test |
| public void testDiskDefWithBlockIO() { |
| String filePath = "/var/lib/libvirt/images/disk.qcow2"; |
| String diskLabel = "vda"; |
| |
| DiskDef disk = new DiskDef(); |
| DiskDef.DiskBus bus = DiskDef.DiskBus.VIRTIO; |
| DiskDef.DiskFmtType type = DiskDef.DiskFmtType.QCOW2; |
| DiskDef.DiskCacheMode cacheMode = DiskDef.DiskCacheMode.WRITEBACK; |
| |
| disk.defFileBasedDisk(filePath, diskLabel, bus, type); |
| disk.setCacheMode(cacheMode); |
| disk.setLogicalBlockIOSize(DiskDef.BlockIOSize.SIZE_4K); |
| |
| assertEquals(filePath, disk.getDiskPath()); |
| assertEquals(diskLabel, disk.getDiskLabel()); |
| assertEquals(bus, disk.getBusType()); |
| assertEquals(DiskDef.DeviceType.DISK, disk.getDeviceType()); |
| |
| String expectedXmlLogical = "<disk device='disk' type='file'>\n<driver name='qemu' type='" + type.toString() + "' cache='" + cacheMode.toString() + "' />\n" + |
| "<source file='" + filePath + "'/>\n<target dev='" + diskLabel + "' bus='" + bus.toString() + "'/>\n<blockio logical_block_size='4096' />\n</disk>\n"; |
| |
| assertEquals(expectedXmlLogical, disk.toString()); |
| |
| String expectedXmlPhysical = "<disk device='disk' type='file'>\n<driver name='qemu' type='" + type.toString() + "' cache='" + cacheMode.toString() + "' />\n" + |
| "<source file='" + filePath + "'/>\n<target dev='" + diskLabel + "' bus='" + bus.toString() + "'/>\n<blockio physical_block_size='4096' />\n</disk>\n"; |
| |
| disk.setLogicalBlockIOSize(null); |
| disk.setPhysicalBlockIOSize(DiskDef.BlockIOSize.SIZE_4K); |
| assertEquals(expectedXmlPhysical, disk.toString()); |
| |
| disk.setLogicalBlockIOSize(DiskDef.BlockIOSize.SIZE_512); |
| String expectedXml = "<disk device='disk' type='file'>\n<driver name='qemu' type='" + type.toString() + "' cache='" + cacheMode.toString() + "' />\n" + |
| "<source file='" + filePath + "'/>\n<target dev='" + diskLabel + "' bus='" + bus.toString() + "'/>\n<blockio logical_block_size='512' physical_block_size='4096' />\n</disk>\n"; |
| assertEquals(expectedXml, disk.toString()); |
| } |
| |
| @Test |
| public void testDiskDefWithMultipleHosts() { |
| String path = "/mnt/primary1"; |
| String host = "10.11.12.13,10.11.12.14,10.11.12.15"; |
| int port = 3300; |
| String authUsername = "admin"; |
| String uuid = "40b3f216-36b5-11ed-9357-9b4e21b0ed91"; |
| int devId = 2; |
| |
| DiskDef diskdef = new DiskDef(); |
| diskdef.defNetworkBasedDisk(path, host, port, authUsername, |
| uuid, devId, DiskDef.DiskBus.VIRTIO, DiskDef.DiskProtocol.RBD, DiskDef.DiskFmtType.RAW); |
| |
| assertEquals(path, diskdef.getDiskPath()); |
| assertEquals(DiskDef.DiskType.NETWORK, diskdef.getDiskType()); |
| assertEquals(DiskDef.DiskFmtType.RAW, diskdef.getDiskFormatType()); |
| |
| String expected = "<disk device='disk' type='network'>\n" + |
| "<driver name='qemu' type='raw' cache='none' />\n" + |
| "<source protocol='rbd' name='/mnt/primary1'>\n" + |
| "<host name='10.11.12.13' port='3300'/>\n" + |
| "<host name='10.11.12.14' port='3300'/>\n" + |
| "<host name='10.11.12.15' port='3300'/>\n" + |
| "</source>\n" + |
| "<auth username='admin'>\n" + |
| "<secret type='ceph' uuid='40b3f216-36b5-11ed-9357-9b4e21b0ed91'/>\n" + |
| "</auth>\n" + |
| "<target dev='vdc' bus='virtio'/>\n" + |
| "</disk>\n"; |
| |
| assertEquals(expected, diskdef.toString()); |
| } |
| |
| @Test |
| public void testDiskDefWithMultipleHostsIpv6() { |
| String path = "/mnt/primary1"; |
| String host = "[fc00:1234::1],[fc00:1234::2],[fc00:1234::3]"; |
| int port = 3300; |
| String authUsername = "admin"; |
| String uuid = "40b3f216-36b5-11ed-9357-9b4e21b0ed91"; |
| int devId = 2; |
| |
| DiskDef diskdef = new DiskDef(); |
| diskdef.defNetworkBasedDisk(path, host, port, authUsername, |
| uuid, devId, DiskDef.DiskBus.VIRTIO, DiskDef.DiskProtocol.RBD, DiskDef.DiskFmtType.RAW); |
| |
| assertEquals(path, diskdef.getDiskPath()); |
| assertEquals(DiskDef.DiskType.NETWORK, diskdef.getDiskType()); |
| assertEquals(DiskDef.DiskFmtType.RAW, diskdef.getDiskFormatType()); |
| |
| String expected = "<disk device='disk' type='network'>\n" + |
| "<driver name='qemu' type='raw' cache='none' />\n" + |
| "<source protocol='rbd' name='/mnt/primary1'>\n" + |
| "<host name='fc00:1234::1' port='3300'/>\n" + |
| "<host name='fc00:1234::2' port='3300'/>\n" + |
| "<host name='fc00:1234::3' port='3300'/>\n" + |
| "</source>\n" + |
| "<auth username='admin'>\n" + |
| "<secret type='ceph' uuid='40b3f216-36b5-11ed-9357-9b4e21b0ed91'/>\n" + |
| "</auth>\n" + |
| "<target dev='vdc' bus='virtio'/>\n" + |
| "</disk>\n"; |
| |
| assertEquals(expected, diskdef.toString()); |
| } |
| |
| @Test |
| public void testDiskDefWithBurst() { |
| String filePath = "/var/lib/libvirt/images/disk.qcow2"; |
| String diskLabel = "vda"; |
| |
| DiskDef disk = new DiskDef(); |
| DiskDef.DiskBus bus = DiskDef.DiskBus.VIRTIO; |
| DiskDef.DiskFmtType type = DiskDef.DiskFmtType.QCOW2; |
| disk.defFileBasedDisk(filePath, diskLabel, bus, type); |
| |
| |
| Long iopsReadRate = 500L; |
| Long iopsReadRateMax = 2000L; |
| Long iopsReadRateMaxLength = 120L; |
| Long iopsWriteRate = 501L; |
| Long iopsWriteRateMax = 2001L; |
| Long iopsWriteRateMaxLength = 121L; |
| Long bytesReadRate = 1000L; |
| Long bytesReadRateMax = 2500L; |
| Long bytesReadRateMaxLength = 122L; |
| Long bytesWriteRate = 1001L; |
| Long bytesWriteRateMax = 2501L; |
| Long bytesWriteRateMaxLength = 123L; |
| |
| |
| disk.setIopsReadRate(iopsReadRate); |
| disk.setIopsReadRateMax(iopsReadRateMax); |
| disk.setIopsReadRateMaxLength(iopsReadRateMaxLength); |
| disk.setIopsWriteRate(iopsWriteRate); |
| disk.setIopsWriteRateMax(iopsWriteRateMax); |
| disk.setIopsWriteRateMaxLength(iopsWriteRateMaxLength); |
| disk.setBytesReadRate(bytesReadRate); |
| disk.setBytesReadRateMax(bytesReadRateMax); |
| disk.setBytesReadRateMaxLength(bytesReadRateMaxLength); |
| disk.setBytesWriteRate(bytesWriteRate); |
| disk.setBytesWriteRateMax(bytesWriteRateMax); |
| disk.setBytesWriteRateMaxLength(bytesWriteRateMaxLength); |
| |
| LibvirtVMDef.setGlobalQemuVersion(2006000L); |
| LibvirtVMDef.setGlobalLibvirtVersion(9008L); |
| |
| String xmlDef = disk.toString(); |
| String expectedXml = "<disk device='disk' type='file'>\n<driver name='qemu' type='" + type.toString() + "' cache='none' />\n" + |
| "<source file='" + filePath + "'/>\n<target dev='" + diskLabel + "' bus='" + bus.toString() + "'/>\n" + |
| "<iotune>\n<read_bytes_sec>"+bytesReadRate+"</read_bytes_sec>\n<write_bytes_sec>"+bytesWriteRate+"</write_bytes_sec>\n" + |
| "<read_iops_sec>"+iopsReadRate+"</read_iops_sec>\n<write_iops_sec>"+iopsWriteRate+"</write_iops_sec>\n" + |
| "<read_bytes_sec_max>"+bytesReadRateMax+"</read_bytes_sec_max>\n<write_bytes_sec_max>"+bytesWriteRateMax+"</write_bytes_sec_max>\n" + |
| "<read_iops_sec_max>"+iopsReadRateMax+"</read_iops_sec_max>\n<write_iops_sec_max>"+iopsWriteRateMax+"</write_iops_sec_max>\n" + |
| "<read_bytes_sec_max_length>"+bytesReadRateMaxLength+"</read_bytes_sec_max_length>\n<write_bytes_sec_max_length>"+bytesWriteRateMaxLength+"</write_bytes_sec_max_length>\n" + |
| "<read_iops_sec_max_length>"+iopsReadRateMaxLength+"</read_iops_sec_max_length>\n<write_iops_sec_max_length>"+iopsWriteRateMaxLength+"</write_iops_sec_max_length>\n</iotune>\n</disk>\n"; |
| |
| assertEquals(expectedXml, xmlDef); |
| } |
| |
| @Test |
| public void memBalloonDefTestNone() { |
| String expectedXml = "<memballoon model='none'>\n</memballoon>"; |
| MemBalloonDef memBalloonDef = new MemBalloonDef(); |
| memBalloonDef.defNoneMemBalloon(); |
| |
| String xmlDef = memBalloonDef.toString(); |
| |
| assertEquals(expectedXml, xmlDef); |
| } |
| |
| @Test |
| public void memBalloonDefTestVirtio() { |
| String expectedXml = "<memballoon model='virtio'>\n<stats period='60'/>\n</memballoon>"; |
| MemBalloonDef memBalloonDef = new MemBalloonDef(); |
| memBalloonDef.defVirtioMemBalloon("60"); |
| |
| String xmlDef = memBalloonDef.toString(); |
| |
| assertEquals(expectedXml, xmlDef); |
| } |
| |
| @Test |
| public void testHypervEnlightDef() { |
| LibvirtVMDef.FeaturesDef featuresDef = new LibvirtVMDef.FeaturesDef(); |
| LibvirtVMDef.HyperVEnlightenmentFeatureDef hyperVEnlightenmentFeatureDef = new LibvirtVMDef.HyperVEnlightenmentFeatureDef(); |
| hyperVEnlightenmentFeatureDef.setFeature("relaxed", true); |
| hyperVEnlightenmentFeatureDef.setFeature("vapic", true); |
| hyperVEnlightenmentFeatureDef.setFeature("spinlocks", true); |
| hyperVEnlightenmentFeatureDef.setRetries(8096); |
| featuresDef.addHyperVFeature(hyperVEnlightenmentFeatureDef); |
| String defs = featuresDef.toString(); |
| assertTrue(defs.contains("relaxed")); |
| assertTrue(defs.contains("vapic")); |
| assertTrue(defs.contains("spinlocks")); |
| |
| featuresDef = new LibvirtVMDef.FeaturesDef(); |
| featuresDef.addFeatures("pae"); |
| defs = featuresDef.toString(); |
| assertFalse(defs.contains("relaxed")); |
| assertFalse(defs.contains("vapic")); |
| assertFalse(defs.contains("spinlocks")); |
| assertTrue("Windows PV".contains("Windows PV")); |
| |
| } |
| |
| @Test |
| public void testRngDef() { |
| LibvirtVMDef.RngDef.RngBackendModel backendModel = LibvirtVMDef.RngDef.RngBackendModel.RANDOM; |
| String path = "/dev/random"; |
| int period = 2000; |
| int bytes = 2048; |
| |
| LibvirtVMDef.RngDef def = new LibvirtVMDef.RngDef(path, backendModel, bytes, period); |
| assertEquals(path, def.getPath()); |
| assertEquals(backendModel, def.getRngBackendModel()); |
| assertEquals(LibvirtVMDef.RngDef.RngModel.VIRTIO, def.getRngModel()); |
| assertEquals(bytes, def.getRngRateBytes()); |
| assertEquals(period, def.getRngRatePeriod()); |
| } |
| |
| @Test |
| public void testChannelDef() { |
| ChannelDef.ChannelType type = ChannelDef.ChannelType.UNIX; |
| ChannelDef.ChannelState state = ChannelDef.ChannelState.CONNECTED; |
| String name = "v-136-VM.org.qemu.guest_agent.0"; |
| File path = new File("/var/lib/libvirt/qemu/" + name); |
| |
| ChannelDef channelDef = new ChannelDef(name, type, state, path); |
| |
| assertEquals(state, channelDef.getChannelState()); |
| assertEquals(type, channelDef.getChannelType()); |
| assertEquals(name, channelDef.getName()); |
| assertEquals(path, channelDef.getPath()); |
| } |
| |
| @Test |
| public void testWatchDogDef() { |
| LibvirtVMDef.WatchDogDef.WatchDogModel model = LibvirtVMDef.WatchDogDef.WatchDogModel.I6300ESB; |
| LibvirtVMDef.WatchDogDef.WatchDogAction action = LibvirtVMDef.WatchDogDef.WatchDogAction.RESET; |
| |
| LibvirtVMDef.WatchDogDef def = new LibvirtVMDef.WatchDogDef(action, model); |
| assertEquals(model, def.getModel()); |
| assertEquals(action, def.getAction()); |
| } |
| |
| @Test |
| public void testSCSIDef() { |
| SCSIDef def = new SCSIDef((short)0, 0, 0, 9, 0, 4); |
| String str = def.toString(); |
| String expected = "<controller type='scsi' index='0' model='virtio-scsi'>\n" + |
| "<address type='pci' domain='0x0000' bus='0x00' slot='0x09' function='0x0'/>\n" + |
| "<driver queues='4'/>\n" + |
| "</controller>\n"; |
| assertEquals(expected, str); |
| } |
| } |
