1 package PVE
::QemuServer
;
23 use Storable
qw(dclone);
25 use PVE
::Exception
qw(raise raise_param_exc);
27 use PVE
::Tools
qw(run_command lock_file lock_file_full file_read_firstline dir_glob_foreach $IPV6RE);
28 use PVE
::JSONSchema
qw(get_standard_option);
29 use PVE
::Cluster
qw(cfs_register_file cfs_read_file cfs_write_file cfs_lock_file);
34 use PVE
::RPCEnvironment
;
35 use PVE
::GuestHelpers
;
36 use PVE
::QemuServer
::PCI
qw(print_pci_addr print_pcie_addr);
37 use PVE
::QemuServer
::Memory
;
38 use PVE
::QemuServer
::USB
qw(parse_usb_device);
39 use PVE
::QemuServer
::Cloudinit
;
42 use Time
::HiRes
qw(gettimeofday);
43 use File
::Copy
qw(copy);
46 my $EDK2_FW_BASE = '/usr/share/pve-edk2-firmware/';
49 "$EDK2_FW_BASE/OVMF_CODE.fd",
50 "$EDK2_FW_BASE/OVMF_VARS.fd"
53 "$EDK2_FW_BASE/AAVMF_CODE.fd",
54 "$EDK2_FW_BASE/AAVMF_VARS.fd"
58 my $qemu_snap_storage = { rbd
=> 1 };
60 my $cpuinfo = PVE
::ProcFSTools
::read_cpuinfo
();
62 my $QEMU_FORMAT_RE = qr/raw|cow|qcow|qcow2|qed|vmdk|cloop/;
64 # Note about locking: we use flock on the config file protect
65 # against concurent actions.
66 # Aditionaly, we have a 'lock' setting in the config file. This
67 # can be set to 'migrate', 'backup', 'snapshot' or 'rollback'. Most actions are not
68 # allowed when such lock is set. But you can ignore this kind of
69 # lock with the --skiplock flag.
71 cfs_register_file
('/qemu-server/',
75 PVE
::JSONSchema
::register_standard_option
('pve-qm-stateuri', {
76 description
=> "Some command save/restore state from this location.",
82 PVE
::JSONSchema
::register_standard_option
('pve-qm-image-format', {
84 enum
=> [qw(raw cow qcow qed qcow2 vmdk cloop)],
85 description
=> "The drive's backing file's data format.",
89 PVE
::JSONSchema
::register_standard_option
('pve-qemu-machine', {
90 description
=> "Specifies the Qemu machine type.",
92 pattern
=> '(pc|pc(-i440fx)?-\d+\.\d+(\.pxe)?|q35|pc-q35-\d+\.\d+(\.pxe)?|virt(?:-\d+\.\d+)?)',
97 #no warnings 'redefine';
100 my ($controller, $vmid, $option, $value) = @_;
102 my $path = "/sys/fs/cgroup/$controller/qemu.slice/$vmid.scope/$option";
103 PVE
::ProcFSTools
::write_proc_entry
($path, $value);
107 my $nodename = PVE
::INotify
::nodename
();
109 mkdir "/etc/pve/nodes/$nodename";
110 my $confdir = "/etc/pve/nodes/$nodename/qemu-server";
113 my $var_run_tmpdir = "/var/run/qemu-server";
114 mkdir $var_run_tmpdir;
116 my $lock_dir = "/var/lock/qemu-server";
119 my $cpu_vendor_list = {
121 486 => 'GenuineIntel',
122 pentium
=> 'GenuineIntel',
123 pentium2
=> 'GenuineIntel',
124 pentium3
=> 'GenuineIntel',
125 coreduo
=> 'GenuineIntel',
126 core2duo
=> 'GenuineIntel',
127 Conroe
=> 'GenuineIntel',
128 Penryn
=> 'GenuineIntel',
129 Nehalem
=> 'GenuineIntel',
130 'Nehalem-IBRS' => 'GenuineIntel',
131 Westmere
=> 'GenuineIntel',
132 'Westmere-IBRS' => 'GenuineIntel',
133 SandyBridge
=> 'GenuineIntel',
134 'SandyBridge-IBRS' => 'GenuineIntel',
135 IvyBridge
=> 'GenuineIntel',
136 'IvyBridge-IBRS' => 'GenuineIntel',
137 Haswell
=> 'GenuineIntel',
138 'Haswell-IBRS' => 'GenuineIntel',
139 'Haswell-noTSX' => 'GenuineIntel',
140 'Haswell-noTSX-IBRS' => 'GenuineIntel',
141 Broadwell
=> 'GenuineIntel',
142 'Broadwell-IBRS' => 'GenuineIntel',
143 'Broadwell-noTSX' => 'GenuineIntel',
144 'Broadwell-noTSX-IBRS' => 'GenuineIntel',
145 'Skylake-Client' => 'GenuineIntel',
146 'Skylake-Client-IBRS' => 'GenuineIntel',
147 'Skylake-Server' => 'GenuineIntel',
148 'Skylake-Server-IBRS' => 'GenuineIntel',
151 athlon
=> 'AuthenticAMD',
152 phenom
=> 'AuthenticAMD',
153 Opteron_G1
=> 'AuthenticAMD',
154 Opteron_G2
=> 'AuthenticAMD',
155 Opteron_G3
=> 'AuthenticAMD',
156 Opteron_G4
=> 'AuthenticAMD',
157 Opteron_G5
=> 'AuthenticAMD',
158 EPYC
=> 'AuthenticAMD',
159 'EPYC-IBPB' => 'AuthenticAMD',
161 # generic types, use vendor from host node
170 my @supported_cpu_flags = (
184 my $cpu_flag = qr/[+-](@{[join('|', @supported_cpu_flags)]})/;
188 description
=> "Emulated CPU type.",
190 enum
=> [ sort { "\L$a" cmp "\L$b" } keys %$cpu_vendor_list ],
195 description
=> "Do not identify as a KVM virtual machine.",
202 pattern
=> qr/[a-zA-Z0-9]{1,12}/,
203 format_description
=> 'vendor-id',
204 description
=> 'The Hyper-V vendor ID. Some drivers or programs inside Windows guests need a specific ID.',
208 description
=> "List of additional CPU flags separated by ';'."
209 . " Use '+FLAG' to enable, '-FLAG' to disable a flag."
210 . " Currently supported flags: @{[join(', ', @supported_cpu_flags)]}.",
211 format_description
=> '+FLAG[;-FLAG...]',
213 pattern
=> qr/$cpu_flag(;$cpu_flag)*/,
222 enum
=> [qw(i6300esb ib700)],
223 description
=> "Watchdog type to emulate.",
224 default => 'i6300esb',
229 enum
=> [qw(reset shutdown poweroff pause debug none)],
230 description
=> "The action to perform if after activation the guest fails to poll the watchdog in time.",
234 PVE
::JSONSchema
::register_format
('pve-qm-watchdog', $watchdog_fmt);
238 description
=> "Enable/disable Qemu GuestAgent.",
243 fstrim_cloned_disks
=> {
244 description
=> "Run fstrim after cloning/moving a disk.",
253 description
=> "Select the VGA type.",
258 enum
=> [qw(cirrus qxl qxl2 qxl3 qxl4 none serial0 serial1 serial2 serial3 std virtio vmware)],
261 description
=> "Sets the VGA memory (in MiB). Has no effect with serial display.",
273 description
=> "The size of the file in MB.",
277 pattern
=> '[a-zA-Z0-9\-]+',
279 format_description
=> 'string',
280 description
=> "The name of the file. Will be prefixed with 'pve-shm-'. Default is the VMID. Will be deleted when the VM is stopped.",
287 enum
=> [qw(ich9-intel-hda intel-hda AC97)],
288 description
=> "Configure an audio device."
295 description
=> "Driver backend for the audio device."
299 my $spice_enhancements_fmt = {
303 description
=> "Enable folder sharing via SPICE. Needs Spice-WebDAV daemon installed in the VM."
307 enum
=> ['off', 'all', 'filter'],
309 description
=> "Enable video streaming. Uses compression for detected video streams."
317 description
=> "Specifies whether a VM will be started during system bootup.",
323 description
=> "Automatic restart after crash (currently ignored).",
328 type
=> 'string', format
=> 'pve-hotplug-features',
329 description
=> "Selectively enable hotplug features. This is a comma separated list of hotplug features: 'network', 'disk', 'cpu', 'memory' and 'usb'. Use '0' to disable hotplug completely. Value '1' is an alias for the default 'network,disk,usb'.",
330 default => 'network,disk,usb',
335 description
=> "Allow reboot. If set to '0' the VM exit on reboot.",
341 description
=> "Lock/unlock the VM.",
342 enum
=> [qw(backup clone create migrate rollback snapshot snapshot-delete suspending suspended)],
347 description
=> "Limit of CPU usage.",
348 verbose_description
=> "Limit of CPU usage.\n\nNOTE: If the computer has 2 CPUs, it has total of '2' CPU time. Value '0' indicates no CPU limit.",
356 description
=> "CPU weight for a VM.",
357 verbose_description
=> "CPU weight for a VM. Argument is used in the kernel fair scheduler. The larger the number is, the more CPU time this VM gets. Number is relative to weights of all the other running VMs.",
365 description
=> "Amount of RAM for the VM in MB. This is the maximum available memory when you use the balloon device.",
372 description
=> "Amount of target RAM for the VM in MB. Using zero disables the ballon driver.",
378 description
=> "Amount of memory shares for auto-ballooning. The larger the number is, the more memory this VM gets. Number is relative to weights of all other running VMs. Using zero disables auto-ballooning. Auto-ballooning is done by pvestatd.",
386 description
=> "Keybord layout for vnc server. Default is read from the '/etc/pve/datacenter.cfg' configuration file.".
387 "It should not be necessary to set it.",
388 enum
=> PVE
::Tools
::kvmkeymaplist
(),
393 type
=> 'string', format
=> 'dns-name',
394 description
=> "Set a name for the VM. Only used on the configuration web interface.",
399 description
=> "SCSI controller model",
400 enum
=> [qw(lsi lsi53c810 virtio-scsi-pci virtio-scsi-single megasas pvscsi)],
406 description
=> "Description for the VM. Only used on the configuration web interface. This is saved as comment inside the configuration file.",
411 enum
=> [qw(other wxp w2k w2k3 w2k8 wvista win7 win8 win10 l24 l26 solaris)],
412 description
=> "Specify guest operating system.",
413 verbose_description
=> <<EODESC,
414 Specify guest operating system. This is used to enable special
415 optimization/features for specific operating systems:
418 other;; unspecified OS
419 wxp;; Microsoft Windows XP
420 w2k;; Microsoft Windows 2000
421 w2k3;; Microsoft Windows 2003
422 w2k8;; Microsoft Windows 2008
423 wvista;; Microsoft Windows Vista
424 win7;; Microsoft Windows 7
425 win8;; Microsoft Windows 8/2012/2012r2
426 win10;; Microsoft Windows 10/2016
427 l24;; Linux 2.4 Kernel
428 l26;; Linux 2.6/3.X Kernel
429 solaris;; Solaris/OpenSolaris/OpenIndiania kernel
435 description
=> "Boot on floppy (a), hard disk (c), CD-ROM (d), or network (n).",
436 pattern
=> '[acdn]{1,4}',
441 type
=> 'string', format
=> 'pve-qm-bootdisk',
442 description
=> "Enable booting from specified disk.",
443 pattern
=> '(ide|sata|scsi|virtio)\d+',
448 description
=> "The number of CPUs. Please use option -sockets instead.",
455 description
=> "The number of CPU sockets.",
462 description
=> "The number of cores per socket.",
469 description
=> "Enable/disable NUMA.",
475 description
=> "Enable/disable hugepages memory.",
476 enum
=> [qw(any 2 1024)],
481 description
=> "Number of hotplugged vcpus.",
488 description
=> "Enable/disable ACPI.",
493 description
=> "Enable/disable Qemu GuestAgent and its properties.",
495 format
=> $agent_fmt,
500 description
=> "Enable/disable KVM hardware virtualization.",
506 description
=> "Enable/disable time drift fix.",
512 description
=> "Set the real time clock to local time. This is enabled by default if ostype indicates a Microsoft OS.",
517 description
=> "Freeze CPU at startup (use 'c' monitor command to start execution).",
521 type
=> 'string', format
=> $vga_fmt,
522 description
=> "Configure the VGA hardware.",
523 verbose_description
=> "Configure the VGA Hardware. If you want to use ".
524 "high resolution modes (>= 1280x1024x16) you may need to increase " .
525 "the vga memory option. Since QEMU 2.9 the default VGA display type " .
526 "is 'std' for all OS types besides some Windows versions (XP and " .
527 "older) which use 'cirrus'. The 'qxl' option enables the SPICE " .
528 "display server. For win* OS you can select how many independent " .
529 "displays you want, Linux guests can add displays them self.\n".
530 "You can also run without any graphic card, using a serial device as terminal.",
534 type
=> 'string', format
=> 'pve-qm-watchdog',
535 description
=> "Create a virtual hardware watchdog device.",
536 verbose_description
=> "Create a virtual hardware watchdog device. Once enabled" .
537 " (by a guest action), the watchdog must be periodically polled " .
538 "by an agent inside the guest or else the watchdog will reset " .
539 "the guest (or execute the respective action specified)",
544 typetext
=> "(now | YYYY-MM-DD | YYYY-MM-DDTHH:MM:SS)",
545 description
=> "Set the initial date of the real time clock. Valid format for date are: 'now' or '2006-06-17T16:01:21' or '2006-06-17'.",
546 pattern
=> '(now|\d{4}-\d{1,2}-\d{1,2}(T\d{1,2}:\d{1,2}:\d{1,2})?)',
549 startup
=> get_standard_option
('pve-startup-order'),
553 description
=> "Enable/disable Template.",
559 description
=> "Arbitrary arguments passed to kvm.",
560 verbose_description
=> <<EODESCR,
561 Arbitrary arguments passed to kvm, for example:
563 args: -no-reboot -no-hpet
565 NOTE: this option is for experts only.
572 description
=> "Enable/disable the USB tablet device.",
573 verbose_description
=> "Enable/disable the USB tablet device. This device is " .
574 "usually needed to allow absolute mouse positioning with VNC. " .
575 "Else the mouse runs out of sync with normal VNC clients. " .
576 "If you're running lots of console-only guests on one host, " .
577 "you may consider disabling this to save some context switches. " .
578 "This is turned off by default if you use spice (-vga=qxl).",
583 description
=> "Set maximum speed (in MB/s) for migrations. Value 0 is no limit.",
587 migrate_downtime
=> {
590 description
=> "Set maximum tolerated downtime (in seconds) for migrations.",
596 type
=> 'string', format
=> 'pve-qm-ide',
597 typetext
=> '<volume>',
598 description
=> "This is an alias for option -ide2",
602 description
=> "Emulated CPU type.",
606 parent
=> get_standard_option
('pve-snapshot-name', {
608 description
=> "Parent snapshot name. This is used internally, and should not be modified.",
612 description
=> "Timestamp for snapshots.",
618 type
=> 'string', format
=> 'pve-volume-id',
619 description
=> "Reference to a volume which stores the VM state. This is used internally for snapshots.",
621 vmstatestorage
=> get_standard_option
('pve-storage-id', {
622 description
=> "Default storage for VM state volumes/files.",
625 runningmachine
=> get_standard_option
('pve-qemu-machine', {
626 description
=> "Specifies the Qemu machine type of the running vm. This is used internally for snapshots.",
628 machine
=> get_standard_option
('pve-qemu-machine'),
630 description
=> "Virtual processor architecture. Defaults to the host.",
633 enum
=> [qw(x86_64 aarch64)],
636 description
=> "Specify SMBIOS type 1 fields.",
637 type
=> 'string', format
=> 'pve-qm-smbios1',
644 description
=> "Sets the protection flag of the VM. This will disable the remove VM and remove disk operations.",
650 enum
=> [ qw(seabios ovmf) ],
651 description
=> "Select BIOS implementation.",
652 default => 'seabios',
656 pattern
=> '(?:[a-fA-F0-9]{8}(?:-[a-fA-F0-9]{4}){3}-[a-fA-F0-9]{12}|[01])',
657 format_description
=> 'UUID',
658 description
=> "Set VM Generation ID. Use '1' to autogenerate on create or update, pass '0' to disable explicitly.",
659 verbose_description
=> "The VM generation ID (vmgenid) device exposes a".
660 " 128-bit integer value identifier to the guest OS. This allows to".
661 " notify the guest operating system when the virtual machine is".
662 " executed with a different configuration (e.g. snapshot execution".
663 " or creation from a template). The guest operating system notices".
664 " the change, and is then able to react as appropriate by marking".
665 " its copies of distributed databases as dirty, re-initializing its".
666 " random number generator, etc.\n".
667 "Note that auto-creation only works when done throug API/CLI create".
668 " or update methods, but not when manually editing the config file.",
669 default => "1 (autogenerated)",
674 format
=> 'pve-volume-id',
676 description
=> "Script that will be executed during various steps in the vms lifetime.",
680 format
=> $ivshmem_fmt,
681 description
=> "Inter-VM shared memory. Useful for direct communication between VMs, or to the host.",
686 format
=> $audio_fmt,
687 description
=> "Configure a audio device, useful in combination with QXL/Spice.",
690 spice_enhancements
=> {
692 format
=> $spice_enhancements_fmt,
693 description
=> "Configure additional enhancements for SPICE.",
702 description
=> 'Specify a custom file containing all meta data passed to the VM via cloud-init. This is provider specific meaning configdrive2 and nocloud differ.',
703 format
=> 'pve-volume-id',
704 format_description
=> 'volume',
709 description
=> 'Specify a custom file containing all network data passed to the VM via cloud-init.',
710 format
=> 'pve-volume-id',
711 format_description
=> 'volume',
716 description
=> 'Specify a custom file containing all user data passed to the VM via cloud-init.',
717 format
=> 'pve-volume-id',
718 format_description
=> 'volume',
721 PVE
::JSONSchema
::register_format
('pve-qm-cicustom', $cicustom_fmt);
723 my $confdesc_cloudinit = {
727 description
=> 'Specifies the cloud-init configuration format. The default depends on the configured operating system type (`ostype`. We use the `nocloud` format for Linux, and `configdrive2` for windows.',
728 enum
=> ['configdrive2', 'nocloud'],
733 description
=> "cloud-init: User name to change ssh keys and password for instead of the image's configured default user.",
738 description
=> 'cloud-init: Password to assign the user. Using this is generally not recommended. Use ssh keys instead. Also note that older cloud-init versions do not support hashed passwords.',
743 description
=> 'cloud-init: Specify custom files to replace the automatically generated ones at start.',
744 format
=> 'pve-qm-cicustom',
749 description
=> "cloud-init: Sets DNS search domains for a container. Create will automatically use the setting from the host if neither searchdomain nor nameserver are set.",
753 type
=> 'string', format
=> 'address-list',
754 description
=> "cloud-init: Sets DNS server IP address for a container. Create will automatically use the setting from the host if neither searchdomain nor nameserver are set.",
759 format
=> 'urlencoded',
760 description
=> "cloud-init: Setup public SSH keys (one key per line, OpenSSH format).",
764 # what about other qemu settings ?
766 #machine => 'string',
779 ##soundhw => 'string',
781 while (my ($k, $v) = each %$confdesc) {
782 PVE
::JSONSchema
::register_standard_option
("pve-qm-$k", $v);
785 my $MAX_IDE_DISKS = 4;
786 my $MAX_SCSI_DISKS = 14;
787 my $MAX_VIRTIO_DISKS = 16;
788 my $MAX_SATA_DISKS = 6;
789 my $MAX_USB_DEVICES = 5;
791 my $MAX_UNUSED_DISKS = 256;
792 my $MAX_HOSTPCI_DEVICES = 4;
793 my $MAX_SERIAL_PORTS = 4;
794 my $MAX_PARALLEL_PORTS = 3;
800 pattern
=> qr/\d+(?:-\d+)?(?:;\d+(?:-\d+)?)*/,
801 description
=> "CPUs accessing this NUMA node.",
802 format_description
=> "id[-id];...",
806 description
=> "Amount of memory this NUMA node provides.",
811 pattern
=> qr/\d+(?:-\d+)?(?:;\d+(?:-\d+)?)*/,
812 description
=> "Host NUMA nodes to use.",
813 format_description
=> "id[-id];...",
818 enum
=> [qw(preferred bind interleave)],
819 description
=> "NUMA allocation policy.",
823 PVE
::JSONSchema
::register_format
('pve-qm-numanode', $numa_fmt);
826 type
=> 'string', format
=> $numa_fmt,
827 description
=> "NUMA topology.",
829 PVE
::JSONSchema
::register_standard_option
("pve-qm-numanode", $numadesc);
831 for (my $i = 0; $i < $MAX_NUMA; $i++) {
832 $confdesc->{"numa$i"} = $numadesc;
835 my $nic_model_list = ['rtl8139', 'ne2k_pci', 'e1000', 'pcnet', 'virtio',
836 'ne2k_isa', 'i82551', 'i82557b', 'i82559er', 'vmxnet3',
837 'e1000-82540em', 'e1000-82544gc', 'e1000-82545em'];
838 my $nic_model_list_txt = join(' ', sort @$nic_model_list);
840 my $net_fmt_bridge_descr = <<__EOD__;
841 Bridge to attach the network device to. The Proxmox VE standard bridge
844 If you do not specify a bridge, we create a kvm user (NATed) network
845 device, which provides DHCP and DNS services. The following addresses
852 The DHCP server assign addresses to the guest starting from 10.0.2.15.
856 macaddr
=> get_standard_option
('mac-addr', {
857 description
=> "MAC address. That address must be unique withing your network. This is automatically generated if not specified.",
861 description
=> "Network Card Model. The 'virtio' model provides the best performance with very low CPU overhead. If your guest does not support this driver, it is usually best to use 'e1000'.",
862 enum
=> $nic_model_list,
865 (map { $_ => { keyAlias
=> 'model', alias
=> 'macaddr' }} @$nic_model_list),
868 description
=> $net_fmt_bridge_descr,
869 format_description
=> 'bridge',
874 minimum
=> 0, maximum
=> 16,
875 description
=> 'Number of packet queues to be used on the device.',
881 description
=> "Rate limit in mbps (megabytes per second) as floating point number.",
886 minimum
=> 1, maximum
=> 4094,
887 description
=> 'VLAN tag to apply to packets on this interface.',
892 pattern
=> qr/\d+(?:-\d+)?(?:;\d+(?:-\d+)?)*/,
893 description
=> 'VLAN trunks to pass through this interface.',
894 format_description
=> 'vlanid[;vlanid...]',
899 description
=> 'Whether this interface should be protected by the firewall.',
904 description
=> 'Whether this interface should be disconnected (like pulling the plug).',
911 type
=> 'string', format
=> $net_fmt,
912 description
=> "Specify network devices.",
915 PVE
::JSONSchema
::register_standard_option
("pve-qm-net", $netdesc);
920 format
=> 'pve-ipv4-config',
921 format_description
=> 'IPv4Format/CIDR',
922 description
=> 'IPv4 address in CIDR format.',
929 format_description
=> 'GatewayIPv4',
930 description
=> 'Default gateway for IPv4 traffic.',
936 format
=> 'pve-ipv6-config',
937 format_description
=> 'IPv6Format/CIDR',
938 description
=> 'IPv6 address in CIDR format.',
945 format_description
=> 'GatewayIPv6',
946 description
=> 'Default gateway for IPv6 traffic.',
951 PVE
::JSONSchema
::register_format
('pve-qm-ipconfig', $ipconfig_fmt);
954 type
=> 'string', format
=> 'pve-qm-ipconfig',
955 description
=> <<'EODESCR',
956 cloud-init: Specify IP addresses and gateways for the corresponding interface.
958 IP addresses use CIDR notation, gateways are optional but need an IP of the same type specified.
960 The special string 'dhcp' can be used for IP addresses to use DHCP, in which case no explicit gateway should be provided.
961 For IPv6 the special string 'auto' can be used to use stateless autoconfiguration.
963 If cloud-init is enabled and neither an IPv4 nor an IPv6 address is specified, it defaults to using dhcp on IPv4.
966 PVE
::JSONSchema
::register_standard_option
("pve-qm-ipconfig", $netdesc);
968 for (my $i = 0; $i < $MAX_NETS; $i++) {
969 $confdesc->{"net$i"} = $netdesc;
970 $confdesc_cloudinit->{"ipconfig$i"} = $ipconfigdesc;
973 foreach my $key (keys %$confdesc_cloudinit) {
974 $confdesc->{$key} = $confdesc_cloudinit->{$key};
977 PVE
::JSONSchema
::register_format
('pve-volume-id-or-qm-path', \
&verify_volume_id_or_qm_path
);
978 sub verify_volume_id_or_qm_path
{
979 my ($volid, $noerr) = @_;
981 if ($volid eq 'none' || $volid eq 'cdrom' || $volid =~ m
|^/|) {
985 # if its neither 'none' nor 'cdrom' nor a path, check if its a volume-id
986 $volid = eval { PVE
::JSONSchema
::check_format
('pve-volume-id', $volid, '') };
988 return undef if $noerr;
996 my %drivedesc_base = (
997 volume
=> { alias
=> 'file' },
1000 format
=> 'pve-volume-id-or-qm-path',
1002 format_description
=> 'volume',
1003 description
=> "The drive's backing volume.",
1007 enum
=> [qw(cdrom disk)],
1008 description
=> "The drive's media type.",
1014 description
=> "Force the drive's physical geometry to have a specific cylinder count.",
1019 description
=> "Force the drive's physical geometry to have a specific head count.",
1024 description
=> "Force the drive's physical geometry to have a specific sector count.",
1029 enum
=> [qw(none lba auto)],
1030 description
=> "Force disk geometry bios translation mode.",
1035 description
=> "Controls qemu's snapshot mode feature."
1036 . " If activated, changes made to the disk are temporary and will"
1037 . " be discarded when the VM is shutdown.",
1042 enum
=> [qw(none writethrough writeback unsafe directsync)],
1043 description
=> "The drive's cache mode",
1046 format
=> get_standard_option
('pve-qm-image-format'),
1049 format
=> 'disk-size',
1050 format_description
=> 'DiskSize',
1051 description
=> "Disk size. This is purely informational and has no effect.",
1056 description
=> "Whether the drive should be included when making backups.",
1061 description
=> 'Whether the drive should considered for replication jobs.',
1067 enum
=> [qw(ignore report stop)],
1068 description
=> 'Read error action.',
1073 enum
=> [qw(enospc ignore report stop)],
1074 description
=> 'Write error action.',
1079 enum
=> [qw(native threads)],
1080 description
=> 'AIO type to use.',
1085 enum
=> [qw(ignore on)],
1086 description
=> 'Controls whether to pass discard/trim requests to the underlying storage.',
1091 description
=> 'Controls whether to detect and try to optimize writes of zeroes.',
1096 format
=> 'urlencoded',
1097 format_description
=> 'serial',
1098 maxLength
=> 20*3, # *3 since it's %xx url enoded
1099 description
=> "The drive's reported serial number, url-encoded, up to 20 bytes long.",
1104 description
=> 'Mark this locally-managed volume as available on all nodes',
1105 verbose_description
=> "Mark this locally-managed volume as available on all nodes.\n\nWARNING: This option does not share the volume automatically, it assumes it is shared already!",
1111 my %iothread_fmt = ( iothread
=> {
1113 description
=> "Whether to use iothreads for this drive",
1120 format
=> 'urlencoded',
1121 format_description
=> 'model',
1122 maxLength
=> 40*3, # *3 since it's %xx url enoded
1123 description
=> "The drive's reported model name, url-encoded, up to 40 bytes long.",
1131 description
=> "Number of queues.",
1137 my %scsiblock_fmt = (
1140 description
=> "whether to use scsi-block for full passthrough of host block device\n\nWARNING: can lead to I/O errors in combination with low memory or high memory fragmentation on host",
1149 description
=> "Whether to expose this drive as an SSD, rather than a rotational hard disk.",
1157 pattern
=> qr/^(0x)[0-9a-fA-F]{16}/,
1158 format_description
=> 'wwn',
1159 description
=> "The drive's worldwide name, encoded as 16 bytes hex string, prefixed by '0x'.",
1164 my $add_throttle_desc = sub {
1165 my ($key, $type, $what, $unit, $longunit, $minimum) = @_;
1168 format_description
=> $unit,
1169 description
=> "Maximum $what in $longunit.",
1172 $d->{minimum
} = $minimum if defined($minimum);
1173 $drivedesc_base{$key} = $d;
1175 # throughput: (leaky bucket)
1176 $add_throttle_desc->('bps', 'integer', 'r/w speed', 'bps', 'bytes per second');
1177 $add_throttle_desc->('bps_rd', 'integer', 'read speed', 'bps', 'bytes per second');
1178 $add_throttle_desc->('bps_wr', 'integer', 'write speed', 'bps', 'bytes per second');
1179 $add_throttle_desc->('mbps', 'number', 'r/w speed', 'mbps', 'megabytes per second');
1180 $add_throttle_desc->('mbps_rd', 'number', 'read speed', 'mbps', 'megabytes per second');
1181 $add_throttle_desc->('mbps_wr', 'number', 'write speed', 'mbps', 'megabytes per second');
1182 $add_throttle_desc->('iops', 'integer', 'r/w I/O', 'iops', 'operations per second');
1183 $add_throttle_desc->('iops_rd', 'integer', 'read I/O', 'iops', 'operations per second');
1184 $add_throttle_desc->('iops_wr', 'integer', 'write I/O', 'iops', 'operations per second');
1186 # pools: (pool of IO before throttling starts taking effect)
1187 $add_throttle_desc->('mbps_max', 'number', 'unthrottled r/w pool', 'mbps', 'megabytes per second');
1188 $add_throttle_desc->('mbps_rd_max', 'number', 'unthrottled read pool', 'mbps', 'megabytes per second');
1189 $add_throttle_desc->('mbps_wr_max', 'number', 'unthrottled write pool', 'mbps', 'megabytes per second');
1190 $add_throttle_desc->('iops_max', 'integer', 'unthrottled r/w I/O pool', 'iops', 'operations per second');
1191 $add_throttle_desc->('iops_rd_max', 'integer', 'unthrottled read I/O pool', 'iops', 'operations per second');
1192 $add_throttle_desc->('iops_wr_max', 'integer', 'unthrottled write I/O pool', 'iops', 'operations per second');
1195 $add_throttle_desc->('bps_max_length', 'integer', 'length of I/O bursts', 'seconds', 'seconds', 1);
1196 $add_throttle_desc->('bps_rd_max_length', 'integer', 'length of read I/O bursts', 'seconds', 'seconds', 1);
1197 $add_throttle_desc->('bps_wr_max_length', 'integer', 'length of write I/O bursts', 'seconds', 'seconds', 1);
1198 $add_throttle_desc->('iops_max_length', 'integer', 'length of I/O bursts', 'seconds', 'seconds', 1);
1199 $add_throttle_desc->('iops_rd_max_length', 'integer', 'length of read I/O bursts', 'seconds', 'seconds', 1);
1200 $add_throttle_desc->('iops_wr_max_length', 'integer', 'length of write I/O bursts', 'seconds', 'seconds', 1);
1203 $drivedesc_base{'bps_rd_length'} = { alias
=> 'bps_rd_max_length' };
1204 $drivedesc_base{'bps_wr_length'} = { alias
=> 'bps_wr_max_length' };
1205 $drivedesc_base{'iops_rd_length'} = { alias
=> 'iops_rd_max_length' };
1206 $drivedesc_base{'iops_wr_length'} = { alias
=> 'iops_wr_max_length' };
1214 PVE
::JSONSchema
::register_format
("pve-qm-ide", $ide_fmt);
1218 type
=> 'string', format
=> $ide_fmt,
1219 description
=> "Use volume as IDE hard disk or CD-ROM (n is 0 to " .($MAX_IDE_DISKS -1) . ").",
1221 PVE
::JSONSchema
::register_standard_option
("pve-qm-ide", $idedesc);
1233 type
=> 'string', format
=> $scsi_fmt,
1234 description
=> "Use volume as SCSI hard disk or CD-ROM (n is 0 to " . ($MAX_SCSI_DISKS - 1) . ").",
1236 PVE
::JSONSchema
::register_standard_option
("pve-qm-scsi", $scsidesc);
1245 type
=> 'string', format
=> $sata_fmt,
1246 description
=> "Use volume as SATA hard disk or CD-ROM (n is 0 to " . ($MAX_SATA_DISKS - 1). ").",
1248 PVE
::JSONSchema
::register_standard_option
("pve-qm-sata", $satadesc);
1256 type
=> 'string', format
=> $virtio_fmt,
1257 description
=> "Use volume as VIRTIO hard disk (n is 0 to " . ($MAX_VIRTIO_DISKS - 1) . ").",
1259 PVE
::JSONSchema
::register_standard_option
("pve-qm-virtio", $virtiodesc);
1261 my $alldrive_fmt = {
1272 volume
=> { alias
=> 'file' },
1275 format
=> 'pve-volume-id-or-qm-path',
1277 format_description
=> 'volume',
1278 description
=> "The drive's backing volume.",
1280 format
=> get_standard_option
('pve-qm-image-format'),
1283 format
=> 'disk-size',
1284 format_description
=> 'DiskSize',
1285 description
=> "Disk size. This is purely informational and has no effect.",
1290 my $efidisk_desc = {
1292 type
=> 'string', format
=> $efidisk_fmt,
1293 description
=> "Configure a Disk for storing EFI vars",
1296 PVE
::JSONSchema
::register_standard_option
("pve-qm-efidisk", $efidisk_desc);
1301 type
=> 'string', format
=> 'pve-qm-usb-device',
1302 format_description
=> 'HOSTUSBDEVICE|spice',
1303 description
=> <<EODESCR,
1304 The Host USB device or port or the value 'spice'. HOSTUSBDEVICE syntax is:
1306 'bus-port(.port)*' (decimal numbers) or
1307 'vendor_id:product_id' (hexadeciaml numbers) or
1310 You can use the 'lsusb -t' command to list existing usb devices.
1312 NOTE: This option allows direct access to host hardware. So it is no longer possible to migrate such machines - use with special care.
1314 The value 'spice' can be used to add a usb redirection devices for spice.
1320 description
=> "Specifies whether if given host option is a USB3 device or port (this does currently not work reliably with spice redirection and is then ignored).",
1327 type
=> 'string', format
=> $usb_fmt,
1328 description
=> "Configure an USB device (n is 0 to 4).",
1330 PVE
::JSONSchema
::register_standard_option
("pve-qm-usb", $usbdesc);
1332 my $PCIRE = qr/[a-f0-9]{2}:[a-f0-9]{2}(?:\.[a-f0-9])?/;
1337 pattern
=> qr/$PCIRE(;$PCIRE)*/,
1338 format_description
=> 'HOSTPCIID[;HOSTPCIID2...]',
1339 description
=> <<EODESCR,
1340 Host PCI device pass through. The PCI ID of a host's PCI device or a list
1341 of PCI virtual functions of the host. HOSTPCIID syntax is:
1343 'bus:dev.func' (hexadecimal numbers)
1345 You can us the 'lspci' command to list existing PCI devices.
1350 description
=> "Specify whether or not the device's ROM will be visible in the guest's memory map.",
1356 pattern
=> '[^,;]+',
1357 format_description
=> 'string',
1358 description
=> "Custom pci device rom filename (must be located in /usr/share/kvm/).",
1363 description
=> "Choose the PCI-express bus (needs the 'q35' machine model).",
1369 description
=> "Enable vfio-vga device support.",
1375 format_description
=> 'string',
1376 pattern
=> '[^/\.:]+',
1378 description
=> <<EODESCR
1379 The type of mediated device to use.
1380 An instance of this type will be created on startup of the VM and
1381 will be cleaned up when the VM stops.
1385 PVE
::JSONSchema
::register_format
('pve-qm-hostpci', $hostpci_fmt);
1389 type
=> 'string', format
=> 'pve-qm-hostpci',
1390 description
=> "Map host PCI devices into guest.",
1391 verbose_description
=> <<EODESCR,
1392 Map host PCI devices into guest.
1394 NOTE: This option allows direct access to host hardware. So it is no longer
1395 possible to migrate such machines - use with special care.
1397 CAUTION: Experimental! User reported problems with this option.
1400 PVE
::JSONSchema
::register_standard_option
("pve-qm-hostpci", $hostpcidesc);
1405 pattern
=> '(/dev/.+|socket)',
1406 description
=> "Create a serial device inside the VM (n is 0 to 3)",
1407 verbose_description
=> <<EODESCR,
1408 Create a serial device inside the VM (n is 0 to 3), and pass through a
1409 host serial device (i.e. /dev/ttyS0), or create a unix socket on the
1410 host side (use 'qm terminal' to open a terminal connection).
1412 NOTE: If you pass through a host serial device, it is no longer possible to migrate such machines - use with special care.
1414 CAUTION: Experimental! User reported problems with this option.
1421 pattern
=> '/dev/parport\d+|/dev/usb/lp\d+',
1422 description
=> "Map host parallel devices (n is 0 to 2).",
1423 verbose_description
=> <<EODESCR,
1424 Map host parallel devices (n is 0 to 2).
1426 NOTE: This option allows direct access to host hardware. So it is no longer possible to migrate such machines - use with special care.
1428 CAUTION: Experimental! User reported problems with this option.
1432 for (my $i = 0; $i < $MAX_PARALLEL_PORTS; $i++) {
1433 $confdesc->{"parallel$i"} = $paralleldesc;
1436 for (my $i = 0; $i < $MAX_SERIAL_PORTS; $i++) {
1437 $confdesc->{"serial$i"} = $serialdesc;
1440 for (my $i = 0; $i < $MAX_HOSTPCI_DEVICES; $i++) {
1441 $confdesc->{"hostpci$i"} = $hostpcidesc;
1444 for (my $i = 0; $i < $MAX_IDE_DISKS; $i++) {
1445 $drivename_hash->{"ide$i"} = 1;
1446 $confdesc->{"ide$i"} = $idedesc;
1449 for (my $i = 0; $i < $MAX_SATA_DISKS; $i++) {
1450 $drivename_hash->{"sata$i"} = 1;
1451 $confdesc->{"sata$i"} = $satadesc;
1454 for (my $i = 0; $i < $MAX_SCSI_DISKS; $i++) {
1455 $drivename_hash->{"scsi$i"} = 1;
1456 $confdesc->{"scsi$i"} = $scsidesc ;
1459 for (my $i = 0; $i < $MAX_VIRTIO_DISKS; $i++) {
1460 $drivename_hash->{"virtio$i"} = 1;
1461 $confdesc->{"virtio$i"} = $virtiodesc;
1464 $drivename_hash->{efidisk0
} = 1;
1465 $confdesc->{efidisk0
} = $efidisk_desc;
1467 for (my $i = 0; $i < $MAX_USB_DEVICES; $i++) {
1468 $confdesc->{"usb$i"} = $usbdesc;
1473 type
=> 'string', format
=> 'pve-volume-id',
1474 description
=> "Reference to unused volumes. This is used internally, and should not be modified manually.",
1477 for (my $i = 0; $i < $MAX_UNUSED_DISKS; $i++) {
1478 $confdesc->{"unused$i"} = $unuseddesc;
1481 my $kvm_api_version = 0;
1484 return $kvm_api_version if $kvm_api_version;
1486 open my $fh, '<', '/dev/kvm'
1489 # 0xae00 => KVM_GET_API_VERSION
1490 $kvm_api_version = ioctl($fh, 0xae00, 0);
1492 return $kvm_api_version;
1495 my $kvm_user_version = {};
1498 sub kvm_user_version
{
1501 $binary //= get_command_for_arch
(get_host_arch
()); # get the native arch by default
1502 my $st = stat($binary);
1504 my $cachedmtime = $kvm_mtime->{$binary} // -1;
1505 return $kvm_user_version->{$binary} if $kvm_user_version->{$binary} &&
1506 $cachedmtime == $st->mtime;
1508 $kvm_user_version->{$binary} = 'unknown';
1509 $kvm_mtime->{$binary} = $st->mtime;
1513 if ($line =~ m/^QEMU( PC)? emulator version (\d+\.\d+(\.\d+)?)(\.\d+)?[,\s]/) {
1514 $kvm_user_version->{$binary} = $2;
1518 eval { run_command
([$binary, '--version'], outfunc
=> $code); };
1521 return $kvm_user_version->{$binary};
1525 sub kernel_has_vhost_net
{
1526 return -c
'/dev/vhost-net';
1529 sub valid_drive_names
{
1530 # order is important - used to autoselect boot disk
1531 return ((map { "ide$_" } (0 .. ($MAX_IDE_DISKS - 1))),
1532 (map { "scsi$_" } (0 .. ($MAX_SCSI_DISKS - 1))),
1533 (map { "virtio$_" } (0 .. ($MAX_VIRTIO_DISKS - 1))),
1534 (map { "sata$_" } (0 .. ($MAX_SATA_DISKS - 1))),
1538 sub is_valid_drivename
{
1541 return defined($drivename_hash->{$dev});
1546 return defined($confdesc->{$key});
1550 return $nic_model_list;
1553 sub os_list_description
{
1557 wxp
=> 'Windows XP',
1558 w2k
=> 'Windows 2000',
1559 w2k3
=>, 'Windows 2003',
1560 w2k8
=> 'Windows 2008',
1561 wvista
=> 'Windows Vista',
1562 win7
=> 'Windows 7',
1563 win8
=> 'Windows 8/2012',
1564 win10
=> 'Windows 10/2016',
1572 sub get_cdrom_path
{
1574 return $cdrom_path if $cdrom_path;
1576 return $cdrom_path = "/dev/cdrom" if -l
"/dev/cdrom";
1577 return $cdrom_path = "/dev/cdrom1" if -l
"/dev/cdrom1";
1578 return $cdrom_path = "/dev/cdrom2" if -l
"/dev/cdrom2";
1582 my ($storecfg, $vmid, $cdrom) = @_;
1584 if ($cdrom eq 'cdrom') {
1585 return get_cdrom_path
();
1586 } elsif ($cdrom eq 'none') {
1588 } elsif ($cdrom =~ m
|^/|) {
1591 return PVE
::Storage
::path
($storecfg, $cdrom);
1595 # try to convert old style file names to volume IDs
1596 sub filename_to_volume_id
{
1597 my ($vmid, $file, $media) = @_;
1599 if (!($file eq 'none' || $file eq 'cdrom' ||
1600 $file =~ m
|^/dev/.+| || $file =~ m/^([^:]+):(.+)$/)) {
1602 return undef if $file =~ m
|/|;
1604 if ($media && $media eq 'cdrom') {
1605 $file = "local:iso/$file";
1607 $file = "local:$vmid/$file";
1614 sub verify_media_type
{
1615 my ($opt, $vtype, $media) = @_;
1620 if ($media eq 'disk') {
1622 } elsif ($media eq 'cdrom') {
1625 die "internal error";
1628 return if ($vtype eq $etype);
1630 raise_param_exc
({ $opt => "unexpected media type ($vtype != $etype)" });
1633 sub cleanup_drive_path
{
1634 my ($opt, $storecfg, $drive) = @_;
1636 # try to convert filesystem paths to volume IDs
1638 if (($drive->{file
} !~ m/^(cdrom|none)$/) &&
1639 ($drive->{file
} !~ m
|^/dev/.+|) &&
1640 ($drive->{file
} !~ m/^([^:]+):(.+)$/) &&
1641 ($drive->{file
} !~ m/^\d+$/)) {
1642 my ($vtype, $volid) = PVE
::Storage
::path_to_volume_id
($storecfg, $drive->{file
});
1643 raise_param_exc
({ $opt => "unable to associate path '$drive->{file}' to any storage"}) if !$vtype;
1644 $drive->{media
} = 'cdrom' if !$drive->{media
} && $vtype eq 'iso';
1645 verify_media_type
($opt, $vtype, $drive->{media
});
1646 $drive->{file
} = $volid;
1649 $drive->{media
} = 'cdrom' if !$drive->{media
} && $drive->{file
} =~ m/^(cdrom|none)$/;
1652 sub parse_hotplug_features
{
1657 return $res if $data eq '0';
1659 $data = $confdesc->{hotplug
}->{default} if $data eq '1';
1661 foreach my $feature (PVE
::Tools
::split_list
($data)) {
1662 if ($feature =~ m/^(network|disk|cpu|memory|usb)$/) {
1665 die "invalid hotplug feature '$feature'\n";
1671 PVE
::JSONSchema
::register_format
('pve-hotplug-features', \
&pve_verify_hotplug_features
);
1672 sub pve_verify_hotplug_features
{
1673 my ($value, $noerr) = @_;
1675 return $value if parse_hotplug_features
($value);
1677 return undef if $noerr;
1679 die "unable to parse hotplug option\n";
1682 # ideX = [volume=]volume-id[,media=d][,cyls=c,heads=h,secs=s[,trans=t]]
1683 # [,snapshot=on|off][,cache=on|off][,format=f][,backup=yes|no]
1684 # [,rerror=ignore|report|stop][,werror=enospc|ignore|report|stop]
1685 # [,aio=native|threads][,discard=ignore|on][,detect_zeroes=on|off]
1686 # [,iothread=on][,serial=serial][,model=model]
1689 my ($key, $data) = @_;
1691 my ($interface, $index);
1693 if ($key =~ m/^([^\d]+)(\d+)$/) {
1700 my $desc = $key =~ /^unused\d+$/ ?
$alldrive_fmt
1701 : $confdesc->{$key}->{format
};
1703 warn "invalid drive key: $key\n";
1706 my $res = eval { PVE
::JSONSchema
::parse_property_string
($desc, $data) };
1707 return undef if !$res;
1708 $res->{interface
} = $interface;
1709 $res->{index} = $index;
1712 foreach my $opt (qw(bps bps_rd bps_wr)) {
1713 if (my $bps = defined(delete $res->{$opt})) {
1714 if (defined($res->{"m$opt"})) {
1715 warn "both $opt and m$opt specified\n";
1719 $res->{"m$opt"} = sprintf("%.3f", $bps / (1024*1024.0));
1723 # can't use the schema's 'requires' because of the mbps* => bps* "transforming aliases"
1724 for my $requirement (
1725 [mbps_max
=> 'mbps'],
1726 [mbps_rd_max
=> 'mbps_rd'],
1727 [mbps_wr_max
=> 'mbps_wr'],
1728 [miops_max
=> 'miops'],
1729 [miops_rd_max
=> 'miops_rd'],
1730 [miops_wr_max
=> 'miops_wr'],
1731 [bps_max_length
=> 'mbps_max'],
1732 [bps_rd_max_length
=> 'mbps_rd_max'],
1733 [bps_wr_max_length
=> 'mbps_wr_max'],
1734 [iops_max_length
=> 'iops_max'],
1735 [iops_rd_max_length
=> 'iops_rd_max'],
1736 [iops_wr_max_length
=> 'iops_wr_max']) {
1737 my ($option, $requires) = @$requirement;
1738 if ($res->{$option} && !$res->{$requires}) {
1739 warn "$option requires $requires\n";
1744 return undef if $error;
1746 return undef if $res->{mbps_rd
} && $res->{mbps
};
1747 return undef if $res->{mbps_wr
} && $res->{mbps
};
1748 return undef if $res->{iops_rd
} && $res->{iops
};
1749 return undef if $res->{iops_wr
} && $res->{iops
};
1751 if ($res->{media
} && ($res->{media
} eq 'cdrom')) {
1752 return undef if $res->{snapshot
} || $res->{trans
} || $res->{format
};
1753 return undef if $res->{heads
} || $res->{secs
} || $res->{cyls
};
1754 return undef if $res->{interface
} eq 'virtio';
1757 if (my $size = $res->{size
}) {
1758 return undef if !defined($res->{size
} = PVE
::JSONSchema
::parse_size
($size));
1765 my ($vmid, $drive) = @_;
1766 my $data = { %$drive };
1767 delete $data->{$_} for qw(index interface);
1768 return PVE
::JSONSchema
::print_property_string
($data, $alldrive_fmt);
1772 my($fh, $noerr) = @_;
1775 my $SG_GET_VERSION_NUM = 0x2282;
1777 my $versionbuf = "\x00" x
8;
1778 my $ret = ioctl($fh, $SG_GET_VERSION_NUM, $versionbuf);
1780 die "scsi ioctl SG_GET_VERSION_NUM failoed - $!\n" if !$noerr;
1783 my $version = unpack("I", $versionbuf);
1784 if ($version < 30000) {
1785 die "scsi generic interface too old\n" if !$noerr;
1789 my $buf = "\x00" x
36;
1790 my $sensebuf = "\x00" x
8;
1791 my $cmd = pack("C x3 C x1", 0x12, 36);
1793 # see /usr/include/scsi/sg.h
1794 my $sg_io_hdr_t = "i i C C s I P P P I I i P C C C C S S i I I";
1796 my $packet = pack($sg_io_hdr_t, ord('S'), -3, length($cmd),
1797 length($sensebuf), 0, length($buf), $buf,
1798 $cmd, $sensebuf, 6000);
1800 $ret = ioctl($fh, $SG_IO, $packet);
1802 die "scsi ioctl SG_IO failed - $!\n" if !$noerr;
1806 my @res = unpack($sg_io_hdr_t, $packet);
1807 if ($res[17] || $res[18]) {
1808 die "scsi ioctl SG_IO status error - $!\n" if !$noerr;
1813 (my $byte0, my $byte1, $res->{vendor
},
1814 $res->{product
}, $res->{revision
}) = unpack("C C x6 A8 A16 A4", $buf);
1816 $res->{removable
} = $byte1 & 128 ?
1 : 0;
1817 $res->{type
} = $byte0 & 31;
1825 my $fh = IO
::File-
>new("+<$path") || return undef;
1826 my $res = scsi_inquiry
($fh, 1);
1832 sub machine_type_is_q35
{
1835 return $conf->{machine
} && ($conf->{machine
} =~ m/q35/) ?
1 : 0;
1838 sub print_tabletdevice_full
{
1839 my ($conf, $arch) = @_;
1841 my $q35 = machine_type_is_q35
($conf);
1843 # we use uhci for old VMs because tablet driver was buggy in older qemu
1845 if (machine_type_is_q35
($conf) || $arch eq 'aarch64') {
1851 return "usb-tablet,id=tablet,bus=$usbbus.0,port=1";
1854 sub print_keyboarddevice_full
{
1855 my ($conf, $arch, $machine) = @_;
1857 return undef if $arch ne 'aarch64';
1859 return "usb-kbd,id=keyboard,bus=ehci.0,port=2";
1862 sub print_drivedevice_full
{
1863 my ($storecfg, $conf, $vmid, $drive, $bridges, $arch, $machine_type) = @_;
1868 if ($drive->{interface
} eq 'virtio') {
1869 my $pciaddr = print_pci_addr
("$drive->{interface}$drive->{index}", $bridges, $arch, $machine_type);
1870 $device = "virtio-blk-pci,drive=drive-$drive->{interface}$drive->{index},id=$drive->{interface}$drive->{index}$pciaddr";
1871 $device .= ",iothread=iothread-$drive->{interface}$drive->{index}" if $drive->{iothread
};
1872 } elsif ($drive->{interface
} eq 'scsi') {
1874 my ($maxdev, $controller, $controller_prefix) = scsihw_infos
($conf, $drive);
1875 my $unit = $drive->{index} % $maxdev;
1876 my $devicetype = 'hd';
1878 if (drive_is_cdrom
($drive)) {
1881 if ($drive->{file
} =~ m
|^/|) {
1882 $path = $drive->{file
};
1883 if (my $info = path_is_scsi
($path)) {
1884 if ($info->{type
} == 0 && $drive->{scsiblock
}) {
1885 $devicetype = 'block';
1886 } elsif ($info->{type
} == 1) { # tape
1887 $devicetype = 'generic';
1891 $path = PVE
::Storage
::path
($storecfg, $drive->{file
});
1894 if($path =~ m/^iscsi\:\/\
//){
1895 $devicetype = 'generic';
1899 if (!$conf->{scsihw
} || ($conf->{scsihw
} =~ m/^lsi/)){
1900 $device = "scsi-$devicetype,bus=$controller_prefix$controller.0,scsi-id=$unit,drive=drive-$drive->{interface}$drive->{index},id=$drive->{interface}$drive->{index}";
1902 $device = "scsi-$devicetype,bus=$controller_prefix$controller.0,channel=0,scsi-id=0,lun=$drive->{index},drive=drive-$drive->{interface}$drive->{index},id=$drive->{interface}$drive->{index}";
1905 if ($drive->{ssd
} && ($devicetype eq 'block' || $devicetype eq 'hd')) {
1906 $device .= ",rotation_rate=1";
1908 $device .= ",wwn=$drive->{wwn}" if $drive->{wwn
};
1910 } elsif ($drive->{interface
} eq 'ide' || $drive->{interface
} eq 'sata') {
1911 my $maxdev = ($drive->{interface
} eq 'sata') ?
$MAX_SATA_DISKS : 2;
1912 my $controller = int($drive->{index} / $maxdev);
1913 my $unit = $drive->{index} % $maxdev;
1914 my $devicetype = ($drive->{media
} && $drive->{media
} eq 'cdrom') ?
"cd" : "hd";
1916 $device = "ide-$devicetype";
1917 if ($drive->{interface
} eq 'ide') {
1918 $device .= ",bus=ide.$controller,unit=$unit";
1920 $device .= ",bus=ahci$controller.$unit";
1922 $device .= ",drive=drive-$drive->{interface}$drive->{index},id=$drive->{interface}$drive->{index}";
1924 if ($devicetype eq 'hd') {
1925 if (my $model = $drive->{model
}) {
1926 $model = URI
::Escape
::uri_unescape
($model);
1927 $device .= ",model=$model";
1929 if ($drive->{ssd
}) {
1930 $device .= ",rotation_rate=1";
1933 $device .= ",wwn=$drive->{wwn}" if $drive->{wwn
};
1934 } elsif ($drive->{interface
} eq 'usb') {
1936 # -device ide-drive,bus=ide.1,unit=0,drive=drive-ide0-1-0,id=ide0-1-0
1938 die "unsupported interface type";
1941 $device .= ",bootindex=$drive->{bootindex}" if $drive->{bootindex
};
1943 if (my $serial = $drive->{serial
}) {
1944 $serial = URI
::Escape
::uri_unescape
($serial);
1945 $device .= ",serial=$serial";
1952 sub get_initiator_name
{
1955 my $fh = IO
::File-
>new('/etc/iscsi/initiatorname.iscsi') || return undef;
1956 while (defined(my $line = <$fh>)) {
1957 next if $line !~ m/^\s*InitiatorName\s*=\s*([\.\-:\w]+)/;
1966 sub print_drive_full
{
1967 my ($storecfg, $vmid, $drive) = @_;
1970 my $volid = $drive->{file
};
1973 if (drive_is_cdrom
($drive)) {
1974 $path = get_iso_path
($storecfg, $vmid, $volid);
1976 my ($storeid, $volname) = PVE
::Storage
::parse_volume_id
($volid, 1);
1978 $path = PVE
::Storage
::path
($storecfg, $volid);
1979 my $scfg = PVE
::Storage
::storage_config
($storecfg, $storeid);
1980 $format = qemu_img_format
($scfg, $volname);
1988 my @qemu_drive_options = qw(heads secs cyls trans media format cache rerror werror aio discard);
1989 foreach my $o (@qemu_drive_options) {
1990 $opts .= ",$o=$drive->{$o}" if defined($drive->{$o});
1993 # snapshot only accepts on|off
1994 if (defined($drive->{snapshot
})) {
1995 my $v = $drive->{snapshot
} ?
'on' : 'off';
1996 $opts .= ",snapshot=$v";
1999 foreach my $type (['', '-total'], [_rd
=> '-read'], [_wr
=> '-write']) {
2000 my ($dir, $qmpname) = @$type;
2001 if (my $v = $drive->{"mbps$dir"}) {
2002 $opts .= ",throttling.bps$qmpname=".int($v*1024*1024);
2004 if (my $v = $drive->{"mbps${dir}_max"}) {
2005 $opts .= ",throttling.bps$qmpname-max=".int($v*1024*1024);
2007 if (my $v = $drive->{"bps${dir}_max_length"}) {
2008 $opts .= ",throttling.bps$qmpname-max-length=$v";
2010 if (my $v = $drive->{"iops${dir}"}) {
2011 $opts .= ",throttling.iops$qmpname=$v";
2013 if (my $v = $drive->{"iops${dir}_max"}) {
2014 $opts .= ",throttling.iops$qmpname-max=$v";
2016 if (my $v = $drive->{"iops${dir}_max_length"}) {
2017 $opts .= ",throttling.iops$qmpname-max-length=$v";
2021 $opts .= ",format=$format" if $format && !$drive->{format
};
2023 my $cache_direct = 0;
2025 if (my $cache = $drive->{cache
}) {
2026 $cache_direct = $cache =~ /^(?:off|none|directsync)$/;
2027 } elsif (!drive_is_cdrom
($drive)) {
2028 $opts .= ",cache=none";
2032 # aio native works only with O_DIRECT
2033 if (!$drive->{aio
}) {
2035 $opts .= ",aio=native";
2037 $opts .= ",aio=threads";
2041 if (!drive_is_cdrom
($drive)) {
2043 if (defined($drive->{detect_zeroes
}) && !$drive->{detect_zeroes
}) {
2044 $detectzeroes = 'off';
2045 } elsif ($drive->{discard
}) {
2046 $detectzeroes = $drive->{discard
} eq 'on' ?
'unmap' : 'on';
2048 # This used to be our default with discard not being specified:
2049 $detectzeroes = 'on';
2051 $opts .= ",detect-zeroes=$detectzeroes" if $detectzeroes;
2054 my $pathinfo = $path ?
"file=$path," : '';
2056 return "${pathinfo}if=none,id=drive-$drive->{interface}$drive->{index}$opts";
2059 sub print_netdevice_full
{
2060 my ($vmid, $conf, $net, $netid, $bridges, $use_old_bios_files, $arch, $machine_type) = @_;
2062 my $bootorder = $conf->{boot
} || $confdesc->{boot
}->{default};
2064 my $device = $net->{model
};
2065 if ($net->{model
} eq 'virtio') {
2066 $device = 'virtio-net-pci';
2069 my $pciaddr = print_pci_addr
("$netid", $bridges, $arch, $machine_type);
2070 my $tmpstr = "$device,mac=$net->{macaddr},netdev=$netid$pciaddr,id=$netid";
2071 if ($net->{queues
} && $net->{queues
} > 1 && $net->{model
} eq 'virtio'){
2072 #Consider we have N queues, the number of vectors needed is 2*N + 2 (plus one config interrupt and control vq)
2073 my $vectors = $net->{queues
} * 2 + 2;
2074 $tmpstr .= ",vectors=$vectors,mq=on";
2076 $tmpstr .= ",bootindex=$net->{bootindex}" if $net->{bootindex
} ;
2078 if ($use_old_bios_files) {
2080 if ($device eq 'virtio-net-pci') {
2081 $romfile = 'pxe-virtio.rom';
2082 } elsif ($device eq 'e1000') {
2083 $romfile = 'pxe-e1000.rom';
2084 } elsif ($device eq 'ne2k') {
2085 $romfile = 'pxe-ne2k_pci.rom';
2086 } elsif ($device eq 'pcnet') {
2087 $romfile = 'pxe-pcnet.rom';
2088 } elsif ($device eq 'rtl8139') {
2089 $romfile = 'pxe-rtl8139.rom';
2091 $tmpstr .= ",romfile=$romfile" if $romfile;
2097 sub print_netdev_full
{
2098 my ($vmid, $conf, $arch, $net, $netid, $hotplug) = @_;
2101 if ($netid =~ m/^net(\d+)$/) {
2105 die "got strange net id '$i'\n" if $i >= ${MAX_NETS
};
2107 my $ifname = "tap${vmid}i$i";
2109 # kvm uses TUNSETIFF ioctl, and that limits ifname length
2110 die "interface name '$ifname' is too long (max 15 character)\n"
2111 if length($ifname) >= 16;
2113 my $vhostparam = '';
2114 if (is_native
($arch)) {
2115 $vhostparam = ',vhost=on' if kernel_has_vhost_net
() && $net->{model
} eq 'virtio';
2118 my $vmname = $conf->{name
} || "vm$vmid";
2121 my $script = $hotplug ?
"pve-bridge-hotplug" : "pve-bridge";
2123 if ($net->{bridge
}) {
2124 $netdev = "type=tap,id=$netid,ifname=${ifname},script=/var/lib/qemu-server/$script,downscript=/var/lib/qemu-server/pve-bridgedown$vhostparam";
2126 $netdev = "type=user,id=$netid,hostname=$vmname";
2129 $netdev .= ",queues=$net->{queues}" if ($net->{queues
} && $net->{model
} eq 'virtio');
2135 sub print_cpu_device
{
2136 my ($conf, $id) = @_;
2138 my $kvm = $conf->{kvm
} // 1;
2139 my $cpu = $kvm ?
"kvm64" : "qemu64";
2140 if (my $cputype = $conf->{cpu
}) {
2141 my $cpuconf = PVE
::JSONSchema
::parse_property_string
($cpu_fmt, $cputype)
2142 or die "Cannot parse cpu description: $cputype\n";
2143 $cpu = $cpuconf->{cputype
};
2146 my $cores = $conf->{cores
} || 1;
2148 my $current_core = ($id - 1) % $cores;
2149 my $current_socket = int(($id - 1 - $current_core)/$cores);
2151 return "$cpu-x86_64-cpu,id=cpu$id,socket-id=$current_socket,core-id=$current_core,thread-id=0";
2155 'cirrus' => 'cirrus-vga',
2157 'vmware' => 'vmware-svga',
2158 'virtio' => 'virtio-vga',
2161 sub print_vga_device
{
2162 my ($conf, $vga, $arch, $machine, $id, $qxlnum, $bridges) = @_;
2164 my $type = $vga_map->{$vga->{type
}};
2165 if ($arch eq 'aarch64' && defined($type) && $type eq 'virtio-vga') {
2166 $type = 'virtio-gpu';
2168 my $vgamem_mb = $vga->{memory
};
2170 $type = $id ?
'qxl' : 'qxl-vga';
2172 die "no devicetype for $vga->{type}\n" if !$type;
2176 if ($vga->{type
} eq 'virtio') {
2177 my $bytes = PVE
::Tools
::convert_size
($vgamem_mb, "mb" => "b");
2178 $memory = ",max_hostmem=$bytes";
2180 # from https://www.spice-space.org/multiple-monitors.html
2181 $memory = ",vgamem_mb=$vga->{memory}";
2182 my $ram = $vgamem_mb * 4;
2183 my $vram = $vgamem_mb * 2;
2184 $memory .= ",ram_size_mb=$ram,vram_size_mb=$vram";
2186 $memory = ",vgamem_mb=$vga->{memory}";
2188 } elsif ($qxlnum && $id) {
2189 $memory = ",ram_size=67108864,vram_size=33554432";
2192 my $q35 = machine_type_is_q35
($conf);
2193 my $vgaid = "vga" . ($id // '');
2196 if ($q35 && $vgaid eq 'vga') {
2197 # the first display uses pcie.0 bus on q35 machines
2198 $pciaddr = print_pcie_addr
($vgaid, $bridges, $arch, $machine);
2200 $pciaddr = print_pci_addr
($vgaid, $bridges, $arch, $machine);
2203 return "$type,id=${vgaid}${memory}${pciaddr}";
2206 sub drive_is_cloudinit
{
2208 return $drive->{file
} =~ m
@[:/]vm-\d
+-cloudinit
(?
:\
.$QEMU_FORMAT_RE)?
$@;
2211 sub drive_is_cdrom
{
2212 my ($drive, $exclude_cloudinit) = @_;
2214 return 0 if $exclude_cloudinit && drive_is_cloudinit
($drive);
2216 return $drive && $drive->{media
} && ($drive->{media
} eq 'cdrom');
2220 sub parse_number_sets
{
2223 foreach my $part (split(/;/, $set)) {
2224 if ($part =~ /^\s*(\d+)(?:-(\d+))?\s*$/) {
2225 die "invalid range: $part ($2 < $1)\n" if defined($2) && $2 < $1;
2226 push @$res, [ $1, $2 ];
2228 die "invalid range: $part\n";
2237 my $res = PVE
::JSONSchema
::parse_property_string
($numa_fmt, $data);
2238 $res->{cpus
} = parse_number_sets
($res->{cpus
}) if defined($res->{cpus
});
2239 $res->{hostnodes
} = parse_number_sets
($res->{hostnodes
}) if defined($res->{hostnodes
});
2246 return undef if !$value;
2248 my $res = PVE
::JSONSchema
::parse_property_string
($hostpci_fmt, $value);
2250 my @idlist = split(/;/, $res->{host
});
2251 delete $res->{host
};
2252 foreach my $id (@idlist) {
2253 if ($id =~ m/\./) { # full id 00:00.1
2254 push @{$res->{pciid
}}, {
2257 } else { # partial id 00:00
2258 $res->{pciid
} = PVE
::SysFSTools
::lspci
($id);
2264 # netX: e1000=XX:XX:XX:XX:XX:XX,bridge=vmbr0,rate=<mbps>
2268 my $res = eval { PVE
::JSONSchema
::parse_property_string
($net_fmt, $data) };
2273 if (!defined($res->{macaddr
})) {
2274 my $dc = PVE
::Cluster
::cfs_read_file
('datacenter.cfg');
2275 $res->{macaddr
} = PVE
::Tools
::random_ether_addr
($dc->{mac_prefix
});
2280 # ipconfigX ip=cidr,gw=ip,ip6=cidr,gw6=ip
2281 sub parse_ipconfig
{
2284 my $res = eval { PVE
::JSONSchema
::parse_property_string
($ipconfig_fmt, $data) };
2290 if ($res->{gw
} && !$res->{ip
}) {
2291 warn 'gateway specified without specifying an IP address';
2294 if ($res->{gw6
} && !$res->{ip6
}) {
2295 warn 'IPv6 gateway specified without specifying an IPv6 address';
2298 if ($res->{gw
} && $res->{ip
} eq 'dhcp') {
2299 warn 'gateway specified together with DHCP';
2302 if ($res->{gw6
} && $res->{ip6
} !~ /^$IPV6RE/) {
2304 warn "IPv6 gateway specified together with $res->{ip6} address";
2308 if (!$res->{ip
} && !$res->{ip6
}) {
2309 return { ip
=> 'dhcp', ip6
=> 'dhcp' };
2318 return PVE
::JSONSchema
::print_property_string
($net, $net_fmt);
2321 sub add_random_macs
{
2322 my ($settings) = @_;
2324 foreach my $opt (keys %$settings) {
2325 next if $opt !~ m/^net(\d+)$/;
2326 my $net = parse_net
($settings->{$opt});
2328 $settings->{$opt} = print_net
($net);
2332 sub vm_is_volid_owner
{
2333 my ($storecfg, $vmid, $volid) = @_;
2335 if ($volid !~ m
|^/|) {
2337 eval { ($path, $owner) = PVE
::Storage
::path
($storecfg, $volid); };
2338 if ($owner && ($owner == $vmid)) {
2346 sub split_flagged_list
{
2347 my $text = shift || '';
2348 $text =~ s/[,;]/ /g;
2350 return { map { /^(!?)(.*)$/ && ($2, $1) } ($text =~ /\S+/g) };
2353 sub join_flagged_list
{
2354 my ($how, $lst) = @_;
2355 join $how, map { $lst->{$_} . $_ } keys %$lst;
2358 sub vmconfig_delete_pending_option
{
2359 my ($conf, $key, $force) = @_;
2361 delete $conf->{pending
}->{$key};
2362 my $pending_delete_hash = split_flagged_list
($conf->{pending
}->{delete});
2363 $pending_delete_hash->{$key} = $force ?
'!' : '';
2364 $conf->{pending
}->{delete} = join_flagged_list
(',', $pending_delete_hash);
2367 sub vmconfig_undelete_pending_option
{
2368 my ($conf, $key) = @_;
2370 my $pending_delete_hash = split_flagged_list
($conf->{pending
}->{delete});
2371 delete $pending_delete_hash->{$key};
2373 if (%$pending_delete_hash) {
2374 $conf->{pending
}->{delete} = join_flagged_list
(',', $pending_delete_hash);
2376 delete $conf->{pending
}->{delete};
2380 sub vmconfig_register_unused_drive
{
2381 my ($storecfg, $vmid, $conf, $drive) = @_;
2383 if (drive_is_cloudinit
($drive)) {
2384 eval { PVE
::Storage
::vdisk_free
($storecfg, $drive->{file
}) };
2386 } elsif (!drive_is_cdrom
($drive)) {
2387 my $volid = $drive->{file
};
2388 if (vm_is_volid_owner
($storecfg, $vmid, $volid)) {
2389 PVE
::QemuConfig-
>add_unused_volume($conf, $volid, $vmid);
2394 sub vmconfig_cleanup_pending
{
2397 # remove pending changes when nothing changed
2399 foreach my $opt (keys %{$conf->{pending
}}) {
2400 if (defined($conf->{$opt}) && ($conf->{pending
}->{$opt} eq $conf->{$opt})) {
2402 delete $conf->{pending
}->{$opt};
2406 my $current_delete_hash = split_flagged_list
($conf->{pending
}->{delete});
2407 my $pending_delete_hash = {};
2408 while (my ($opt, $force) = each %$current_delete_hash) {
2409 if (defined($conf->{$opt})) {
2410 $pending_delete_hash->{$opt} = $force;
2416 if (%$pending_delete_hash) {
2417 $conf->{pending
}->{delete} = join_flagged_list
(',', $pending_delete_hash);
2419 delete $conf->{pending
}->{delete};
2425 # smbios: [manufacturer=str][,product=str][,version=str][,serial=str][,uuid=uuid][,sku=str][,family=str][,base64=bool]
2429 pattern
=> '[a-fA-F0-9]{8}(?:-[a-fA-F0-9]{4}){3}-[a-fA-F0-9]{12}',
2430 format_description
=> 'UUID',
2431 description
=> "Set SMBIOS1 UUID.",
2436 pattern
=> '[A-Za-z0-9+\/]+={0,2}',
2437 format_description
=> 'Base64 encoded string',
2438 description
=> "Set SMBIOS1 version.",
2443 pattern
=> '[A-Za-z0-9+\/]+={0,2}',
2444 format_description
=> 'Base64 encoded string',
2445 description
=> "Set SMBIOS1 serial number.",
2450 pattern
=> '[A-Za-z0-9+\/]+={0,2}',
2451 format_description
=> 'Base64 encoded string',
2452 description
=> "Set SMBIOS1 manufacturer.",
2457 pattern
=> '[A-Za-z0-9+\/]+={0,2}',
2458 format_description
=> 'Base64 encoded string',
2459 description
=> "Set SMBIOS1 product ID.",
2464 pattern
=> '[A-Za-z0-9+\/]+={0,2}',
2465 format_description
=> 'Base64 encoded string',
2466 description
=> "Set SMBIOS1 SKU string.",
2471 pattern
=> '[A-Za-z0-9+\/]+={0,2}',
2472 format_description
=> 'Base64 encoded string',
2473 description
=> "Set SMBIOS1 family string.",
2478 description
=> 'Flag to indicate that the SMBIOS values are base64 encoded',
2486 my $res = eval { PVE
::JSONSchema
::parse_property_string
($smbios1_fmt, $data) };
2493 return PVE
::JSONSchema
::print_property_string
($smbios1, $smbios1_fmt);
2496 PVE
::JSONSchema
::register_format
('pve-qm-smbios1', $smbios1_fmt);
2498 PVE
::JSONSchema
::register_format
('pve-qm-bootdisk', \
&verify_bootdisk
);
2499 sub verify_bootdisk
{
2500 my ($value, $noerr) = @_;
2502 return $value if is_valid_drivename
($value);
2504 return undef if $noerr;
2506 die "invalid boot disk '$value'\n";
2509 sub parse_watchdog
{
2512 return undef if !$value;
2514 my $res = eval { PVE
::JSONSchema
::parse_property_string
($watchdog_fmt, $value) };
2519 sub parse_guest_agent
{
2522 return {} if !defined($value->{agent
});
2524 my $res = eval { PVE
::JSONSchema
::parse_property_string
($agent_fmt, $value->{agent
}) };
2527 # if the agent is disabled ignore the other potentially set properties
2528 return {} if !$res->{enabled
};
2535 return {} if !$value;
2536 my $res = eval { PVE
::JSONSchema
::parse_property_string
($vga_fmt, $value) };
2541 PVE
::JSONSchema
::register_format
('pve-qm-usb-device', \
&verify_usb_device
);
2542 sub verify_usb_device
{
2543 my ($value, $noerr) = @_;
2545 return $value if parse_usb_device
($value);
2547 return undef if $noerr;
2549 die "unable to parse usb device\n";
2552 # add JSON properties for create and set function
2553 sub json_config_properties
{
2556 foreach my $opt (keys %$confdesc) {
2557 next if $opt eq 'parent' || $opt eq 'snaptime' || $opt eq 'vmstate' || $opt eq 'runningmachine';
2558 $prop->{$opt} = $confdesc->{$opt};
2564 # return copy of $confdesc_cloudinit to generate documentation
2565 sub cloudinit_config_properties
{
2567 return dclone
($confdesc_cloudinit);
2571 my ($key, $value) = @_;
2573 die "unknown setting '$key'\n" if !$confdesc->{$key};
2575 my $type = $confdesc->{$key}->{type
};
2577 if (!defined($value)) {
2578 die "got undefined value\n";
2581 if ($value =~ m/[\n\r]/) {
2582 die "property contains a line feed\n";
2585 if ($type eq 'boolean') {
2586 return 1 if ($value eq '1') || ($value =~ m/^(on|yes|true)$/i);
2587 return 0 if ($value eq '0') || ($value =~ m/^(off|no|false)$/i);
2588 die "type check ('boolean') failed - got '$value'\n";
2589 } elsif ($type eq 'integer') {
2590 return int($1) if $value =~ m/^(\d+)$/;
2591 die "type check ('integer') failed - got '$value'\n";
2592 } elsif ($type eq 'number') {
2593 return $value if $value =~ m/^(\d+)(\.\d+)?$/;
2594 die "type check ('number') failed - got '$value'\n";
2595 } elsif ($type eq 'string') {
2596 if (my $fmt = $confdesc->{$key}->{format
}) {
2597 PVE
::JSONSchema
::check_format
($fmt, $value);
2600 $value =~ s/^\"(.*)\"$/$1/;
2603 die "internal error"
2610 my $conf = PVE
::QemuConfig-
>config_file($vmid);
2611 utime undef, undef, $conf;
2615 my ($storecfg, $vmid, $keep_empty_config, $skiplock) = @_;
2617 my $conffile = PVE
::QemuConfig-
>config_file($vmid);
2619 my $conf = PVE
::QemuConfig-
>load_config($vmid);
2621 PVE
::QemuConfig-
>check_lock($conf) if !$skiplock;
2623 if ($conf->{template
}) {
2624 # check if any base image is still used by a linked clone
2625 foreach_drive
($conf, sub {
2626 my ($ds, $drive) = @_;
2628 return if drive_is_cdrom
($drive);
2630 my $volid = $drive->{file
};
2632 return if !$volid || $volid =~ m
|^/|;
2634 die "base volume '$volid' is still in use by linked cloned\n"
2635 if PVE
::Storage
::volume_is_base_and_used
($storecfg, $volid);
2640 # only remove disks owned by this VM
2641 foreach_drive
($conf, sub {
2642 my ($ds, $drive) = @_;
2644 return if drive_is_cdrom
($drive, 1);
2646 my $volid = $drive->{file
};
2648 return if !$volid || $volid =~ m
|^/|;
2650 my ($path, $owner) = PVE
::Storage
::path
($storecfg, $volid);
2651 return if !$path || !$owner || ($owner != $vmid);
2654 PVE
::Storage
::vdisk_free
($storecfg, $volid);
2656 warn "Could not remove disk '$volid', check manually: $@" if $@;
2660 if ($keep_empty_config) {
2661 PVE
::Tools
::file_set_contents
($conffile, "memory: 128\n");
2666 # also remove unused disk
2668 my $dl = PVE
::Storage
::vdisk_list
($storecfg, undef, $vmid);
2671 PVE
::Storage
::foreach_volid
($dl, sub {
2672 my ($volid, $sid, $volname, $d) = @_;
2673 PVE
::Storage
::vdisk_free
($storecfg, $volid);
2682 sub parse_vm_config
{
2683 my ($filename, $raw) = @_;
2685 return undef if !defined($raw);
2688 digest
=> Digest
::SHA
::sha1_hex
($raw),
2693 $filename =~ m
|/qemu-server/(\d
+)\
.conf
$|
2694 || die "got strange filename '$filename'";
2702 my @lines = split(/\n/, $raw);
2703 foreach my $line (@lines) {
2704 next if $line =~ m/^\s*$/;
2706 if ($line =~ m/^\[PENDING\]\s*$/i) {
2707 $section = 'pending';
2708 if (defined($descr)) {
2710 $conf->{description
} = $descr;
2713 $conf = $res->{$section} = {};
2716 } elsif ($line =~ m/^\[([a-z][a-z0-9_\-]+)\]\s*$/i) {
2718 if (defined($descr)) {
2720 $conf->{description
} = $descr;
2723 $conf = $res->{snapshots
}->{$section} = {};
2727 if ($line =~ m/^\#(.*)\s*$/) {
2728 $descr = '' if !defined($descr);
2729 $descr .= PVE
::Tools
::decode_text
($1) . "\n";
2733 if ($line =~ m/^(description):\s*(.*\S)\s*$/) {
2734 $descr = '' if !defined($descr);
2735 $descr .= PVE
::Tools
::decode_text
($2);
2736 } elsif ($line =~ m/snapstate:\s*(prepare|delete)\s*$/) {
2737 $conf->{snapstate
} = $1;
2738 } elsif ($line =~ m/^(args):\s*(.*\S)\s*$/) {
2741 $conf->{$key} = $value;
2742 } elsif ($line =~ m/^delete:\s*(.*\S)\s*$/) {
2744 if ($section eq 'pending') {
2745 $conf->{delete} = $value; # we parse this later
2747 warn "vm $vmid - propertry 'delete' is only allowed in [PENDING]\n";
2749 } elsif ($line =~ m/^([a-z][a-z_]*\d*):\s*(.+?)\s*$/) {
2752 eval { $value = check_type
($key, $value); };
2754 warn "vm $vmid - unable to parse value of '$key' - $@";
2756 $key = 'ide2' if $key eq 'cdrom';
2757 my $fmt = $confdesc->{$key}->{format
};
2758 if ($fmt && $fmt =~ /^pve-qm-(?:ide|scsi|virtio|sata)$/) {
2759 my $v = parse_drive
($key, $value);
2760 if (my $volid = filename_to_volume_id
($vmid, $v->{file
}, $v->{media
})) {
2761 $v->{file
} = $volid;
2762 $value = print_drive
($vmid, $v);
2764 warn "vm $vmid - unable to parse value of '$key'\n";
2769 $conf->{$key} = $value;
2774 if (defined($descr)) {
2776 $conf->{description
} = $descr;
2778 delete $res->{snapstate
}; # just to be sure
2783 sub write_vm_config
{
2784 my ($filename, $conf) = @_;
2786 delete $conf->{snapstate
}; # just to be sure
2788 if ($conf->{cdrom
}) {
2789 die "option ide2 conflicts with cdrom\n" if $conf->{ide2
};
2790 $conf->{ide2
} = $conf->{cdrom
};
2791 delete $conf->{cdrom
};
2794 # we do not use 'smp' any longer
2795 if ($conf->{sockets
}) {
2796 delete $conf->{smp
};
2797 } elsif ($conf->{smp
}) {
2798 $conf->{sockets
} = $conf->{smp
};
2799 delete $conf->{cores
};
2800 delete $conf->{smp
};
2803 my $used_volids = {};
2805 my $cleanup_config = sub {
2806 my ($cref, $pending, $snapname) = @_;
2808 foreach my $key (keys %$cref) {
2809 next if $key eq 'digest' || $key eq 'description' || $key eq 'snapshots' ||
2810 $key eq 'snapstate' || $key eq 'pending';
2811 my $value = $cref->{$key};
2812 if ($key eq 'delete') {
2813 die "propertry 'delete' is only allowed in [PENDING]\n"
2815 # fixme: check syntax?
2818 eval { $value = check_type
($key, $value); };
2819 die "unable to parse value of '$key' - $@" if $@;
2821 $cref->{$key} = $value;
2823 if (!$snapname && is_valid_drivename
($key)) {
2824 my $drive = parse_drive
($key, $value);
2825 $used_volids->{$drive->{file
}} = 1 if $drive && $drive->{file
};
2830 &$cleanup_config($conf);
2832 &$cleanup_config($conf->{pending
}, 1);
2834 foreach my $snapname (keys %{$conf->{snapshots
}}) {
2835 die "internal error" if $snapname eq 'pending';
2836 &$cleanup_config($conf->{snapshots
}->{$snapname}, undef, $snapname);
2839 # remove 'unusedX' settings if we re-add a volume
2840 foreach my $key (keys %$conf) {
2841 my $value = $conf->{$key};
2842 if ($key =~ m/^unused/ && $used_volids->{$value}) {
2843 delete $conf->{$key};
2847 my $generate_raw_config = sub {
2848 my ($conf, $pending) = @_;
2852 # add description as comment to top of file
2853 if (defined(my $descr = $conf->{description
})) {
2855 foreach my $cl (split(/\n/, $descr)) {
2856 $raw .= '#' . PVE
::Tools
::encode_text
($cl) . "\n";
2859 $raw .= "#\n" if $pending;
2863 foreach my $key (sort keys %$conf) {
2864 next if $key eq 'digest' || $key eq 'description' || $key eq 'pending' || $key eq 'snapshots';
2865 $raw .= "$key: $conf->{$key}\n";
2870 my $raw = &$generate_raw_config($conf);
2872 if (scalar(keys %{$conf->{pending
}})){
2873 $raw .= "\n[PENDING]\n";
2874 $raw .= &$generate_raw_config($conf->{pending
}, 1);
2877 foreach my $snapname (sort keys %{$conf->{snapshots
}}) {
2878 $raw .= "\n[$snapname]\n";
2879 $raw .= &$generate_raw_config($conf->{snapshots
}->{$snapname});
2889 # we use static defaults from our JSON schema configuration
2890 foreach my $key (keys %$confdesc) {
2891 if (defined(my $default = $confdesc->{$key}->{default})) {
2892 $res->{$key} = $default;
2900 my $vmlist = PVE
::Cluster
::get_vmlist
();
2902 return $res if !$vmlist || !$vmlist->{ids
};
2903 my $ids = $vmlist->{ids
};
2905 foreach my $vmid (keys %$ids) {
2906 my $d = $ids->{$vmid};
2907 next if !$d->{node
} || $d->{node
} ne $nodename;
2908 next if !$d->{type
} || $d->{type
} ne 'qemu';
2909 $res->{$vmid}->{exists} = 1;
2914 # test if VM uses local resources (to prevent migration)
2915 sub check_local_resources
{
2916 my ($conf, $noerr) = @_;
2920 push @loc_res, "hostusb" if $conf->{hostusb
}; # old syntax
2921 push @loc_res, "hostpci" if $conf->{hostpci
}; # old syntax
2923 push @loc_res, "ivshmem" if $conf->{ivshmem
};
2925 foreach my $k (keys %$conf) {
2926 next if $k =~ m/^usb/ && ($conf->{$k} eq 'spice');
2927 # sockets are safe: they will recreated be on the target side post-migrate
2928 next if $k =~ m/^serial/ && ($conf->{$k} eq 'socket');
2929 push @loc_res, $k if $k =~ m/^(usb|hostpci|serial|parallel)\d+$/;
2932 die "VM uses local resources\n" if scalar @loc_res && !$noerr;
2937 # check if used storages are available on all nodes (use by migrate)
2938 sub check_storage_availability
{
2939 my ($storecfg, $conf, $node) = @_;
2941 foreach_drive
($conf, sub {
2942 my ($ds, $drive) = @_;
2944 my $volid = $drive->{file
};
2947 my ($sid, $volname) = PVE
::Storage
::parse_volume_id
($volid, 1);
2950 # check if storage is available on both nodes
2951 my $scfg = PVE
::Storage
::storage_check_node
($storecfg, $sid);
2952 PVE
::Storage
::storage_check_node
($storecfg, $sid, $node);
2956 # list nodes where all VM images are available (used by has_feature API)
2958 my ($conf, $storecfg) = @_;
2960 my $nodelist = PVE
::Cluster
::get_nodelist
();
2961 my $nodehash = { map { $_ => 1 } @$nodelist };
2962 my $nodename = PVE
::INotify
::nodename
();
2964 foreach_drive
($conf, sub {
2965 my ($ds, $drive) = @_;
2967 my $volid = $drive->{file
};
2970 my ($storeid, $volname) = PVE
::Storage
::parse_volume_id
($volid, 1);
2972 my $scfg = PVE
::Storage
::storage_config
($storecfg, $storeid);
2973 if ($scfg->{disable
}) {
2975 } elsif (my $avail = $scfg->{nodes
}) {
2976 foreach my $node (keys %$nodehash) {
2977 delete $nodehash->{$node} if !$avail->{$node};
2979 } elsif (!$scfg->{shared
}) {
2980 foreach my $node (keys %$nodehash) {
2981 delete $nodehash->{$node} if $node ne $nodename
2990 sub check_local_storage_availability
{
2991 my ($conf, $storecfg) = @_;
2993 my $nodelist = PVE
::Cluster
::get_nodelist
();
2994 my $nodehash = { map { $_ => {} } @$nodelist };
2996 foreach_drive
($conf, sub {
2997 my ($ds, $drive) = @_;
2999 my $volid = $drive->{file
};
3002 my ($storeid, $volname) = PVE
::Storage
::parse_volume_id
($volid, 1);
3004 my $scfg = PVE
::Storage
::storage_config
($storecfg, $storeid);
3006 if ($scfg->{disable
}) {
3007 foreach my $node (keys %$nodehash) {
3008 $nodehash->{$node}->{unavailable_storages
}->{$storeid} = 1;
3010 } elsif (my $avail = $scfg->{nodes
}) {
3011 foreach my $node (keys %$nodehash) {
3012 if (!$avail->{$node}) {
3013 $nodehash->{$node}->{unavailable_storages
}->{$storeid} = 1;
3020 foreach my $node (values %$nodehash) {
3021 if (my $unavail = $node->{unavailable_storages
}) {
3022 $node->{unavailable_storages
} = [ sort keys %$unavail ];
3030 my ($pidfile, $pid) = @_;
3032 my $fh = IO
::File-
>new("/proc/$pid/cmdline", "r");
3036 return undef if !$line;
3037 my @param = split(/\0/, $line);
3039 my $cmd = $param[0];
3040 return if !$cmd || ($cmd !~ m
|kvm
$| && $cmd !~ m
@(?
:^|/)qemu-system-[^/]+$@);
3042 for (my $i = 0; $i < scalar (@param); $i++) {
3045 if (($p eq '-pidfile') || ($p eq '--pidfile')) {
3046 my $p = $param[$i+1];
3047 return 1 if $p && ($p eq $pidfile);
3056 my ($vmid, $nocheck, $node) = @_;
3058 my $filename = PVE
::QemuConfig-
>config_file($vmid, $node);
3060 die "unable to find configuration file for VM $vmid - no such machine\n"
3061 if !$nocheck && ! -f
$filename;
3063 my $pidfile = pidfile_name
($vmid);
3065 if (my $fd = IO
::File-
>new("<$pidfile")) {
3070 my $mtime = $st->mtime;
3071 if ($mtime > time()) {
3072 warn "file '$filename' modified in future\n";
3075 if ($line =~ m/^(\d+)$/) {
3077 if (check_cmdline
($pidfile, $pid)) {
3078 if (my $pinfo = PVE
::ProcFSTools
::check_process_running
($pid)) {
3090 my $vzlist = config_list
();
3092 my $fd = IO
::Dir-
>new($var_run_tmpdir) || return $vzlist;
3094 while (defined(my $de = $fd->read)) {
3095 next if $de !~ m/^(\d+)\.pid$/;
3097 next if !defined($vzlist->{$vmid});
3098 if (my $pid = check_running
($vmid)) {
3099 $vzlist->{$vmid}->{pid
} = $pid;
3107 my ($storecfg, $conf) = @_;
3109 my $bootdisk = $conf->{bootdisk
};
3110 return undef if !$bootdisk;
3111 return undef if !is_valid_drivename
($bootdisk);
3113 return undef if !$conf->{$bootdisk};
3115 my $drive = parse_drive
($bootdisk, $conf->{$bootdisk});
3116 return undef if !defined($drive);
3118 return undef if drive_is_cdrom
($drive);
3120 my $volid = $drive->{file
};
3121 return undef if !$volid;
3123 return $drive->{size
};
3126 our $vmstatus_return_properties = {
3127 vmid
=> get_standard_option
('pve-vmid'),
3129 description
=> "Qemu process status.",
3131 enum
=> ['stopped', 'running'],
3134 description
=> "Maximum memory in bytes.",
3137 renderer
=> 'bytes',
3140 description
=> "Root disk size in bytes.",
3143 renderer
=> 'bytes',
3146 description
=> "VM name.",
3151 description
=> "Qemu QMP agent status.",
3156 description
=> "PID of running qemu process.",
3161 description
=> "Uptime.",
3164 renderer
=> 'duration',
3167 description
=> "Maximum usable CPUs.",
3172 description
=> "The current config lock, if any.",
3178 my $last_proc_pid_stat;
3180 # get VM status information
3181 # This must be fast and should not block ($full == false)
3182 # We only query KVM using QMP if $full == true (this can be slow)
3184 my ($opt_vmid, $full) = @_;
3188 my $storecfg = PVE
::Storage
::config
();
3190 my $list = vzlist
();
3191 my $defaults = load_defaults
();
3193 my ($uptime) = PVE
::ProcFSTools
::read_proc_uptime
(1);
3195 my $cpucount = $cpuinfo->{cpus
} || 1;
3197 foreach my $vmid (keys %$list) {
3198 next if $opt_vmid && ($vmid ne $opt_vmid);
3200 my $cfspath = PVE
::QemuConfig-
>cfs_config_path($vmid);
3201 my $conf = PVE
::Cluster
::cfs_read_file
($cfspath) || {};
3203 my $d = { vmid
=> $vmid };
3204 $d->{pid
} = $list->{$vmid}->{pid
};
3206 # fixme: better status?
3207 $d->{status
} = $list->{$vmid}->{pid
} ?
'running' : 'stopped';
3209 my $size = disksize
($storecfg, $conf);
3210 if (defined($size)) {
3211 $d->{disk
} = 0; # no info available
3212 $d->{maxdisk
} = $size;
3218 $d->{cpus
} = ($conf->{sockets
} || $defaults->{sockets
})
3219 * ($conf->{cores
} || $defaults->{cores
});
3220 $d->{cpus
} = $cpucount if $d->{cpus
} > $cpucount;
3221 $d->{cpus
} = $conf->{vcpus
} if $conf->{vcpus
};
3223 $d->{name
} = $conf->{name
} || "VM $vmid";
3224 $d->{maxmem
} = $conf->{memory
} ?
$conf->{memory
}*(1024*1024)
3225 : $defaults->{memory
}*(1024*1024);
3227 if ($conf->{balloon
}) {
3228 $d->{balloon_min
} = $conf->{balloon
}*(1024*1024);
3229 $d->{shares
} = defined($conf->{shares
}) ?
$conf->{shares
}
3230 : $defaults->{shares
};
3241 $d->{diskwrite
} = 0;
3243 $d->{template
} = PVE
::QemuConfig-
>is_template($conf);
3245 $d->{serial
} = 1 if conf_has_serial
($conf);
3246 $d->{lock} = $conf->{lock} if $conf->{lock};
3251 my $netdev = PVE
::ProcFSTools
::read_proc_net_dev
();
3252 foreach my $dev (keys %$netdev) {
3253 next if $dev !~ m/^tap([1-9]\d*)i/;
3255 my $d = $res->{$vmid};
3258 $d->{netout
} += $netdev->{$dev}->{receive
};
3259 $d->{netin
} += $netdev->{$dev}->{transmit
};
3262 $d->{nics
}->{$dev}->{netout
} = $netdev->{$dev}->{receive
};
3263 $d->{nics
}->{$dev}->{netin
} = $netdev->{$dev}->{transmit
};
3268 my $ctime = gettimeofday
;
3270 foreach my $vmid (keys %$list) {
3272 my $d = $res->{$vmid};
3273 my $pid = $d->{pid
};
3276 my $pstat = PVE
::ProcFSTools
::read_proc_pid_stat
($pid);
3277 next if !$pstat; # not running
3279 my $used = $pstat->{utime} + $pstat->{stime
};
3281 $d->{uptime
} = int(($uptime - $pstat->{starttime
})/$cpuinfo->{user_hz
});
3283 if ($pstat->{vsize
}) {
3284 $d->{mem
} = int(($pstat->{rss
}/$pstat->{vsize
})*$d->{maxmem
});
3287 my $old = $last_proc_pid_stat->{$pid};
3289 $last_proc_pid_stat->{$pid} = {
3297 my $dtime = ($ctime - $old->{time}) * $cpucount * $cpuinfo->{user_hz
};
3299 if ($dtime > 1000) {
3300 my $dutime = $used - $old->{used
};
3302 $d->{cpu
} = (($dutime/$dtime)* $cpucount) / $d->{cpus
};
3303 $last_proc_pid_stat->{$pid} = {
3309 $d->{cpu
} = $old->{cpu
};
3313 return $res if !$full;
3315 my $qmpclient = PVE
::QMPClient-
>new();
3317 my $ballooncb = sub {
3318 my ($vmid, $resp) = @_;
3320 my $info = $resp->{'return'};
3321 return if !$info->{max_mem
};
3323 my $d = $res->{$vmid};
3325 # use memory assigned to VM
3326 $d->{maxmem
} = $info->{max_mem
};
3327 $d->{balloon
} = $info->{actual
};
3329 if (defined($info->{total_mem
}) && defined($info->{free_mem
})) {
3330 $d->{mem
} = $info->{total_mem
} - $info->{free_mem
};
3331 $d->{freemem
} = $info->{free_mem
};
3334 $d->{ballooninfo
} = $info;
3337 my $blockstatscb = sub {
3338 my ($vmid, $resp) = @_;
3339 my $data = $resp->{'return'} || [];
3340 my $totalrdbytes = 0;
3341 my $totalwrbytes = 0;
3343 for my $blockstat (@$data) {
3344 $totalrdbytes = $totalrdbytes + $blockstat->{stats
}->{rd_bytes
};
3345 $totalwrbytes = $totalwrbytes + $blockstat->{stats
}->{wr_bytes
};
3347 $blockstat->{device
} =~ s/drive-//;
3348 $res->{$vmid}->{blockstat
}->{$blockstat->{device
}} = $blockstat->{stats
};
3350 $res->{$vmid}->{diskread
} = $totalrdbytes;
3351 $res->{$vmid}->{diskwrite
} = $totalwrbytes;
3354 my $statuscb = sub {
3355 my ($vmid, $resp) = @_;
3357 $qmpclient->queue_cmd($vmid, $blockstatscb, 'query-blockstats');
3358 # this fails if ballon driver is not loaded, so this must be
3359 # the last commnand (following command are aborted if this fails).
3360 $qmpclient->queue_cmd($vmid, $ballooncb, 'query-balloon');
3362 my $status = 'unknown';
3363 if (!defined($status = $resp->{'return'}->{status
})) {
3364 warn "unable to get VM status\n";
3368 $res->{$vmid}->{qmpstatus
} = $resp->{'return'}->{status
};
3371 foreach my $vmid (keys %$list) {
3372 next if $opt_vmid && ($vmid ne $opt_vmid);
3373 next if !$res->{$vmid}->{pid
}; # not running
3374 $qmpclient->queue_cmd($vmid, $statuscb, 'query-status');
3377 $qmpclient->queue_execute(undef, 2);
3379 foreach my $vmid (keys %$list) {
3380 next if $opt_vmid && ($vmid ne $opt_vmid);
3381 $res->{$vmid}->{qmpstatus
} = $res->{$vmid}->{status
} if !$res->{$vmid}->{qmpstatus
};
3388 my ($conf, $func, @param) = @_;
3390 foreach my $ds (valid_drive_names
()) {
3391 next if !defined($conf->{$ds});
3393 my $drive = parse_drive
($ds, $conf->{$ds});
3396 &$func($ds, $drive, @param);
3401 my ($conf, $func, @param) = @_;
3405 my $test_volid = sub {
3406 my ($volid, $is_cdrom, $replicate, $shared, $snapname, $size) = @_;
3410 $volhash->{$volid}->{cdrom
} //= 1;
3411 $volhash->{$volid}->{cdrom
} = 0 if !$is_cdrom;
3413 $volhash->{$volid}->{replicate
} //= 0;
3414 $volhash->{$volid}->{replicate
} = 1 if $replicate;
3416 $volhash->{$volid}->{shared
} //= 0;
3417 $volhash->{$volid}->{shared
} = 1 if $shared;
3419 $volhash->{$volid}->{referenced_in_config
} //= 0;
3420 $volhash->{$volid}->{referenced_in_config
} = 1 if !defined($snapname);
3422 $volhash->{$volid}->{referenced_in_snapshot
}->{$snapname} = 1
3423 if defined($snapname);
3424 $volhash->{$volid}->{size
} = $size if $size;
3427 foreach_drive
($conf, sub {
3428 my ($ds, $drive) = @_;
3429 $test_volid->($drive->{file
}, drive_is_cdrom
($drive), $drive->{replicate
} // 1, $drive->{shared
}, undef, $drive->{size
});
3432 foreach my $snapname (keys %{$conf->{snapshots
}}) {
3433 my $snap = $conf->{snapshots
}->{$snapname};
3434 $test_volid->($snap->{vmstate
}, 0, 1, $snapname);
3435 foreach_drive
($snap, sub {
3436 my ($ds, $drive) = @_;
3437 $test_volid->($drive->{file
}, drive_is_cdrom
($drive), $drive->{replicate
} // 1, $drive->{shared
}, $snapname);
3441 foreach my $volid (keys %$volhash) {
3442 &$func($volid, $volhash->{$volid}, @param);
3446 sub conf_has_serial
{
3449 for (my $i = 0; $i < $MAX_SERIAL_PORTS; $i++) {
3450 if ($conf->{"serial$i"}) {
3458 sub conf_has_audio
{
3459 my ($conf, $id) = @_;
3462 my $audio = $conf->{"audio$id"};
3463 return undef if !defined($audio);
3465 my $audioproperties = PVE
::JSONSchema
::parse_property_string
($audio_fmt, $audio);
3466 my $audiodriver = $audioproperties->{driver
} // 'spice';
3469 dev
=> $audioproperties->{device
},
3470 dev_id
=> "audiodev$id",
3471 backend
=> $audiodriver,
3472 backend_id
=> "$audiodriver-backend${id}",
3476 sub vga_conf_has_spice
{
3479 my $vgaconf = parse_vga
($vga);
3480 my $vgatype = $vgaconf->{type
};
3481 return 0 if !$vgatype || $vgatype !~ m/^qxl([234])?$/;
3486 my $host_arch; # FIXME: fix PVE::Tools::get_host_arch
3487 sub get_host_arch
() {
3488 $host_arch = (POSIX
::uname
())[4] if !$host_arch;
3494 return get_host_arch
() eq $arch;
3497 my $default_machines = {
3502 sub get_basic_machine_info
{
3503 my ($conf, $forcemachine) = @_;
3505 my $arch = $conf->{arch
} // get_host_arch
();
3506 my $machine = $forcemachine || $conf->{machine
} || $default_machines->{$arch};
3507 return ($arch, $machine);
3510 sub get_ovmf_files
($) {
3513 my $ovmf = $OVMF->{$arch}
3514 or die "no OVMF images known for architecture '$arch'\n";
3520 aarch64
=> '/usr/bin/qemu-system-aarch64',
3521 x86_64
=> '/usr/bin/qemu-system-x86_64',
3523 sub get_command_for_arch
($) {
3525 return '/usr/bin/kvm' if is_native
($arch);
3527 my $cmd = $Arch2Qemu->{$arch}
3528 or die "don't know how to emulate architecture '$arch'\n";
3532 sub get_cpu_options
{
3533 my ($conf, $arch, $kvm, $machine_type, $kvm_off, $kvmver, $winversion, $gpu_passthrough) = @_;
3536 my $ostype = $conf->{ostype
};
3538 my $cpu = $kvm ?
"kvm64" : "qemu64";
3539 if ($arch eq 'aarch64') {
3540 $cpu = 'cortex-a57';
3543 if (my $cputype = $conf->{cpu
}) {
3544 my $cpuconf = PVE
::JSONSchema
::parse_property_string
($cpu_fmt, $cputype)
3545 or die "Cannot parse cpu description: $cputype\n";
3546 $cpu = $cpuconf->{cputype
};
3547 $kvm_off = 1 if $cpuconf->{hidden
};
3548 $hv_vendor_id = $cpuconf->{'hv-vendor-id'};
3550 if (defined(my $flags = $cpuconf->{flags
})) {
3551 push @$cpuFlags, split(";", $flags);
3555 push @$cpuFlags , '+lahf_lm' if $cpu eq 'kvm64' && $arch eq 'x86_64';
3557 push @$cpuFlags , '-x2apic'
3558 if $conf->{ostype
} && $conf->{ostype
} eq 'solaris';
3560 push @$cpuFlags, '+sep' if $cpu eq 'kvm64' || $cpu eq 'kvm32';
3562 push @$cpuFlags, '-rdtscp' if $cpu =~ m/^Opteron/;
3564 if (qemu_machine_feature_enabled
($machine_type, $kvmver, 2, 3) && $arch eq 'x86_64') {
3566 push @$cpuFlags , '+kvm_pv_unhalt' if $kvm;
3567 push @$cpuFlags , '+kvm_pv_eoi' if $kvm;
3570 add_hyperv_enlightenments
($cpuFlags, $winversion, $machine_type, $kvmver, $conf->{bios
}, $gpu_passthrough, $hv_vendor_id) if $kvm;
3572 push @$cpuFlags, 'enforce' if $cpu ne 'host' && $kvm && $arch eq 'x86_64';
3574 push @$cpuFlags, 'kvm=off' if $kvm_off;
3576 if (my $cpu_vendor = $cpu_vendor_list->{$cpu}) {
3577 push @$cpuFlags, "vendor=${cpu_vendor}"
3578 if $cpu_vendor ne 'default';
3579 } elsif ($arch ne 'aarch64') {
3580 die "internal error"; # should not happen
3583 $cpu .= "," . join(',', @$cpuFlags) if scalar(@$cpuFlags);
3585 return ('-cpu', $cpu);
3588 sub config_to_command
{
3589 my ($storecfg, $vmid, $conf, $defaults, $forcemachine) = @_;
3592 my $globalFlags = [];
3593 my $machineFlags = [];
3598 my $vernum = 0; # unknown
3599 my $ostype = $conf->{ostype
};
3600 my $winversion = windows_version
($ostype);
3601 my $kvm = $conf->{kvm
};
3603 my ($arch, $machine_type) = get_basic_machine_info
($conf, $forcemachine);
3604 my $kvm_binary = get_command_for_arch
($arch);
3605 my $kvmver = kvm_user_version
($kvm_binary);
3606 $kvm //= 1 if is_native
($arch);
3609 die "KVM virtualisation configured, but not available. Either disable in VM configuration or enable in BIOS.\n"
3610 if !defined kvm_version
();
3613 if ($kvmver =~ m/^(\d+)\.(\d+)$/) {
3614 $vernum = $1*1000000+$2*1000;
3615 } elsif ($kvmver =~ m/^(\d+)\.(\d+)\.(\d+)$/) {
3616 $vernum = $1*1000000+$2*1000+$3;
3619 die "detected old qemu-kvm binary ($kvmver)\n" if $vernum < 15000;
3621 my $have_ovz = -f
'/proc/vz/vestat';
3623 my $q35 = machine_type_is_q35
($conf);
3624 my $hotplug_features = parse_hotplug_features
(defined($conf->{hotplug
}) ?
$conf->{hotplug
} : '1');
3625 my $use_old_bios_files = undef;
3626 ($use_old_bios_files, $machine_type) = qemu_use_old_bios_files
($machine_type);
3628 my $cpuunits = defined($conf->{cpuunits
}) ?
3629 $conf->{cpuunits
} : $defaults->{cpuunits
};
3631 push @$cmd, $kvm_binary;
3633 push @$cmd, '-id', $vmid;
3635 my $vmname = $conf->{name
} || "vm$vmid";
3637 push @$cmd, '-name', $vmname;
3641 my $qmpsocket = qmp_socket
($vmid);
3642 push @$cmd, '-chardev', "socket,id=qmp,path=$qmpsocket,server,nowait";
3643 push @$cmd, '-mon', "chardev=qmp,mode=control";
3645 if (qemu_machine_feature_enabled
($machine_type, $kvmver, 2, 12)) {
3646 push @$cmd, '-chardev', "socket,id=qmp-event,path=/var/run/qmeventd.sock,reconnect=5";
3647 push @$cmd, '-mon', "chardev=qmp-event,mode=control";
3650 push @$cmd, '-pidfile' , pidfile_name
($vmid);
3652 push @$cmd, '-daemonize';
3654 if ($conf->{smbios1
}) {
3655 my $smbios_conf = parse_smbios1
($conf->{smbios1
});
3656 if ($smbios_conf->{base64
}) {
3657 # Do not pass base64 flag to qemu
3658 delete $smbios_conf->{base64
};
3659 my $smbios_string = "";
3660 foreach my $key (keys %$smbios_conf) {
3662 if ($key eq "uuid") {
3663 $value = $smbios_conf->{uuid
}
3665 $value = decode_base64
($smbios_conf->{$key});
3667 # qemu accepts any binary data, only commas need escaping by double comma
3669 $smbios_string .= "," . $key . "=" . $value if $value;
3671 push @$cmd, '-smbios', "type=1" . $smbios_string;
3673 push @$cmd, '-smbios', "type=1,$conf->{smbios1}";
3677 if ($conf->{vmgenid
}) {
3678 push @$devices, '-device', 'vmgenid,guid='.$conf->{vmgenid
};
3681 my ($ovmf_code, $ovmf_vars) = get_ovmf_files
($arch);
3682 if ($conf->{bios
} && $conf->{bios
} eq 'ovmf') {
3683 die "uefi base image not found\n" if ! -f
$ovmf_code;
3687 if (my $efidisk = $conf->{efidisk0
}) {
3688 my $d = PVE
::JSONSchema
::parse_property_string
($efidisk_fmt, $efidisk);
3689 my ($storeid, $volname) = PVE
::Storage
::parse_volume_id
($d->{file
}, 1);
3690 $format = $d->{format
};
3692 $path = PVE
::Storage
::path
($storecfg, $d->{file
});
3693 if (!defined($format)) {
3694 my $scfg = PVE
::Storage
::storage_config
($storecfg, $storeid);
3695 $format = qemu_img_format
($scfg, $volname);
3699 die "efidisk format must be specified\n"
3700 if !defined($format);
3703 warn "no efidisk configured! Using temporary efivars disk.\n";
3704 $path = "/tmp/$vmid-ovmf.fd";
3705 PVE
::Tools
::file_copy
($ovmf_vars, $path, -s
$ovmf_vars);
3709 push @$cmd, '-drive', "if=pflash,unit=0,format=raw,readonly,file=$ovmf_code";
3710 push @$cmd, '-drive', "if=pflash,unit=1,format=$format,id=drive-efidisk0,file=$path";
3715 # we use different pcie-port hardware for qemu >= 4.0 for passthrough
3716 if (qemu_machine_feature_enabled
($machine_type, $kvmver, 4, 0)) {
3717 push @$devices, '-readconfig', '/usr/share/qemu-server/pve-q35-4.0.cfg';
3719 push @$devices, '-readconfig', '/usr/share/qemu-server/pve-q35.cfg';
3723 # add usb controllers
3724 my @usbcontrollers = PVE
::QemuServer
::USB
::get_usb_controllers
($conf, $bridges, $arch, $machine_type, $usbdesc->{format
}, $MAX_USB_DEVICES);
3725 push @$devices, @usbcontrollers if @usbcontrollers;
3726 my $vga = parse_vga
($conf->{vga
});
3728 my $qxlnum = vga_conf_has_spice
($conf->{vga
});
3729 $vga->{type
} = 'qxl' if $qxlnum;
3731 if (!$vga->{type
}) {
3732 if ($arch eq 'aarch64') {
3733 $vga->{type
} = 'virtio';
3734 } elsif (qemu_machine_feature_enabled
($machine_type, $kvmver, 2, 9)) {
3735 $vga->{type
} = (!$winversion || $winversion >= 6) ?
'std' : 'cirrus';
3737 $vga->{type
} = ($winversion >= 6) ?
'std' : 'cirrus';
3741 # enable absolute mouse coordinates (needed by vnc)
3743 if (defined($conf->{tablet
})) {
3744 $tablet = $conf->{tablet
};
3746 $tablet = $defaults->{tablet
};
3747 $tablet = 0 if $qxlnum; # disable for spice because it is not needed
3748 $tablet = 0 if $vga->{type
} =~ m/^serial\d+$/; # disable if we use serial terminal (no vga card)
3752 push @$devices, '-device', print_tabletdevice_full
($conf, $arch) if $tablet;
3753 my $kbd = print_keyboarddevice_full
($conf, $arch);
3754 push @$devices, '-device', $kbd if defined($kbd);
3758 my $gpu_passthrough;
3761 for (my $i = 0; $i < $MAX_HOSTPCI_DEVICES; $i++) {
3762 my $d = parse_hostpci
($conf->{"hostpci$i"});
3765 my $pcie = $d->{pcie
};
3767 die "q35 machine model is not enabled" if !$q35;
3768 # win7 wants to have the pcie devices directly on the pcie bus
3769 # instead of in the root port
3770 if ($winversion == 7) {
3771 $pciaddr = print_pcie_addr
("hostpci${i}bus0");
3773 $pciaddr = print_pcie_addr
("hostpci$i");
3776 $pciaddr = print_pci_addr
("hostpci$i", $bridges, $arch, $machine_type);
3779 my $rombar = defined($d->{rombar
}) && !$d->{rombar
} ?
',rombar=0' : '';
3780 my $romfile = $d->{romfile
};
3783 if ($d->{'x-vga'}) {
3784 $xvga = ',x-vga=on';
3786 $vga->{type
} = 'none' if !defined($conf->{vga
});
3787 $gpu_passthrough = 1;
3789 if ($conf->{bios
} && $conf->{bios
} eq 'ovmf') {
3793 my $pcidevices = $d->{pciid
};
3794 my $multifunction = 1 if @$pcidevices > 1;
3796 if ($d->{mdev
} && scalar(@$pcidevices) == 1) {
3797 my $id = $pcidevices->[0]->{id
};
3798 my $uuid = PVE
::SysFSTools
::generate_mdev_uuid
($vmid, $i);
3799 $sysfspath = "/sys/bus/pci/devices/0000:$id/$uuid";
3800 } elsif ($d->{mdev
}) {
3801 warn "ignoring mediated device with multifunction device\n";
3805 foreach my $pcidevice (@$pcidevices) {
3807 my $id = "hostpci$i";
3808 $id .= ".$j" if $multifunction;
3809 my $addr = $pciaddr;
3810 $addr .= ".$j" if $multifunction;
3811 my $devicestr = "vfio-pci";
3813 $devicestr .= ",sysfsdev=$sysfspath";
3815 $devicestr .= ",host=$pcidevice->{id}";
3817 $devicestr .= ",id=$id$addr";
3820 $devicestr .= "$rombar$xvga";
3821 $devicestr .= ",multifunction=on" if $multifunction;
3822 $devicestr .= ",romfile=/usr/share/kvm/$romfile" if $romfile;
3825 push @$devices, '-device', $devicestr;
3831 my @usbdevices = PVE
::QemuServer
::USB
::get_usb_devices
($conf, $usbdesc->{format
}, $MAX_USB_DEVICES);
3832 push @$devices, @usbdevices if @usbdevices;
3834 for (my $i = 0; $i < $MAX_SERIAL_PORTS; $i++) {
3835 if (my $path = $conf->{"serial$i"}) {
3836 if ($path eq 'socket') {
3837 my $socket = "/var/run/qemu-server/${vmid}.serial$i";
3838 push @$devices, '-chardev', "socket,id=serial$i,path=$socket,server,nowait";
3839 # On aarch64, serial0 is the UART device. Qemu only allows
3840 # connecting UART devices via the '-serial' command line, as
3841 # the device has a fixed slot on the hardware...
3842 if ($arch eq 'aarch64' && $i == 0) {
3843 push @$devices, '-serial', "chardev:serial$i";
3845 push @$devices, '-device', "isa-serial,chardev=serial$i";
3848 die "no such serial device\n" if ! -c
$path;
3849 push @$devices, '-chardev', "tty,id=serial$i,path=$path";
3850 push @$devices, '-device', "isa-serial,chardev=serial$i";
3856 for (my $i = 0; $i < $MAX_PARALLEL_PORTS; $i++) {
3857 if (my $path = $conf->{"parallel$i"}) {
3858 die "no such parallel device\n" if ! -c
$path;
3859 my $devtype = $path =~ m!^/dev/usb/lp! ?
'tty' : 'parport';
3860 push @$devices, '-chardev', "$devtype,id=parallel$i,path=$path";
3861 push @$devices, '-device', "isa-parallel,chardev=parallel$i";
3865 if (my $audio = conf_has_audio
($conf)) {
3867 my $audiopciaddr = print_pci_addr
("audio0", $bridges, $arch, $machine_type);
3869 my $id = $audio->{dev_id
};
3870 if ($audio->{dev
} eq 'AC97') {
3871 push @$devices, '-device', "AC97,id=${id}${audiopciaddr}";
3872 } elsif ($audio->{dev
} =~ /intel\-hda$/) {
3873 push @$devices, '-device', "$audio->{dev},id=${id}${audiopciaddr}";
3874 push @$devices, '-device', "hda-micro,id=${id}-codec0,bus=${id}.0,cad=0";
3875 push @$devices, '-device', "hda-duplex,id=${id}-codec1,bus=${id}.0,cad=1";
3877 die "unkown audio device '$audio->{dev}', implement me!";
3880 push @$devices, '-audiodev', "$audio->{backend},id=$audio->{backend_id}";
3884 $sockets = $conf->{smp
} if $conf->{smp
}; # old style - no longer iused
3885 $sockets = $conf->{sockets
} if $conf->{sockets
};
3887 my $cores = $conf->{cores
} || 1;
3889 my $maxcpus = $sockets * $cores;
3891 my $vcpus = $conf->{vcpus
} ?
$conf->{vcpus
} : $maxcpus;
3893 my $allowed_vcpus = $cpuinfo->{cpus
};
3895 die "MAX $allowed_vcpus vcpus allowed per VM on this node\n"
3896 if ($allowed_vcpus < $maxcpus);
3898 if($hotplug_features->{cpu
} && qemu_machine_feature_enabled
($machine_type, $kvmver, 2, 7)) {
3900 push @$cmd, '-smp', "1,sockets=$sockets,cores=$cores,maxcpus=$maxcpus";
3901 for (my $i = 2; $i <= $vcpus; $i++) {
3902 my $cpustr = print_cpu_device
($conf,$i);
3903 push @$cmd, '-device', $cpustr;
3908 push @$cmd, '-smp', "$vcpus,sockets=$sockets,cores=$cores,maxcpus=$maxcpus";
3910 push @$cmd, '-nodefaults';
3912 my $bootorder = $conf->{boot
} || $confdesc->{boot
}->{default};
3914 my $bootindex_hash = {};
3916 foreach my $o (split(//, $bootorder)) {
3917 $bootindex_hash->{$o} = $i*100;
3921 push @$cmd, '-boot', "menu=on,strict=on,reboot-timeout=1000,splash=/usr/share/qemu-server/bootsplash.jpg";
3923 push @$cmd, '-no-acpi' if defined($conf->{acpi
}) && $conf->{acpi
} == 0;
3925 push @$cmd, '-no-reboot' if defined($conf->{reboot
}) && $conf->{reboot
} == 0;
3927 if ($vga->{type
} && $vga->{type
} !~ m/^serial\d+$/ && $vga->{type
} ne 'none'){
3928 push @$devices, '-device', print_vga_device
($conf, $vga, $arch, $machine_type, undef, $qxlnum, $bridges);
3929 my $socket = vnc_socket
($vmid);
3930 push @$cmd, '-vnc', "unix:$socket,password";
3932 push @$cmd, '-vga', 'none' if $vga->{type
} eq 'none';
3933 push @$cmd, '-nographic';
3937 my $tdf = defined($conf->{tdf
}) ?
$conf->{tdf
} : $defaults->{tdf
};
3939 my $useLocaltime = $conf->{localtime};
3941 if ($winversion >= 5) { # windows
3942 $useLocaltime = 1 if !defined($conf->{localtime});
3944 # use time drift fix when acpi is enabled
3945 if (!(defined($conf->{acpi
}) && $conf->{acpi
} == 0)) {
3946 $tdf = 1 if !defined($conf->{tdf
});
3950 if ($winversion >= 6) {
3951 push @$globalFlags, 'kvm-pit.lost_tick_policy=discard';
3952 push @$cmd, '-no-hpet';
3955 push @$rtcFlags, 'driftfix=slew' if $tdf;
3958 push @$machineFlags, 'accel=tcg';
3961 if ($machine_type) {
3962 push @$machineFlags, "type=${machine_type}";
3965 if (($conf->{startdate
}) && ($conf->{startdate
} ne 'now')) {
3966 push @$rtcFlags, "base=$conf->{startdate}";
3967 } elsif ($useLocaltime) {
3968 push @$rtcFlags, 'base=localtime';
3971 push @$cmd, get_cpu_options
($conf, $arch, $kvm, $machine_type, $kvm_off, $kvmver, $winversion, $gpu_passthrough);
3973 PVE
::QemuServer
::Memory
::config
($conf, $vmid, $sockets, $cores, $defaults, $hotplug_features, $cmd);
3975 push @$cmd, '-S' if $conf->{freeze
};
3977 push @$cmd, '-k', $conf->{keyboard
} if defined($conf->{keyboard
});
3979 if (parse_guest_agent
($conf)->{enabled
}) {
3980 my $qgasocket = qmp_socket
($vmid, 1);
3981 my $pciaddr = print_pci_addr
("qga0", $bridges, $arch, $machine_type);
3982 push @$devices, '-chardev', "socket,path=$qgasocket,server,nowait,id=qga0";
3983 push @$devices, '-device', "virtio-serial,id=qga0$pciaddr";
3984 push @$devices, '-device', 'virtserialport,chardev=qga0,name=org.qemu.guest_agent.0';
3992 for(my $i = 1; $i < $qxlnum; $i++){
3993 push @$devices, '-device', print_vga_device
($conf, $vga, $arch, $machine_type, $i, $qxlnum, $bridges);
3996 # assume other OS works like Linux
3997 my ($ram, $vram) = ("134217728", "67108864");
3998 if ($vga->{memory
}) {
3999 $ram = PVE
::Tools
::convert_size
($qxlnum*4*$vga->{memory
}, 'mb' => 'b');
4000 $vram = PVE
::Tools
::convert_size
($qxlnum*2*$vga->{memory
}, 'mb' => 'b');
4002 push @$cmd, '-global', "qxl-vga.ram_size=$ram";
4003 push @$cmd, '-global', "qxl-vga.vram_size=$vram";
4007 my $pciaddr = print_pci_addr
("spice", $bridges, $arch, $machine_type);
4009 my $nodename = PVE
::INotify
::nodename
();
4010 my $pfamily = PVE
::Tools
::get_host_address_family
($nodename);
4011 my @nodeaddrs = PVE
::Tools
::getaddrinfo_all
('localhost', family
=> $pfamily);
4012 die "failed to get an ip address of type $pfamily for 'localhost'\n" if !@nodeaddrs;
4013 my $localhost = PVE
::Network
::addr_to_ip
($nodeaddrs[0]->{addr
});
4014 $spice_port = PVE
::Tools
::next_spice_port
($pfamily, $localhost);
4016 my $spice_enhancement = PVE
::JSONSchema
::parse_property_string
($spice_enhancements_fmt, $conf->{spice_enhancements
} // '');
4017 if ($spice_enhancement->{foldersharing
}) {
4018 push @$devices, '-chardev', "spiceport,id=foldershare,name=org.spice-space.webdav.0";
4019 push @$devices, '-device', "virtserialport,chardev=foldershare,name=org.spice-space.webdav.0";
4022 my $spice_opts = "tls-port=${spice_port},addr=$localhost,tls-ciphers=HIGH,seamless-migration=on";
4023 $spice_opts .= ",streaming-video=$spice_enhancement->{videostreaming}" if $spice_enhancement->{videostreaming
};
4024 push @$devices, '-spice', "$spice_opts";
4026 push @$devices, '-device', "virtio-serial,id=spice$pciaddr";
4027 push @$devices, '-chardev', "spicevmc,id=vdagent,name=vdagent";
4028 push @$devices, '-device', "virtserialport,chardev=vdagent,name=com.redhat.spice.0";
4032 # enable balloon by default, unless explicitly disabled
4033 if (!defined($conf->{balloon
}) || $conf->{balloon
}) {
4034 $pciaddr = print_pci_addr
("balloon0", $bridges, $arch, $machine_type);
4035 push @$devices, '-device', "virtio-balloon-pci,id=balloon0$pciaddr";
4038 if ($conf->{watchdog
}) {
4039 my $wdopts = parse_watchdog
($conf->{watchdog
});
4040 $pciaddr = print_pci_addr
("watchdog", $bridges, $arch, $machine_type);
4041 my $watchdog = $wdopts->{model
} || 'i6300esb';
4042 push @$devices, '-device', "$watchdog$pciaddr";
4043 push @$devices, '-watchdog-action', $wdopts->{action
} if $wdopts->{action
};
4047 my $scsicontroller = {};
4048 my $ahcicontroller = {};
4049 my $scsihw = defined($conf->{scsihw
}) ?
$conf->{scsihw
} : $defaults->{scsihw
};
4051 # Add iscsi initiator name if available
4052 if (my $initiator = get_initiator_name
()) {
4053 push @$devices, '-iscsi', "initiator-name=$initiator";
4056 foreach_drive
($conf, sub {
4057 my ($ds, $drive) = @_;
4059 if (PVE
::Storage
::parse_volume_id
($drive->{file
}, 1)) {
4060 push @$vollist, $drive->{file
};
4063 # ignore efidisk here, already added in bios/fw handling code above
4064 return if $drive->{interface
} eq 'efidisk';
4066 $use_virtio = 1 if $ds =~ m/^virtio/;
4068 if (drive_is_cdrom
($drive)) {
4069 if ($bootindex_hash->{d
}) {
4070 $drive->{bootindex
} = $bootindex_hash->{d
};
4071 $bootindex_hash->{d
} += 1;
4074 if ($bootindex_hash->{c
}) {
4075 $drive->{bootindex
} = $bootindex_hash->{c
} if $conf->{bootdisk
} && ($conf->{bootdisk
} eq $ds);
4076 $bootindex_hash->{c
} += 1;
4080 if($drive->{interface
} eq 'virtio'){
4081 push @$cmd, '-object', "iothread,id=iothread-$ds" if $drive->{iothread
};
4084 if ($drive->{interface
} eq 'scsi') {
4086 my ($maxdev, $controller, $controller_prefix) = scsihw_infos
($conf, $drive);
4088 $pciaddr = print_pci_addr
("$controller_prefix$controller", $bridges, $arch, $machine_type);
4089 my $scsihw_type = $scsihw =~ m/^virtio-scsi-single/ ?
"virtio-scsi-pci" : $scsihw;
4092 if($conf->{scsihw
} && $conf->{scsihw
} eq "virtio-scsi-single" && $drive->{iothread
}){
4093 $iothread .= ",iothread=iothread-$controller_prefix$controller";
4094 push @$cmd, '-object', "iothread,id=iothread-$controller_prefix$controller";
4095 } elsif ($drive->{iothread
}) {
4096 warn "iothread is only valid with virtio disk or virtio-scsi-single controller, ignoring\n";
4100 if($conf->{scsihw
} && $conf->{scsihw
} eq "virtio-scsi-single" && $drive->{queues
}){
4101 $queues = ",num_queues=$drive->{queues}";
4104 push @$devices, '-device', "$scsihw_type,id=$controller_prefix$controller$pciaddr$iothread$queues" if !$scsicontroller->{$controller};
4105 $scsicontroller->{$controller}=1;
4108 if ($drive->{interface
} eq 'sata') {
4109 my $controller = int($drive->{index} / $MAX_SATA_DISKS);
4110 $pciaddr = print_pci_addr
("ahci$controller", $bridges, $arch, $machine_type);
4111 push @$devices, '-device', "ahci,id=ahci$controller,multifunction=on$pciaddr" if !$ahcicontroller->{$controller};
4112 $ahcicontroller->{$controller}=1;
4115 my $drive_cmd = print_drive_full
($storecfg, $vmid, $drive);
4116 push @$devices, '-drive',$drive_cmd;
4117 push @$devices, '-device', print_drivedevice_full
($storecfg, $conf, $vmid, $drive, $bridges, $arch, $machine_type);
4120 for (my $i = 0; $i < $MAX_NETS; $i++) {
4121 next if !$conf->{"net$i"};
4122 my $d = parse_net
($conf->{"net$i"});
4125 $use_virtio = 1 if $d->{model
} eq 'virtio';
4127 if ($bootindex_hash->{n
}) {
4128 $d->{bootindex
} = $bootindex_hash->{n
};
4129 $bootindex_hash->{n
} += 1;
4132 my $netdevfull = print_netdev_full
($vmid, $conf, $arch, $d, "net$i");
4133 push @$devices, '-netdev', $netdevfull;
4135 my $netdevicefull = print_netdevice_full
($vmid, $conf, $d, "net$i", $bridges, $use_old_bios_files, $arch, $machine_type);
4136 push @$devices, '-device', $netdevicefull;
4139 if ($conf->{ivshmem
}) {
4140 my $ivshmem = PVE
::JSONSchema
::parse_property_string
($ivshmem_fmt, $conf->{ivshmem
});
4144 $bus = print_pcie_addr
("ivshmem");
4146 $bus = print_pci_addr
("ivshmem", $bridges, $arch, $machine_type);
4149 my $ivshmem_name = $ivshmem->{name
} // $vmid;
4150 my $path = '/dev/shm/pve-shm-' . $ivshmem_name;
4152 push @$devices, '-device', "ivshmem-plain,memdev=ivshmem$bus,";
4153 push @$devices, '-object', "memory-backend-file,id=ivshmem,share=on,mem-path=$path,size=$ivshmem->{size}M";
4158 if (qemu_machine_feature_enabled
($machine_type, $kvmver, 2, 3)) {
4163 $bridges->{3} = 1 if $scsihw =~ m/^virtio-scsi-single/;
4165 while (my ($k, $v) = each %$bridges) {
4166 $pciaddr = print_pci_addr
("pci.$k", undef, $arch, $machine_type);
4167 unshift @$devices, '-device', "pci-bridge,id=pci.$k,chassis_nr=$k$pciaddr" if $k > 0;
4171 push @$cmd, @$devices;
4172 push @$cmd, '-rtc', join(',', @$rtcFlags)
4173 if scalar(@$rtcFlags);
4174 push @$cmd, '-machine', join(',', @$machineFlags)
4175 if scalar(@$machineFlags);
4176 push @$cmd, '-global', join(',', @$globalFlags)
4177 if scalar(@$globalFlags);
4179 if (my $vmstate = $conf->{vmstate
}) {
4180 my $statepath = PVE
::Storage
::path
($storecfg, $vmstate);
4181 PVE
::Storage
::activate_volumes
($storecfg, [$vmstate]);
4182 push @$cmd, '-loadstate', $statepath;
4186 if ($conf->{args
}) {
4187 my $aa = PVE
::Tools
::split_args
($conf->{args
});
4191 return wantarray ?
($cmd, $vollist, $spice_port) : $cmd;
4196 return "${var_run_tmpdir}/$vmid.vnc";
4202 my $res = vm_mon_cmd
($vmid, 'query-spice');
4204 return $res->{'tls-port'} || $res->{'port'} || die "no spice port\n";
4208 my ($vmid, $qga, $name) = @_;
4209 my $sockettype = $qga ?
'qga' : 'qmp';
4210 my $ext = $name ?
'-'.$name : '';
4211 return "${var_run_tmpdir}/$vmid$ext.$sockettype";
4216 return "${var_run_tmpdir}/$vmid.pid";
4219 sub vm_devices_list
{
4222 my $res = vm_mon_cmd
($vmid, 'query-pci');
4223 my $devices_to_check = [];
4225 foreach my $pcibus (@$res) {
4226 push @$devices_to_check, @{$pcibus->{devices
}},
4229 while (@$devices_to_check) {
4231 for my $d (@$devices_to_check) {
4232 $devices->{$d->{'qdev_id'}} = 1 if $d->{'qdev_id'};
4233 next if !$d->{'pci_bridge'};
4235 $devices->{$d->{'qdev_id'}} += scalar(@{$d->{'pci_bridge'}->{devices
}});
4236 push @$to_check, @{$d->{'pci_bridge'}->{devices
}};
4238 $devices_to_check = $to_check;
4241 my $resblock = vm_mon_cmd
($vmid, 'query-block');
4242 foreach my $block (@$resblock) {
4243 if($block->{device
} =~ m/^drive-(\S+)/){
4248 my $resmice = vm_mon_cmd
($vmid, 'query-mice');
4249 foreach my $mice (@$resmice) {
4250 if ($mice->{name
} eq 'QEMU HID Tablet') {
4251 $devices->{tablet
} = 1;
4256 # for usb devices there is no query-usb
4257 # but we can iterate over the entries in
4258 # qom-list path=/machine/peripheral
4259 my $resperipheral = vm_mon_cmd
($vmid, 'qom-list', path
=> '/machine/peripheral');
4260 foreach my $per (@$resperipheral) {
4261 if ($per->{name
} =~ m/^usb\d+$/) {
4262 $devices->{$per->{name
}} = 1;
4270 my ($storecfg, $conf, $vmid, $deviceid, $device, $arch, $machine_type) = @_;
4272 my $q35 = machine_type_is_q35
($conf);
4274 my $devices_list = vm_devices_list
($vmid);
4275 return 1 if defined($devices_list->{$deviceid});
4277 qemu_add_pci_bridge
($storecfg, $conf, $vmid, $deviceid, $arch, $machine_type); # add PCI bridge if we need it for the device
4279 if ($deviceid eq 'tablet') {
4281 qemu_deviceadd
($vmid, print_tabletdevice_full
($conf, $arch));
4283 } elsif ($deviceid eq 'keyboard') {
4285 qemu_deviceadd
($vmid, print_keyboarddevice_full
($conf, $arch));
4287 } elsif ($deviceid =~ m/^usb(\d+)$/) {
4289 die "usb hotplug currently not reliable\n";
4290 # since we can't reliably hot unplug all added usb devices
4291 # and usb passthrough disables live migration
4292 # we disable usb hotplugging for now
4293 qemu_deviceadd
($vmid, PVE
::QemuServer
::USB
::print_usbdevice_full
($conf, $deviceid, $device));
4295 } elsif ($deviceid =~ m/^(virtio)(\d+)$/) {
4297 qemu_iothread_add
($vmid, $deviceid, $device);
4299 qemu_driveadd
($storecfg, $vmid, $device);
4300 my $devicefull = print_drivedevice_full
($storecfg, $conf, $vmid, $device, $arch, $machine_type);
4302 qemu_deviceadd
($vmid, $devicefull);
4303 eval { qemu_deviceaddverify
($vmid, $deviceid); };
4305 eval { qemu_drivedel
($vmid, $deviceid); };
4310 } elsif ($deviceid =~ m/^(virtioscsi|scsihw)(\d+)$/) {
4313 my $scsihw = defined($conf->{scsihw
}) ?
$conf->{scsihw
} : "lsi";
4314 my $pciaddr = print_pci_addr
($deviceid, undef, $arch, $machine_type);
4315 my $scsihw_type = $scsihw eq 'virtio-scsi-single' ?
"virtio-scsi-pci" : $scsihw;
4317 my $devicefull = "$scsihw_type,id=$deviceid$pciaddr";
4319 if($deviceid =~ m/^virtioscsi(\d+)$/ && $device->{iothread
}) {
4320 qemu_iothread_add
($vmid, $deviceid, $device);
4321 $devicefull .= ",iothread=iothread-$deviceid";
4324 if($deviceid =~ m/^virtioscsi(\d+)$/ && $device->{queues
}) {
4325 $devicefull .= ",num_queues=$device->{queues}";
4328 qemu_deviceadd
($vmid, $devicefull);
4329 qemu_deviceaddverify
($vmid, $deviceid);
4331 } elsif ($deviceid =~ m/^(scsi)(\d+)$/) {
4333 qemu_findorcreatescsihw
($storecfg,$conf, $vmid, $device, $arch, $machine_type);
4334 qemu_driveadd
($storecfg, $vmid, $device);
4336 my $devicefull = print_drivedevice_full
($storecfg, $conf, $vmid, $device, $arch, $machine_type);
4337 eval { qemu_deviceadd
($vmid, $devicefull); };
4339 eval { qemu_drivedel
($vmid, $deviceid); };
4344 } elsif ($deviceid =~ m/^(net)(\d+)$/) {
4346 return undef if !qemu_netdevadd
($vmid, $conf, $arch, $device, $deviceid);
4348 my $machine_type = PVE
::QemuServer
::qemu_machine_pxe
($vmid, $conf);
4349 my $use_old_bios_files = undef;
4350 ($use_old_bios_files, $machine_type) = qemu_use_old_bios_files
($machine_type);
4352 my $netdevicefull = print_netdevice_full
($vmid, $conf, $device, $deviceid, undef, $use_old_bios_files, $arch, $machine_type);
4353 qemu_deviceadd
($vmid, $netdevicefull);
4355 qemu_deviceaddverify
($vmid, $deviceid);
4356 qemu_set_link_status
($vmid, $deviceid, !$device->{link_down
});
4359 eval { qemu_netdevdel
($vmid, $deviceid); };
4364 } elsif (!$q35 && $deviceid =~ m/^(pci\.)(\d+)$/) {
4367 my $pciaddr = print_pci_addr
($deviceid, undef, $arch, $machine_type);
4368 my $devicefull = "pci-bridge,id=pci.$bridgeid,chassis_nr=$bridgeid$pciaddr";
4370 qemu_deviceadd
($vmid, $devicefull);
4371 qemu_deviceaddverify
($vmid, $deviceid);
4374 die "can't hotplug device '$deviceid'\n";
4380 # fixme: this should raise exceptions on error!
4381 sub vm_deviceunplug
{
4382 my ($vmid, $conf, $deviceid) = @_;
4384 my $devices_list = vm_devices_list
($vmid);
4385 return 1 if !defined($devices_list->{$deviceid});
4387 die "can't unplug bootdisk" if $conf->{bootdisk
} && $conf->{bootdisk
} eq $deviceid;
4389 if ($deviceid eq 'tablet' || $deviceid eq 'keyboard') {
4391 qemu_devicedel
($vmid, $deviceid);
4393 } elsif ($deviceid =~ m/^usb\d+$/) {
4395 die "usb hotplug currently not reliable\n";
4396 # when unplugging usb devices this way,
4397 # there may be remaining usb controllers/hubs
4398 # so we disable it for now
4399 qemu_devicedel
($vmid, $deviceid);
4400 qemu_devicedelverify
($vmid, $deviceid);
4402 } elsif ($deviceid =~ m/^(virtio)(\d+)$/) {
4404 qemu_devicedel
($vmid, $deviceid);
4405 qemu_devicedelverify
($vmid, $deviceid);
4406 qemu_drivedel
($vmid, $deviceid);
4407 qemu_iothread_del
($conf, $vmid, $deviceid);
4409 } elsif ($deviceid =~ m/^(virtioscsi|scsihw)(\d+)$/) {
4411 qemu_devicedel
($vmid, $deviceid);
4412 qemu_devicedelverify
($vmid, $deviceid);
4413 qemu_iothread_del
($conf, $vmid, $deviceid);
4415 } elsif ($deviceid =~ m/^(scsi)(\d+)$/) {
4417 qemu_devicedel
($vmid, $deviceid);
4418 qemu_drivedel
($vmid, $deviceid);
4419 qemu_deletescsihw
($conf, $vmid, $deviceid);
4421 } elsif ($deviceid =~ m/^(net)(\d+)$/) {
4423 qemu_devicedel
($vmid, $deviceid);
4424 qemu_devicedelverify
($vmid, $deviceid);
4425 qemu_netdevdel
($vmid, $deviceid);
4428 die "can't unplug device '$deviceid'\n";
4434 sub qemu_deviceadd
{
4435 my ($vmid, $devicefull) = @_;
4437 $devicefull = "driver=".$devicefull;
4438 my %options = split(/[=,]/, $devicefull);
4440 vm_mon_cmd
($vmid, "device_add" , %options);
4443 sub qemu_devicedel
{
4444 my ($vmid, $deviceid) = @_;
4446 my $ret = vm_mon_cmd
($vmid, "device_del", id
=> $deviceid);
4449 sub qemu_iothread_add
{
4450 my($vmid, $deviceid, $device) = @_;
4452 if ($device->{iothread
}) {
4453 my $iothreads = vm_iothreads_list
($vmid);
4454 qemu_objectadd
($vmid, "iothread-$deviceid", "iothread") if !$iothreads->{"iothread-$deviceid"};
4458 sub qemu_iothread_del
{
4459 my($conf, $vmid, $deviceid) = @_;
4461 my $confid = $deviceid;
4462 if ($deviceid =~ m/^(?:virtioscsi|scsihw)(\d+)$/) {
4463 $confid = 'scsi' . $1;
4465 my $device = parse_drive
($confid, $conf->{$confid});
4466 if ($device->{iothread
}) {
4467 my $iothreads = vm_iothreads_list
($vmid);
4468 qemu_objectdel
($vmid, "iothread-$deviceid") if $iothreads->{"iothread-$deviceid"};
4472 sub qemu_objectadd
{
4473 my($vmid, $objectid, $qomtype) = @_;
4475 vm_mon_cmd
($vmid, "object-add", id
=> $objectid, "qom-type" => $qomtype);
4480 sub qemu_objectdel
{
4481 my($vmid, $objectid) = @_;
4483 vm_mon_cmd
($vmid, "object-del", id
=> $objectid);
4489 my ($storecfg, $vmid, $device) = @_;
4491 my $drive = print_drive_full
($storecfg, $vmid, $device);
4492 $drive =~ s/\\/\\\\/g;
4493 my $ret = vm_human_monitor_command
($vmid, "drive_add auto \"$drive\"");
4495 # If the command succeeds qemu prints: "OK
"
4496 return 1 if $ret =~ m/OK/s;
4498 die "adding drive failed
: $ret\n";
4502 my($vmid, $deviceid) = @_;
4504 my $ret = vm_human_monitor_command($vmid, "drive_del drive-
$deviceid");
4507 return 1 if $ret eq "";
4509 # NB: device not found errors mean the drive was auto-deleted and we ignore the error
4510 return 1 if $ret =~ m/Device \'.*?\' not found/s;
4512 die "deleting drive
$deviceid failed
: $ret\n";
4515 sub qemu_deviceaddverify {
4516 my ($vmid, $deviceid) = @_;
4518 for (my $i = 0; $i <= 5; $i++) {
4519 my $devices_list = vm_devices_list($vmid);
4520 return 1 if defined($devices_list->{$deviceid});
4524 die "error on hotplug device
'$deviceid'\n";
4528 sub qemu_devicedelverify {
4529 my ($vmid, $deviceid) = @_;
4531 # need to verify that the device is correctly removed as device_del
4532 # is async and empty return is not reliable
4534 for (my $i = 0; $i <= 5; $i++) {
4535 my $devices_list = vm_devices_list($vmid);
4536 return 1 if !defined($devices_list->{$deviceid});
4540 die "error on hot-unplugging device
'$deviceid'\n";
4543 sub qemu_findorcreatescsihw {
4544 my ($storecfg, $conf, $vmid, $device, $arch, $machine_type) = @_;
4546 my ($maxdev, $controller, $controller_prefix) = scsihw_infos($conf, $device);
4548 my $scsihwid="$controller_prefix$controller";
4549 my $devices_list = vm_devices_list($vmid);
4551 if(!defined($devices_list->{$scsihwid})) {
4552 vm_deviceplug($storecfg, $conf, $vmid, $scsihwid, $device, $arch, $machine_type);
4558 sub qemu_deletescsihw {
4559 my ($conf, $vmid, $opt) = @_;
4561 my $device = parse_drive($opt, $conf->{$opt});
4563 if ($conf->{scsihw} && ($conf->{scsihw} eq 'virtio-scsi-single')) {
4564 vm_deviceunplug($vmid, $conf, "virtioscsi
$device->{index}");
4568 my ($maxdev, $controller, $controller_prefix) = scsihw_infos($conf, $device);
4570 my $devices_list = vm_devices_list($vmid);
4571 foreach my $opt (keys %{$devices_list}) {
4572 if (PVE::QemuServer::is_valid_drivename($opt)) {
4573 my $drive = PVE::QemuServer::parse_drive($opt, $conf->{$opt});
4574 if($drive->{interface} eq 'scsi' && $drive->{index} < (($maxdev-1)*($controller+1))) {
4580 my $scsihwid="scsihw
$controller";
4582 vm_deviceunplug($vmid, $conf, $scsihwid);
4587 sub qemu_add_pci_bridge {
4588 my ($storecfg, $conf, $vmid, $device, $arch, $machine_type) = @_;
4594 print_pci_addr($device, $bridges, $arch, $machine_type);
4596 while (my ($k, $v) = each %$bridges) {
4599 return 1 if !defined($bridgeid) || $bridgeid < 1;
4601 my $bridge = "pci
.$bridgeid";
4602 my $devices_list = vm_devices_list($vmid);
4604 if (!defined($devices_list->{$bridge})) {
4605 vm_deviceplug($storecfg, $conf, $vmid, $bridge, $arch, $machine_type);
4611 sub qemu_set_link_status {
4612 my ($vmid, $device, $up) = @_;
4614 vm_mon_cmd($vmid, "set_link
", name => $device,
4615 up => $up ? JSON::true : JSON::false);
4618 sub qemu_netdevadd {
4619 my ($vmid, $conf, $arch, $device, $deviceid) = @_;
4621 my $netdev = print_netdev_full($vmid, $conf, $arch, $device, $deviceid, 1);
4622 my %options = split(/[=,]/, $netdev);
4624 vm_mon_cmd($vmid, "netdev_add
", %options);
4628 sub qemu_netdevdel {
4629 my ($vmid, $deviceid) = @_;
4631 vm_mon_cmd($vmid, "netdev_del
", id => $deviceid);
4634 sub qemu_usb_hotplug {
4635 my ($storecfg, $conf, $vmid, $deviceid, $device, $arch, $machine_type) = @_;
4639 # remove the old one first
4640 vm_deviceunplug($vmid, $conf, $deviceid);
4642 # check if xhci controller is necessary and available
4643 if ($device->{usb3}) {
4645 my $devicelist = vm_devices_list($vmid);
4647 if (!$devicelist->{xhci}) {
4648 my $pciaddr = print_pci_addr("xhci
", undef, $arch, $machine_type);
4649 qemu_deviceadd($vmid, "nec-usb-xhci
,id
=xhci
$pciaddr");
4652 my $d = parse_usb_device($device->{host});
4653 $d->{usb3} = $device->{usb3};
4656 vm_deviceplug($storecfg, $conf, $vmid, $deviceid, $d, $arch, $machine_type);
4659 sub qemu_cpu_hotplug {
4660 my ($vmid, $conf, $vcpus) = @_;
4662 my $machine_type = PVE::QemuServer::get_current_qemu_machine($vmid);
4665 $sockets = $conf->{smp} if $conf->{smp}; # old style - no longer iused
4666 $sockets = $conf->{sockets} if $conf->{sockets};
4667 my $cores = $conf->{cores} || 1;
4668 my $maxcpus = $sockets * $cores;
4670 $vcpus = $maxcpus if !$vcpus;
4672 die "you can
't add more vcpus than maxcpus\n"
4673 if $vcpus > $maxcpus;
4675 my $currentvcpus = $conf->{vcpus} || $maxcpus;
4677 if ($vcpus < $currentvcpus) {
4679 if (qemu_machine_feature_enabled ($machine_type, undef, 2, 7)) {
4681 for (my $i = $currentvcpus; $i > $vcpus; $i--) {
4682 qemu_devicedel($vmid, "cpu$i");
4684 my $currentrunningvcpus = undef;
4686 $currentrunningvcpus = vm_mon_cmd($vmid, "query-cpus");
4687 last if scalar(@{$currentrunningvcpus}) == $i-1;
4688 raise_param_exc({ vcpus => "error unplugging cpu$i" }) if $retry > 5;
4692 #update conf after each succesfull cpu unplug
4693 $conf->{vcpus} = scalar(@{$currentrunningvcpus});
4694 PVE::QemuConfig->write_config($vmid, $conf);
4697 die "cpu hot-unplugging requires qemu version 2.7 or higher\n";
4703 my $currentrunningvcpus = vm_mon_cmd($vmid, "query-cpus");
4704 die "vcpus in running vm does not match its configuration\n"
4705 if scalar(@{$currentrunningvcpus}) != $currentvcpus;
4707 if (qemu_machine_feature_enabled ($machine_type, undef, 2, 7)) {
4709 for (my $i = $currentvcpus+1; $i <= $vcpus; $i++) {
4710 my $cpustr = print_cpu_device($conf, $i);
4711 qemu_deviceadd($vmid, $cpustr);
4714 my $currentrunningvcpus = undef;
4716 $currentrunningvcpus = vm_mon_cmd($vmid, "query-cpus");
4717 last if scalar(@{$currentrunningvcpus}) == $i;
4718 raise_param_exc({ vcpus => "error hotplugging cpu$i" }) if $retry > 10;
4722 #update conf after each succesfull cpu hotplug
4723 $conf->{vcpus} = scalar(@{$currentrunningvcpus});
4724 PVE::QemuConfig->write_config($vmid, $conf);
4728 for (my $i = $currentvcpus; $i < $vcpus; $i++) {
4729 vm_mon_cmd($vmid, "cpu-add", id => int($i));
4734 sub qemu_block_set_io_throttle {
4735 my ($vmid, $deviceid,
4736 $bps, $bps_rd, $bps_wr, $iops, $iops_rd, $iops_wr,
4737 $bps_max, $bps_rd_max, $bps_wr_max, $iops_max, $iops_rd_max, $iops_wr_max,
4738 $bps_max_length, $bps_rd_max_length, $bps_wr_max_length,
4739 $iops_max_length, $iops_rd_max_length, $iops_wr_max_length) = @_;
4741 return if !check_running($vmid) ;
4743 vm_mon_cmd($vmid, "block_set_io_throttle", device => $deviceid,
4745 bps_rd => int($bps_rd),
4746 bps_wr => int($bps_wr),
4748 iops_rd => int($iops_rd),
4749 iops_wr => int($iops_wr),
4750 bps_max => int($bps_max),
4751 bps_rd_max => int($bps_rd_max),
4752 bps_wr_max => int($bps_wr_max),
4753 iops_max => int($iops_max),
4754 iops_rd_max => int($iops_rd_max),
4755 iops_wr_max => int($iops_wr_max),
4756 bps_max_length => int($bps_max_length),
4757 bps_rd_max_length => int($bps_rd_max_length),
4758 bps_wr_max_length => int($bps_wr_max_length),
4759 iops_max_length => int($iops_max_length),
4760 iops_rd_max_length => int($iops_rd_max_length),
4761 iops_wr_max_length => int($iops_wr_max_length),
4766 # old code, only used to shutdown old VM after update
4768 my ($fh, $timeout) = @_;
4770 my $sel = new IO::Select;
4777 while (scalar (@ready = $sel->can_read($timeout))) {
4779 if ($count = $fh->sysread($buf, 8192)) {
4780 if ($buf =~ /^(.*)\(qemu\) $/s) {
4787 if (!defined($count)) {
4794 die "monitor read timeout\n" if !scalar(@ready);
4799 sub qemu_block_resize {
4800 my ($vmid, $deviceid, $storecfg, $volid, $size) = @_;
4802 my $running = check_running($vmid);
4804 $size = 0 if !PVE::Storage::volume_resize($storecfg, $volid, $size, $running);
4806 return if !$running;
4808 vm_mon_cmd($vmid, "block_resize", device => $deviceid, size => int($size));
4812 sub qemu_volume_snapshot {
4813 my ($vmid, $deviceid, $storecfg, $volid, $snap) = @_;
4815 my $running = check_running($vmid);
4817 if ($running && do_snapshots_with_qemu($storecfg, $volid)){
4818 vm_mon_cmd($vmid, 'blockdev-snapshot-internal-sync
', device => $deviceid, name => $snap);
4820 PVE::Storage::volume_snapshot($storecfg, $volid, $snap);
4824 sub qemu_volume_snapshot_delete {
4825 my ($vmid, $deviceid, $storecfg, $volid, $snap) = @_;
4827 my $running = check_running($vmid);
4832 my $conf = PVE::QemuConfig->load_config($vmid);
4833 foreach_drive($conf, sub {
4834 my ($ds, $drive) = @_;
4835 $running = 1 if $drive->{file} eq $volid;
4839 if ($running && do_snapshots_with_qemu($storecfg, $volid)){
4840 vm_mon_cmd($vmid, 'blockdev-snapshot-delete-internal-sync
', device => $deviceid, name => $snap);
4842 PVE::Storage::volume_snapshot_delete($storecfg, $volid, $snap, $running);
4846 sub set_migration_caps {
4852 "auto-converge" => 1,
4854 "x-rdma-pin-all" => 0,
4859 my $supported_capabilities = vm_mon_cmd_nocheck($vmid, "query-migrate-capabilities");
4861 for my $supported_capability (@$supported_capabilities) {
4863 capability => $supported_capability->{capability},
4864 state => $enabled_cap->{$supported_capability->{capability}} ? JSON::true : JSON::false,
4868 vm_mon_cmd_nocheck($vmid, "migrate-set-capabilities", capabilities => $cap_ref);
4871 my $fast_plug_option = {
4879 'vmstatestorage
' => 1,
4883 # hotplug changes in [PENDING]
4884 # $selection hash can be used to only apply specified options, for
4885 # example: { cores => 1 } (only apply changed 'cores
')
4886 # $errors ref is used to return error messages
4887 sub vmconfig_hotplug_pending {
4888 my ($vmid, $conf, $storecfg, $selection, $errors) = @_;
4890 my $defaults = load_defaults();
4891 my ($arch, $machine_type) = get_basic_machine_info($conf, undef);
4893 # commit values which do not have any impact on running VM first
4894 # Note: those option cannot raise errors, we we do not care about
4895 # $selection and always apply them.
4897 my $add_error = sub {
4898 my ($opt, $msg) = @_;
4899 $errors->{$opt} = "hotplug problem - $msg";
4903 foreach my $opt (keys %{$conf->{pending}}) { # add/change
4904 if ($fast_plug_option->{$opt}) {
4905 $conf->{$opt} = $conf->{pending}->{$opt};
4906 delete $conf->{pending}->{$opt};
4912 PVE::QemuConfig->write_config($vmid, $conf);
4913 $conf = PVE::QemuConfig->load_config($vmid); # update/reload
4916 my $hotplug_features = parse_hotplug_features(defined($conf->{hotplug}) ? $conf->{hotplug} : '1');
4918 my $pending_delete_hash = split_flagged_list($conf->{pending}->{delete});
4919 while (my ($opt, $force) = each %$pending_delete_hash) {
4920 next if $selection && !$selection->{$opt};
4922 if ($opt eq 'hotplug
') {
4923 die "skip\n" if ($conf->{hotplug} =~ /memory/);
4924 } elsif ($opt eq 'tablet
') {
4925 die "skip\n" if !$hotplug_features->{usb};
4926 if ($defaults->{tablet}) {
4927 vm_deviceplug($storecfg, $conf, $vmid, 'tablet
', $arch, $machine_type);
4928 vm_deviceplug($storecfg, $conf, $vmid, 'keyboard
', $arch, $machine_type)
4929 if $arch eq 'aarch64
';
4931 vm_deviceunplug($vmid, $conf, 'tablet
');
4932 vm_deviceunplug($vmid, $conf, 'keyboard
') if $arch eq 'aarch64
';
4934 } elsif ($opt =~ m/^usb\d+/) {
4936 # since we cannot reliably hot unplug usb devices
4937 # we are disabling it
4938 die "skip\n" if !$hotplug_features->{usb} || $conf->{$opt} =~ m/spice/i;
4939 vm_deviceunplug($vmid, $conf, $opt);
4940 } elsif ($opt eq 'vcpus
') {
4941 die "skip\n" if !$hotplug_features->{cpu};
4942 qemu_cpu_hotplug($vmid, $conf, undef);
4943 } elsif ($opt eq 'balloon
') {
4944 # enable balloon device is not hotpluggable
4945 die "skip\n" if defined($conf->{balloon}) && $conf->{balloon} == 0;
4946 # here we reset the ballooning value to memory
4947 my $balloon = $conf->{memory} || $defaults->{memory};
4948 vm_mon_cmd($vmid, "balloon", value => $balloon*1024*1024);
4949 } elsif ($fast_plug_option->{$opt}) {
4951 } elsif ($opt =~ m/^net(\d+)$/) {
4952 die "skip\n" if !$hotplug_features->{network};
4953 vm_deviceunplug($vmid, $conf, $opt);
4954 } elsif (is_valid_drivename($opt)) {
4955 die "skip\n" if !$hotplug_features->{disk} || $opt =~ m/(ide|sata)(\d+)/;
4956 vm_deviceunplug($vmid, $conf, $opt);
4957 vmconfig_delete_or_detach_drive($vmid, $storecfg, $conf, $opt, $force);
4958 } elsif ($opt =~ m/^memory$/) {
4959 die "skip\n" if !$hotplug_features->{memory};
4960 PVE::QemuServer::Memory::qemu_memory_hotplug($vmid, $conf, $defaults, $opt);
4961 } elsif ($opt eq 'cpuunits
') {
4962 cgroups_write("cpu", $vmid, "cpu.shares", $defaults->{cpuunits});
4963 } elsif ($opt eq 'cpulimit
') {
4964 cgroups_write("cpu", $vmid, "cpu.cfs_quota_us", -1);
4970 &$add_error($opt, $err) if $err ne "skip\n";
4972 # save new config if hotplug was successful
4973 delete $conf->{$opt};
4974 vmconfig_undelete_pending_option($conf, $opt);
4975 PVE::QemuConfig->write_config($vmid, $conf);
4976 $conf = PVE::QemuConfig->load_config($vmid); # update/reload
4980 my $apply_pending_cloudinit;
4981 $apply_pending_cloudinit = sub {
4982 my ($key, $value) = @_;
4983 $apply_pending_cloudinit = sub {}; # once is enough
4985 my @cloudinit_opts = keys %$confdesc_cloudinit;
4986 foreach my $opt (keys %{$conf->{pending}}) {
4987 next if !grep { $_ eq $opt } @cloudinit_opts;
4988 $conf->{$opt} = delete $conf->{pending}->{$opt};
4991 my $new_conf = { %$conf };
4992 $new_conf->{$key} = $value;
4993 PVE::QemuServer::Cloudinit::generate_cloudinitconfig($new_conf, $vmid);
4996 foreach my $opt (keys %{$conf->{pending}}) {
4997 next if $selection && !$selection->{$opt};
4998 my $value = $conf->{pending}->{$opt};
5000 if ($opt eq 'hotplug
') {
5001 die "skip\n" if ($value =~ /memory/) || ($value !~ /memory/ && $conf->{hotplug} =~ /memory/);
5002 } elsif ($opt eq 'tablet
') {
5003 die "skip\n" if !$hotplug_features->{usb};
5005 vm_deviceplug($storecfg, $conf, $vmid, 'tablet
', $arch, $machine_type);
5006 vm_deviceplug($storecfg, $conf, $vmid, 'keyboard
', $arch, $machine_type)
5007 if $arch eq 'aarch64
';
5008 } elsif ($value == 0) {
5009 vm_deviceunplug($vmid, $conf, 'tablet
');
5010 vm_deviceunplug($vmid, $conf, 'keyboard
') if $arch eq 'aarch64
';
5012 } elsif ($opt =~ m/^usb\d+$/) {
5014 # since we cannot reliably hot unplug usb devices
5015 # we are disabling it
5016 die "skip\n" if !$hotplug_features->{usb} || $value =~ m/spice/i;
5017 my $d = eval { PVE::JSONSchema::parse_property_string($usbdesc->{format}, $value) };
5018 die "skip\n" if !$d;
5019 qemu_usb_hotplug($storecfg, $conf, $vmid, $opt, $d, $arch, $machine_type);
5020 } elsif ($opt eq 'vcpus
') {
5021 die "skip\n" if !$hotplug_features->{cpu};
5022 qemu_cpu_hotplug($vmid, $conf, $value);
5023 } elsif ($opt eq 'balloon
') {
5024 # enable/disable balloning device is not hotpluggable
5025 my $old_balloon_enabled = !!(!defined($conf->{balloon}) || $conf->{balloon});
5026 my $new_balloon_enabled = !!(!defined($conf->{pending}->{balloon}) || $conf->{pending}->{balloon});
5027 die "skip\n" if $old_balloon_enabled != $new_balloon_enabled;
5029 # allow manual ballooning if shares is set to zero
5030 if ((defined($conf->{shares}) && ($conf->{shares} == 0))) {
5031 my $balloon = $conf->{pending}->{balloon} || $conf->{memory} || $defaults->{memory};
5032 vm_mon_cmd($vmid, "balloon", value => $balloon*1024*1024);
5034 } elsif ($opt =~ m/^net(\d+)$/) {
5035 # some changes can be done without hotplug
5036 vmconfig_update_net($storecfg, $conf, $hotplug_features->{network},
5037 $vmid, $opt, $value, $arch, $machine_type);
5038 } elsif (is_valid_drivename($opt)) {
5039 # some changes can be done without hotplug
5040 my $drive = parse_drive($opt, $value);
5041 if (drive_is_cloudinit($drive)) {
5042 &$apply_pending_cloudinit($opt, $value);
5044 vmconfig_update_disk($storecfg, $conf, $hotplug_features->{disk},
5045 $vmid, $opt, $value, 1, $arch, $machine_type);
5046 } elsif ($opt =~ m/^memory$/) { #dimms
5047 die "skip\n" if !$hotplug_features->{memory};
5048 $value = PVE::QemuServer::Memory::qemu_memory_hotplug($vmid, $conf, $defaults, $opt, $value);
5049 } elsif ($opt eq 'cpuunits
') {
5050 cgroups_write("cpu", $vmid, "cpu.shares", $conf->{pending}->{$opt});
5051 } elsif ($opt eq 'cpulimit
') {
5052 my $cpulimit = $conf->{pending}->{$opt} == 0 ? -1 : int($conf->{pending}->{$opt} * 100000);
5053 cgroups_write("cpu", $vmid, "cpu.cfs_quota_us", $cpulimit);
5055 die "skip\n"; # skip non-hot-pluggable options
5059 &$add_error($opt, $err) if $err ne "skip\n";
5061 # save new config if hotplug was successful
5062 $conf->{$opt} = $value;
5063 delete $conf->{pending}->{$opt};
5064 PVE::QemuConfig->write_config($vmid, $conf);
5065 $conf = PVE::QemuConfig->load_config($vmid); # update/reload
5070 sub try_deallocate_drive {
5071 my ($storecfg, $vmid, $conf, $key, $drive, $rpcenv, $authuser, $force) = @_;
5073 if (($force || $key =~ /^unused/) && !drive_is_cdrom($drive, 1)) {
5074 my $volid = $drive->{file};
5075 if (vm_is_volid_owner($storecfg, $vmid, $volid)) {
5076 my $sid = PVE::Storage::parse_volume_id($volid);
5077 $rpcenv->check($authuser, "/storage/$sid", ['Datastore
.AllocateSpace
']);
5079 # check if the disk is really unused
5080 die "unable to delete '$volid' - volume is still in use (snapshot?)\n"
5081 if is_volume_in_use($storecfg, $conf, $key, $volid);
5082 PVE::Storage::vdisk_free($storecfg, $volid);
5085 # If vm is not owner of this disk remove from config
5093 sub vmconfig_delete_or_detach_drive {
5094 my ($vmid, $storecfg, $conf, $opt, $force) = @_;
5096 my $drive = parse_drive($opt, $conf->{$opt});
5098 my $rpcenv = PVE::RPCEnvironment::get();
5099 my $authuser = $rpcenv->get_user();
5102 $rpcenv->check_vm_perm($authuser, $vmid, undef, ['VM
.Config
.Disk
']);
5103 try_deallocate_drive($storecfg, $vmid, $conf, $opt, $drive, $rpcenv, $authuser, $force);
5105 vmconfig_register_unused_drive($storecfg, $vmid, $conf, $drive);
5109 sub vmconfig_apply_pending {
5110 my ($vmid, $conf, $storecfg) = @_;
5114 my $pending_delete_hash = split_flagged_list($conf->{pending}->{delete});
5115 while (my ($opt, $force) = each %$pending_delete_hash) {
5116 die "internal error" if $opt =~ m/^unused/;
5117 $conf = PVE::QemuConfig->load_config($vmid); # update/reload
5118 if (!defined($conf->{$opt})) {
5119 vmconfig_undelete_pending_option($conf, $opt);
5120 PVE::QemuConfig->write_config($vmid, $conf);
5121 } elsif (is_valid_drivename($opt)) {
5122 vmconfig_delete_or_detach_drive($vmid, $storecfg, $conf, $opt, $force);
5123 vmconfig_undelete_pending_option($conf, $opt);
5124 delete $conf->{$opt};
5125 PVE::QemuConfig->write_config($vmid, $conf);
5127 vmconfig_undelete_pending_option($conf, $opt);
5128 delete $conf->{$opt};
5129 PVE::QemuConfig->write_config($vmid, $conf);
5133 $conf = PVE::QemuConfig->load_config($vmid); # update/reload
5135 foreach my $opt (keys %{$conf->{pending}}) { # add/change
5136 $conf = PVE::QemuConfig->load_config($vmid); # update/reload
5138 if (defined($conf->{$opt}) && ($conf->{$opt} eq $conf->{pending}->{$opt})) {
5139 # skip if nothing changed
5140 } elsif (is_valid_drivename($opt)) {
5141 vmconfig_register_unused_drive($storecfg, $vmid, $conf, parse_drive($opt, $conf->{$opt}))
5142 if defined($conf->{$opt});
5143 $conf->{$opt} = $conf->{pending}->{$opt};
5145 $conf->{$opt} = $conf->{pending}->{$opt};
5148 delete $conf->{pending}->{$opt};
5149 PVE::QemuConfig->write_config($vmid, $conf);
5153 my $safe_num_ne = sub {
5156 return 0 if !defined($a) && !defined($b);
5157 return 1 if !defined($a);
5158 return 1 if !defined($b);
5163 my $safe_string_ne = sub {
5166 return 0 if !defined($a) && !defined($b);
5167 return 1 if !defined($a);
5168 return 1 if !defined($b);
5173 sub vmconfig_update_net {
5174 my ($storecfg, $conf, $hotplug, $vmid, $opt, $value, $arch, $machine_type) = @_;
5176 my $newnet = parse_net($value);
5178 if ($conf->{$opt}) {
5179 my $oldnet = parse_net($conf->{$opt});
5181 if (&$safe_string_ne($oldnet->{model}, $newnet->{model}) ||
5182 &$safe_string_ne($oldnet->{macaddr}, $newnet->{macaddr}) ||
5183 &$safe_num_ne($oldnet->{queues}, $newnet->{queues}) ||
5184 !($newnet->{bridge} && $oldnet->{bridge})) { # bridge/nat mode change
5186 # for non online change, we try to hot-unplug
5187 die "skip\n" if !$hotplug;
5188 vm_deviceunplug($vmid, $conf, $opt);
5191 die "internal error" if $opt !~ m/net(\d+)/;
5192 my $iface = "tap${vmid}i$1";
5194 if (&$safe_string_ne($oldnet->{bridge}, $newnet->{bridge}) ||
5195 &$safe_num_ne($oldnet->{tag}, $newnet->{tag}) ||
5196 &$safe_string_ne($oldnet->{trunks}, $newnet->{trunks}) ||
5197 &$safe_num_ne($oldnet->{firewall}, $newnet->{firewall})) {
5198 PVE::Network::tap_unplug($iface);
5199 PVE::Network::tap_plug($iface, $newnet->{bridge}, $newnet->{tag}, $newnet->{firewall}, $newnet->{trunks}, $newnet->{rate});
5200 } elsif (&$safe_num_ne($oldnet->{rate}, $newnet->{rate})) {
5201 # Rate can be applied on its own but any change above needs to
5202 # include the rate in tap_plug since OVS resets everything.
5203 PVE::Network::tap_rate_limit($iface, $newnet->{rate});
5206 if (&$safe_string_ne($oldnet->{link_down}, $newnet->{link_down})) {
5207 qemu_set_link_status($vmid, $opt, !$newnet->{link_down});
5215 vm_deviceplug($storecfg, $conf, $vmid, $opt, $newnet, $arch, $machine_type);
5221 sub vmconfig_update_disk {
5222 my ($storecfg, $conf, $hotplug, $vmid, $opt, $value, $force, $arch, $machine_type) = @_;
5224 # fixme: do we need force?
5226 my $drive = parse_drive($opt, $value);
5228 if ($conf->{$opt}) {
5230 if (my $old_drive = parse_drive($opt, $conf->{$opt})) {
5232 my $media = $drive->{media} || 'disk
';
5233 my $oldmedia = $old_drive->{media} || 'disk
';
5234 die "unable to change media type\n" if $media ne $oldmedia;
5236 if (!drive_is_cdrom($old_drive)) {
5238 if ($drive->{file} ne $old_drive->{file}) {
5240 die "skip\n" if !$hotplug;
5242 # unplug and register as unused
5243 vm_deviceunplug($vmid, $conf, $opt);
5244 vmconfig_register_unused_drive($storecfg, $vmid, $conf, $old_drive)
5247 # update existing disk
5249 # skip non hotpluggable value
5250 if (&$safe_string_ne($drive->{discard}, $old_drive->{discard}) ||
5251 &$safe_string_ne($drive->{iothread}, $old_drive->{iothread}) ||
5252 &$safe_string_ne($drive->{queues}, $old_drive->{queues}) ||
5253 &$safe_string_ne($drive->{cache}, $old_drive->{cache})) {
5258 if (&$safe_num_ne($drive->{mbps}, $old_drive->{mbps}) ||
5259 &$safe_num_ne($drive->{mbps_rd}, $old_drive->{mbps_rd}) ||
5260 &$safe_num_ne($drive->{mbps_wr}, $old_drive->{mbps_wr}) ||
5261 &$safe_num_ne($drive->{iops}, $old_drive->{iops}) ||
5262 &$safe_num_ne($drive->{iops_rd}, $old_drive->{iops_rd}) ||
5263 &$safe_num_ne($drive->{iops_wr}, $old_drive->{iops_wr}) ||
5264 &$safe_num_ne($drive->{mbps_max}, $old_drive->{mbps_max}) ||
5265 &$safe_num_ne($drive->{mbps_rd_max}, $old_drive->{mbps_rd_max}) ||
5266 &$safe_num_ne($drive->{mbps_wr_max}, $old_drive->{mbps_wr_max}) ||
5267 &$safe_num_ne($drive->{iops_max}, $old_drive->{iops_max}) ||
5268 &$safe_num_ne($drive->{iops_rd_max}, $old_drive->{iops_rd_max}) ||
5269 &$safe_num_ne($drive->{iops_wr_max}, $old_drive->{iops_wr_max}) ||
5270 &$safe_num_ne($drive->{bps_max_length}, $old_drive->{bps_max_length}) ||
5271 &$safe_num_ne($drive->{bps_rd_max_length}, $old_drive->{bps_rd_max_length}) ||
5272 &$safe_num_ne($drive->{bps_wr_max_length}, $old_drive->{bps_wr_max_length}) ||
5273 &$safe_num_ne($drive->{iops_max_length}, $old_drive->{iops_max_length}) ||
5274 &$safe_num_ne($drive->{iops_rd_max_length}, $old_drive->{iops_rd_max_length}) ||
5275 &$safe_num_ne($drive->{iops_wr_max_length}, $old_drive->{iops_wr_max_length})) {
5277 qemu_block_set_io_throttle($vmid,"drive-$opt",
5278 ($drive->{mbps} || 0)*1024*1024,
5279 ($drive->{mbps_rd} || 0)*1024*1024,
5280 ($drive->{mbps_wr} || 0)*1024*1024,
5281 $drive->{iops} || 0,
5282 $drive->{iops_rd} || 0,
5283 $drive->{iops_wr} || 0,
5284 ($drive->{mbps_max} || 0)*1024*1024,
5285 ($drive->{mbps_rd_max} || 0)*1024*1024,
5286 ($drive->{mbps_wr_max} || 0)*1024*1024,
5287 $drive->{iops_max} || 0,
5288 $drive->{iops_rd_max} || 0,
5289 $drive->{iops_wr_max} || 0,
5290 $drive->{bps_max_length} || 1,
5291 $drive->{bps_rd_max_length} || 1,
5292 $drive->{bps_wr_max_length} || 1,
5293 $drive->{iops_max_length} || 1,
5294 $drive->{iops_rd_max_length} || 1,
5295 $drive->{iops_wr_max_length} || 1);
5304 if ($drive->{file} eq 'none
') {
5305 vm_mon_cmd($vmid, "eject",force => JSON::true,device => "drive-$opt");
5306 if (drive_is_cloudinit($old_drive)) {
5307 vmconfig_register_unused_drive($storecfg, $vmid, $conf, $old_drive);
5310 my $path = get_iso_path($storecfg, $vmid, $drive->{file});
5311 vm_mon_cmd($vmid, "eject", force => JSON::true,device => "drive-$opt"); # force eject if locked
5312 vm_mon_cmd($vmid, "change", device => "drive-$opt",target => "$path") if $path;
5320 die "skip\n" if !$hotplug || $opt =~ m/(ide|sata)(\d+)/;
5322 PVE::Storage::activate_volumes($storecfg, [$drive->{file}]) if $drive->{file} !~ m|^/dev/.+|;
5323 vm_deviceplug($storecfg, $conf, $vmid, $opt, $drive, $arch, $machine_type);
5327 my ($storecfg, $vmid, $statefile, $skiplock, $migratedfrom, $paused,
5328 $forcemachine, $spice_ticket, $migration_network, $migration_type, $targetstorage) = @_;
5330 PVE::QemuConfig->lock_config($vmid, sub {
5331 my $conf = PVE::QemuConfig->load_config($vmid, $migratedfrom);
5333 die "you can't start a vm
if it
's a template\n" if PVE::QemuConfig->is_template($conf);
5335 my $is_suspended = PVE::QemuConfig->has_lock($conf, 'suspended
');
5337 PVE::QemuConfig->check_lock($conf)
5338 if !($skiplock || $is_suspended);
5340 die "VM $vmid already running\n" if check_running($vmid, undef, $migratedfrom);
5342 if (!$statefile && scalar(keys %{$conf->{pending}})) {
5343 vmconfig_apply_pending($vmid, $conf, $storecfg);
5344 $conf = PVE::QemuConfig->load_config($vmid); # update/reload
5347 PVE::QemuServer::Cloudinit::generate_cloudinitconfig($conf, $vmid);
5349 my $defaults = load_defaults();
5351 # set environment variable useful inside network script
5352 $ENV{PVE_MIGRATED_FROM} = $migratedfrom if $migratedfrom;
5354 my $local_volumes = {};
5356 if ($targetstorage) {
5357 foreach_drive($conf, sub {
5358 my ($ds, $drive) = @_;
5360 return if drive_is_cdrom($drive);
5362 my $volid = $drive->{file};
5366 my ($storeid, $volname) = PVE::Storage::parse_volume_id($volid);
5368 my $scfg = PVE::Storage::storage_config($storecfg, $storeid);
5369 return if $scfg->{shared};
5370 $local_volumes->{$ds} = [$volid, $storeid, $volname];
5375 foreach my $opt (sort keys %$local_volumes) {
5377 my ($volid, $storeid, $volname) = @{$local_volumes->{$opt}};
5378 my $drive = parse_drive($opt, $conf->{$opt});
5380 #if remote storage is specified, use default format
5381 if ($targetstorage && $targetstorage ne "1") {
5382 $storeid = $targetstorage;
5383 my ($defFormat, $validFormats) = PVE::Storage::storage_default_format($storecfg, $storeid);
5384 $format = $defFormat;
5386 #else we use same format than original
5387 my $scfg = PVE::Storage::storage_config($storecfg, $storeid);
5388 $format = qemu_img_format($scfg, $volid);
5391 my $newvolid = PVE::Storage::vdisk_alloc($storecfg, $storeid, $vmid, $format, undef, ($drive->{size}/1024));
5392 my $newdrive = $drive;
5393 $newdrive->{format} = $format;
5394 $newdrive->{file} = $newvolid;
5395 my $drivestr = PVE::QemuServer::print_drive($vmid, $newdrive);
5396 $local_volumes->{$opt} = $drivestr;
5397 #pass drive to conf for command line
5398 $conf->{$opt} = $drivestr;
5402 PVE::GuestHelpers::exec_hookscript($conf, $vmid, 'pre-start
', 1);
5404 if ($is_suspended) {
5405 # enforce machine type on suspended vm to ensure HW compatibility
5406 $forcemachine = $conf->{runningmachine};
5407 print "Resuming suspended VM\n";
5410 my ($cmd, $vollist, $spice_port) = config_to_command($storecfg, $vmid, $conf, $defaults, $forcemachine);
5412 my $migrate_port = 0;
5415 if ($statefile eq 'tcp
') {
5416 my $localip = "localhost";
5417 my $datacenterconf = PVE::Cluster::cfs_read_file('datacenter
.cfg
');
5418 my $nodename = PVE::INotify::nodename();
5420 if (!defined($migration_type)) {
5421 if (defined($datacenterconf->{migration}->{type})) {
5422 $migration_type = $datacenterconf->{migration}->{type};
5424 $migration_type = 'secure
';
5428 if ($migration_type eq 'insecure
') {
5429 my $migrate_network_addr = PVE::Cluster::get_local_migration_ip($migration_network);
5430 if ($migrate_network_addr) {
5431 $localip = $migrate_network_addr;
5433 $localip = PVE::Cluster::remote_node_ip($nodename, 1);
5436 $localip = "[$localip]" if Net::IP::ip_is_ipv6($localip);
5439 my $pfamily = PVE::Tools::get_host_address_family($nodename);
5440 $migrate_port = PVE::Tools::next_migrate_port($pfamily);
5441 $migrate_uri = "tcp:${localip}:${migrate_port}";
5442 push @$cmd, '-incoming
', $migrate_uri;
5445 } elsif ($statefile eq 'unix
') {
5446 # should be default for secure migrations as a ssh TCP forward
5447 # tunnel is not deterministic reliable ready and fails regurarly
5448 # to set up in time, so use UNIX socket forwards
5449 my $socket_addr = "/run/qemu-server/$vmid.migrate";
5450 unlink $socket_addr;
5452 $migrate_uri = "unix:$socket_addr";
5454 push @$cmd, '-incoming
', $migrate_uri;
5458 push @$cmd, '-loadstate
', $statefile;
5465 for (my $i = 0; $i < $MAX_HOSTPCI_DEVICES; $i++) {
5466 my $d = parse_hostpci($conf->{"hostpci$i"});
5468 my $pcidevices = $d->{pciid};
5469 foreach my $pcidevice (@$pcidevices) {
5470 my $pciid = $pcidevice->{id};
5472 my $info = PVE::SysFSTools::pci_device_info("0000:$pciid");
5473 die "IOMMU not present\n" if !PVE::SysFSTools::check_iommu_support();
5474 die "no pci device info for device '$pciid'\n" if !$info;
5477 my $uuid = PVE::SysFSTools::generate_mdev_uuid($vmid, $i);
5478 PVE::SysFSTools::pci_create_mdev_device($pciid, $uuid, $d->{mdev});
5480 die "can't unbind
/bind pci group to vfio
'$pciid'\n"
5481 if !PVE::SysFSTools::pci_dev_group_bind_to_vfio($pciid);
5482 die "can
't reset pci device '$pciid'\n"
5483 if $info->{has_fl_reset} and !PVE::SysFSTools::pci_dev_reset($info);
5488 PVE::Storage::activate_volumes($storecfg, $vollist);
5491 run_command(['/bin/systemctl
', 'stop
', "$vmid.scope"],
5492 outfunc => sub {}, errfunc => sub {});
5494 # Issues with the above 'stop
' not being fully completed are extremely rare, a very low
5495 # timeout should be more than enough here...
5496 PVE::Systemd::wait_for_unit_removed("$vmid.scope", 5);
5498 my $cpuunits = defined($conf->{cpuunits}) ? $conf->{cpuunits}
5499 : $defaults->{cpuunits};
5501 my $start_timeout = ($conf->{hugepages} || $is_suspended) ? 300 : 30;
5502 my %run_params = (timeout => $statefile ? undef : $start_timeout, umask => 0077);
5505 Slice => 'qemu
.slice
',
5507 CPUShares => $cpuunits
5510 if (my $cpulimit = $conf->{cpulimit}) {
5511 $properties{CPUQuota} = int($cpulimit * 100);
5513 $properties{timeout} = 10 if $statefile; # setting up the scope shoul be quick
5515 my $run_qemu = sub {
5516 PVE::Tools::run_fork sub {
5517 PVE::Systemd::enter_systemd_scope($vmid, "Proxmox VE VM $vmid", %properties);
5518 run_command($cmd, %run_params);
5522 if ($conf->{hugepages}) {
5525 my $hugepages_topology = PVE::QemuServer::Memory::hugepages_topology($conf);
5526 my $hugepages_host_topology = PVE::QemuServer::Memory::hugepages_host_topology();
5528 PVE::QemuServer::Memory::hugepages_mount();
5529 PVE::QemuServer::Memory::hugepages_allocate($hugepages_topology, $hugepages_host_topology);
5531 eval { $run_qemu->() };
5533 PVE::QemuServer::Memory::hugepages_reset($hugepages_host_topology);
5537 PVE::QemuServer::Memory::hugepages_pre_deallocate($hugepages_topology);
5539 eval { PVE::QemuServer::Memory::hugepages_update_locked($code); };
5542 eval { $run_qemu->() };
5546 # deactivate volumes if start fails
5547 eval { PVE::Storage::deactivate_volumes($storecfg, $vollist); };
5548 die "start failed: $err";
5551 print "migration listens on $migrate_uri\n" if $migrate_uri;
5553 if ($statefile && $statefile ne 'tcp
' && $statefile ne 'unix
') {
5554 eval { vm_mon_cmd_nocheck($vmid, "cont"); };
5558 #start nbd server for storage migration
5559 if ($targetstorage) {
5560 my $nodename = PVE::INotify::nodename();
5561 my $migrate_network_addr = PVE::Cluster::get_local_migration_ip($migration_network);
5562 my $localip = $migrate_network_addr ? $migrate_network_addr : PVE::Cluster::remote_node_ip($nodename, 1);
5563 my $pfamily = PVE::Tools::get_host_address_family($nodename);
5564 $migrate_port = PVE::Tools::next_migrate_port($pfamily);
5566 vm_mon_cmd_nocheck($vmid, "nbd-server-start", addr => { type => 'inet
', data => { host => "${localip}", port => "${migrate_port}" } } );
5568 $localip = "[$localip]" if Net::IP::ip_is_ipv6($localip);
5570 foreach my $opt (sort keys %$local_volumes) {
5571 my $volid = $local_volumes->{$opt};
5572 vm_mon_cmd_nocheck($vmid, "nbd-server-add", device => "drive-$opt", writable => JSON::true );
5573 my $migrate_storage_uri = "nbd:${localip}:${migrate_port}:exportname=drive-$opt";
5574 print "storage migration listens on $migrate_storage_uri volume:$volid\n";
5578 if ($migratedfrom) {
5580 set_migration_caps($vmid);
5585 print "spice listens on port $spice_port\n";
5586 if ($spice_ticket) {
5587 vm_mon_cmd_nocheck($vmid, "set_password", protocol => 'spice
', password => $spice_ticket);
5588 vm_mon_cmd_nocheck($vmid, "expire_password", protocol => 'spice
', time => "+30");
5593 vm_mon_cmd_nocheck($vmid, "balloon", value => $conf->{balloon}*1024*1024)
5594 if !$statefile && $conf->{balloon};
5596 foreach my $opt (keys %$conf) {
5597 next if $opt !~ m/^net\d+$/;
5598 my $nicconf = parse_net($conf->{$opt});
5599 qemu_set_link_status($vmid, $opt, 0) if $nicconf->{link_down};
5603 vm_mon_cmd_nocheck($vmid, 'qom-set
',
5604 path => "machine/peripheral/balloon0",
5605 property => "guest-stats-polling-interval",
5606 value => 2) if (!defined($conf->{balloon}) || $conf->{balloon});
5608 if ($is_suspended && (my $vmstate = $conf->{vmstate})) {
5609 print "Resumed VM, removing state\n";
5610 delete $conf->@{qw(lock vmstate runningmachine)};
5611 PVE
::Storage
::deactivate_volumes
($storecfg, [$vmstate]);
5612 PVE
::Storage
::vdisk_free
($storecfg, $vmstate);
5613 PVE
::QemuConfig-
>write_config($vmid, $conf);
5616 PVE
::GuestHelpers
::exec_hookscript
($conf, $vmid, 'post-start');
5621 my ($vmid, $execute, %params) = @_;
5623 my $cmd = { execute
=> $execute, arguments
=> \
%params };
5624 vm_qmp_command
($vmid, $cmd);
5627 sub vm_mon_cmd_nocheck
{
5628 my ($vmid, $execute, %params) = @_;
5630 my $cmd = { execute
=> $execute, arguments
=> \
%params };
5631 vm_qmp_command
($vmid, $cmd, 1);
5634 sub vm_qmp_command
{
5635 my ($vmid, $cmd, $nocheck) = @_;
5640 if ($cmd->{arguments
}) {
5641 $timeout = delete $cmd->{arguments
}->{timeout
};
5645 die "VM $vmid not running\n" if !check_running
($vmid, $nocheck);
5646 my $sname = qmp_socket
($vmid);
5647 if (-e
$sname) { # test if VM is reasonambe new and supports qmp/qga
5648 my $qmpclient = PVE
::QMPClient-
>new();
5650 $res = $qmpclient->cmd($vmid, $cmd, $timeout);
5652 die "unable to open monitor socket\n";
5656 syslog
("err", "VM $vmid qmp command failed - $err");
5663 sub vm_human_monitor_command
{
5664 my ($vmid, $cmdline) = @_;
5667 execute
=> 'human-monitor-command',
5668 arguments
=> { 'command-line' => $cmdline},
5671 return vm_qmp_command
($vmid, $cmd);
5674 sub vm_commandline
{
5675 my ($storecfg, $vmid, $snapname) = @_;
5677 my $conf = PVE
::QemuConfig-
>load_config($vmid);
5680 my $snapshot = $conf->{snapshots
}->{$snapname};
5681 die "snapshot '$snapname' does not exist\n" if !defined($snapshot);
5683 $snapshot->{digest
} = $conf->{digest
}; # keep file digest for API
5688 my $defaults = load_defaults
();
5690 my $cmd = config_to_command
($storecfg, $vmid, $conf, $defaults);
5692 return PVE
::Tools
::cmd2string
($cmd);
5696 my ($vmid, $skiplock) = @_;
5698 PVE
::QemuConfig-
>lock_config($vmid, sub {
5700 my $conf = PVE
::QemuConfig-
>load_config($vmid);
5702 PVE
::QemuConfig-
>check_lock($conf) if !$skiplock;
5704 vm_mon_cmd
($vmid, "system_reset");
5708 sub get_vm_volumes
{
5712 foreach_volid
($conf, sub {
5713 my ($volid, $attr) = @_;
5715 return if $volid =~ m
|^/|;
5717 my ($sid, $volname) = PVE
::Storage
::parse_volume_id
($volid, 1);
5720 push @$vollist, $volid;
5726 sub vm_stop_cleanup
{
5727 my ($storecfg, $vmid, $conf, $keepActive, $apply_pending_changes) = @_;
5732 my $vollist = get_vm_volumes
($conf);
5733 PVE
::Storage
::deactivate_volumes
($storecfg, $vollist);
5736 foreach my $ext (qw(mon qmp pid vnc qga)) {
5737 unlink "/var/run/qemu-server/${vmid}.$ext";
5740 if ($conf->{ivshmem
}) {
5741 my $ivshmem = PVE
::JSONSchema
::parse_property_string
($ivshmem_fmt, $conf->{ivshmem
});
5742 # just delete it for now, VMs which have this already open do not
5743 # are affected, but new VMs will get a separated one. If this
5744 # becomes an issue we either add some sort of ref-counting or just
5745 # add a "don't delete on stop" flag to the ivshmem format.
5746 unlink '/dev/shm/pve-shm-' . ($ivshmem->{name
} // $vmid);
5749 foreach my $key (keys %$conf) {
5750 next if $key !~ m/^hostpci(\d+)$/;
5751 my $hostpciindex = $1;
5752 my $d = parse_hostpci
($conf->{$key});
5753 my $uuid = PVE
::SysFSTools
::generate_mdev_uuid
($vmid, $hostpciindex);
5755 foreach my $pci (@{$d->{pciid
}}) {
5756 my $pciid = $pci->{id
};
5757 PVE
::SysFSTools
::pci_cleanup_mdev_device
($pciid, $uuid);
5761 vmconfig_apply_pending
($vmid, $conf, $storecfg) if $apply_pending_changes;
5763 warn $@ if $@; # avoid errors - just warn
5766 # Note: use $nockeck to skip tests if VM configuration file exists.
5767 # We need that when migration VMs to other nodes (files already moved)
5768 # Note: we set $keepActive in vzdump stop mode - volumes need to stay active
5770 my ($storecfg, $vmid, $skiplock, $nocheck, $timeout, $shutdown, $force, $keepActive, $migratedfrom) = @_;
5772 $force = 1 if !defined($force) && !$shutdown;
5775 my $pid = check_running
($vmid, $nocheck, $migratedfrom);
5776 kill 15, $pid if $pid;
5777 my $conf = PVE
::QemuConfig-
>load_config($vmid, $migratedfrom);
5778 vm_stop_cleanup
($storecfg, $vmid, $conf, $keepActive, 0);
5782 PVE
::QemuConfig-
>lock_config($vmid, sub {
5784 my $pid = check_running
($vmid, $nocheck);
5789 $conf = PVE
::QemuConfig-
>load_config($vmid);
5790 PVE
::QemuConfig-
>check_lock($conf) if !$skiplock;
5791 if (!defined($timeout) && $shutdown && $conf->{startup
}) {
5792 my $opts = PVE
::JSONSchema
::pve_parse_startup_order
($conf->{startup
});
5793 $timeout = $opts->{down
} if $opts->{down
};
5795 PVE
::GuestHelpers
::exec_hookscript
($conf, $vmid, 'pre-stop');
5800 if (defined($conf) && parse_guest_agent
($conf)->{enabled
}) {
5801 vm_qmp_command
($vmid, {
5802 execute
=> "guest-shutdown",
5803 arguments
=> { timeout
=> $timeout }
5806 vm_qmp_command
($vmid, { execute
=> "system_powerdown" }, $nocheck);
5809 vm_qmp_command
($vmid, { execute
=> "quit" }, $nocheck);
5815 $timeout = 60 if !defined($timeout);
5818 while (($count < $timeout) && check_running
($vmid, $nocheck)) {
5823 if ($count >= $timeout) {
5825 warn "VM still running - terminating now with SIGTERM\n";
5828 die "VM quit/powerdown failed - got timeout\n";
5831 vm_stop_cleanup
($storecfg, $vmid, $conf, $keepActive, 1) if $conf;
5836 warn "VM quit/powerdown failed - terminating now with SIGTERM\n";
5839 die "VM quit/powerdown failed\n";
5847 while (($count < $timeout) && check_running
($vmid, $nocheck)) {
5852 if ($count >= $timeout) {
5853 warn "VM still running - terminating now with SIGKILL\n";
5858 vm_stop_cleanup
($storecfg, $vmid, $conf, $keepActive, 1) if $conf;
5863 my ($vmid, $skiplock, $includestate, $statestorage) = @_;
5870 PVE
::QemuConfig-
>lock_config($vmid, sub {
5872 $conf = PVE
::QemuConfig-
>load_config($vmid);
5874 my $is_backing_up = PVE
::QemuConfig-
>has_lock($conf, 'backup');
5875 PVE
::QemuConfig-
>check_lock($conf)
5876 if !($skiplock || $is_backing_up);
5878 die "cannot suspend to disk during backup\n"
5879 if $is_backing_up && $includestate;
5881 if ($includestate) {
5882 $conf->{lock} = 'suspending';
5883 my $date = strftime
("%Y-%m-%d", localtime(time()));
5884 $storecfg = PVE
::Storage
::config
();
5885 $vmstate = PVE
::QemuConfig-
>__snapshot_save_vmstate($vmid, $conf, "suspend-$date", $storecfg, $statestorage, 1);
5886 $path = PVE
::Storage
::path
($storecfg, $vmstate);
5887 PVE
::QemuConfig-
>write_config($vmid, $conf);
5889 vm_mon_cmd
($vmid, "stop");
5893 if ($includestate) {
5895 PVE
::Storage
::activate_volumes
($storecfg, [$vmstate]);
5898 vm_mon_cmd
($vmid, "savevm-start", statefile
=> $path);
5900 my $state = vm_mon_cmd_nocheck
($vmid, "query-savevm");
5901 if (!$state->{status
}) {
5902 die "savevm not active\n";
5903 } elsif ($state->{status
} eq 'active') {
5906 } elsif ($state->{status
} eq 'completed') {
5907 print "State saved, quitting\n";
5909 } elsif ($state->{status
} eq 'failed' && $state->{error
}) {
5910 die "query-savevm failed with error '$state->{error}'\n"
5912 die "query-savevm returned status '$state->{status}'\n";
5918 PVE
::QemuConfig-
>lock_config($vmid, sub {
5919 $conf = PVE
::QemuConfig-
>load_config($vmid);
5921 # cleanup, but leave suspending lock, to indicate something went wrong
5923 vm_mon_cmd
($vmid, "savevm-end");
5924 PVE
::Storage
::deactivate_volumes
($storecfg, [$vmstate]);
5925 PVE
::Storage
::vdisk_free
($storecfg, $vmstate);
5926 delete $conf->@{qw(vmstate runningmachine)};
5927 PVE
::QemuConfig-
>write_config($vmid, $conf);
5933 die "lock changed unexpectedly\n"
5934 if !PVE
::QemuConfig-
>has_lock($conf, 'suspending');
5936 vm_qmp_command
($vmid, { execute
=> "quit" });
5937 $conf->{lock} = 'suspended';
5938 PVE
::QemuConfig-
>write_config($vmid, $conf);
5944 my ($vmid, $skiplock, $nocheck) = @_;
5946 PVE
::QemuConfig-
>lock_config($vmid, sub {
5947 my $vm_mon_cmd = $nocheck ? \
&vm_mon_cmd_nocheck
: \
&vm_mon_cmd
;
5948 my $res = $vm_mon_cmd->($vmid, 'query-status');
5949 my $resume_cmd = 'cont';
5951 if ($res->{status
} && $res->{status
} eq 'suspended') {
5952 $resume_cmd = 'system_wakeup';
5957 my $conf = PVE
::QemuConfig-
>load_config($vmid);
5959 PVE
::QemuConfig-
>check_lock($conf)
5960 if !($skiplock || PVE
::QemuConfig-
>has_lock($conf, 'backup'));
5963 $vm_mon_cmd->($vmid, $resume_cmd);
5968 my ($vmid, $skiplock, $key) = @_;
5970 PVE
::QemuConfig-
>lock_config($vmid, sub {
5972 my $conf = PVE
::QemuConfig-
>load_config($vmid);
5974 # there is no qmp command, so we use the human monitor command
5975 my $res = vm_human_monitor_command
($vmid, "sendkey $key");
5976 die $res if $res ne '';
5981 my ($storecfg, $vmid, $skiplock) = @_;
5983 PVE
::QemuConfig-
>lock_config($vmid, sub {
5985 my $conf = PVE
::QemuConfig-
>load_config($vmid);
5987 if (!check_running
($vmid)) {
5988 destroy_vm
($storecfg, $vmid, undef, $skiplock);
5990 die "VM $vmid is running - destroy failed\n";
5995 # vzdump restore implementaion
5997 sub tar_archive_read_firstfile
{
5998 my $archive = shift;
6000 die "ERROR: file '$archive' does not exist\n" if ! -f
$archive;
6002 # try to detect archive type first
6003 my $pid = open (my $fh, '-|', 'tar', 'tf', $archive) ||
6004 die "unable to open file '$archive'\n";
6005 my $firstfile = <$fh>;
6009 die "ERROR: archive contaions no data\n" if !$firstfile;
6015 sub tar_restore_cleanup
{
6016 my ($storecfg, $statfile) = @_;
6018 print STDERR
"starting cleanup\n";
6020 if (my $fd = IO
::File-
>new($statfile, "r")) {
6021 while (defined(my $line = <$fd>)) {
6022 if ($line =~ m/vzdump:([^\s:]*):(\S+)$/) {
6025 if ($volid =~ m
|^/|) {
6026 unlink $volid || die 'unlink failed\n';
6028 PVE
::Storage
::vdisk_free
($storecfg, $volid);
6030 print STDERR
"temporary volume '$volid' sucessfuly removed\n";
6032 print STDERR
"unable to cleanup '$volid' - $@" if $@;
6034 print STDERR
"unable to parse line in statfile - $line";
6041 sub restore_archive
{
6042 my ($archive, $vmid, $user, $opts) = @_;
6044 my $format = $opts->{format
};
6047 if ($archive =~ m/\.tgz$/ || $archive =~ m/\.tar\.gz$/) {
6048 $format = 'tar' if !$format;
6050 } elsif ($archive =~ m/\.tar$/) {
6051 $format = 'tar' if !$format;
6052 } elsif ($archive =~ m/.tar.lzo$/) {
6053 $format = 'tar' if !$format;
6055 } elsif ($archive =~ m/\.vma$/) {
6056 $format = 'vma' if !$format;
6057 } elsif ($archive =~ m/\.vma\.gz$/) {
6058 $format = 'vma' if !$format;
6060 } elsif ($archive =~ m/\.vma\.lzo$/) {
6061 $format = 'vma' if !$format;
6064 $format = 'vma' if !$format; # default
6067 # try to detect archive format
6068 if ($format eq 'tar') {
6069 return restore_tar_archive
($archive, $vmid, $user, $opts);
6071 return restore_vma_archive
($archive, $vmid, $user, $opts, $comp);
6075 sub restore_update_config_line
{
6076 my ($outfd, $cookie, $vmid, $map, $line, $unique) = @_;
6078 return if $line =~ m/^\#qmdump\#/;
6079 return if $line =~ m/^\#vzdump\#/;
6080 return if $line =~ m/^lock:/;
6081 return if $line =~ m/^unused\d+:/;
6082 return if $line =~ m/^parent:/;
6084 my $dc = PVE
::Cluster
::cfs_read_file
('datacenter.cfg');
6085 if (($line =~ m/^(vlan(\d+)):\s*(\S+)\s*$/)) {
6086 # try to convert old 1.X settings
6087 my ($id, $ind, $ethcfg) = ($1, $2, $3);
6088 foreach my $devconfig (PVE
::Tools
::split_list
($ethcfg)) {
6089 my ($model, $macaddr) = split(/\=/, $devconfig);
6090 $macaddr = PVE
::Tools
::random_ether_addr
($dc->{mac_prefix
}) if !$macaddr || $unique;
6093 bridge
=> "vmbr$ind",
6094 macaddr
=> $macaddr,
6096 my $netstr = print_net
($net);
6098 print $outfd "net$cookie->{netcount}: $netstr\n";
6099 $cookie->{netcount
}++;
6101 } elsif (($line =~ m/^(net\d+):\s*(\S+)\s*$/) && $unique) {
6102 my ($id, $netstr) = ($1, $2);
6103 my $net = parse_net
($netstr);
6104 $net->{macaddr
} = PVE
::Tools
::random_ether_addr
($dc->{mac_prefix
}) if $net->{macaddr
};
6105 $netstr = print_net
($net);
6106 print $outfd "$id: $netstr\n";
6107 } elsif ($line =~ m/^((ide|scsi|virtio|sata|efidisk)\d+):\s*(\S+)\s*$/) {
6110 my $di = parse_drive
($virtdev, $value);
6111 if (defined($di->{backup
}) && !$di->{backup
}) {
6112 print $outfd "#$line";
6113 } elsif ($map->{$virtdev}) {
6114 delete $di->{format
}; # format can change on restore
6115 $di->{file
} = $map->{$virtdev};
6116 $value = print_drive
($vmid, $di);
6117 print $outfd "$virtdev: $value\n";
6121 } elsif (($line =~ m/^vmgenid: (.*)/)) {
6123 if ($vmgenid ne '0') {
6124 # always generate a new vmgenid if there was a valid one setup
6125 $vmgenid = generate_uuid
();
6127 print $outfd "vmgenid: $vmgenid\n";
6128 } elsif (($line =~ m/^(smbios1: )(.*)/) && $unique) {
6129 my ($uuid, $uuid_str);
6130 UUID
::generate
($uuid);
6131 UUID
::unparse
($uuid, $uuid_str);
6132 my $smbios1 = parse_smbios1
($2);
6133 $smbios1->{uuid
} = $uuid_str;
6134 print $outfd $1.print_smbios1
($smbios1)."\n";
6141 my ($cfg, $vmid) = @_;
6143 my $info = PVE
::Storage
::vdisk_list
($cfg, undef, $vmid);
6145 my $volid_hash = {};
6146 foreach my $storeid (keys %$info) {
6147 foreach my $item (@{$info->{$storeid}}) {
6148 next if !($item->{volid
} && $item->{size
});
6149 $item->{path
} = PVE
::Storage
::path
($cfg, $item->{volid
});
6150 $volid_hash->{$item->{volid
}} = $item;
6157 sub is_volume_in_use
{
6158 my ($storecfg, $conf, $skip_drive, $volid) = @_;
6160 my $path = PVE
::Storage
::path
($storecfg, $volid);
6162 my $scan_config = sub {
6163 my ($cref, $snapname) = @_;
6165 foreach my $key (keys %$cref) {
6166 my $value = $cref->{$key};
6167 if (is_valid_drivename
($key)) {
6168 next if $skip_drive && $key eq $skip_drive;
6169 my $drive = parse_drive
($key, $value);
6170 next if !$drive || !$drive->{file
} || drive_is_cdrom
($drive);
6171 return 1 if $volid eq $drive->{file
};
6172 if ($drive->{file
} =~ m!^/!) {
6173 return 1 if $drive->{file
} eq $path;
6175 my ($storeid, $volname) = PVE
::Storage
::parse_volume_id
($drive->{file
}, 1);
6177 my $scfg = PVE
::Storage
::storage_config
($storecfg, $storeid, 1);
6179 return 1 if $path eq PVE
::Storage
::path
($storecfg, $drive->{file
}, $snapname);
6187 return 1 if &$scan_config($conf);
6191 foreach my $snapname (keys %{$conf->{snapshots
}}) {
6192 return 1 if &$scan_config($conf->{snapshots
}->{$snapname}, $snapname);
6198 sub update_disksize
{
6199 my ($vmid, $conf, $volid_hash) = @_;
6202 my $prefix = "VM $vmid:";
6204 # used and unused disks
6205 my $referenced = {};
6207 # Note: it is allowed to define multiple storages with same path (alias), so
6208 # we need to check both 'volid' and real 'path' (two different volid can point
6209 # to the same path).
6211 my $referencedpath = {};
6214 foreach my $opt (keys %$conf) {
6215 if (is_valid_drivename
($opt)) {
6216 my $drive = parse_drive
($opt, $conf->{$opt});
6217 my $volid = $drive->{file
};
6220 $referenced->{$volid} = 1;
6221 if ($volid_hash->{$volid} &&
6222 (my $path = $volid_hash->{$volid}->{path
})) {
6223 $referencedpath->{$path} = 1;
6226 next if drive_is_cdrom
($drive);
6227 next if !$volid_hash->{$volid};
6229 $drive->{size
} = $volid_hash->{$volid}->{size
};
6230 my $new = print_drive
($vmid, $drive);
6231 if ($new ne $conf->{$opt}) {
6233 $conf->{$opt} = $new;
6234 print "$prefix update disk '$opt' information.\n";
6239 # remove 'unusedX' entry if volume is used
6240 foreach my $opt (keys %$conf) {
6241 next if $opt !~ m/^unused\d+$/;
6242 my $volid = $conf->{$opt};
6243 my $path = $volid_hash->{$volid}->{path
} if $volid_hash->{$volid};
6244 if ($referenced->{$volid} || ($path && $referencedpath->{$path})) {
6245 print "$prefix remove entry '$opt', its volume '$volid' is in use.\n";
6247 delete $conf->{$opt};
6250 $referenced->{$volid} = 1;
6251 $referencedpath->{$path} = 1 if $path;
6254 foreach my $volid (sort keys %$volid_hash) {
6255 next if $volid =~ m/vm-$vmid-state-/;
6256 next if $referenced->{$volid};
6257 my $path = $volid_hash->{$volid}->{path
};
6258 next if !$path; # just to be sure
6259 next if $referencedpath->{$path};
6261 my $key = PVE
::QemuConfig-
>add_unused_volume($conf, $volid);
6262 print "$prefix add unreferenced volume '$volid' as '$key' to config.\n";
6263 $referencedpath->{$path} = 1; # avoid to add more than once (aliases)
6270 my ($vmid, $nolock, $dryrun) = @_;
6272 my $cfg = PVE
::Storage
::config
();
6274 # FIXME: Remove once our RBD plugin can handle CT and VM on a single storage
6275 # see: https://pve.proxmox.com/pipermail/pve-devel/2018-July/032900.html
6276 foreach my $stor (keys %{$cfg->{ids
}}) {
6277 delete($cfg->{ids
}->{$stor}) if ! $cfg->{ids
}->{$stor}->{content
}->{images
};
6280 print "rescan volumes...\n";
6281 my $volid_hash = scan_volids
($cfg, $vmid);
6283 my $updatefn = sub {
6286 my $conf = PVE
::QemuConfig-
>load_config($vmid);
6288 PVE
::QemuConfig-
>check_lock($conf);
6291 foreach my $volid (keys %$volid_hash) {
6292 my $info = $volid_hash->{$volid};
6293 $vm_volids->{$volid} = $info if $info->{vmid
} && $info->{vmid
} == $vmid;
6296 my $changes = update_disksize
($vmid, $conf, $vm_volids);
6298 PVE
::QemuConfig-
>write_config($vmid, $conf) if $changes && !$dryrun;
6301 if (defined($vmid)) {
6305 PVE
::QemuConfig-
>lock_config($vmid, $updatefn, $vmid);
6308 my $vmlist = config_list
();
6309 foreach my $vmid (keys %$vmlist) {
6313 PVE
::QemuConfig-
>lock_config($vmid, $updatefn, $vmid);
6319 sub restore_vma_archive
{
6320 my ($archive, $vmid, $user, $opts, $comp) = @_;
6322 my $readfrom = $archive;
6324 my $cfg = PVE
::Storage
::config
();
6326 my $bwlimit = $opts->{bwlimit
};
6328 my $dbg_cmdstring = '';
6329 my $add_pipe = sub {
6331 push @$commands, $cmd;
6332 $dbg_cmdstring .= ' | ' if length($dbg_cmdstring);
6333 $dbg_cmdstring .= PVE
::Tools
::cmd2string
($cmd);
6338 if ($archive eq '-') {
6341 # If we use a backup from a PVE defined storage we also consider that
6342 # storage's rate limit:
6343 my (undef, $volid) = PVE
::Storage
::path_to_volume_id
($cfg, $archive);
6344 if (defined($volid)) {
6345 my ($sid, undef) = PVE
::Storage
::parse_volume_id
($volid);
6346 my $readlimit = PVE
::Storage
::get_bandwidth_limit
('restore', [$sid], $bwlimit);
6348 print STDERR
"applying read rate limit: $readlimit\n";
6349 my $cstream = ['cstream', '-t', $readlimit*1024, '--', $readfrom];
6350 $add_pipe->($cstream);
6357 if ($comp eq 'gzip') {
6358 $cmd = ['zcat', $readfrom];
6359 } elsif ($comp eq 'lzop') {
6360 $cmd = ['lzop', '-d', '-c', $readfrom];
6362 die "unknown compression method '$comp'\n";
6367 my $tmpdir = "/var/tmp/vzdumptmp$$";
6370 # disable interrupts (always do cleanups)
6374 local $SIG{HUP
} = sub { warn "got interrupt - ignored\n"; };
6376 my $mapfifo = "/var/tmp/vzdumptmp$$.fifo";
6377 POSIX
::mkfifo
($mapfifo, 0600);
6380 my $openfifo = sub {
6381 open($fifofh, '>', $mapfifo) || die $!;
6384 $add_pipe->(['vma', 'extract', '-v', '-r', $mapfifo, $readfrom, $tmpdir]);
6391 my $rpcenv = PVE
::RPCEnvironment
::get
();
6393 my $conffile = PVE
::QemuConfig-
>config_file($vmid);
6394 my $tmpfn = "$conffile.$$.tmp";
6396 # Note: $oldconf is undef if VM does not exists
6397 my $cfs_path = PVE
::QemuConfig-
>cfs_config_path($vmid);
6398 my $oldconf = PVE
::Cluster
::cfs_read_file
($cfs_path);
6402 my $print_devmap = sub {
6403 my $virtdev_hash = {};
6405 my $cfgfn = "$tmpdir/qemu-server.conf";
6407 # we can read the config - that is already extracted
6408 my $fh = IO
::File-
>new($cfgfn, "r") ||
6409 "unable to read qemu-server.conf - $!\n";
6411 my $fwcfgfn = "$tmpdir/qemu-server.fw";
6413 my $pve_firewall_dir = '/etc/pve/firewall';
6414 mkdir $pve_firewall_dir; # make sure the dir exists
6415 PVE
::Tools
::file_copy
($fwcfgfn, "${pve_firewall_dir}/$vmid.fw");
6418 while (defined(my $line = <$fh>)) {
6419 if ($line =~ m/^\#qmdump\#map:(\S+):(\S+):(\S*):(\S*):$/) {
6420 my ($virtdev, $devname, $storeid, $format) = ($1, $2, $3, $4);
6421 die "archive does not contain data for drive '$virtdev'\n"
6422 if !$devinfo->{$devname};
6423 if (defined($opts->{storage
})) {
6424 $storeid = $opts->{storage
} || 'local';
6425 } elsif (!$storeid) {
6428 $format = 'raw' if !$format;
6429 $devinfo->{$devname}->{devname
} = $devname;
6430 $devinfo->{$devname}->{virtdev
} = $virtdev;
6431 $devinfo->{$devname}->{format
} = $format;
6432 $devinfo->{$devname}->{storeid
} = $storeid;
6434 # check permission on storage
6435 my $pool = $opts->{pool
}; # todo: do we need that?
6436 if ($user ne 'root@pam') {
6437 $rpcenv->check($user, "/storage/$storeid", ['Datastore.AllocateSpace']);
6440 $storage_limits{$storeid} = $bwlimit;
6442 $virtdev_hash->{$virtdev} = $devinfo->{$devname};
6443 } elsif ($line =~ m/^((?:ide|sata|scsi)\d+):\s*(.*)\s*$/) {
6445 my $drive = parse_drive
($virtdev, $2);
6446 if (drive_is_cloudinit
($drive)) {
6447 my ($storeid, $volname) = PVE
::Storage
::parse_volume_id
($drive->{file
});
6448 my $scfg = PVE
::Storage
::storage_config
($cfg, $storeid);
6449 my $format = qemu_img_format
($scfg, $volname); # has 'raw' fallback
6453 storeid
=> $opts->{storage
} // $storeid,
6454 size
=> PVE
::QemuServer
::Cloudinit
::CLOUDINIT_DISK_SIZE
,
6455 file
=> $drive->{file
}, # to make drive_is_cloudinit check possible
6456 name
=> "vm-$vmid-cloudinit",
6459 $virtdev_hash->{$virtdev} = $d;
6464 foreach my $key (keys %storage_limits) {
6465 my $limit = PVE
::Storage
::get_bandwidth_limit
('restore', [$key], $bwlimit);
6467 print STDERR
"rate limit for storage $key: $limit KiB/s\n";
6468 $storage_limits{$key} = $limit * 1024;
6471 foreach my $devname (keys %$devinfo) {
6472 die "found no device mapping information for device '$devname'\n"
6473 if !$devinfo->{$devname}->{virtdev
};
6476 # create empty/temp config
6478 PVE
::Tools
::file_set_contents
($conffile, "memory: 128\n");
6479 foreach_drive
($oldconf, sub {
6480 my ($ds, $drive) = @_;
6482 return if !$drive->{is_cloudinit
} && drive_is_cdrom
($drive);
6484 my $volid = $drive->{file
};
6485 return if !$volid || $volid =~ m
|^/|;
6487 my ($path, $owner) = PVE
::Storage
::path
($cfg, $volid);
6488 return if !$path || !$owner || ($owner != $vmid);
6490 # Note: only delete disk we want to restore
6491 # other volumes will become unused
6492 if ($virtdev_hash->{$ds}) {
6493 eval { PVE
::Storage
::vdisk_free
($cfg, $volid); };
6500 # delete vmstate files, after the restore we have no snapshots anymore
6501 foreach my $snapname (keys %{$oldconf->{snapshots
}}) {
6502 my $snap = $oldconf->{snapshots
}->{$snapname};
6503 if ($snap->{vmstate
}) {
6504 eval { PVE
::Storage
::vdisk_free
($cfg, $snap->{vmstate
}); };
6513 foreach my $virtdev (sort keys %$virtdev_hash) {
6514 my $d = $virtdev_hash->{$virtdev};
6515 my $alloc_size = int(($d->{size
} + 1024 - 1)/1024);
6516 my $storeid = $d->{storeid
};
6517 my $scfg = PVE
::Storage
::storage_config
($cfg, $storeid);
6520 if (my $limit = $storage_limits{$storeid}) {
6521 $map_opts .= "throttling.bps=$limit:throttling.group=$storeid:";
6524 # test if requested format is supported
6525 my ($defFormat, $validFormats) = PVE
::Storage
::storage_default_format
($cfg, $storeid);
6526 my $supported = grep { $_ eq $d->{format
} } @$validFormats;
6527 $d->{format
} = $defFormat if !$supported;
6530 if ($d->{is_cloudinit
}) {
6532 $name .= ".$d->{format}" if $d->{format
} ne 'raw';
6535 my $volid = PVE
::Storage
::vdisk_alloc
($cfg, $storeid, $vmid, $d->{format
}, $name, $alloc_size);
6536 print STDERR
"new volume ID is '$volid'\n";
6537 $d->{volid
} = $volid;
6539 PVE
::Storage
::activate_volumes
($cfg, [$volid]);
6541 my $write_zeros = 1;
6542 if (PVE
::Storage
::volume_has_feature
($cfg, 'sparseinit', $volid)) {
6546 if (!$d->{is_cloudinit
}) {
6547 my $path = PVE
::Storage
::path
($cfg, $volid);
6549 print $fifofh "${map_opts}format=$d->{format}:${write_zeros}:$d->{devname}=$path\n";
6551 print "map '$d->{devname}' to '$path' (write zeros = ${write_zeros})\n";
6553 $map->{$virtdev} = $volid;
6556 $fh->seek(0, 0) || die "seek failed - $!\n";
6558 my $outfd = new IO
::File
($tmpfn, "w") ||
6559 die "unable to write config for VM $vmid\n";
6561 my $cookie = { netcount
=> 0 };
6562 while (defined(my $line = <$fh>)) {
6563 restore_update_config_line
($outfd, $cookie, $vmid, $map, $line, $opts->{unique
});
6576 local $SIG{PIPE
} = sub { die "interrupted by signal\n"; };
6577 local $SIG{ALRM
} = sub { die "got timeout\n"; };
6579 $oldtimeout = alarm($timeout);
6586 if ($line =~ m/^DEV:\sdev_id=(\d+)\ssize:\s(\d+)\sdevname:\s(\S+)$/) {
6587 my ($dev_id, $size, $devname) = ($1, $2, $3);
6588 $devinfo->{$devname} = { size
=> $size, dev_id
=> $dev_id };
6589 } elsif ($line =~ m/^CTIME: /) {
6590 # we correctly received the vma config, so we can disable
6591 # the timeout now for disk allocation (set to 10 minutes, so
6592 # that we always timeout if something goes wrong)
6595 print $fifofh "done\n";
6596 my $tmp = $oldtimeout || 0;
6597 $oldtimeout = undef;
6603 print "restore vma archive: $dbg_cmdstring\n";
6604 run_command
($commands, input
=> $input, outfunc
=> $parser, afterfork
=> $openfifo);
6608 alarm($oldtimeout) if $oldtimeout;
6611 foreach my $devname (keys %$devinfo) {
6612 my $volid = $devinfo->{$devname}->{volid
};
6613 push @$vollist, $volid if $volid;
6616 PVE
::Storage
::deactivate_volumes
($cfg, $vollist);
6624 foreach my $devname (keys %$devinfo) {
6625 my $volid = $devinfo->{$devname}->{volid
};
6628 if ($volid =~ m
|^/|) {
6629 unlink $volid || die 'unlink failed\n';
6631 PVE
::Storage
::vdisk_free
($cfg, $volid);
6633 print STDERR
"temporary volume '$volid' sucessfuly removed\n";
6635 print STDERR
"unable to cleanup '$volid' - $@" if $@;
6642 rename($tmpfn, $conffile) ||
6643 die "unable to commit configuration file '$conffile'\n";
6645 PVE
::Cluster
::cfs_update
(); # make sure we read new file
6647 eval { rescan
($vmid, 1); };
6651 sub restore_tar_archive
{
6652 my ($archive, $vmid, $user, $opts) = @_;
6654 if ($archive ne '-') {
6655 my $firstfile = tar_archive_read_firstfile
($archive);
6656 die "ERROR: file '$archive' dos not lock like a QemuServer vzdump backup\n"
6657 if $firstfile ne 'qemu-server.conf';
6660 my $storecfg = PVE
::Storage
::config
();
6662 # destroy existing data - keep empty config
6663 my $vmcfgfn = PVE
::QemuConfig-
>config_file($vmid);
6664 destroy_vm
($storecfg, $vmid, 1) if -f
$vmcfgfn;
6666 my $tocmd = "/usr/lib/qemu-server/qmextract";
6668 $tocmd .= " --storage " . PVE
::Tools
::shellquote
($opts->{storage
}) if $opts->{storage
};
6669 $tocmd .= " --pool " . PVE
::Tools
::shellquote
($opts->{pool
}) if $opts->{pool
};
6670 $tocmd .= ' --prealloc' if $opts->{prealloc
};
6671 $tocmd .= ' --info' if $opts->{info
};
6673 # tar option "xf" does not autodetect compression when read from STDIN,
6674 # so we pipe to zcat
6675 my $cmd = "zcat -f|tar xf " . PVE
::Tools
::shellquote
($archive) . " " .
6676 PVE
::Tools
::shellquote
("--to-command=$tocmd");
6678 my $tmpdir = "/var/tmp/vzdumptmp$$";
6681 local $ENV{VZDUMP_TMPDIR
} = $tmpdir;
6682 local $ENV{VZDUMP_VMID
} = $vmid;
6683 local $ENV{VZDUMP_USER
} = $user;
6685 my $conffile = PVE
::QemuConfig-
>config_file($vmid);
6686 my $tmpfn = "$conffile.$$.tmp";
6688 # disable interrupts (always do cleanups)
6692 local $SIG{HUP
} = sub { print STDERR
"got interrupt - ignored\n"; };
6700 local $SIG{PIPE
} = sub { die "interrupted by signal\n"; };
6702 if ($archive eq '-') {
6703 print "extracting archive from STDIN\n";
6704 run_command
($cmd, input
=> "<&STDIN");
6706 print "extracting archive '$archive'\n";
6710 return if $opts->{info
};
6714 my $statfile = "$tmpdir/qmrestore.stat";
6715 if (my $fd = IO
::File-
>new($statfile, "r")) {
6716 while (defined (my $line = <$fd>)) {
6717 if ($line =~ m/vzdump:([^\s:]*):(\S+)$/) {
6718 $map->{$1} = $2 if $1;
6720 print STDERR
"unable to parse line in statfile - $line\n";
6726 my $confsrc = "$tmpdir/qemu-server.conf";
6728 my $srcfd = new IO
::File
($confsrc, "r") ||
6729 die "unable to open file '$confsrc'\n";
6731 my $outfd = new IO
::File
($tmpfn, "w") ||
6732 die "unable to write config for VM $vmid\n";
6734 my $cookie = { netcount
=> 0 };
6735 while (defined (my $line = <$srcfd>)) {
6736 restore_update_config_line
($outfd, $cookie, $vmid, $map, $line, $opts->{unique
});
6748 tar_restore_cleanup
($storecfg, "$tmpdir/qmrestore.stat") if !$opts->{info
};
6755 rename $tmpfn, $conffile ||
6756 die "unable to commit configuration file '$conffile'\n";
6758 PVE
::Cluster
::cfs_update
(); # make sure we read new file
6760 eval { rescan
($vmid, 1); };
6764 sub foreach_storage_used_by_vm
{
6765 my ($conf, $func) = @_;
6769 foreach_drive
($conf, sub {
6770 my ($ds, $drive) = @_;
6771 return if drive_is_cdrom
($drive);
6773 my $volid = $drive->{file
};
6775 my ($sid, $volname) = PVE
::Storage
::parse_volume_id
($volid, 1);
6776 $sidhash->{$sid} = $sid if $sid;
6779 foreach my $sid (sort keys %$sidhash) {
6784 sub do_snapshots_with_qemu
{
6785 my ($storecfg, $volid) = @_;
6787 my $storage_name = PVE
::Storage
::parse_volume_id
($volid);
6788 my $scfg = $storecfg->{ids
}->{$storage_name};
6790 if ($qemu_snap_storage->{$scfg->{type
}} && !$scfg->{krbd
}){
6794 if ($volid =~ m/\.(qcow2|qed)$/){
6801 sub qga_check_running
{
6802 my ($vmid, $nowarn) = @_;
6804 eval { vm_mon_cmd
($vmid, "guest-ping", timeout
=> 3); };
6806 warn "Qemu Guest Agent is not running - $@" if !$nowarn;
6812 sub template_create
{
6813 my ($vmid, $conf, $disk) = @_;
6815 my $storecfg = PVE
::Storage
::config
();
6817 foreach_drive
($conf, sub {
6818 my ($ds, $drive) = @_;
6820 return if drive_is_cdrom
($drive);
6821 return if $disk && $ds ne $disk;
6823 my $volid = $drive->{file
};
6824 return if !PVE
::Storage
::volume_has_feature
($storecfg, 'template', $volid);
6826 my $voliddst = PVE
::Storage
::vdisk_create_base
($storecfg, $volid);
6827 $drive->{file
} = $voliddst;
6828 $conf->{$ds} = print_drive
($vmid, $drive);
6829 PVE
::QemuConfig-
>write_config($vmid, $conf);
6833 sub convert_iscsi_path
{
6836 if ($path =~ m
|^iscsi
://([^/]+)/([^/]+)/(.+)$|) {
6841 my $initiator_name = get_initiator_name
();
6843 return "file.driver=iscsi,file.transport=tcp,file.initiator-name=$initiator_name,".
6844 "file.portal=$portal,file.target=$target,file.lun=$lun,driver=raw";
6847 die "cannot convert iscsi path '$path', unkown format\n";
6850 sub qemu_img_convert
{
6851 my ($src_volid, $dst_volid, $size, $snapname, $is_zero_initialized) = @_;
6853 my $storecfg = PVE
::Storage
::config
();
6854 my ($src_storeid, $src_volname) = PVE
::Storage
::parse_volume_id
($src_volid, 1);
6855 my ($dst_storeid, $dst_volname) = PVE
::Storage
::parse_volume_id
($dst_volid, 1);
6857 if ($src_storeid && $dst_storeid) {
6859 PVE
::Storage
::activate_volumes
($storecfg, [$src_volid], $snapname);
6861 my $src_scfg = PVE
::Storage
::storage_config
($storecfg, $src_storeid);
6862 my $dst_scfg = PVE
::Storage
::storage_config
($storecfg, $dst_storeid);
6864 my $src_format = qemu_img_format
($src_scfg, $src_volname);
6865 my $dst_format = qemu_img_format
($dst_scfg, $dst_volname);
6867 my $src_path = PVE
::Storage
::path
($storecfg, $src_volid, $snapname);
6868 my $dst_path = PVE
::Storage
::path
($storecfg, $dst_volid);
6870 my $src_is_iscsi = ($src_path =~ m
|^iscsi
://|);
6871 my $dst_is_iscsi = ($dst_path =~ m
|^iscsi
://|);
6874 push @$cmd, '/usr/bin/qemu-img', 'convert', '-p', '-n';
6875 push @$cmd, '-l', "snapshot.name=$snapname" if($snapname && $src_format eq "qcow2");
6876 push @$cmd, '-t', 'none' if $dst_scfg->{type
} eq 'zfspool';
6877 push @$cmd, '-T', 'none' if $src_scfg->{type
} eq 'zfspool';
6879 if ($src_is_iscsi) {
6880 push @$cmd, '--image-opts';
6881 $src_path = convert_iscsi_path
($src_path);
6883 push @$cmd, '-f', $src_format;
6886 if ($dst_is_iscsi) {
6887 push @$cmd, '--target-image-opts';
6888 $dst_path = convert_iscsi_path
($dst_path);
6890 push @$cmd, '-O', $dst_format;
6893 push @$cmd, $src_path;
6895 if (!$dst_is_iscsi && $is_zero_initialized) {
6896 push @$cmd, "zeroinit:$dst_path";
6898 push @$cmd, $dst_path;
6903 if($line =~ m/\((\S+)\/100\
%\)/){
6905 my $transferred = int($size * $percent / 100);
6906 my $remaining = $size - $transferred;
6908 print "transferred: $transferred bytes remaining: $remaining bytes total: $size bytes progression: $percent %\n";
6913 eval { run_command
($cmd, timeout
=> undef, outfunc
=> $parser); };
6915 die "copy failed: $err" if $err;
6919 sub qemu_img_format
{
6920 my ($scfg, $volname) = @_;
6922 if ($scfg->{path
} && $volname =~ m/\.($QEMU_FORMAT_RE)$/) {
6929 sub qemu_drive_mirror
{
6930 my ($vmid, $drive, $dst_volid, $vmiddst, $is_zero_initialized, $jobs, $skipcomplete, $qga, $bwlimit) = @_;
6932 $jobs = {} if !$jobs;
6936 $jobs->{"drive-$drive"} = {};
6938 if ($dst_volid =~ /^nbd:/) {
6939 $qemu_target = $dst_volid;
6942 my $storecfg = PVE
::Storage
::config
();
6943 my ($dst_storeid, $dst_volname) = PVE
::Storage
::parse_volume_id
($dst_volid);
6945 my $dst_scfg = PVE
::Storage
::storage_config
($storecfg, $dst_storeid);
6947 $format = qemu_img_format
($dst_scfg, $dst_volname);
6949 my $dst_path = PVE
::Storage
::path
($storecfg, $dst_volid);
6951 $qemu_target = $is_zero_initialized ?
"zeroinit:$dst_path" : $dst_path;
6954 my $opts = { timeout
=> 10, device
=> "drive-$drive", mode
=> "existing", sync
=> "full", target
=> $qemu_target };
6955 $opts->{format
} = $format if $format;
6957 if (defined($bwlimit)) {
6958 $opts->{speed
} = $bwlimit * 1024;
6959 print "drive mirror is starting for drive-$drive with bandwidth limit: ${bwlimit} KB/s\n";
6961 print "drive mirror is starting for drive-$drive\n";
6964 # if a job already runs for this device we get an error, catch it for cleanup
6965 eval { vm_mon_cmd
($vmid, "drive-mirror", %$opts); };
6967 eval { PVE
::QemuServer
::qemu_blockjobs_cancel
($vmid, $jobs) };
6969 die "mirroring error: $err\n";
6972 qemu_drive_mirror_monitor
($vmid, $vmiddst, $jobs, $skipcomplete, $qga);
6975 sub qemu_drive_mirror_monitor
{
6976 my ($vmid, $vmiddst, $jobs, $skipcomplete, $qga) = @_;
6979 my $err_complete = 0;
6982 die "storage migration timed out\n" if $err_complete > 300;
6984 my $stats = vm_mon_cmd
($vmid, "query-block-jobs");
6986 my $running_mirror_jobs = {};
6987 foreach my $stat (@$stats) {
6988 next if $stat->{type
} ne 'mirror';
6989 $running_mirror_jobs->{$stat->{device
}} = $stat;
6992 my $readycounter = 0;
6994 foreach my $job (keys %$jobs) {
6996 if(defined($jobs->{$job}->{complete
}) && !defined($running_mirror_jobs->{$job})) {
6997 print "$job : finished\n";
6998 delete $jobs->{$job};
7002 die "$job: mirroring has been cancelled\n" if !defined($running_mirror_jobs->{$job});
7004 my $busy = $running_mirror_jobs->{$job}->{busy
};
7005 my $ready = $running_mirror_jobs->{$job}->{ready
};
7006 if (my $total = $running_mirror_jobs->{$job}->{len
}) {
7007 my $transferred = $running_mirror_jobs->{$job}->{offset
} || 0;
7008 my $remaining = $total - $transferred;
7009 my $percent = sprintf "%.2f", ($transferred * 100 / $total);
7011 print "$job: transferred: $transferred bytes remaining: $remaining bytes total: $total bytes progression: $percent % busy: $busy ready: $ready \n";
7014 $readycounter++ if $running_mirror_jobs->{$job}->{ready
};
7017 last if scalar(keys %$jobs) == 0;
7019 if ($readycounter == scalar(keys %$jobs)) {
7020 print "all mirroring jobs are ready \n";
7021 last if $skipcomplete; #do the complete later
7023 if ($vmiddst && $vmiddst != $vmid) {
7024 my $agent_running = $qga && qga_check_running
($vmid);
7025 if ($agent_running) {
7026 print "freeze filesystem\n";
7027 eval { PVE
::QemuServer
::vm_mon_cmd
($vmid, "guest-fsfreeze-freeze"); };
7029 print "suspend vm\n";
7030 eval { PVE
::QemuServer
::vm_suspend
($vmid, 1); };
7033 # if we clone a disk for a new target vm, we don't switch the disk
7034 PVE
::QemuServer
::qemu_blockjobs_cancel
($vmid, $jobs);
7036 if ($agent_running) {
7037 print "unfreeze filesystem\n";
7038 eval { PVE
::QemuServer
::vm_mon_cmd
($vmid, "guest-fsfreeze-thaw"); };
7040 print "resume vm\n";
7041 eval { PVE
::QemuServer
::vm_resume
($vmid, 1, 1); };
7047 foreach my $job (keys %$jobs) {
7048 # try to switch the disk if source and destination are on the same guest
7049 print "$job: Completing block job...\n";
7051 eval { vm_mon_cmd
($vmid, "block-job-complete", device
=> $job) };
7052 if ($@ =~ m/cannot be completed/) {
7053 print "$job: Block job cannot be completed, try again.\n";
7056 print "$job: Completed successfully.\n";
7057 $jobs->{$job}->{complete
} = 1;
7068 eval { PVE
::QemuServer
::qemu_blockjobs_cancel
($vmid, $jobs) };
7069 die "mirroring error: $err";
7074 sub qemu_blockjobs_cancel
{
7075 my ($vmid, $jobs) = @_;
7077 foreach my $job (keys %$jobs) {
7078 print "$job: Cancelling block job\n";
7079 eval { vm_mon_cmd
($vmid, "block-job-cancel", device
=> $job); };
7080 $jobs->{$job}->{cancel
} = 1;
7084 my $stats = vm_mon_cmd
($vmid, "query-block-jobs");
7086 my $running_jobs = {};
7087 foreach my $stat (@$stats) {
7088 $running_jobs->{$stat->{device
}} = $stat;
7091 foreach my $job (keys %$jobs) {
7093 if (defined($jobs->{$job}->{cancel
}) && !defined($running_jobs->{$job})) {
7094 print "$job: Done.\n";
7095 delete $jobs->{$job};
7099 last if scalar(keys %$jobs) == 0;
7106 my ($storecfg, $vmid, $running, $drivename, $drive, $snapname,
7107 $newvmid, $storage, $format, $full, $newvollist, $jobs, $skipcomplete, $qga, $bwlimit) = @_;
7112 print "create linked clone of drive $drivename ($drive->{file})\n";
7113 $newvolid = PVE
::Storage
::vdisk_clone
($storecfg, $drive->{file
}, $newvmid, $snapname);
7114 push @$newvollist, $newvolid;
7117 my ($storeid, $volname) = PVE
::Storage
::parse_volume_id
($drive->{file
});
7118 $storeid = $storage if $storage;
7120 my $dst_format = resolve_dst_disk_format
($storecfg, $storeid, $volname, $format);
7121 my ($size) = PVE
::Storage
::volume_size_info
($storecfg, $drive->{file
}, 3);
7123 print "create full clone of drive $drivename ($drive->{file})\n";
7125 if (drive_is_cloudinit
($drive)) {
7126 $name = "vm-$newvmid-cloudinit";
7128 # we only get here if it's supported by QEMU_FORMAT_RE, so just accept
7129 if ($dst_format ne 'raw') {
7130 $name .= ".$dst_format";
7133 $newvolid = PVE
::Storage
::vdisk_alloc
($storecfg, $storeid, $newvmid, $dst_format, $name, ($size/1024));
7134 push @$newvollist, $newvolid;
7136 PVE
::Storage
::activate_volumes
($storecfg, [$newvolid]);
7138 my $sparseinit = PVE
::Storage
::volume_has_feature
($storecfg, 'sparseinit', $newvolid);
7139 if (!$running || $snapname) {
7140 # TODO: handle bwlimits
7141 qemu_img_convert
($drive->{file
}, $newvolid, $size, $snapname, $sparseinit);
7144 my $kvmver = get_running_qemu_version
($vmid);
7145 if (!qemu_machine_feature_enabled
(undef, $kvmver, 2, 7)) {
7146 die "drive-mirror with iothread requires qemu version 2.7 or higher\n"
7147 if $drive->{iothread
};
7150 qemu_drive_mirror
($vmid, $drivename, $newvolid, $newvmid, $sparseinit, $jobs, $skipcomplete, $qga, $bwlimit);
7154 my ($size) = PVE
::Storage
::volume_size_info
($storecfg, $newvolid, 3);
7157 $disk->{format
} = undef;
7158 $disk->{file
} = $newvolid;
7159 $disk->{size
} = $size;
7164 # this only works if VM is running
7165 sub get_current_qemu_machine
{
7168 my $cmd = { execute
=> 'query-machines', arguments
=> {} };
7169 my $res = vm_qmp_command
($vmid, $cmd);
7171 my ($current, $default);
7172 foreach my $e (@$res) {
7173 $default = $e->{name
} if $e->{'is-default'};
7174 $current = $e->{name
} if $e->{'is-current'};
7177 # fallback to the default machine if current is not supported by qemu
7178 return $current || $default || 'pc';
7181 sub get_running_qemu_version
{
7183 my $cmd = { execute
=> 'query-version', arguments
=> {} };
7184 my $res = vm_qmp_command
($vmid, $cmd);
7185 return "$res->{qemu}->{major}.$res->{qemu}->{minor}";
7188 sub qemu_machine_feature_enabled
{
7189 my ($machine, $kvmver, $version_major, $version_minor) = @_;
7194 if ($machine && $machine =~ m/^((?:pc(-i440fx|-q35)?|virt)-(\d+)\.(\d+))/) {
7196 $current_major = $3;
7197 $current_minor = $4;
7199 } elsif ($kvmver =~ m/^(\d+)\.(\d+)/) {
7201 $current_major = $1;
7202 $current_minor = $2;
7205 return 1 if $current_major > $version_major ||
7206 ($current_major == $version_major &&
7207 $current_minor >= $version_minor);
7210 sub qemu_machine_pxe
{
7211 my ($vmid, $conf) = @_;
7213 my $machine = PVE
::QemuServer
::get_current_qemu_machine
($vmid);
7215 if ($conf->{machine
} && $conf->{machine
} =~ m/\.pxe$/) {
7222 sub qemu_use_old_bios_files
{
7223 my ($machine_type) = @_;
7225 return if !$machine_type;
7227 my $use_old_bios_files = undef;
7229 if ($machine_type =~ m/^(\S+)\.pxe$/) {
7231 $use_old_bios_files = 1;
7233 my $kvmver = kvm_user_version
();
7234 # Note: kvm version < 2.4 use non-efi pxe files, and have problems when we
7235 # load new efi bios files on migration. So this hack is required to allow
7236 # live migration from qemu-2.2 to qemu-2.4, which is sometimes used when
7237 # updrading from proxmox-ve-3.X to proxmox-ve 4.0
7238 $use_old_bios_files = !qemu_machine_feature_enabled
($machine_type, $kvmver, 2, 4);
7241 return ($use_old_bios_files, $machine_type);
7244 sub create_efidisk
($$$$$) {
7245 my ($storecfg, $storeid, $vmid, $fmt, $arch) = @_;
7247 my (undef, $ovmf_vars) = get_ovmf_files
($arch);
7248 die "EFI vars default image not found\n" if ! -f
$ovmf_vars;
7250 my $vars_size = PVE
::Tools
::convert_size
(-s
$ovmf_vars, 'b' => 'kb');
7251 my $volid = PVE
::Storage
::vdisk_alloc
($storecfg, $storeid, $vmid, $fmt, undef, $vars_size);
7252 PVE
::Storage
::activate_volumes
($storecfg, [$volid]);
7254 my $path = PVE
::Storage
::path
($storecfg, $volid);
7256 run_command
(['/usr/bin/qemu-img', 'convert', '-n', '-f', 'raw', '-O', $fmt, $ovmf_vars, $path]);
7258 die "Copying EFI vars image failed: $@" if $@;
7260 return ($volid, $vars_size);
7263 sub vm_iothreads_list
{
7266 my $res = vm_mon_cmd
($vmid, 'query-iothreads');
7269 foreach my $iothread (@$res) {
7270 $iothreads->{ $iothread->{id
} } = $iothread->{"thread-id"};
7277 my ($conf, $drive) = @_;
7281 if (!$conf->{scsihw
} || ($conf->{scsihw
} =~ m/^lsi/)) {
7283 } elsif ($conf->{scsihw
} && ($conf->{scsihw
} eq 'virtio-scsi-single')) {
7289 my $controller = int($drive->{index} / $maxdev);
7290 my $controller_prefix = ($conf->{scsihw
} && $conf->{scsihw
} eq 'virtio-scsi-single') ?
"virtioscsi" : "scsihw";
7292 return ($maxdev, $controller, $controller_prefix);
7295 sub add_hyperv_enlightenments
{
7296 my ($cpuFlags, $winversion, $machine_type, $kvmver, $bios, $gpu_passthrough, $hv_vendor_id) = @_;
7298 return if $winversion < 6;
7299 return if $bios && $bios eq 'ovmf' && $winversion < 8;
7301 if ($gpu_passthrough || defined($hv_vendor_id)) {
7302 $hv_vendor_id //= 'proxmox';
7303 push @$cpuFlags , "hv_vendor_id=$hv_vendor_id";
7306 if (qemu_machine_feature_enabled
($machine_type, $kvmver, 2, 3)) {
7307 push @$cpuFlags , 'hv_spinlocks=0x1fff';
7308 push @$cpuFlags , 'hv_vapic';
7309 push @$cpuFlags , 'hv_time';
7311 push @$cpuFlags , 'hv_spinlocks=0xffff';
7314 if (qemu_machine_feature_enabled
($machine_type, $kvmver, 2, 6)) {
7315 push @$cpuFlags , 'hv_reset';
7316 push @$cpuFlags , 'hv_vpindex';
7317 push @$cpuFlags , 'hv_runtime';
7320 if ($winversion >= 7) {
7321 push @$cpuFlags , 'hv_relaxed';
7323 if (qemu_machine_feature_enabled
($machine_type, $kvmver, 2, 12)) {
7324 push @$cpuFlags , 'hv_synic';
7325 push @$cpuFlags , 'hv_stimer';
7328 if (qemu_machine_feature_enabled
($machine_type, $kvmver, 3, 1)) {
7329 push @$cpuFlags , 'hv_ipi';
7334 sub windows_version
{
7337 return 0 if !$ostype;
7341 if($ostype eq 'wxp' || $ostype eq 'w2k3' || $ostype eq 'w2k') {
7343 } elsif($ostype eq 'w2k8' || $ostype eq 'wvista') {
7345 } elsif ($ostype =~ m/^win(\d+)$/) {
7352 sub resolve_dst_disk_format
{
7353 my ($storecfg, $storeid, $src_volname, $format) = @_;
7354 my ($defFormat, $validFormats) = PVE
::Storage
::storage_default_format
($storecfg, $storeid);
7357 # if no target format is specified, use the source disk format as hint
7359 my $scfg = PVE
::Storage
::storage_config
($storecfg, $storeid);
7360 $format = qemu_img_format
($scfg, $src_volname);
7366 # test if requested format is supported - else use default
7367 my $supported = grep { $_ eq $format } @$validFormats;
7368 $format = $defFormat if !$supported;
7372 sub resolve_first_disk
{
7374 my @disks = PVE
::QemuServer
::valid_drive_names
();
7376 foreach my $ds (reverse @disks) {
7377 next if !$conf->{$ds};
7378 my $disk = PVE
::QemuServer
::parse_drive
($ds, $conf->{$ds});
7379 next if PVE
::QemuServer
::drive_is_cdrom
($disk);
7386 my ($uuid, $uuid_str);
7387 UUID
::generate
($uuid);
7388 UUID
::unparse
($uuid, $uuid_str);
7392 sub generate_smbios1_uuid
{
7393 return "uuid=".generate_uuid
();
7399 vm_mon_cmd
($vmid, 'nbd-server-stop');
7402 # bash completion helper
7404 sub complete_backup_archives
{
7405 my ($cmdname, $pname, $cvalue) = @_;
7407 my $cfg = PVE
::Storage
::config
();
7411 if ($cvalue =~ m/^([^:]+):/) {
7415 my $data = PVE
::Storage
::template_list
($cfg, $storeid, 'backup');
7418 foreach my $id (keys %$data) {
7419 foreach my $item (@{$data->{$id}}) {
7420 next if $item->{format
} !~ m/^vma\.(gz|lzo)$/;
7421 push @$res, $item->{volid
} if defined($item->{volid
});
7428 my $complete_vmid_full = sub {
7431 my $idlist = vmstatus
();
7435 foreach my $id (keys %$idlist) {
7436 my $d = $idlist->{$id};
7437 if (defined($running)) {
7438 next if $d->{template
};
7439 next if $running && $d->{status
} ne 'running';
7440 next if !$running && $d->{status
} eq 'running';
7449 return &$complete_vmid_full();
7452 sub complete_vmid_stopped
{
7453 return &$complete_vmid_full(0);
7456 sub complete_vmid_running
{
7457 return &$complete_vmid_full(1);
7460 sub complete_storage
{
7462 my $cfg = PVE
::Storage
::config
();
7463 my $ids = $cfg->{ids
};
7466 foreach my $sid (keys %$ids) {
7467 next if !PVE
::Storage
::storage_check_enabled
($cfg, $sid, undef, 1);
7468 next if !$ids->{$sid}->{content
}->{images
};