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 $cpu_flag = qr/[+-](pcid|spec-ctrl|ibpb|ssbd|virt-ssbd|amd-ssbd|amd-no-ssb|pdpe1gb|md-clear)/;
174 description
=> "Emulated CPU type.",
176 enum
=> [ sort { "\L$a" cmp "\L$b" } keys %$cpu_vendor_list ],
181 description
=> "Do not identify as a KVM virtual machine.",
188 pattern
=> qr/[a-zA-Z0-9]{1,12}/,
189 format_description
=> 'vendor-id',
190 description
=> 'The Hyper-V vendor ID. Some drivers or programs inside Windows guests need a specific ID.',
194 description
=> "List of additional CPU flags separated by ';'."
195 . " Use '+FLAG' to enable, '-FLAG' to disable a flag."
196 . " Currently supported flags: 'pcid', 'spec-ctrl', 'ibpb', 'ssbd', 'virt-ssbd', 'amd-ssbd', 'amd-no-ssb', 'pdpe1gb', 'md-clear'.",
197 format_description
=> '+FLAG[;-FLAG...]',
199 pattern
=> qr/$cpu_flag(;$cpu_flag)*/,
208 enum
=> [qw(i6300esb ib700)],
209 description
=> "Watchdog type to emulate.",
210 default => 'i6300esb',
215 enum
=> [qw(reset shutdown poweroff pause debug none)],
216 description
=> "The action to perform if after activation the guest fails to poll the watchdog in time.",
220 PVE
::JSONSchema
::register_format
('pve-qm-watchdog', $watchdog_fmt);
224 description
=> "Enable/disable Qemu GuestAgent.",
229 fstrim_cloned_disks
=> {
230 description
=> "Run fstrim after cloning/moving a disk.",
239 description
=> "Select the VGA type.",
244 enum
=> [qw(cirrus qxl qxl2 qxl3 qxl4 none serial0 serial1 serial2 serial3 std virtio vmware)],
247 description
=> "Sets the VGA memory (in MiB). Has no effect with serial display.",
259 description
=> "The size of the file in MB.",
263 pattern
=> '[a-zA-Z0-9\-]+',
265 format_description
=> 'string',
266 description
=> "The name of the file. Will be prefixed with 'pve-shm-'. Default is the VMID. Will be deleted when the VM is stopped.",
274 description
=> "Specifies whether a VM will be started during system bootup.",
280 description
=> "Automatic restart after crash (currently ignored).",
285 type
=> 'string', format
=> 'pve-hotplug-features',
286 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'.",
287 default => 'network,disk,usb',
292 description
=> "Allow reboot. If set to '0' the VM exit on reboot.",
298 description
=> "Lock/unlock the VM.",
299 enum
=> [qw(backup clone create migrate rollback snapshot snapshot-delete suspending suspended)],
304 description
=> "Limit of CPU usage.",
305 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.",
313 description
=> "CPU weight for a VM.",
314 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.",
322 description
=> "Amount of RAM for the VM in MB. This is the maximum available memory when you use the balloon device.",
329 description
=> "Amount of target RAM for the VM in MB. Using zero disables the ballon driver.",
335 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.",
343 description
=> "Keybord layout for vnc server. Default is read from the '/etc/pve/datacenter.cfg' configuration file.".
344 "It should not be necessary to set it.",
345 enum
=> PVE
::Tools
::kvmkeymaplist
(),
350 type
=> 'string', format
=> 'dns-name',
351 description
=> "Set a name for the VM. Only used on the configuration web interface.",
356 description
=> "SCSI controller model",
357 enum
=> [qw(lsi lsi53c810 virtio-scsi-pci virtio-scsi-single megasas pvscsi)],
363 description
=> "Description for the VM. Only used on the configuration web interface. This is saved as comment inside the configuration file.",
368 enum
=> [qw(other wxp w2k w2k3 w2k8 wvista win7 win8 win10 l24 l26 solaris)],
369 description
=> "Specify guest operating system.",
370 verbose_description
=> <<EODESC,
371 Specify guest operating system. This is used to enable special
372 optimization/features for specific operating systems:
375 other;; unspecified OS
376 wxp;; Microsoft Windows XP
377 w2k;; Microsoft Windows 2000
378 w2k3;; Microsoft Windows 2003
379 w2k8;; Microsoft Windows 2008
380 wvista;; Microsoft Windows Vista
381 win7;; Microsoft Windows 7
382 win8;; Microsoft Windows 8/2012/2012r2
383 win10;; Microsoft Windows 10/2016
384 l24;; Linux 2.4 Kernel
385 l26;; Linux 2.6/3.X Kernel
386 solaris;; Solaris/OpenSolaris/OpenIndiania kernel
392 description
=> "Boot on floppy (a), hard disk (c), CD-ROM (d), or network (n).",
393 pattern
=> '[acdn]{1,4}',
398 type
=> 'string', format
=> 'pve-qm-bootdisk',
399 description
=> "Enable booting from specified disk.",
400 pattern
=> '(ide|sata|scsi|virtio)\d+',
405 description
=> "The number of CPUs. Please use option -sockets instead.",
412 description
=> "The number of CPU sockets.",
419 description
=> "The number of cores per socket.",
426 description
=> "Enable/disable NUMA.",
432 description
=> "Enable/disable hugepages memory.",
433 enum
=> [qw(any 2 1024)],
438 description
=> "Number of hotplugged vcpus.",
445 description
=> "Enable/disable ACPI.",
450 description
=> "Enable/disable Qemu GuestAgent and its properties.",
452 format
=> $agent_fmt,
457 description
=> "Enable/disable KVM hardware virtualization.",
463 description
=> "Enable/disable time drift fix.",
469 description
=> "Set the real time clock to local time. This is enabled by default if ostype indicates a Microsoft OS.",
474 description
=> "Freeze CPU at startup (use 'c' monitor command to start execution).",
478 type
=> 'string', format
=> $vga_fmt,
479 description
=> "Configure the VGA hardware.",
480 verbose_description
=> "Configure the VGA Hardware. If you want to use ".
481 "high resolution modes (>= 1280x1024x16) you may need to increase " .
482 "the vga memory option. Since QEMU 2.9 the default VGA display type " .
483 "is 'std' for all OS types besides some Windows versions (XP and " .
484 "older) which use 'cirrus'. The 'qxl' option enables the SPICE " .
485 "display server. For win* OS you can select how many independent " .
486 "displays you want, Linux guests can add displays them self.\n".
487 "You can also run without any graphic card, using a serial device as terminal.",
491 type
=> 'string', format
=> 'pve-qm-watchdog',
492 description
=> "Create a virtual hardware watchdog device.",
493 verbose_description
=> "Create a virtual hardware watchdog device. Once enabled" .
494 " (by a guest action), the watchdog must be periodically polled " .
495 "by an agent inside the guest or else the watchdog will reset " .
496 "the guest (or execute the respective action specified)",
501 typetext
=> "(now | YYYY-MM-DD | YYYY-MM-DDTHH:MM:SS)",
502 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'.",
503 pattern
=> '(now|\d{4}-\d{1,2}-\d{1,2}(T\d{1,2}:\d{1,2}:\d{1,2})?)',
506 startup
=> get_standard_option
('pve-startup-order'),
510 description
=> "Enable/disable Template.",
516 description
=> "Arbitrary arguments passed to kvm.",
517 verbose_description
=> <<EODESCR,
518 Arbitrary arguments passed to kvm, for example:
520 args: -no-reboot -no-hpet
522 NOTE: this option is for experts only.
529 description
=> "Enable/disable the USB tablet device.",
530 verbose_description
=> "Enable/disable the USB tablet device. This device is " .
531 "usually needed to allow absolute mouse positioning with VNC. " .
532 "Else the mouse runs out of sync with normal VNC clients. " .
533 "If you're running lots of console-only guests on one host, " .
534 "you may consider disabling this to save some context switches. " .
535 "This is turned off by default if you use spice (-vga=qxl).",
540 description
=> "Set maximum speed (in MB/s) for migrations. Value 0 is no limit.",
544 migrate_downtime
=> {
547 description
=> "Set maximum tolerated downtime (in seconds) for migrations.",
553 type
=> 'string', format
=> 'pve-qm-ide',
554 typetext
=> '<volume>',
555 description
=> "This is an alias for option -ide2",
559 description
=> "Emulated CPU type.",
563 parent
=> get_standard_option
('pve-snapshot-name', {
565 description
=> "Parent snapshot name. This is used internally, and should not be modified.",
569 description
=> "Timestamp for snapshots.",
575 type
=> 'string', format
=> 'pve-volume-id',
576 description
=> "Reference to a volume which stores the VM state. This is used internally for snapshots.",
578 vmstatestorage
=> get_standard_option
('pve-storage-id', {
579 description
=> "Default storage for VM state volumes/files.",
582 runningmachine
=> get_standard_option
('pve-qemu-machine', {
583 description
=> "Specifies the Qemu machine type of the running vm. This is used internally for snapshots.",
585 machine
=> get_standard_option
('pve-qemu-machine'),
587 description
=> "Virtual processor architecture. Defaults to the host.",
590 enum
=> [qw(x86_64 aarch64)],
593 description
=> "Specify SMBIOS type 1 fields.",
594 type
=> 'string', format
=> 'pve-qm-smbios1',
601 description
=> "Sets the protection flag of the VM. This will disable the remove VM and remove disk operations.",
607 enum
=> [ qw(seabios ovmf) ],
608 description
=> "Select BIOS implementation.",
609 default => 'seabios',
613 pattern
=> '(?:[a-fA-F0-9]{8}(?:-[a-fA-F0-9]{4}){3}-[a-fA-F0-9]{12}|[01])',
614 format_description
=> 'UUID',
615 description
=> "Set VM Generation ID. Use '1' to autogenerate on create or update, pass '0' to disable explicitly.",
616 verbose_description
=> "The VM generation ID (vmgenid) device exposes a".
617 " 128-bit integer value identifier to the guest OS. This allows to".
618 " notify the guest operating system when the virtual machine is".
619 " executed with a different configuration (e.g. snapshot execution".
620 " or creation from a template). The guest operating system notices".
621 " the change, and is then able to react as appropriate by marking".
622 " its copies of distributed databases as dirty, re-initializing its".
623 " random number generator, etc.\n".
624 "Note that auto-creation only works when done throug API/CLI create".
625 " or update methods, but not when manually editing the config file.",
626 default => "1 (autogenerated)",
631 format
=> 'pve-volume-id',
633 description
=> "Script that will be executed during various steps in the vms lifetime.",
637 format
=> $ivshmem_fmt,
638 description
=> "Inter-VM shared memory. Useful for direct communication between VMs, or to the host.",
647 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.',
648 format
=> 'pve-volume-id',
649 format_description
=> 'volume',
654 description
=> 'Specify a custom file containing all network data passed to the VM via cloud-init.',
655 format
=> 'pve-volume-id',
656 format_description
=> 'volume',
661 description
=> 'Specify a custom file containing all user data passed to the VM via cloud-init.',
662 format
=> 'pve-volume-id',
663 format_description
=> 'volume',
666 PVE
::JSONSchema
::register_format
('pve-qm-cicustom', $cicustom_fmt);
668 my $confdesc_cloudinit = {
672 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.',
673 enum
=> ['configdrive2', 'nocloud'],
678 description
=> "cloud-init: User name to change ssh keys and password for instead of the image's configured default user.",
683 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.',
688 description
=> 'cloud-init: Specify custom files to replace the automatically generated ones at start.',
689 format
=> 'pve-qm-cicustom',
694 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.",
698 type
=> 'string', format
=> 'address-list',
699 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.",
704 format
=> 'urlencoded',
705 description
=> "cloud-init: Setup public SSH keys (one key per line, OpenSSH format).",
709 # what about other qemu settings ?
711 #machine => 'string',
724 ##soundhw => 'string',
726 while (my ($k, $v) = each %$confdesc) {
727 PVE
::JSONSchema
::register_standard_option
("pve-qm-$k", $v);
730 my $MAX_IDE_DISKS = 4;
731 my $MAX_SCSI_DISKS = 14;
732 my $MAX_VIRTIO_DISKS = 16;
733 my $MAX_SATA_DISKS = 6;
734 my $MAX_USB_DEVICES = 5;
736 my $MAX_UNUSED_DISKS = 256;
737 my $MAX_HOSTPCI_DEVICES = 4;
738 my $MAX_SERIAL_PORTS = 4;
739 my $MAX_PARALLEL_PORTS = 3;
745 pattern
=> qr/\d+(?:-\d+)?(?:;\d+(?:-\d+)?)*/,
746 description
=> "CPUs accessing this NUMA node.",
747 format_description
=> "id[-id];...",
751 description
=> "Amount of memory this NUMA node provides.",
756 pattern
=> qr/\d+(?:-\d+)?(?:;\d+(?:-\d+)?)*/,
757 description
=> "Host NUMA nodes to use.",
758 format_description
=> "id[-id];...",
763 enum
=> [qw(preferred bind interleave)],
764 description
=> "NUMA allocation policy.",
768 PVE
::JSONSchema
::register_format
('pve-qm-numanode', $numa_fmt);
771 type
=> 'string', format
=> $numa_fmt,
772 description
=> "NUMA topology.",
774 PVE
::JSONSchema
::register_standard_option
("pve-qm-numanode", $numadesc);
776 for (my $i = 0; $i < $MAX_NUMA; $i++) {
777 $confdesc->{"numa$i"} = $numadesc;
780 my $nic_model_list = ['rtl8139', 'ne2k_pci', 'e1000', 'pcnet', 'virtio',
781 'ne2k_isa', 'i82551', 'i82557b', 'i82559er', 'vmxnet3',
782 'e1000-82540em', 'e1000-82544gc', 'e1000-82545em'];
783 my $nic_model_list_txt = join(' ', sort @$nic_model_list);
785 my $net_fmt_bridge_descr = <<__EOD__;
786 Bridge to attach the network device to. The Proxmox VE standard bridge
789 If you do not specify a bridge, we create a kvm user (NATed) network
790 device, which provides DHCP and DNS services. The following addresses
797 The DHCP server assign addresses to the guest starting from 10.0.2.15.
801 macaddr
=> get_standard_option
('mac-addr', {
802 description
=> "MAC address. That address must be unique withing your network. This is automatically generated if not specified.",
806 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'.",
807 enum
=> $nic_model_list,
810 (map { $_ => { keyAlias
=> 'model', alias
=> 'macaddr' }} @$nic_model_list),
813 description
=> $net_fmt_bridge_descr,
814 format_description
=> 'bridge',
819 minimum
=> 0, maximum
=> 16,
820 description
=> 'Number of packet queues to be used on the device.',
826 description
=> "Rate limit in mbps (megabytes per second) as floating point number.",
831 minimum
=> 1, maximum
=> 4094,
832 description
=> 'VLAN tag to apply to packets on this interface.',
837 pattern
=> qr/\d+(?:-\d+)?(?:;\d+(?:-\d+)?)*/,
838 description
=> 'VLAN trunks to pass through this interface.',
839 format_description
=> 'vlanid[;vlanid...]',
844 description
=> 'Whether this interface should be protected by the firewall.',
849 description
=> 'Whether this interface should be disconnected (like pulling the plug).',
856 type
=> 'string', format
=> $net_fmt,
857 description
=> "Specify network devices.",
860 PVE
::JSONSchema
::register_standard_option
("pve-qm-net", $netdesc);
865 format
=> 'pve-ipv4-config',
866 format_description
=> 'IPv4Format/CIDR',
867 description
=> 'IPv4 address in CIDR format.',
874 format_description
=> 'GatewayIPv4',
875 description
=> 'Default gateway for IPv4 traffic.',
881 format
=> 'pve-ipv6-config',
882 format_description
=> 'IPv6Format/CIDR',
883 description
=> 'IPv6 address in CIDR format.',
890 format_description
=> 'GatewayIPv6',
891 description
=> 'Default gateway for IPv6 traffic.',
896 PVE
::JSONSchema
::register_format
('pve-qm-ipconfig', $ipconfig_fmt);
899 type
=> 'string', format
=> 'pve-qm-ipconfig',
900 description
=> <<'EODESCR',
901 cloud-init: Specify IP addresses and gateways for the corresponding interface.
903 IP addresses use CIDR notation, gateways are optional but need an IP of the same type specified.
905 The special string 'dhcp' can be used for IP addresses to use DHCP, in which case no explicit gateway should be provided.
906 For IPv6 the special string 'auto' can be used to use stateless autoconfiguration.
908 If cloud-init is enabled and neither an IPv4 nor an IPv6 address is specified, it defaults to using dhcp on IPv4.
911 PVE
::JSONSchema
::register_standard_option
("pve-qm-ipconfig", $netdesc);
913 for (my $i = 0; $i < $MAX_NETS; $i++) {
914 $confdesc->{"net$i"} = $netdesc;
915 $confdesc_cloudinit->{"ipconfig$i"} = $ipconfigdesc;
918 foreach my $key (keys %$confdesc_cloudinit) {
919 $confdesc->{$key} = $confdesc_cloudinit->{$key};
922 PVE
::JSONSchema
::register_format
('pve-volume-id-or-qm-path', \
&verify_volume_id_or_qm_path
);
923 sub verify_volume_id_or_qm_path
{
924 my ($volid, $noerr) = @_;
926 if ($volid eq 'none' || $volid eq 'cdrom' || $volid =~ m
|^/|) {
930 # if its neither 'none' nor 'cdrom' nor a path, check if its a volume-id
931 $volid = eval { PVE
::JSONSchema
::check_format
('pve-volume-id', $volid, '') };
933 return undef if $noerr;
941 my %drivedesc_base = (
942 volume
=> { alias
=> 'file' },
945 format
=> 'pve-volume-id-or-qm-path',
947 format_description
=> 'volume',
948 description
=> "The drive's backing volume.",
952 enum
=> [qw(cdrom disk)],
953 description
=> "The drive's media type.",
959 description
=> "Force the drive's physical geometry to have a specific cylinder count.",
964 description
=> "Force the drive's physical geometry to have a specific head count.",
969 description
=> "Force the drive's physical geometry to have a specific sector count.",
974 enum
=> [qw(none lba auto)],
975 description
=> "Force disk geometry bios translation mode.",
980 description
=> "Controls qemu's snapshot mode feature."
981 . " If activated, changes made to the disk are temporary and will"
982 . " be discarded when the VM is shutdown.",
987 enum
=> [qw(none writethrough writeback unsafe directsync)],
988 description
=> "The drive's cache mode",
991 format
=> get_standard_option
('pve-qm-image-format'),
994 format
=> 'disk-size',
995 format_description
=> 'DiskSize',
996 description
=> "Disk size. This is purely informational and has no effect.",
1001 description
=> "Whether the drive should be included when making backups.",
1006 description
=> 'Whether the drive should considered for replication jobs.',
1012 enum
=> [qw(ignore report stop)],
1013 description
=> 'Read error action.',
1018 enum
=> [qw(enospc ignore report stop)],
1019 description
=> 'Write error action.',
1024 enum
=> [qw(native threads)],
1025 description
=> 'AIO type to use.',
1030 enum
=> [qw(ignore on)],
1031 description
=> 'Controls whether to pass discard/trim requests to the underlying storage.',
1036 description
=> 'Controls whether to detect and try to optimize writes of zeroes.',
1041 format
=> 'urlencoded',
1042 format_description
=> 'serial',
1043 maxLength
=> 20*3, # *3 since it's %xx url enoded
1044 description
=> "The drive's reported serial number, url-encoded, up to 20 bytes long.",
1049 description
=> 'Mark this locally-managed volume as available on all nodes',
1050 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!",
1056 my %iothread_fmt = ( iothread
=> {
1058 description
=> "Whether to use iothreads for this drive",
1065 format
=> 'urlencoded',
1066 format_description
=> 'model',
1067 maxLength
=> 40*3, # *3 since it's %xx url enoded
1068 description
=> "The drive's reported model name, url-encoded, up to 40 bytes long.",
1076 description
=> "Number of queues.",
1082 my %scsiblock_fmt = (
1085 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",
1094 description
=> "Whether to expose this drive as an SSD, rather than a rotational hard disk.",
1102 pattern
=> qr/^(0x)[0-9a-fA-F]{16}/,
1103 format_description
=> 'wwn',
1104 description
=> "The drive's worldwide name, encoded as 16 bytes hex string, prefixed by '0x'.",
1109 my $add_throttle_desc = sub {
1110 my ($key, $type, $what, $unit, $longunit, $minimum) = @_;
1113 format_description
=> $unit,
1114 description
=> "Maximum $what in $longunit.",
1117 $d->{minimum
} = $minimum if defined($minimum);
1118 $drivedesc_base{$key} = $d;
1120 # throughput: (leaky bucket)
1121 $add_throttle_desc->('bps', 'integer', 'r/w speed', 'bps', 'bytes per second');
1122 $add_throttle_desc->('bps_rd', 'integer', 'read speed', 'bps', 'bytes per second');
1123 $add_throttle_desc->('bps_wr', 'integer', 'write speed', 'bps', 'bytes per second');
1124 $add_throttle_desc->('mbps', 'number', 'r/w speed', 'mbps', 'megabytes per second');
1125 $add_throttle_desc->('mbps_rd', 'number', 'read speed', 'mbps', 'megabytes per second');
1126 $add_throttle_desc->('mbps_wr', 'number', 'write speed', 'mbps', 'megabytes per second');
1127 $add_throttle_desc->('iops', 'integer', 'r/w I/O', 'iops', 'operations per second');
1128 $add_throttle_desc->('iops_rd', 'integer', 'read I/O', 'iops', 'operations per second');
1129 $add_throttle_desc->('iops_wr', 'integer', 'write I/O', 'iops', 'operations per second');
1131 # pools: (pool of IO before throttling starts taking effect)
1132 $add_throttle_desc->('mbps_max', 'number', 'unthrottled r/w pool', 'mbps', 'megabytes per second');
1133 $add_throttle_desc->('mbps_rd_max', 'number', 'unthrottled read pool', 'mbps', 'megabytes per second');
1134 $add_throttle_desc->('mbps_wr_max', 'number', 'unthrottled write pool', 'mbps', 'megabytes per second');
1135 $add_throttle_desc->('iops_max', 'integer', 'unthrottled r/w I/O pool', 'iops', 'operations per second');
1136 $add_throttle_desc->('iops_rd_max', 'integer', 'unthrottled read I/O pool', 'iops', 'operations per second');
1137 $add_throttle_desc->('iops_wr_max', 'integer', 'unthrottled write I/O pool', 'iops', 'operations per second');
1140 $add_throttle_desc->('bps_max_length', 'integer', 'length of I/O bursts', 'seconds', 'seconds', 1);
1141 $add_throttle_desc->('bps_rd_max_length', 'integer', 'length of read I/O bursts', 'seconds', 'seconds', 1);
1142 $add_throttle_desc->('bps_wr_max_length', 'integer', 'length of write I/O bursts', 'seconds', 'seconds', 1);
1143 $add_throttle_desc->('iops_max_length', 'integer', 'length of I/O bursts', 'seconds', 'seconds', 1);
1144 $add_throttle_desc->('iops_rd_max_length', 'integer', 'length of read I/O bursts', 'seconds', 'seconds', 1);
1145 $add_throttle_desc->('iops_wr_max_length', 'integer', 'length of write I/O bursts', 'seconds', 'seconds', 1);
1148 $drivedesc_base{'bps_rd_length'} = { alias
=> 'bps_rd_max_length' };
1149 $drivedesc_base{'bps_wr_length'} = { alias
=> 'bps_wr_max_length' };
1150 $drivedesc_base{'iops_rd_length'} = { alias
=> 'iops_rd_max_length' };
1151 $drivedesc_base{'iops_wr_length'} = { alias
=> 'iops_wr_max_length' };
1159 PVE
::JSONSchema
::register_format
("pve-qm-ide", $ide_fmt);
1163 type
=> 'string', format
=> $ide_fmt,
1164 description
=> "Use volume as IDE hard disk or CD-ROM (n is 0 to " .($MAX_IDE_DISKS -1) . ").",
1166 PVE
::JSONSchema
::register_standard_option
("pve-qm-ide", $idedesc);
1178 type
=> 'string', format
=> $scsi_fmt,
1179 description
=> "Use volume as SCSI hard disk or CD-ROM (n is 0 to " . ($MAX_SCSI_DISKS - 1) . ").",
1181 PVE
::JSONSchema
::register_standard_option
("pve-qm-scsi", $scsidesc);
1190 type
=> 'string', format
=> $sata_fmt,
1191 description
=> "Use volume as SATA hard disk or CD-ROM (n is 0 to " . ($MAX_SATA_DISKS - 1). ").",
1193 PVE
::JSONSchema
::register_standard_option
("pve-qm-sata", $satadesc);
1201 type
=> 'string', format
=> $virtio_fmt,
1202 description
=> "Use volume as VIRTIO hard disk (n is 0 to " . ($MAX_VIRTIO_DISKS - 1) . ").",
1204 PVE
::JSONSchema
::register_standard_option
("pve-qm-virtio", $virtiodesc);
1206 my $alldrive_fmt = {
1217 volume
=> { alias
=> 'file' },
1220 format
=> 'pve-volume-id-or-qm-path',
1222 format_description
=> 'volume',
1223 description
=> "The drive's backing volume.",
1225 format
=> get_standard_option
('pve-qm-image-format'),
1228 format
=> 'disk-size',
1229 format_description
=> 'DiskSize',
1230 description
=> "Disk size. This is purely informational and has no effect.",
1235 my $efidisk_desc = {
1237 type
=> 'string', format
=> $efidisk_fmt,
1238 description
=> "Configure a Disk for storing EFI vars",
1241 PVE
::JSONSchema
::register_standard_option
("pve-qm-efidisk", $efidisk_desc);
1246 type
=> 'string', format
=> 'pve-qm-usb-device',
1247 format_description
=> 'HOSTUSBDEVICE|spice',
1248 description
=> <<EODESCR,
1249 The Host USB device or port or the value 'spice'. HOSTUSBDEVICE syntax is:
1251 'bus-port(.port)*' (decimal numbers) or
1252 'vendor_id:product_id' (hexadeciaml numbers) or
1255 You can use the 'lsusb -t' command to list existing usb devices.
1257 NOTE: This option allows direct access to host hardware. So it is no longer possible to migrate such machines - use with special care.
1259 The value 'spice' can be used to add a usb redirection devices for spice.
1265 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).",
1272 type
=> 'string', format
=> $usb_fmt,
1273 description
=> "Configure an USB device (n is 0 to 4).",
1275 PVE
::JSONSchema
::register_standard_option
("pve-qm-usb", $usbdesc);
1277 my $PCIRE = qr/[a-f0-9]{2}:[a-f0-9]{2}(?:\.[a-f0-9])?/;
1282 pattern
=> qr/$PCIRE(;$PCIRE)*/,
1283 format_description
=> 'HOSTPCIID[;HOSTPCIID2...]',
1284 description
=> <<EODESCR,
1285 Host PCI device pass through. The PCI ID of a host's PCI device or a list
1286 of PCI virtual functions of the host. HOSTPCIID syntax is:
1288 'bus:dev.func' (hexadecimal numbers)
1290 You can us the 'lspci' command to list existing PCI devices.
1295 description
=> "Specify whether or not the device's ROM will be visible in the guest's memory map.",
1301 pattern
=> '[^,;]+',
1302 format_description
=> 'string',
1303 description
=> "Custom pci device rom filename (must be located in /usr/share/kvm/).",
1308 description
=> "Choose the PCI-express bus (needs the 'q35' machine model).",
1314 description
=> "Enable vfio-vga device support.",
1320 format_description
=> 'string',
1321 pattern
=> '[^/\.:]+',
1323 description
=> <<EODESCR
1324 The type of mediated device to use.
1325 An instance of this type will be created on startup of the VM and
1326 will be cleaned up when the VM stops.
1330 PVE
::JSONSchema
::register_format
('pve-qm-hostpci', $hostpci_fmt);
1334 type
=> 'string', format
=> 'pve-qm-hostpci',
1335 description
=> "Map host PCI devices into guest.",
1336 verbose_description
=> <<EODESCR,
1337 Map host PCI devices into guest.
1339 NOTE: This option allows direct access to host hardware. So it is no longer
1340 possible to migrate such machines - use with special care.
1342 CAUTION: Experimental! User reported problems with this option.
1345 PVE
::JSONSchema
::register_standard_option
("pve-qm-hostpci", $hostpcidesc);
1350 pattern
=> '(/dev/.+|socket)',
1351 description
=> "Create a serial device inside the VM (n is 0 to 3)",
1352 verbose_description
=> <<EODESCR,
1353 Create a serial device inside the VM (n is 0 to 3), and pass through a
1354 host serial device (i.e. /dev/ttyS0), or create a unix socket on the
1355 host side (use 'qm terminal' to open a terminal connection).
1357 NOTE: If you pass through a host serial device, it is no longer possible to migrate such machines - use with special care.
1359 CAUTION: Experimental! User reported problems with this option.
1366 pattern
=> '/dev/parport\d+|/dev/usb/lp\d+',
1367 description
=> "Map host parallel devices (n is 0 to 2).",
1368 verbose_description
=> <<EODESCR,
1369 Map host parallel devices (n is 0 to 2).
1371 NOTE: This option allows direct access to host hardware. So it is no longer possible to migrate such machines - use with special care.
1373 CAUTION: Experimental! User reported problems with this option.
1377 for (my $i = 0; $i < $MAX_PARALLEL_PORTS; $i++) {
1378 $confdesc->{"parallel$i"} = $paralleldesc;
1381 for (my $i = 0; $i < $MAX_SERIAL_PORTS; $i++) {
1382 $confdesc->{"serial$i"} = $serialdesc;
1385 for (my $i = 0; $i < $MAX_HOSTPCI_DEVICES; $i++) {
1386 $confdesc->{"hostpci$i"} = $hostpcidesc;
1389 for (my $i = 0; $i < $MAX_IDE_DISKS; $i++) {
1390 $drivename_hash->{"ide$i"} = 1;
1391 $confdesc->{"ide$i"} = $idedesc;
1394 for (my $i = 0; $i < $MAX_SATA_DISKS; $i++) {
1395 $drivename_hash->{"sata$i"} = 1;
1396 $confdesc->{"sata$i"} = $satadesc;
1399 for (my $i = 0; $i < $MAX_SCSI_DISKS; $i++) {
1400 $drivename_hash->{"scsi$i"} = 1;
1401 $confdesc->{"scsi$i"} = $scsidesc ;
1404 for (my $i = 0; $i < $MAX_VIRTIO_DISKS; $i++) {
1405 $drivename_hash->{"virtio$i"} = 1;
1406 $confdesc->{"virtio$i"} = $virtiodesc;
1409 $drivename_hash->{efidisk0
} = 1;
1410 $confdesc->{efidisk0
} = $efidisk_desc;
1412 for (my $i = 0; $i < $MAX_USB_DEVICES; $i++) {
1413 $confdesc->{"usb$i"} = $usbdesc;
1418 type
=> 'string', format
=> 'pve-volume-id',
1419 description
=> "Reference to unused volumes. This is used internally, and should not be modified manually.",
1422 for (my $i = 0; $i < $MAX_UNUSED_DISKS; $i++) {
1423 $confdesc->{"unused$i"} = $unuseddesc;
1426 my $kvm_api_version = 0;
1429 return $kvm_api_version if $kvm_api_version;
1431 open my $fh, '<', '/dev/kvm'
1434 # 0xae00 => KVM_GET_API_VERSION
1435 $kvm_api_version = ioctl($fh, 0xae00, 0);
1437 return $kvm_api_version;
1440 my $kvm_user_version;
1442 sub kvm_user_version
{
1444 return $kvm_user_version if $kvm_user_version;
1446 $kvm_user_version = 'unknown';
1450 if ($line =~ m/^QEMU( PC)? emulator version (\d+\.\d+(\.\d+)?)(\.\d+)?[,\s]/) {
1451 $kvm_user_version = $2;
1455 eval { run_command
("kvm -version", outfunc
=> $code); };
1458 return $kvm_user_version;
1462 sub kernel_has_vhost_net
{
1463 return -c
'/dev/vhost-net';
1466 sub valid_drive_names
{
1467 # order is important - used to autoselect boot disk
1468 return ((map { "ide$_" } (0 .. ($MAX_IDE_DISKS - 1))),
1469 (map { "scsi$_" } (0 .. ($MAX_SCSI_DISKS - 1))),
1470 (map { "virtio$_" } (0 .. ($MAX_VIRTIO_DISKS - 1))),
1471 (map { "sata$_" } (0 .. ($MAX_SATA_DISKS - 1))),
1475 sub is_valid_drivename
{
1478 return defined($drivename_hash->{$dev});
1483 return defined($confdesc->{$key});
1487 return $nic_model_list;
1490 sub os_list_description
{
1494 wxp
=> 'Windows XP',
1495 w2k
=> 'Windows 2000',
1496 w2k3
=>, 'Windows 2003',
1497 w2k8
=> 'Windows 2008',
1498 wvista
=> 'Windows Vista',
1499 win7
=> 'Windows 7',
1500 win8
=> 'Windows 8/2012',
1501 win10
=> 'Windows 10/2016',
1509 sub get_cdrom_path
{
1511 return $cdrom_path if $cdrom_path;
1513 return $cdrom_path = "/dev/cdrom" if -l
"/dev/cdrom";
1514 return $cdrom_path = "/dev/cdrom1" if -l
"/dev/cdrom1";
1515 return $cdrom_path = "/dev/cdrom2" if -l
"/dev/cdrom2";
1519 my ($storecfg, $vmid, $cdrom) = @_;
1521 if ($cdrom eq 'cdrom') {
1522 return get_cdrom_path
();
1523 } elsif ($cdrom eq 'none') {
1525 } elsif ($cdrom =~ m
|^/|) {
1528 return PVE
::Storage
::path
($storecfg, $cdrom);
1532 # try to convert old style file names to volume IDs
1533 sub filename_to_volume_id
{
1534 my ($vmid, $file, $media) = @_;
1536 if (!($file eq 'none' || $file eq 'cdrom' ||
1537 $file =~ m
|^/dev/.+| || $file =~ m/^([^:]+):(.+)$/)) {
1539 return undef if $file =~ m
|/|;
1541 if ($media && $media eq 'cdrom') {
1542 $file = "local:iso/$file";
1544 $file = "local:$vmid/$file";
1551 sub verify_media_type
{
1552 my ($opt, $vtype, $media) = @_;
1557 if ($media eq 'disk') {
1559 } elsif ($media eq 'cdrom') {
1562 die "internal error";
1565 return if ($vtype eq $etype);
1567 raise_param_exc
({ $opt => "unexpected media type ($vtype != $etype)" });
1570 sub cleanup_drive_path
{
1571 my ($opt, $storecfg, $drive) = @_;
1573 # try to convert filesystem paths to volume IDs
1575 if (($drive->{file
} !~ m/^(cdrom|none)$/) &&
1576 ($drive->{file
} !~ m
|^/dev/.+|) &&
1577 ($drive->{file
} !~ m/^([^:]+):(.+)$/) &&
1578 ($drive->{file
} !~ m/^\d+$/)) {
1579 my ($vtype, $volid) = PVE
::Storage
::path_to_volume_id
($storecfg, $drive->{file
});
1580 raise_param_exc
({ $opt => "unable to associate path '$drive->{file}' to any storage"}) if !$vtype;
1581 $drive->{media
} = 'cdrom' if !$drive->{media
} && $vtype eq 'iso';
1582 verify_media_type
($opt, $vtype, $drive->{media
});
1583 $drive->{file
} = $volid;
1586 $drive->{media
} = 'cdrom' if !$drive->{media
} && $drive->{file
} =~ m/^(cdrom|none)$/;
1589 sub parse_hotplug_features
{
1594 return $res if $data eq '0';
1596 $data = $confdesc->{hotplug
}->{default} if $data eq '1';
1598 foreach my $feature (PVE
::Tools
::split_list
($data)) {
1599 if ($feature =~ m/^(network|disk|cpu|memory|usb)$/) {
1602 die "invalid hotplug feature '$feature'\n";
1608 PVE
::JSONSchema
::register_format
('pve-hotplug-features', \
&pve_verify_hotplug_features
);
1609 sub pve_verify_hotplug_features
{
1610 my ($value, $noerr) = @_;
1612 return $value if parse_hotplug_features
($value);
1614 return undef if $noerr;
1616 die "unable to parse hotplug option\n";
1619 # ideX = [volume=]volume-id[,media=d][,cyls=c,heads=h,secs=s[,trans=t]]
1620 # [,snapshot=on|off][,cache=on|off][,format=f][,backup=yes|no]
1621 # [,rerror=ignore|report|stop][,werror=enospc|ignore|report|stop]
1622 # [,aio=native|threads][,discard=ignore|on][,detect_zeroes=on|off]
1623 # [,iothread=on][,serial=serial][,model=model]
1626 my ($key, $data) = @_;
1628 my ($interface, $index);
1630 if ($key =~ m/^([^\d]+)(\d+)$/) {
1637 my $desc = $key =~ /^unused\d+$/ ?
$alldrive_fmt
1638 : $confdesc->{$key}->{format
};
1640 warn "invalid drive key: $key\n";
1643 my $res = eval { PVE
::JSONSchema
::parse_property_string
($desc, $data) };
1644 return undef if !$res;
1645 $res->{interface
} = $interface;
1646 $res->{index} = $index;
1649 foreach my $opt (qw(bps bps_rd bps_wr)) {
1650 if (my $bps = defined(delete $res->{$opt})) {
1651 if (defined($res->{"m$opt"})) {
1652 warn "both $opt and m$opt specified\n";
1656 $res->{"m$opt"} = sprintf("%.3f", $bps / (1024*1024.0));
1660 # can't use the schema's 'requires' because of the mbps* => bps* "transforming aliases"
1661 for my $requirement (
1662 [mbps_max
=> 'mbps'],
1663 [mbps_rd_max
=> 'mbps_rd'],
1664 [mbps_wr_max
=> 'mbps_wr'],
1665 [miops_max
=> 'miops'],
1666 [miops_rd_max
=> 'miops_rd'],
1667 [miops_wr_max
=> 'miops_wr'],
1668 [bps_max_length
=> 'mbps_max'],
1669 [bps_rd_max_length
=> 'mbps_rd_max'],
1670 [bps_wr_max_length
=> 'mbps_wr_max'],
1671 [iops_max_length
=> 'iops_max'],
1672 [iops_rd_max_length
=> 'iops_rd_max'],
1673 [iops_wr_max_length
=> 'iops_wr_max']) {
1674 my ($option, $requires) = @$requirement;
1675 if ($res->{$option} && !$res->{$requires}) {
1676 warn "$option requires $requires\n";
1681 return undef if $error;
1683 return undef if $res->{mbps_rd
} && $res->{mbps
};
1684 return undef if $res->{mbps_wr
} && $res->{mbps
};
1685 return undef if $res->{iops_rd
} && $res->{iops
};
1686 return undef if $res->{iops_wr
} && $res->{iops
};
1688 if ($res->{media
} && ($res->{media
} eq 'cdrom')) {
1689 return undef if $res->{snapshot
} || $res->{trans
} || $res->{format
};
1690 return undef if $res->{heads
} || $res->{secs
} || $res->{cyls
};
1691 return undef if $res->{interface
} eq 'virtio';
1694 if (my $size = $res->{size
}) {
1695 return undef if !defined($res->{size
} = PVE
::JSONSchema
::parse_size
($size));
1702 my ($vmid, $drive) = @_;
1703 my $data = { %$drive };
1704 delete $data->{$_} for qw(index interface);
1705 return PVE
::JSONSchema
::print_property_string
($data, $alldrive_fmt);
1709 my($fh, $noerr) = @_;
1712 my $SG_GET_VERSION_NUM = 0x2282;
1714 my $versionbuf = "\x00" x
8;
1715 my $ret = ioctl($fh, $SG_GET_VERSION_NUM, $versionbuf);
1717 die "scsi ioctl SG_GET_VERSION_NUM failoed - $!\n" if !$noerr;
1720 my $version = unpack("I", $versionbuf);
1721 if ($version < 30000) {
1722 die "scsi generic interface too old\n" if !$noerr;
1726 my $buf = "\x00" x
36;
1727 my $sensebuf = "\x00" x
8;
1728 my $cmd = pack("C x3 C x1", 0x12, 36);
1730 # see /usr/include/scsi/sg.h
1731 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";
1733 my $packet = pack($sg_io_hdr_t, ord('S'), -3, length($cmd),
1734 length($sensebuf), 0, length($buf), $buf,
1735 $cmd, $sensebuf, 6000);
1737 $ret = ioctl($fh, $SG_IO, $packet);
1739 die "scsi ioctl SG_IO failed - $!\n" if !$noerr;
1743 my @res = unpack($sg_io_hdr_t, $packet);
1744 if ($res[17] || $res[18]) {
1745 die "scsi ioctl SG_IO status error - $!\n" if !$noerr;
1750 (my $byte0, my $byte1, $res->{vendor
},
1751 $res->{product
}, $res->{revision
}) = unpack("C C x6 A8 A16 A4", $buf);
1753 $res->{removable
} = $byte1 & 128 ?
1 : 0;
1754 $res->{type
} = $byte0 & 31;
1762 my $fh = IO
::File-
>new("+<$path") || return undef;
1763 my $res = scsi_inquiry
($fh, 1);
1769 sub machine_type_is_q35
{
1772 return $conf->{machine
} && ($conf->{machine
} =~ m/q35/) ?
1 : 0;
1775 sub print_tabletdevice_full
{
1776 my ($conf, $arch) = @_;
1778 my $q35 = machine_type_is_q35
($conf);
1780 # we use uhci for old VMs because tablet driver was buggy in older qemu
1782 if (machine_type_is_q35
($conf) || $arch eq 'aarch64') {
1788 return "usb-tablet,id=tablet,bus=$usbbus.0,port=1";
1791 sub print_keyboarddevice_full
{
1792 my ($conf, $arch, $machine) = @_;
1794 return undef if $arch ne 'aarch64';
1796 return "usb-kbd,id=keyboard,bus=ehci.0,port=2";
1799 sub print_drivedevice_full
{
1800 my ($storecfg, $conf, $vmid, $drive, $bridges, $arch, $machine_type) = @_;
1805 if ($drive->{interface
} eq 'virtio') {
1806 my $pciaddr = print_pci_addr
("$drive->{interface}$drive->{index}", $bridges, $arch, $machine_type);
1807 $device = "virtio-blk-pci,drive=drive-$drive->{interface}$drive->{index},id=$drive->{interface}$drive->{index}$pciaddr";
1808 $device .= ",iothread=iothread-$drive->{interface}$drive->{index}" if $drive->{iothread
};
1809 } elsif ($drive->{interface
} eq 'scsi') {
1811 my ($maxdev, $controller, $controller_prefix) = scsihw_infos
($conf, $drive);
1812 my $unit = $drive->{index} % $maxdev;
1813 my $devicetype = 'hd';
1815 if (drive_is_cdrom
($drive)) {
1818 if ($drive->{file
} =~ m
|^/|) {
1819 $path = $drive->{file
};
1820 if (my $info = path_is_scsi
($path)) {
1821 if ($info->{type
} == 0 && $drive->{scsiblock
}) {
1822 $devicetype = 'block';
1823 } elsif ($info->{type
} == 1) { # tape
1824 $devicetype = 'generic';
1828 $path = PVE
::Storage
::path
($storecfg, $drive->{file
});
1831 if($path =~ m/^iscsi\:\/\
//){
1832 $devicetype = 'generic';
1836 if (!$conf->{scsihw
} || ($conf->{scsihw
} =~ m/^lsi/)){
1837 $device = "scsi-$devicetype,bus=$controller_prefix$controller.0,scsi-id=$unit,drive=drive-$drive->{interface}$drive->{index},id=$drive->{interface}$drive->{index}";
1839 $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}";
1842 if ($drive->{ssd
} && ($devicetype eq 'block' || $devicetype eq 'hd')) {
1843 $device .= ",rotation_rate=1";
1845 $device .= ",wwn=$drive->{wwn}" if $drive->{wwn
};
1847 } elsif ($drive->{interface
} eq 'ide' || $drive->{interface
} eq 'sata') {
1848 my $maxdev = ($drive->{interface
} eq 'sata') ?
$MAX_SATA_DISKS : 2;
1849 my $controller = int($drive->{index} / $maxdev);
1850 my $unit = $drive->{index} % $maxdev;
1851 my $devicetype = ($drive->{media
} && $drive->{media
} eq 'cdrom') ?
"cd" : "hd";
1853 $device = "ide-$devicetype";
1854 if ($drive->{interface
} eq 'ide') {
1855 $device .= ",bus=ide.$controller,unit=$unit";
1857 $device .= ",bus=ahci$controller.$unit";
1859 $device .= ",drive=drive-$drive->{interface}$drive->{index},id=$drive->{interface}$drive->{index}";
1861 if ($devicetype eq 'hd') {
1862 if (my $model = $drive->{model
}) {
1863 $model = URI
::Escape
::uri_unescape
($model);
1864 $device .= ",model=$model";
1866 if ($drive->{ssd
}) {
1867 $device .= ",rotation_rate=1";
1870 $device .= ",wwn=$drive->{wwn}" if $drive->{wwn
};
1871 } elsif ($drive->{interface
} eq 'usb') {
1873 # -device ide-drive,bus=ide.1,unit=0,drive=drive-ide0-1-0,id=ide0-1-0
1875 die "unsupported interface type";
1878 $device .= ",bootindex=$drive->{bootindex}" if $drive->{bootindex
};
1880 if (my $serial = $drive->{serial
}) {
1881 $serial = URI
::Escape
::uri_unescape
($serial);
1882 $device .= ",serial=$serial";
1889 sub get_initiator_name
{
1892 my $fh = IO
::File-
>new('/etc/iscsi/initiatorname.iscsi') || return undef;
1893 while (defined(my $line = <$fh>)) {
1894 next if $line !~ m/^\s*InitiatorName\s*=\s*([\.\-:\w]+)/;
1903 sub print_drive_full
{
1904 my ($storecfg, $vmid, $drive) = @_;
1907 my $volid = $drive->{file
};
1910 if (drive_is_cdrom
($drive)) {
1911 $path = get_iso_path
($storecfg, $vmid, $volid);
1913 my ($storeid, $volname) = PVE
::Storage
::parse_volume_id
($volid, 1);
1915 $path = PVE
::Storage
::path
($storecfg, $volid);
1916 my $scfg = PVE
::Storage
::storage_config
($storecfg, $storeid);
1917 $format = qemu_img_format
($scfg, $volname);
1925 my @qemu_drive_options = qw(heads secs cyls trans media format cache rerror werror aio discard);
1926 foreach my $o (@qemu_drive_options) {
1927 $opts .= ",$o=$drive->{$o}" if defined($drive->{$o});
1930 # snapshot only accepts on|off
1931 if (defined($drive->{snapshot
})) {
1932 my $v = $drive->{snapshot
} ?
'on' : 'off';
1933 $opts .= ",snapshot=$v";
1936 foreach my $type (['', '-total'], [_rd
=> '-read'], [_wr
=> '-write']) {
1937 my ($dir, $qmpname) = @$type;
1938 if (my $v = $drive->{"mbps$dir"}) {
1939 $opts .= ",throttling.bps$qmpname=".int($v*1024*1024);
1941 if (my $v = $drive->{"mbps${dir}_max"}) {
1942 $opts .= ",throttling.bps$qmpname-max=".int($v*1024*1024);
1944 if (my $v = $drive->{"bps${dir}_max_length"}) {
1945 $opts .= ",throttling.bps$qmpname-max-length=$v";
1947 if (my $v = $drive->{"iops${dir}"}) {
1948 $opts .= ",throttling.iops$qmpname=$v";
1950 if (my $v = $drive->{"iops${dir}_max"}) {
1951 $opts .= ",throttling.iops$qmpname-max=$v";
1953 if (my $v = $drive->{"iops${dir}_max_length"}) {
1954 $opts .= ",throttling.iops$qmpname-max-length=$v";
1958 $opts .= ",format=$format" if $format && !$drive->{format
};
1960 my $cache_direct = 0;
1962 if (my $cache = $drive->{cache
}) {
1963 $cache_direct = $cache =~ /^(?:off|none|directsync)$/;
1964 } elsif (!drive_is_cdrom
($drive)) {
1965 $opts .= ",cache=none";
1969 # aio native works only with O_DIRECT
1970 if (!$drive->{aio
}) {
1972 $opts .= ",aio=native";
1974 $opts .= ",aio=threads";
1978 if (!drive_is_cdrom
($drive)) {
1980 if (defined($drive->{detect_zeroes
}) && !$drive->{detect_zeroes
}) {
1981 $detectzeroes = 'off';
1982 } elsif ($drive->{discard
}) {
1983 $detectzeroes = $drive->{discard
} eq 'on' ?
'unmap' : 'on';
1985 # This used to be our default with discard not being specified:
1986 $detectzeroes = 'on';
1988 $opts .= ",detect-zeroes=$detectzeroes" if $detectzeroes;
1991 my $pathinfo = $path ?
"file=$path," : '';
1993 return "${pathinfo}if=none,id=drive-$drive->{interface}$drive->{index}$opts";
1996 sub print_netdevice_full
{
1997 my ($vmid, $conf, $net, $netid, $bridges, $use_old_bios_files, $arch, $machine_type) = @_;
1999 my $bootorder = $conf->{boot
} || $confdesc->{boot
}->{default};
2001 my $device = $net->{model
};
2002 if ($net->{model
} eq 'virtio') {
2003 $device = 'virtio-net-pci';
2006 my $pciaddr = print_pci_addr
("$netid", $bridges, $arch, $machine_type);
2007 my $tmpstr = "$device,mac=$net->{macaddr},netdev=$netid$pciaddr,id=$netid";
2008 if ($net->{queues
} && $net->{queues
} > 1 && $net->{model
} eq 'virtio'){
2009 #Consider we have N queues, the number of vectors needed is 2*N + 2 (plus one config interrupt and control vq)
2010 my $vectors = $net->{queues
} * 2 + 2;
2011 $tmpstr .= ",vectors=$vectors,mq=on";
2013 $tmpstr .= ",bootindex=$net->{bootindex}" if $net->{bootindex
} ;
2015 if ($use_old_bios_files) {
2017 if ($device eq 'virtio-net-pci') {
2018 $romfile = 'pxe-virtio.rom';
2019 } elsif ($device eq 'e1000') {
2020 $romfile = 'pxe-e1000.rom';
2021 } elsif ($device eq 'ne2k') {
2022 $romfile = 'pxe-ne2k_pci.rom';
2023 } elsif ($device eq 'pcnet') {
2024 $romfile = 'pxe-pcnet.rom';
2025 } elsif ($device eq 'rtl8139') {
2026 $romfile = 'pxe-rtl8139.rom';
2028 $tmpstr .= ",romfile=$romfile" if $romfile;
2034 sub print_netdev_full
{
2035 my ($vmid, $conf, $arch, $net, $netid, $hotplug) = @_;
2038 if ($netid =~ m/^net(\d+)$/) {
2042 die "got strange net id '$i'\n" if $i >= ${MAX_NETS
};
2044 my $ifname = "tap${vmid}i$i";
2046 # kvm uses TUNSETIFF ioctl, and that limits ifname length
2047 die "interface name '$ifname' is too long (max 15 character)\n"
2048 if length($ifname) >= 16;
2050 my $vhostparam = '';
2051 if (is_native
($arch)) {
2052 $vhostparam = ',vhost=on' if kernel_has_vhost_net
() && $net->{model
} eq 'virtio';
2055 my $vmname = $conf->{name
} || "vm$vmid";
2058 my $script = $hotplug ?
"pve-bridge-hotplug" : "pve-bridge";
2060 if ($net->{bridge
}) {
2061 $netdev = "type=tap,id=$netid,ifname=${ifname},script=/var/lib/qemu-server/$script,downscript=/var/lib/qemu-server/pve-bridgedown$vhostparam";
2063 $netdev = "type=user,id=$netid,hostname=$vmname";
2066 $netdev .= ",queues=$net->{queues}" if ($net->{queues
} && $net->{model
} eq 'virtio');
2072 sub print_cpu_device
{
2073 my ($conf, $id) = @_;
2075 my $kvm = $conf->{kvm
} // 1;
2076 my $cpu = $kvm ?
"kvm64" : "qemu64";
2077 if (my $cputype = $conf->{cpu
}) {
2078 my $cpuconf = PVE
::JSONSchema
::parse_property_string
($cpu_fmt, $cputype)
2079 or die "Cannot parse cpu description: $cputype\n";
2080 $cpu = $cpuconf->{cputype
};
2083 my $cores = $conf->{cores
} || 1;
2085 my $current_core = ($id - 1) % $cores;
2086 my $current_socket = int(($id - 1 - $current_core)/$cores);
2088 return "$cpu-x86_64-cpu,id=cpu$id,socket-id=$current_socket,core-id=$current_core,thread-id=0";
2092 'cirrus' => 'cirrus-vga',
2094 'vmware' => 'vmware-svga',
2095 'virtio' => 'virtio-vga',
2098 sub print_vga_device
{
2099 my ($conf, $vga, $arch, $machine, $id, $qxlnum, $bridges) = @_;
2101 my $type = $vga_map->{$vga->{type
}};
2102 if ($arch eq 'aarch64' && defined($type) && $type eq 'virtio-vga') {
2103 $type = 'virtio-gpu';
2105 my $vgamem_mb = $vga->{memory
};
2107 $type = $id ?
'qxl' : 'qxl-vga';
2109 die "no devicetype for $vga->{type}\n" if !$type;
2113 if ($vga->{type
} eq 'virtio') {
2114 my $bytes = PVE
::Tools
::convert_size
($vgamem_mb, "mb" => "b");
2115 $memory = ",max_hostmem=$bytes";
2117 # from https://www.spice-space.org/multiple-monitors.html
2118 $memory = ",vgamem_mb=$vga->{memory}";
2119 my $ram = $vgamem_mb * 4;
2120 my $vram = $vgamem_mb * 2;
2121 $memory .= ",ram_size_mb=$ram,vram_size_mb=$vram";
2123 $memory = ",vgamem_mb=$vga->{memory}";
2125 } elsif ($qxlnum && $id) {
2126 $memory = ",ram_size=67108864,vram_size=33554432";
2129 my $q35 = machine_type_is_q35
($conf);
2130 my $vgaid = "vga" . ($id // '');
2133 if ($q35 && $vgaid eq 'vga') {
2134 # the first display uses pcie.0 bus on q35 machines
2135 $pciaddr = print_pcie_addr
($vgaid, $bridges, $arch, $machine);
2137 $pciaddr = print_pci_addr
($vgaid, $bridges, $arch, $machine);
2140 return "$type,id=${vgaid}${memory}${pciaddr}";
2143 sub drive_is_cloudinit
{
2145 return $drive->{file
} =~ m
@[:/]vm-\d
+-cloudinit
(?
:\
.$QEMU_FORMAT_RE)?
$@;
2148 sub drive_is_cdrom
{
2149 my ($drive, $exclude_cloudinit) = @_;
2151 return 0 if $exclude_cloudinit && drive_is_cloudinit
($drive);
2153 return $drive && $drive->{media
} && ($drive->{media
} eq 'cdrom');
2157 sub parse_number_sets
{
2160 foreach my $part (split(/;/, $set)) {
2161 if ($part =~ /^\s*(\d+)(?:-(\d+))?\s*$/) {
2162 die "invalid range: $part ($2 < $1)\n" if defined($2) && $2 < $1;
2163 push @$res, [ $1, $2 ];
2165 die "invalid range: $part\n";
2174 my $res = PVE
::JSONSchema
::parse_property_string
($numa_fmt, $data);
2175 $res->{cpus
} = parse_number_sets
($res->{cpus
}) if defined($res->{cpus
});
2176 $res->{hostnodes
} = parse_number_sets
($res->{hostnodes
}) if defined($res->{hostnodes
});
2183 return undef if !$value;
2185 my $res = PVE
::JSONSchema
::parse_property_string
($hostpci_fmt, $value);
2187 my @idlist = split(/;/, $res->{host
});
2188 delete $res->{host
};
2189 foreach my $id (@idlist) {
2190 if ($id =~ m/\./) { # full id 00:00.1
2191 push @{$res->{pciid
}}, {
2194 } else { # partial id 00:00
2195 $res->{pciid
} = PVE
::SysFSTools
::lspci
($id);
2201 # netX: e1000=XX:XX:XX:XX:XX:XX,bridge=vmbr0,rate=<mbps>
2205 my $res = eval { PVE
::JSONSchema
::parse_property_string
($net_fmt, $data) };
2210 if (!defined($res->{macaddr
})) {
2211 my $dc = PVE
::Cluster
::cfs_read_file
('datacenter.cfg');
2212 $res->{macaddr
} = PVE
::Tools
::random_ether_addr
($dc->{mac_prefix
});
2217 # ipconfigX ip=cidr,gw=ip,ip6=cidr,gw6=ip
2218 sub parse_ipconfig
{
2221 my $res = eval { PVE
::JSONSchema
::parse_property_string
($ipconfig_fmt, $data) };
2227 if ($res->{gw
} && !$res->{ip
}) {
2228 warn 'gateway specified without specifying an IP address';
2231 if ($res->{gw6
} && !$res->{ip6
}) {
2232 warn 'IPv6 gateway specified without specifying an IPv6 address';
2235 if ($res->{gw
} && $res->{ip
} eq 'dhcp') {
2236 warn 'gateway specified together with DHCP';
2239 if ($res->{gw6
} && $res->{ip6
} !~ /^$IPV6RE/) {
2241 warn "IPv6 gateway specified together with $res->{ip6} address";
2245 if (!$res->{ip
} && !$res->{ip6
}) {
2246 return { ip
=> 'dhcp', ip6
=> 'dhcp' };
2255 return PVE
::JSONSchema
::print_property_string
($net, $net_fmt);
2258 sub add_random_macs
{
2259 my ($settings) = @_;
2261 foreach my $opt (keys %$settings) {
2262 next if $opt !~ m/^net(\d+)$/;
2263 my $net = parse_net
($settings->{$opt});
2265 $settings->{$opt} = print_net
($net);
2269 sub vm_is_volid_owner
{
2270 my ($storecfg, $vmid, $volid) = @_;
2272 if ($volid !~ m
|^/|) {
2274 eval { ($path, $owner) = PVE
::Storage
::path
($storecfg, $volid); };
2275 if ($owner && ($owner == $vmid)) {
2283 sub split_flagged_list
{
2284 my $text = shift || '';
2285 $text =~ s/[,;]/ /g;
2287 return { map { /^(!?)(.*)$/ && ($2, $1) } ($text =~ /\S+/g) };
2290 sub join_flagged_list
{
2291 my ($how, $lst) = @_;
2292 join $how, map { $lst->{$_} . $_ } keys %$lst;
2295 sub vmconfig_delete_pending_option
{
2296 my ($conf, $key, $force) = @_;
2298 delete $conf->{pending
}->{$key};
2299 my $pending_delete_hash = split_flagged_list
($conf->{pending
}->{delete});
2300 $pending_delete_hash->{$key} = $force ?
'!' : '';
2301 $conf->{pending
}->{delete} = join_flagged_list
(',', $pending_delete_hash);
2304 sub vmconfig_undelete_pending_option
{
2305 my ($conf, $key) = @_;
2307 my $pending_delete_hash = split_flagged_list
($conf->{pending
}->{delete});
2308 delete $pending_delete_hash->{$key};
2310 if (%$pending_delete_hash) {
2311 $conf->{pending
}->{delete} = join_flagged_list
(',', $pending_delete_hash);
2313 delete $conf->{pending
}->{delete};
2317 sub vmconfig_register_unused_drive
{
2318 my ($storecfg, $vmid, $conf, $drive) = @_;
2320 if (drive_is_cloudinit
($drive)) {
2321 eval { PVE
::Storage
::vdisk_free
($storecfg, $drive->{file
}) };
2323 } elsif (!drive_is_cdrom
($drive)) {
2324 my $volid = $drive->{file
};
2325 if (vm_is_volid_owner
($storecfg, $vmid, $volid)) {
2326 PVE
::QemuConfig-
>add_unused_volume($conf, $volid, $vmid);
2331 sub vmconfig_cleanup_pending
{
2334 # remove pending changes when nothing changed
2336 foreach my $opt (keys %{$conf->{pending
}}) {
2337 if (defined($conf->{$opt}) && ($conf->{pending
}->{$opt} eq $conf->{$opt})) {
2339 delete $conf->{pending
}->{$opt};
2343 my $current_delete_hash = split_flagged_list
($conf->{pending
}->{delete});
2344 my $pending_delete_hash = {};
2345 while (my ($opt, $force) = each %$current_delete_hash) {
2346 if (defined($conf->{$opt})) {
2347 $pending_delete_hash->{$opt} = $force;
2353 if (%$pending_delete_hash) {
2354 $conf->{pending
}->{delete} = join_flagged_list
(',', $pending_delete_hash);
2356 delete $conf->{pending
}->{delete};
2362 # smbios: [manufacturer=str][,product=str][,version=str][,serial=str][,uuid=uuid][,sku=str][,family=str][,base64=bool]
2366 pattern
=> '[a-fA-F0-9]{8}(?:-[a-fA-F0-9]{4}){3}-[a-fA-F0-9]{12}',
2367 format_description
=> 'UUID',
2368 description
=> "Set SMBIOS1 UUID.",
2373 pattern
=> '[A-Za-z0-9+\/]+={0,2}',
2374 format_description
=> 'Base64 encoded string',
2375 description
=> "Set SMBIOS1 version.",
2380 pattern
=> '[A-Za-z0-9+\/]+={0,2}',
2381 format_description
=> 'Base64 encoded string',
2382 description
=> "Set SMBIOS1 serial number.",
2387 pattern
=> '[A-Za-z0-9+\/]+={0,2}',
2388 format_description
=> 'Base64 encoded string',
2389 description
=> "Set SMBIOS1 manufacturer.",
2394 pattern
=> '[A-Za-z0-9+\/]+={0,2}',
2395 format_description
=> 'Base64 encoded string',
2396 description
=> "Set SMBIOS1 product ID.",
2401 pattern
=> '[A-Za-z0-9+\/]+={0,2}',
2402 format_description
=> 'Base64 encoded string',
2403 description
=> "Set SMBIOS1 SKU string.",
2408 pattern
=> '[A-Za-z0-9+\/]+={0,2}',
2409 format_description
=> 'Base64 encoded string',
2410 description
=> "Set SMBIOS1 family string.",
2415 description
=> 'Flag to indicate that the SMBIOS values are base64 encoded',
2423 my $res = eval { PVE
::JSONSchema
::parse_property_string
($smbios1_fmt, $data) };
2430 return PVE
::JSONSchema
::print_property_string
($smbios1, $smbios1_fmt);
2433 PVE
::JSONSchema
::register_format
('pve-qm-smbios1', $smbios1_fmt);
2435 PVE
::JSONSchema
::register_format
('pve-qm-bootdisk', \
&verify_bootdisk
);
2436 sub verify_bootdisk
{
2437 my ($value, $noerr) = @_;
2439 return $value if is_valid_drivename
($value);
2441 return undef if $noerr;
2443 die "invalid boot disk '$value'\n";
2446 sub parse_watchdog
{
2449 return undef if !$value;
2451 my $res = eval { PVE
::JSONSchema
::parse_property_string
($watchdog_fmt, $value) };
2456 sub parse_guest_agent
{
2459 return {} if !defined($value->{agent
});
2461 my $res = eval { PVE
::JSONSchema
::parse_property_string
($agent_fmt, $value->{agent
}) };
2464 # if the agent is disabled ignore the other potentially set properties
2465 return {} if !$res->{enabled
};
2472 return {} if !$value;
2473 my $res = eval { PVE
::JSONSchema
::parse_property_string
($vga_fmt, $value) };
2478 PVE
::JSONSchema
::register_format
('pve-qm-usb-device', \
&verify_usb_device
);
2479 sub verify_usb_device
{
2480 my ($value, $noerr) = @_;
2482 return $value if parse_usb_device
($value);
2484 return undef if $noerr;
2486 die "unable to parse usb device\n";
2489 # add JSON properties for create and set function
2490 sub json_config_properties
{
2493 foreach my $opt (keys %$confdesc) {
2494 next if $opt eq 'parent' || $opt eq 'snaptime' || $opt eq 'vmstate' || $opt eq 'runningmachine';
2495 $prop->{$opt} = $confdesc->{$opt};
2501 # return copy of $confdesc_cloudinit to generate documentation
2502 sub cloudinit_config_properties
{
2504 return dclone
($confdesc_cloudinit);
2508 my ($key, $value) = @_;
2510 die "unknown setting '$key'\n" if !$confdesc->{$key};
2512 my $type = $confdesc->{$key}->{type
};
2514 if (!defined($value)) {
2515 die "got undefined value\n";
2518 if ($value =~ m/[\n\r]/) {
2519 die "property contains a line feed\n";
2522 if ($type eq 'boolean') {
2523 return 1 if ($value eq '1') || ($value =~ m/^(on|yes|true)$/i);
2524 return 0 if ($value eq '0') || ($value =~ m/^(off|no|false)$/i);
2525 die "type check ('boolean') failed - got '$value'\n";
2526 } elsif ($type eq 'integer') {
2527 return int($1) if $value =~ m/^(\d+)$/;
2528 die "type check ('integer') failed - got '$value'\n";
2529 } elsif ($type eq 'number') {
2530 return $value if $value =~ m/^(\d+)(\.\d+)?$/;
2531 die "type check ('number') failed - got '$value'\n";
2532 } elsif ($type eq 'string') {
2533 if (my $fmt = $confdesc->{$key}->{format
}) {
2534 PVE
::JSONSchema
::check_format
($fmt, $value);
2537 $value =~ s/^\"(.*)\"$/$1/;
2540 die "internal error"
2547 my $conf = PVE
::QemuConfig-
>config_file($vmid);
2548 utime undef, undef, $conf;
2552 my ($storecfg, $vmid, $keep_empty_config, $skiplock) = @_;
2554 my $conffile = PVE
::QemuConfig-
>config_file($vmid);
2556 my $conf = PVE
::QemuConfig-
>load_config($vmid);
2558 PVE
::QemuConfig-
>check_lock($conf) if !$skiplock;
2560 if ($conf->{template
}) {
2561 # check if any base image is still used by a linked clone
2562 foreach_drive
($conf, sub {
2563 my ($ds, $drive) = @_;
2565 return if drive_is_cdrom
($drive);
2567 my $volid = $drive->{file
};
2569 return if !$volid || $volid =~ m
|^/|;
2571 die "base volume '$volid' is still in use by linked cloned\n"
2572 if PVE
::Storage
::volume_is_base_and_used
($storecfg, $volid);
2577 # only remove disks owned by this VM
2578 foreach_drive
($conf, sub {
2579 my ($ds, $drive) = @_;
2581 return if drive_is_cdrom
($drive, 1);
2583 my $volid = $drive->{file
};
2585 return if !$volid || $volid =~ m
|^/|;
2587 my ($path, $owner) = PVE
::Storage
::path
($storecfg, $volid);
2588 return if !$path || !$owner || ($owner != $vmid);
2591 PVE
::Storage
::vdisk_free
($storecfg, $volid);
2593 warn "Could not remove disk '$volid', check manually: $@" if $@;
2597 if ($keep_empty_config) {
2598 PVE
::Tools
::file_set_contents
($conffile, "memory: 128\n");
2603 # also remove unused disk
2605 my $dl = PVE
::Storage
::vdisk_list
($storecfg, undef, $vmid);
2608 PVE
::Storage
::foreach_volid
($dl, sub {
2609 my ($volid, $sid, $volname, $d) = @_;
2610 PVE
::Storage
::vdisk_free
($storecfg, $volid);
2619 sub parse_vm_config
{
2620 my ($filename, $raw) = @_;
2622 return undef if !defined($raw);
2625 digest
=> Digest
::SHA
::sha1_hex
($raw),
2630 $filename =~ m
|/qemu-server/(\d
+)\
.conf
$|
2631 || die "got strange filename '$filename'";
2639 my @lines = split(/\n/, $raw);
2640 foreach my $line (@lines) {
2641 next if $line =~ m/^\s*$/;
2643 if ($line =~ m/^\[PENDING\]\s*$/i) {
2644 $section = 'pending';
2645 if (defined($descr)) {
2647 $conf->{description
} = $descr;
2650 $conf = $res->{$section} = {};
2653 } elsif ($line =~ m/^\[([a-z][a-z0-9_\-]+)\]\s*$/i) {
2655 if (defined($descr)) {
2657 $conf->{description
} = $descr;
2660 $conf = $res->{snapshots
}->{$section} = {};
2664 if ($line =~ m/^\#(.*)\s*$/) {
2665 $descr = '' if !defined($descr);
2666 $descr .= PVE
::Tools
::decode_text
($1) . "\n";
2670 if ($line =~ m/^(description):\s*(.*\S)\s*$/) {
2671 $descr = '' if !defined($descr);
2672 $descr .= PVE
::Tools
::decode_text
($2);
2673 } elsif ($line =~ m/snapstate:\s*(prepare|delete)\s*$/) {
2674 $conf->{snapstate
} = $1;
2675 } elsif ($line =~ m/^(args):\s*(.*\S)\s*$/) {
2678 $conf->{$key} = $value;
2679 } elsif ($line =~ m/^delete:\s*(.*\S)\s*$/) {
2681 if ($section eq 'pending') {
2682 $conf->{delete} = $value; # we parse this later
2684 warn "vm $vmid - propertry 'delete' is only allowed in [PENDING]\n";
2686 } elsif ($line =~ m/^([a-z][a-z_]*\d*):\s*(.+?)\s*$/) {
2689 eval { $value = check_type
($key, $value); };
2691 warn "vm $vmid - unable to parse value of '$key' - $@";
2693 $key = 'ide2' if $key eq 'cdrom';
2694 my $fmt = $confdesc->{$key}->{format
};
2695 if ($fmt && $fmt =~ /^pve-qm-(?:ide|scsi|virtio|sata)$/) {
2696 my $v = parse_drive
($key, $value);
2697 if (my $volid = filename_to_volume_id
($vmid, $v->{file
}, $v->{media
})) {
2698 $v->{file
} = $volid;
2699 $value = print_drive
($vmid, $v);
2701 warn "vm $vmid - unable to parse value of '$key'\n";
2706 $conf->{$key} = $value;
2711 if (defined($descr)) {
2713 $conf->{description
} = $descr;
2715 delete $res->{snapstate
}; # just to be sure
2720 sub write_vm_config
{
2721 my ($filename, $conf) = @_;
2723 delete $conf->{snapstate
}; # just to be sure
2725 if ($conf->{cdrom
}) {
2726 die "option ide2 conflicts with cdrom\n" if $conf->{ide2
};
2727 $conf->{ide2
} = $conf->{cdrom
};
2728 delete $conf->{cdrom
};
2731 # we do not use 'smp' any longer
2732 if ($conf->{sockets
}) {
2733 delete $conf->{smp
};
2734 } elsif ($conf->{smp
}) {
2735 $conf->{sockets
} = $conf->{smp
};
2736 delete $conf->{cores
};
2737 delete $conf->{smp
};
2740 my $used_volids = {};
2742 my $cleanup_config = sub {
2743 my ($cref, $pending, $snapname) = @_;
2745 foreach my $key (keys %$cref) {
2746 next if $key eq 'digest' || $key eq 'description' || $key eq 'snapshots' ||
2747 $key eq 'snapstate' || $key eq 'pending';
2748 my $value = $cref->{$key};
2749 if ($key eq 'delete') {
2750 die "propertry 'delete' is only allowed in [PENDING]\n"
2752 # fixme: check syntax?
2755 eval { $value = check_type
($key, $value); };
2756 die "unable to parse value of '$key' - $@" if $@;
2758 $cref->{$key} = $value;
2760 if (!$snapname && is_valid_drivename
($key)) {
2761 my $drive = parse_drive
($key, $value);
2762 $used_volids->{$drive->{file
}} = 1 if $drive && $drive->{file
};
2767 &$cleanup_config($conf);
2769 &$cleanup_config($conf->{pending
}, 1);
2771 foreach my $snapname (keys %{$conf->{snapshots
}}) {
2772 die "internal error" if $snapname eq 'pending';
2773 &$cleanup_config($conf->{snapshots
}->{$snapname}, undef, $snapname);
2776 # remove 'unusedX' settings if we re-add a volume
2777 foreach my $key (keys %$conf) {
2778 my $value = $conf->{$key};
2779 if ($key =~ m/^unused/ && $used_volids->{$value}) {
2780 delete $conf->{$key};
2784 my $generate_raw_config = sub {
2785 my ($conf, $pending) = @_;
2789 # add description as comment to top of file
2790 if (defined(my $descr = $conf->{description
})) {
2792 foreach my $cl (split(/\n/, $descr)) {
2793 $raw .= '#' . PVE
::Tools
::encode_text
($cl) . "\n";
2796 $raw .= "#\n" if $pending;
2800 foreach my $key (sort keys %$conf) {
2801 next if $key eq 'digest' || $key eq 'description' || $key eq 'pending' || $key eq 'snapshots';
2802 $raw .= "$key: $conf->{$key}\n";
2807 my $raw = &$generate_raw_config($conf);
2809 if (scalar(keys %{$conf->{pending
}})){
2810 $raw .= "\n[PENDING]\n";
2811 $raw .= &$generate_raw_config($conf->{pending
}, 1);
2814 foreach my $snapname (sort keys %{$conf->{snapshots
}}) {
2815 $raw .= "\n[$snapname]\n";
2816 $raw .= &$generate_raw_config($conf->{snapshots
}->{$snapname});
2826 # we use static defaults from our JSON schema configuration
2827 foreach my $key (keys %$confdesc) {
2828 if (defined(my $default = $confdesc->{$key}->{default})) {
2829 $res->{$key} = $default;
2837 my $vmlist = PVE
::Cluster
::get_vmlist
();
2839 return $res if !$vmlist || !$vmlist->{ids
};
2840 my $ids = $vmlist->{ids
};
2842 foreach my $vmid (keys %$ids) {
2843 my $d = $ids->{$vmid};
2844 next if !$d->{node
} || $d->{node
} ne $nodename;
2845 next if !$d->{type
} || $d->{type
} ne 'qemu';
2846 $res->{$vmid}->{exists} = 1;
2851 # test if VM uses local resources (to prevent migration)
2852 sub check_local_resources
{
2853 my ($conf, $noerr) = @_;
2857 push @loc_res, "hostusb" if $conf->{hostusb
}; # old syntax
2858 push @loc_res, "hostpci" if $conf->{hostpci
}; # old syntax
2860 push @loc_res, "ivshmem" if $conf->{ivshmem
};
2862 foreach my $k (keys %$conf) {
2863 next if $k =~ m/^usb/ && ($conf->{$k} eq 'spice');
2864 # sockets are safe: they will recreated be on the target side post-migrate
2865 next if $k =~ m/^serial/ && ($conf->{$k} eq 'socket');
2866 push @loc_res, $k if $k =~ m/^(usb|hostpci|serial|parallel)\d+$/;
2869 die "VM uses local resources\n" if scalar @loc_res && !$noerr;
2874 # check if used storages are available on all nodes (use by migrate)
2875 sub check_storage_availability
{
2876 my ($storecfg, $conf, $node) = @_;
2878 foreach_drive
($conf, sub {
2879 my ($ds, $drive) = @_;
2881 my $volid = $drive->{file
};
2884 my ($sid, $volname) = PVE
::Storage
::parse_volume_id
($volid, 1);
2887 # check if storage is available on both nodes
2888 my $scfg = PVE
::Storage
::storage_check_node
($storecfg, $sid);
2889 PVE
::Storage
::storage_check_node
($storecfg, $sid, $node);
2893 # list nodes where all VM images are available (used by has_feature API)
2895 my ($conf, $storecfg) = @_;
2897 my $nodelist = PVE
::Cluster
::get_nodelist
();
2898 my $nodehash = { map { $_ => 1 } @$nodelist };
2899 my $nodename = PVE
::INotify
::nodename
();
2901 foreach_drive
($conf, sub {
2902 my ($ds, $drive) = @_;
2904 my $volid = $drive->{file
};
2907 my ($storeid, $volname) = PVE
::Storage
::parse_volume_id
($volid, 1);
2909 my $scfg = PVE
::Storage
::storage_config
($storecfg, $storeid);
2910 if ($scfg->{disable
}) {
2912 } elsif (my $avail = $scfg->{nodes
}) {
2913 foreach my $node (keys %$nodehash) {
2914 delete $nodehash->{$node} if !$avail->{$node};
2916 } elsif (!$scfg->{shared
}) {
2917 foreach my $node (keys %$nodehash) {
2918 delete $nodehash->{$node} if $node ne $nodename
2927 sub check_local_storage_availability
{
2928 my ($conf, $storecfg) = @_;
2930 my $nodelist = PVE
::Cluster
::get_nodelist
();
2931 my $nodehash = { map { $_ => {} } @$nodelist };
2933 foreach_drive
($conf, sub {
2934 my ($ds, $drive) = @_;
2936 my $volid = $drive->{file
};
2939 my ($storeid, $volname) = PVE
::Storage
::parse_volume_id
($volid, 1);
2941 my $scfg = PVE
::Storage
::storage_config
($storecfg, $storeid);
2943 if ($scfg->{disable
}) {
2944 foreach my $node (keys %$nodehash) {
2945 $nodehash->{$node}->{unavailable_storages
}->{$storeid} = 1;
2947 } elsif (my $avail = $scfg->{nodes
}) {
2948 foreach my $node (keys %$nodehash) {
2949 if (!$avail->{$node}) {
2950 $nodehash->{$node}->{unavailable_storages
}->{$storeid} = 1;
2957 foreach my $node (values %$nodehash) {
2958 if (my $unavail = $node->{unavailable_storages
}) {
2959 $node->{unavailable_storages
} = [ sort keys %$unavail ];
2967 my ($pidfile, $pid) = @_;
2969 my $fh = IO
::File-
>new("/proc/$pid/cmdline", "r");
2973 return undef if !$line;
2974 my @param = split(/\0/, $line);
2976 my $cmd = $param[0];
2977 return if !$cmd || ($cmd !~ m
|kvm
$| && $cmd !~ m
@(?
:^|/)qemu-system-[^/]+$@);
2979 for (my $i = 0; $i < scalar (@param); $i++) {
2982 if (($p eq '-pidfile') || ($p eq '--pidfile')) {
2983 my $p = $param[$i+1];
2984 return 1 if $p && ($p eq $pidfile);
2993 my ($vmid, $nocheck, $node) = @_;
2995 my $filename = PVE
::QemuConfig-
>config_file($vmid, $node);
2997 die "unable to find configuration file for VM $vmid - no such machine\n"
2998 if !$nocheck && ! -f
$filename;
3000 my $pidfile = pidfile_name
($vmid);
3002 if (my $fd = IO
::File-
>new("<$pidfile")) {
3007 my $mtime = $st->mtime;
3008 if ($mtime > time()) {
3009 warn "file '$filename' modified in future\n";
3012 if ($line =~ m/^(\d+)$/) {
3014 if (check_cmdline
($pidfile, $pid)) {
3015 if (my $pinfo = PVE
::ProcFSTools
::check_process_running
($pid)) {
3027 my $vzlist = config_list
();
3029 my $fd = IO
::Dir-
>new($var_run_tmpdir) || return $vzlist;
3031 while (defined(my $de = $fd->read)) {
3032 next if $de !~ m/^(\d+)\.pid$/;
3034 next if !defined($vzlist->{$vmid});
3035 if (my $pid = check_running
($vmid)) {
3036 $vzlist->{$vmid}->{pid
} = $pid;
3044 my ($storecfg, $conf) = @_;
3046 my $bootdisk = $conf->{bootdisk
};
3047 return undef if !$bootdisk;
3048 return undef if !is_valid_drivename
($bootdisk);
3050 return undef if !$conf->{$bootdisk};
3052 my $drive = parse_drive
($bootdisk, $conf->{$bootdisk});
3053 return undef if !defined($drive);
3055 return undef if drive_is_cdrom
($drive);
3057 my $volid = $drive->{file
};
3058 return undef if !$volid;
3060 return $drive->{size
};
3063 our $vmstatus_return_properties = {
3064 vmid
=> get_standard_option
('pve-vmid'),
3066 description
=> "Qemu process status.",
3068 enum
=> ['stopped', 'running'],
3071 description
=> "Maximum memory in bytes.",
3074 renderer
=> 'bytes',
3077 description
=> "Root disk size in bytes.",
3080 renderer
=> 'bytes',
3083 description
=> "VM name.",
3088 description
=> "Qemu QMP agent status.",
3093 description
=> "PID of running qemu process.",
3098 description
=> "Uptime.",
3101 renderer
=> 'duration',
3104 description
=> "Maximum usable CPUs.",
3109 description
=> "The current config lock, if any.",
3115 my $last_proc_pid_stat;
3117 # get VM status information
3118 # This must be fast and should not block ($full == false)
3119 # We only query KVM using QMP if $full == true (this can be slow)
3121 my ($opt_vmid, $full) = @_;
3125 my $storecfg = PVE
::Storage
::config
();
3127 my $list = vzlist
();
3128 my $defaults = load_defaults
();
3130 my ($uptime) = PVE
::ProcFSTools
::read_proc_uptime
(1);
3132 my $cpucount = $cpuinfo->{cpus
} || 1;
3134 foreach my $vmid (keys %$list) {
3135 next if $opt_vmid && ($vmid ne $opt_vmid);
3137 my $cfspath = PVE
::QemuConfig-
>cfs_config_path($vmid);
3138 my $conf = PVE
::Cluster
::cfs_read_file
($cfspath) || {};
3140 my $d = { vmid
=> $vmid };
3141 $d->{pid
} = $list->{$vmid}->{pid
};
3143 # fixme: better status?
3144 $d->{status
} = $list->{$vmid}->{pid
} ?
'running' : 'stopped';
3146 my $size = disksize
($storecfg, $conf);
3147 if (defined($size)) {
3148 $d->{disk
} = 0; # no info available
3149 $d->{maxdisk
} = $size;
3155 $d->{cpus
} = ($conf->{sockets
} || $defaults->{sockets
})
3156 * ($conf->{cores
} || $defaults->{cores
});
3157 $d->{cpus
} = $cpucount if $d->{cpus
} > $cpucount;
3158 $d->{cpus
} = $conf->{vcpus
} if $conf->{vcpus
};
3160 $d->{name
} = $conf->{name
} || "VM $vmid";
3161 $d->{maxmem
} = $conf->{memory
} ?
$conf->{memory
}*(1024*1024)
3162 : $defaults->{memory
}*(1024*1024);
3164 if ($conf->{balloon
}) {
3165 $d->{balloon_min
} = $conf->{balloon
}*(1024*1024);
3166 $d->{shares
} = defined($conf->{shares
}) ?
$conf->{shares
}
3167 : $defaults->{shares
};
3178 $d->{diskwrite
} = 0;
3180 $d->{template
} = PVE
::QemuConfig-
>is_template($conf);
3182 $d->{serial
} = 1 if conf_has_serial
($conf);
3183 $d->{lock} = $conf->{lock} if $conf->{lock};
3188 my $netdev = PVE
::ProcFSTools
::read_proc_net_dev
();
3189 foreach my $dev (keys %$netdev) {
3190 next if $dev !~ m/^tap([1-9]\d*)i/;
3192 my $d = $res->{$vmid};
3195 $d->{netout
} += $netdev->{$dev}->{receive
};
3196 $d->{netin
} += $netdev->{$dev}->{transmit
};
3199 $d->{nics
}->{$dev}->{netout
} = $netdev->{$dev}->{receive
};
3200 $d->{nics
}->{$dev}->{netin
} = $netdev->{$dev}->{transmit
};
3205 my $ctime = gettimeofday
;
3207 foreach my $vmid (keys %$list) {
3209 my $d = $res->{$vmid};
3210 my $pid = $d->{pid
};
3213 my $pstat = PVE
::ProcFSTools
::read_proc_pid_stat
($pid);
3214 next if !$pstat; # not running
3216 my $used = $pstat->{utime} + $pstat->{stime
};
3218 $d->{uptime
} = int(($uptime - $pstat->{starttime
})/$cpuinfo->{user_hz
});
3220 if ($pstat->{vsize
}) {
3221 $d->{mem
} = int(($pstat->{rss
}/$pstat->{vsize
})*$d->{maxmem
});
3224 my $old = $last_proc_pid_stat->{$pid};
3226 $last_proc_pid_stat->{$pid} = {
3234 my $dtime = ($ctime - $old->{time}) * $cpucount * $cpuinfo->{user_hz
};
3236 if ($dtime > 1000) {
3237 my $dutime = $used - $old->{used
};
3239 $d->{cpu
} = (($dutime/$dtime)* $cpucount) / $d->{cpus
};
3240 $last_proc_pid_stat->{$pid} = {
3246 $d->{cpu
} = $old->{cpu
};
3250 return $res if !$full;
3252 my $qmpclient = PVE
::QMPClient-
>new();
3254 my $ballooncb = sub {
3255 my ($vmid, $resp) = @_;
3257 my $info = $resp->{'return'};
3258 return if !$info->{max_mem
};
3260 my $d = $res->{$vmid};
3262 # use memory assigned to VM
3263 $d->{maxmem
} = $info->{max_mem
};
3264 $d->{balloon
} = $info->{actual
};
3266 if (defined($info->{total_mem
}) && defined($info->{free_mem
})) {
3267 $d->{mem
} = $info->{total_mem
} - $info->{free_mem
};
3268 $d->{freemem
} = $info->{free_mem
};
3271 $d->{ballooninfo
} = $info;
3274 my $blockstatscb = sub {
3275 my ($vmid, $resp) = @_;
3276 my $data = $resp->{'return'} || [];
3277 my $totalrdbytes = 0;
3278 my $totalwrbytes = 0;
3280 for my $blockstat (@$data) {
3281 $totalrdbytes = $totalrdbytes + $blockstat->{stats
}->{rd_bytes
};
3282 $totalwrbytes = $totalwrbytes + $blockstat->{stats
}->{wr_bytes
};
3284 $blockstat->{device
} =~ s/drive-//;
3285 $res->{$vmid}->{blockstat
}->{$blockstat->{device
}} = $blockstat->{stats
};
3287 $res->{$vmid}->{diskread
} = $totalrdbytes;
3288 $res->{$vmid}->{diskwrite
} = $totalwrbytes;
3291 my $statuscb = sub {
3292 my ($vmid, $resp) = @_;
3294 $qmpclient->queue_cmd($vmid, $blockstatscb, 'query-blockstats');
3295 # this fails if ballon driver is not loaded, so this must be
3296 # the last commnand (following command are aborted if this fails).
3297 $qmpclient->queue_cmd($vmid, $ballooncb, 'query-balloon');
3299 my $status = 'unknown';
3300 if (!defined($status = $resp->{'return'}->{status
})) {
3301 warn "unable to get VM status\n";
3305 $res->{$vmid}->{qmpstatus
} = $resp->{'return'}->{status
};
3308 foreach my $vmid (keys %$list) {
3309 next if $opt_vmid && ($vmid ne $opt_vmid);
3310 next if !$res->{$vmid}->{pid
}; # not running
3311 $qmpclient->queue_cmd($vmid, $statuscb, 'query-status');
3314 $qmpclient->queue_execute(undef, 2);
3316 foreach my $vmid (keys %$list) {
3317 next if $opt_vmid && ($vmid ne $opt_vmid);
3318 $res->{$vmid}->{qmpstatus
} = $res->{$vmid}->{status
} if !$res->{$vmid}->{qmpstatus
};
3325 my ($conf, $func, @param) = @_;
3327 foreach my $ds (valid_drive_names
()) {
3328 next if !defined($conf->{$ds});
3330 my $drive = parse_drive
($ds, $conf->{$ds});
3333 &$func($ds, $drive, @param);
3338 my ($conf, $func, @param) = @_;
3342 my $test_volid = sub {
3343 my ($volid, $is_cdrom, $replicate, $shared, $snapname, $size) = @_;
3347 $volhash->{$volid}->{cdrom
} //= 1;
3348 $volhash->{$volid}->{cdrom
} = 0 if !$is_cdrom;
3350 $volhash->{$volid}->{replicate
} //= 0;
3351 $volhash->{$volid}->{replicate
} = 1 if $replicate;
3353 $volhash->{$volid}->{shared
} //= 0;
3354 $volhash->{$volid}->{shared
} = 1 if $shared;
3356 $volhash->{$volid}->{referenced_in_config
} //= 0;
3357 $volhash->{$volid}->{referenced_in_config
} = 1 if !defined($snapname);
3359 $volhash->{$volid}->{referenced_in_snapshot
}->{$snapname} = 1
3360 if defined($snapname);
3361 $volhash->{$volid}->{size
} = $size if $size;
3364 foreach_drive
($conf, sub {
3365 my ($ds, $drive) = @_;
3366 $test_volid->($drive->{file
}, drive_is_cdrom
($drive), $drive->{replicate
} // 1, $drive->{shared
}, undef, $drive->{size
});
3369 foreach my $snapname (keys %{$conf->{snapshots
}}) {
3370 my $snap = $conf->{snapshots
}->{$snapname};
3371 $test_volid->($snap->{vmstate
}, 0, 1, $snapname);
3372 foreach_drive
($snap, sub {
3373 my ($ds, $drive) = @_;
3374 $test_volid->($drive->{file
}, drive_is_cdrom
($drive), $drive->{replicate
} // 1, $drive->{shared
}, $snapname);
3378 foreach my $volid (keys %$volhash) {
3379 &$func($volid, $volhash->{$volid}, @param);
3383 sub conf_has_serial
{
3386 for (my $i = 0; $i < $MAX_SERIAL_PORTS; $i++) {
3387 if ($conf->{"serial$i"}) {
3395 sub vga_conf_has_spice
{
3398 my $vgaconf = parse_vga
($vga);
3399 my $vgatype = $vgaconf->{type
};
3400 return 0 if !$vgatype || $vgatype !~ m/^qxl([234])?$/;
3405 my $host_arch; # FIXME: fix PVE::Tools::get_host_arch
3406 sub get_host_arch
() {
3407 $host_arch = (POSIX
::uname
())[4] if !$host_arch;
3413 return get_host_arch
() eq $arch;
3416 my $default_machines = {
3421 sub get_basic_machine_info
{
3422 my ($conf, $forcemachine) = @_;
3424 my $arch = $conf->{arch
} // get_host_arch
();
3425 my $machine = $forcemachine || $conf->{machine
} || $default_machines->{$arch};
3426 return ($arch, $machine);
3429 sub get_ovmf_files
($) {
3432 my $ovmf = $OVMF->{$arch}
3433 or die "no OVMF images known for architecture '$arch'\n";
3439 aarch64
=> '/usr/bin/qemu-system-aarch64',
3440 x86_64
=> '/usr/bin/qemu-system-x86_64',
3442 sub get_command_for_arch
($) {
3444 return '/usr/bin/kvm' if is_native
($arch);
3446 my $cmd = $Arch2Qemu->{$arch}
3447 or die "don't know how to emulate architecture '$arch'\n";
3451 sub get_cpu_options
{
3452 my ($conf, $arch, $kvm, $machine_type, $kvm_off, $kvmver, $winversion, $gpu_passthrough) = @_;
3455 my $ostype = $conf->{ostype
};
3457 my $cpu = $kvm ?
"kvm64" : "qemu64";
3458 if ($arch eq 'aarch64') {
3459 $cpu = 'cortex-a57';
3462 if (my $cputype = $conf->{cpu
}) {
3463 my $cpuconf = PVE
::JSONSchema
::parse_property_string
($cpu_fmt, $cputype)
3464 or die "Cannot parse cpu description: $cputype\n";
3465 $cpu = $cpuconf->{cputype
};
3466 $kvm_off = 1 if $cpuconf->{hidden
};
3467 $hv_vendor_id = $cpuconf->{'hv-vendor-id'};
3469 if (defined(my $flags = $cpuconf->{flags
})) {
3470 push @$cpuFlags, split(";", $flags);
3474 push @$cpuFlags , '+lahf_lm' if $cpu eq 'kvm64' && $arch eq 'x86_64';
3476 push @$cpuFlags , '-x2apic'
3477 if $conf->{ostype
} && $conf->{ostype
} eq 'solaris';
3479 push @$cpuFlags, '+sep' if $cpu eq 'kvm64' || $cpu eq 'kvm32';
3481 push @$cpuFlags, '-rdtscp' if $cpu =~ m/^Opteron/;
3483 if (qemu_machine_feature_enabled
($machine_type, $kvmver, 2, 3) && $arch eq 'x86_64') {
3485 push @$cpuFlags , '+kvm_pv_unhalt' if $kvm;
3486 push @$cpuFlags , '+kvm_pv_eoi' if $kvm;
3489 add_hyperv_enlightenments
($cpuFlags, $winversion, $machine_type, $kvmver, $conf->{bios
}, $gpu_passthrough, $hv_vendor_id) if $kvm;
3491 push @$cpuFlags, 'enforce' if $cpu ne 'host' && $kvm && $arch eq 'x86_64';
3493 push @$cpuFlags, 'kvm=off' if $kvm_off;
3495 if (my $cpu_vendor = $cpu_vendor_list->{$cpu}) {
3496 push @$cpuFlags, "vendor=${cpu_vendor}"
3497 if $cpu_vendor ne 'default';
3498 } elsif ($arch ne 'aarch64') {
3499 die "internal error"; # should not happen
3502 $cpu .= "," . join(',', @$cpuFlags) if scalar(@$cpuFlags);
3504 return ('-cpu', $cpu);
3507 sub config_to_command
{
3508 my ($storecfg, $vmid, $conf, $defaults, $forcemachine) = @_;
3511 my $globalFlags = [];
3512 my $machineFlags = [];
3517 my $kvmver = kvm_user_version
();
3518 my $vernum = 0; # unknown
3519 my $ostype = $conf->{ostype
};
3520 my $winversion = windows_version
($ostype);
3521 my $kvm = $conf->{kvm
};
3523 my ($arch, $machine_type) = get_basic_machine_info
($conf, $forcemachine);
3524 $kvm //= 1 if is_native
($arch);
3527 die "KVM virtualisation configured, but not available. Either disable in VM configuration or enable in BIOS.\n"
3528 if !defined kvm_version
();
3531 if ($kvmver =~ m/^(\d+)\.(\d+)$/) {
3532 $vernum = $1*1000000+$2*1000;
3533 } elsif ($kvmver =~ m/^(\d+)\.(\d+)\.(\d+)$/) {
3534 $vernum = $1*1000000+$2*1000+$3;
3537 die "detected old qemu-kvm binary ($kvmver)\n" if $vernum < 15000;
3539 my $have_ovz = -f
'/proc/vz/vestat';
3541 my $q35 = machine_type_is_q35
($conf);
3542 my $hotplug_features = parse_hotplug_features
(defined($conf->{hotplug
}) ?
$conf->{hotplug
} : '1');
3543 my $use_old_bios_files = undef;
3544 ($use_old_bios_files, $machine_type) = qemu_use_old_bios_files
($machine_type);
3546 my $cpuunits = defined($conf->{cpuunits
}) ?
3547 $conf->{cpuunits
} : $defaults->{cpuunits
};
3549 push @$cmd, get_command_for_arch
($arch);
3551 push @$cmd, '-id', $vmid;
3553 my $vmname = $conf->{name
} || "vm$vmid";
3555 push @$cmd, '-name', $vmname;
3559 my $qmpsocket = qmp_socket
($vmid);
3560 push @$cmd, '-chardev', "socket,id=qmp,path=$qmpsocket,server,nowait";
3561 push @$cmd, '-mon', "chardev=qmp,mode=control";
3563 if (qemu_machine_feature_enabled
($machine_type, $kvmver, 2, 12)) {
3564 push @$cmd, '-chardev', "socket,id=qmp-event,path=/var/run/qmeventd.sock,reconnect=5";
3565 push @$cmd, '-mon', "chardev=qmp-event,mode=control";
3568 push @$cmd, '-pidfile' , pidfile_name
($vmid);
3570 push @$cmd, '-daemonize';
3572 if ($conf->{smbios1
}) {
3573 my $smbios_conf = parse_smbios1
($conf->{smbios1
});
3574 if ($smbios_conf->{base64
}) {
3575 # Do not pass base64 flag to qemu
3576 delete $smbios_conf->{base64
};
3577 my $smbios_string = "";
3578 foreach my $key (keys %$smbios_conf) {
3580 if ($key eq "uuid") {
3581 $value = $smbios_conf->{uuid
}
3583 $value = decode_base64
($smbios_conf->{$key});
3585 # qemu accepts any binary data, only commas need escaping by double comma
3587 $smbios_string .= "," . $key . "=" . $value if $value;
3589 push @$cmd, '-smbios', "type=1" . $smbios_string;
3591 push @$cmd, '-smbios', "type=1,$conf->{smbios1}";
3595 if ($conf->{vmgenid
}) {
3596 push @$devices, '-device', 'vmgenid,guid='.$conf->{vmgenid
};
3599 my ($ovmf_code, $ovmf_vars) = get_ovmf_files
($arch);
3600 if ($conf->{bios
} && $conf->{bios
} eq 'ovmf') {
3601 die "uefi base image not found\n" if ! -f
$ovmf_code;
3605 if (my $efidisk = $conf->{efidisk0
}) {
3606 my $d = PVE
::JSONSchema
::parse_property_string
($efidisk_fmt, $efidisk);
3607 my ($storeid, $volname) = PVE
::Storage
::parse_volume_id
($d->{file
}, 1);
3608 $format = $d->{format
};
3610 $path = PVE
::Storage
::path
($storecfg, $d->{file
});
3611 if (!defined($format)) {
3612 my $scfg = PVE
::Storage
::storage_config
($storecfg, $storeid);
3613 $format = qemu_img_format
($scfg, $volname);
3617 die "efidisk format must be specified\n"
3618 if !defined($format);
3621 warn "no efidisk configured! Using temporary efivars disk.\n";
3622 $path = "/tmp/$vmid-ovmf.fd";
3623 PVE
::Tools
::file_copy
($ovmf_vars, $path, -s
$ovmf_vars);
3627 push @$cmd, '-drive', "if=pflash,unit=0,format=raw,readonly,file=$ovmf_code";
3628 push @$cmd, '-drive', "if=pflash,unit=1,format=$format,id=drive-efidisk0,file=$path";
3633 # we use different pcie-port hardware for qemu >= 4.0 for passthrough
3634 if (qemu_machine_feature_enabled
($machine_type, $kvmver, 4, 0)) {
3635 push @$devices, '-readconfig', '/usr/share/qemu-server/pve-q35-4.0.cfg';
3637 push @$devices, '-readconfig', '/usr/share/qemu-server/pve-q35.cfg';
3641 # add usb controllers
3642 my @usbcontrollers = PVE
::QemuServer
::USB
::get_usb_controllers
($conf, $bridges, $arch, $machine_type, $usbdesc->{format
}, $MAX_USB_DEVICES);
3643 push @$devices, @usbcontrollers if @usbcontrollers;
3644 my $vga = parse_vga
($conf->{vga
});
3646 my $qxlnum = vga_conf_has_spice
($conf->{vga
});
3647 $vga->{type
} = 'qxl' if $qxlnum;
3649 if (!$vga->{type
}) {
3650 if ($arch eq 'aarch64') {
3651 $vga->{type
} = 'virtio';
3652 } elsif (qemu_machine_feature_enabled
($machine_type, $kvmver, 2, 9)) {
3653 $vga->{type
} = (!$winversion || $winversion >= 6) ?
'std' : 'cirrus';
3655 $vga->{type
} = ($winversion >= 6) ?
'std' : 'cirrus';
3659 # enable absolute mouse coordinates (needed by vnc)
3661 if (defined($conf->{tablet
})) {
3662 $tablet = $conf->{tablet
};
3664 $tablet = $defaults->{tablet
};
3665 $tablet = 0 if $qxlnum; # disable for spice because it is not needed
3666 $tablet = 0 if $vga->{type
} =~ m/^serial\d+$/; # disable if we use serial terminal (no vga card)
3670 push @$devices, '-device', print_tabletdevice_full
($conf, $arch) if $tablet;
3671 my $kbd = print_keyboarddevice_full
($conf, $arch);
3672 push @$devices, '-device', $kbd if defined($kbd);
3676 my $gpu_passthrough;
3679 for (my $i = 0; $i < $MAX_HOSTPCI_DEVICES; $i++) {
3680 my $d = parse_hostpci
($conf->{"hostpci$i"});
3683 my $pcie = $d->{pcie
};
3685 die "q35 machine model is not enabled" if !$q35;
3686 # win7 wants to have the pcie devices directly on the pcie bus
3687 # instead of in the root port
3688 if ($winversion == 7) {
3689 $pciaddr = print_pcie_addr
("hostpci${i}bus0");
3691 $pciaddr = print_pcie_addr
("hostpci$i");
3694 $pciaddr = print_pci_addr
("hostpci$i", $bridges, $arch, $machine_type);
3697 my $rombar = defined($d->{rombar
}) && !$d->{rombar
} ?
',rombar=0' : '';
3698 my $romfile = $d->{romfile
};
3701 if ($d->{'x-vga'}) {
3702 $xvga = ',x-vga=on';
3704 $vga->{type
} = 'none' if !defined($conf->{vga
});
3705 $gpu_passthrough = 1;
3707 if ($conf->{bios
} && $conf->{bios
} eq 'ovmf') {
3711 my $pcidevices = $d->{pciid
};
3712 my $multifunction = 1 if @$pcidevices > 1;
3714 if ($d->{mdev
} && scalar(@$pcidevices) == 1) {
3715 my $id = $pcidevices->[0]->{id
};
3716 my $uuid = PVE
::SysFSTools
::generate_mdev_uuid
($vmid, $i);
3717 $sysfspath = "/sys/bus/pci/devices/0000:$id/$uuid";
3718 } elsif ($d->{mdev
}) {
3719 warn "ignoring mediated device with multifunction device\n";
3723 foreach my $pcidevice (@$pcidevices) {
3725 my $id = "hostpci$i";
3726 $id .= ".$j" if $multifunction;
3727 my $addr = $pciaddr;
3728 $addr .= ".$j" if $multifunction;
3729 my $devicestr = "vfio-pci";
3731 $devicestr .= ",sysfsdev=$sysfspath";
3733 $devicestr .= ",host=$pcidevice->{id}";
3735 $devicestr .= ",id=$id$addr";
3738 $devicestr .= "$rombar$xvga";
3739 $devicestr .= ",multifunction=on" if $multifunction;
3740 $devicestr .= ",romfile=/usr/share/kvm/$romfile" if $romfile;
3743 push @$devices, '-device', $devicestr;
3749 my @usbdevices = PVE
::QemuServer
::USB
::get_usb_devices
($conf, $usbdesc->{format
}, $MAX_USB_DEVICES);
3750 push @$devices, @usbdevices if @usbdevices;
3752 for (my $i = 0; $i < $MAX_SERIAL_PORTS; $i++) {
3753 if (my $path = $conf->{"serial$i"}) {
3754 if ($path eq 'socket') {
3755 my $socket = "/var/run/qemu-server/${vmid}.serial$i";
3756 push @$devices, '-chardev', "socket,id=serial$i,path=$socket,server,nowait";
3757 # On aarch64, serial0 is the UART device. Qemu only allows
3758 # connecting UART devices via the '-serial' command line, as
3759 # the device has a fixed slot on the hardware...
3760 if ($arch eq 'aarch64' && $i == 0) {
3761 push @$devices, '-serial', "chardev:serial$i";
3763 push @$devices, '-device', "isa-serial,chardev=serial$i";
3766 die "no such serial device\n" if ! -c
$path;
3767 push @$devices, '-chardev', "tty,id=serial$i,path=$path";
3768 push @$devices, '-device', "isa-serial,chardev=serial$i";
3774 for (my $i = 0; $i < $MAX_PARALLEL_PORTS; $i++) {
3775 if (my $path = $conf->{"parallel$i"}) {
3776 die "no such parallel device\n" if ! -c
$path;
3777 my $devtype = $path =~ m!^/dev/usb/lp! ?
'tty' : 'parport';
3778 push @$devices, '-chardev', "$devtype,id=parallel$i,path=$path";
3779 push @$devices, '-device', "isa-parallel,chardev=parallel$i";
3785 $sockets = $conf->{smp
} if $conf->{smp
}; # old style - no longer iused
3786 $sockets = $conf->{sockets
} if $conf->{sockets
};
3788 my $cores = $conf->{cores
} || 1;
3790 my $maxcpus = $sockets * $cores;
3792 my $vcpus = $conf->{vcpus
} ?
$conf->{vcpus
} : $maxcpus;
3794 my $allowed_vcpus = $cpuinfo->{cpus
};
3796 die "MAX $allowed_vcpus vcpus allowed per VM on this node\n"
3797 if ($allowed_vcpus < $maxcpus);
3799 if($hotplug_features->{cpu
} && qemu_machine_feature_enabled
($machine_type, $kvmver, 2, 7)) {
3801 push @$cmd, '-smp', "1,sockets=$sockets,cores=$cores,maxcpus=$maxcpus";
3802 for (my $i = 2; $i <= $vcpus; $i++) {
3803 my $cpustr = print_cpu_device
($conf,$i);
3804 push @$cmd, '-device', $cpustr;
3809 push @$cmd, '-smp', "$vcpus,sockets=$sockets,cores=$cores,maxcpus=$maxcpus";
3811 push @$cmd, '-nodefaults';
3813 my $bootorder = $conf->{boot
} || $confdesc->{boot
}->{default};
3815 my $bootindex_hash = {};
3817 foreach my $o (split(//, $bootorder)) {
3818 $bootindex_hash->{$o} = $i*100;
3822 push @$cmd, '-boot', "menu=on,strict=on,reboot-timeout=1000,splash=/usr/share/qemu-server/bootsplash.jpg";
3824 push @$cmd, '-no-acpi' if defined($conf->{acpi
}) && $conf->{acpi
} == 0;
3826 push @$cmd, '-no-reboot' if defined($conf->{reboot
}) && $conf->{reboot
} == 0;
3828 if ($vga->{type
} && $vga->{type
} !~ m/^serial\d+$/ && $vga->{type
} ne 'none'){
3829 push @$devices, '-device', print_vga_device
($conf, $vga, $arch, $machine_type, undef, $qxlnum, $bridges);
3830 my $socket = vnc_socket
($vmid);
3831 push @$cmd, '-vnc', "unix:$socket,password";
3833 push @$cmd, '-vga', 'none' if $vga->{type
} eq 'none';
3834 push @$cmd, '-nographic';
3838 my $tdf = defined($conf->{tdf
}) ?
$conf->{tdf
} : $defaults->{tdf
};
3840 my $useLocaltime = $conf->{localtime};
3842 if ($winversion >= 5) { # windows
3843 $useLocaltime = 1 if !defined($conf->{localtime});
3845 # use time drift fix when acpi is enabled
3846 if (!(defined($conf->{acpi
}) && $conf->{acpi
} == 0)) {
3847 $tdf = 1 if !defined($conf->{tdf
});
3851 if ($winversion >= 6) {
3852 push @$globalFlags, 'kvm-pit.lost_tick_policy=discard';
3853 push @$cmd, '-no-hpet';
3856 push @$rtcFlags, 'driftfix=slew' if $tdf;
3859 push @$machineFlags, 'accel=tcg';
3862 if ($machine_type) {
3863 push @$machineFlags, "type=${machine_type}";
3866 if (($conf->{startdate
}) && ($conf->{startdate
} ne 'now')) {
3867 push @$rtcFlags, "base=$conf->{startdate}";
3868 } elsif ($useLocaltime) {
3869 push @$rtcFlags, 'base=localtime';
3872 push @$cmd, get_cpu_options
($conf, $arch, $kvm, $machine_type, $kvm_off, $kvmver, $winversion, $gpu_passthrough);
3874 PVE
::QemuServer
::Memory
::config
($conf, $vmid, $sockets, $cores, $defaults, $hotplug_features, $cmd);
3876 push @$cmd, '-S' if $conf->{freeze
};
3878 push @$cmd, '-k', $conf->{keyboard
} if defined($conf->{keyboard
});
3881 #my $soundhw = $conf->{soundhw} || $defaults->{soundhw};
3882 #push @$cmd, '-soundhw', 'es1370';
3883 #push @$cmd, '-soundhw', $soundhw if $soundhw;
3885 if (parse_guest_agent
($conf)->{enabled
}) {
3886 my $qgasocket = qmp_socket
($vmid, 1);
3887 my $pciaddr = print_pci_addr
("qga0", $bridges, $arch, $machine_type);
3888 push @$devices, '-chardev', "socket,path=$qgasocket,server,nowait,id=qga0";
3889 push @$devices, '-device', "virtio-serial,id=qga0$pciaddr";
3890 push @$devices, '-device', 'virtserialport,chardev=qga0,name=org.qemu.guest_agent.0';
3898 for(my $i = 1; $i < $qxlnum; $i++){
3899 push @$devices, '-device', print_vga_device
($conf, $vga, $arch, $machine_type, $i, $qxlnum, $bridges);
3902 # assume other OS works like Linux
3903 my ($ram, $vram) = ("134217728", "67108864");
3904 if ($vga->{memory
}) {
3905 $ram = PVE
::Tools
::convert_size
($qxlnum*4*$vga->{memory
}, 'mb' => 'b');
3906 $vram = PVE
::Tools
::convert_size
($qxlnum*2*$vga->{memory
}, 'mb' => 'b');
3908 push @$cmd, '-global', "qxl-vga.ram_size=$ram";
3909 push @$cmd, '-global', "qxl-vga.vram_size=$vram";
3913 my $pciaddr = print_pci_addr
("spice", $bridges, $arch, $machine_type);
3915 my $nodename = PVE
::INotify
::nodename
();
3916 my $pfamily = PVE
::Tools
::get_host_address_family
($nodename);
3917 my @nodeaddrs = PVE
::Tools
::getaddrinfo_all
('localhost', family
=> $pfamily);
3918 die "failed to get an ip address of type $pfamily for 'localhost'\n" if !@nodeaddrs;
3919 my $localhost = PVE
::Network
::addr_to_ip
($nodeaddrs[0]->{addr
});
3920 $spice_port = PVE
::Tools
::next_spice_port
($pfamily, $localhost);
3922 push @$devices, '-spice', "tls-port=${spice_port},addr=$localhost,tls-ciphers=HIGH,seamless-migration=on";
3924 push @$devices, '-device', "virtio-serial,id=spice$pciaddr";
3925 push @$devices, '-chardev', "spicevmc,id=vdagent,name=vdagent";
3926 push @$devices, '-device', "virtserialport,chardev=vdagent,name=com.redhat.spice.0";
3929 # enable balloon by default, unless explicitly disabled
3930 if (!defined($conf->{balloon
}) || $conf->{balloon
}) {
3931 $pciaddr = print_pci_addr
("balloon0", $bridges, $arch, $machine_type);
3932 push @$devices, '-device', "virtio-balloon-pci,id=balloon0$pciaddr";
3935 if ($conf->{watchdog
}) {
3936 my $wdopts = parse_watchdog
($conf->{watchdog
});
3937 $pciaddr = print_pci_addr
("watchdog", $bridges, $arch, $machine_type);
3938 my $watchdog = $wdopts->{model
} || 'i6300esb';
3939 push @$devices, '-device', "$watchdog$pciaddr";
3940 push @$devices, '-watchdog-action', $wdopts->{action
} if $wdopts->{action
};
3944 my $scsicontroller = {};
3945 my $ahcicontroller = {};
3946 my $scsihw = defined($conf->{scsihw
}) ?
$conf->{scsihw
} : $defaults->{scsihw
};
3948 # Add iscsi initiator name if available
3949 if (my $initiator = get_initiator_name
()) {
3950 push @$devices, '-iscsi', "initiator-name=$initiator";
3953 foreach_drive
($conf, sub {
3954 my ($ds, $drive) = @_;
3956 if (PVE
::Storage
::parse_volume_id
($drive->{file
}, 1)) {
3957 push @$vollist, $drive->{file
};
3960 # ignore efidisk here, already added in bios/fw handling code above
3961 return if $drive->{interface
} eq 'efidisk';
3963 $use_virtio = 1 if $ds =~ m/^virtio/;
3965 if (drive_is_cdrom
($drive)) {
3966 if ($bootindex_hash->{d
}) {
3967 $drive->{bootindex
} = $bootindex_hash->{d
};
3968 $bootindex_hash->{d
} += 1;
3971 if ($bootindex_hash->{c
}) {
3972 $drive->{bootindex
} = $bootindex_hash->{c
} if $conf->{bootdisk
} && ($conf->{bootdisk
} eq $ds);
3973 $bootindex_hash->{c
} += 1;
3977 if($drive->{interface
} eq 'virtio'){
3978 push @$cmd, '-object', "iothread,id=iothread-$ds" if $drive->{iothread
};
3981 if ($drive->{interface
} eq 'scsi') {
3983 my ($maxdev, $controller, $controller_prefix) = scsihw_infos
($conf, $drive);
3985 $pciaddr = print_pci_addr
("$controller_prefix$controller", $bridges, $arch, $machine_type);
3986 my $scsihw_type = $scsihw =~ m/^virtio-scsi-single/ ?
"virtio-scsi-pci" : $scsihw;
3989 if($conf->{scsihw
} && $conf->{scsihw
} eq "virtio-scsi-single" && $drive->{iothread
}){
3990 $iothread .= ",iothread=iothread-$controller_prefix$controller";
3991 push @$cmd, '-object', "iothread,id=iothread-$controller_prefix$controller";
3992 } elsif ($drive->{iothread
}) {
3993 warn "iothread is only valid with virtio disk or virtio-scsi-single controller, ignoring\n";
3997 if($conf->{scsihw
} && $conf->{scsihw
} eq "virtio-scsi-single" && $drive->{queues
}){
3998 $queues = ",num_queues=$drive->{queues}";
4001 push @$devices, '-device', "$scsihw_type,id=$controller_prefix$controller$pciaddr$iothread$queues" if !$scsicontroller->{$controller};
4002 $scsicontroller->{$controller}=1;
4005 if ($drive->{interface
} eq 'sata') {
4006 my $controller = int($drive->{index} / $MAX_SATA_DISKS);
4007 $pciaddr = print_pci_addr
("ahci$controller", $bridges, $arch, $machine_type);
4008 push @$devices, '-device', "ahci,id=ahci$controller,multifunction=on$pciaddr" if !$ahcicontroller->{$controller};
4009 $ahcicontroller->{$controller}=1;
4012 my $drive_cmd = print_drive_full
($storecfg, $vmid, $drive);
4013 push @$devices, '-drive',$drive_cmd;
4014 push @$devices, '-device', print_drivedevice_full
($storecfg, $conf, $vmid, $drive, $bridges, $arch, $machine_type);
4017 for (my $i = 0; $i < $MAX_NETS; $i++) {
4018 next if !$conf->{"net$i"};
4019 my $d = parse_net
($conf->{"net$i"});
4022 $use_virtio = 1 if $d->{model
} eq 'virtio';
4024 if ($bootindex_hash->{n
}) {
4025 $d->{bootindex
} = $bootindex_hash->{n
};
4026 $bootindex_hash->{n
} += 1;
4029 my $netdevfull = print_netdev_full
($vmid, $conf, $arch, $d, "net$i");
4030 push @$devices, '-netdev', $netdevfull;
4032 my $netdevicefull = print_netdevice_full
($vmid, $conf, $d, "net$i", $bridges, $use_old_bios_files, $arch, $machine_type);
4033 push @$devices, '-device', $netdevicefull;
4036 if ($conf->{ivshmem
}) {
4037 my $ivshmem = PVE
::JSONSchema
::parse_property_string
($ivshmem_fmt, $conf->{ivshmem
});
4041 $bus = print_pcie_addr
("ivshmem");
4043 $bus = print_pci_addr
("ivshmem", $bridges, $arch, $machine_type);
4046 my $ivshmem_name = $ivshmem->{name
} // $vmid;
4047 my $path = '/dev/shm/pve-shm-' . $ivshmem_name;
4049 push @$devices, '-device', "ivshmem-plain,memdev=ivshmem$bus,";
4050 push @$devices, '-object', "memory-backend-file,id=ivshmem,share=on,mem-path=$path,size=$ivshmem->{size}M";
4055 if (qemu_machine_feature_enabled
($machine_type, $kvmver, 2, 3)) {
4060 $bridges->{3} = 1 if $scsihw =~ m/^virtio-scsi-single/;
4062 while (my ($k, $v) = each %$bridges) {
4063 $pciaddr = print_pci_addr
("pci.$k", undef, $arch, $machine_type);
4064 unshift @$devices, '-device', "pci-bridge,id=pci.$k,chassis_nr=$k$pciaddr" if $k > 0;
4068 push @$cmd, @$devices;
4069 push @$cmd, '-rtc', join(',', @$rtcFlags)
4070 if scalar(@$rtcFlags);
4071 push @$cmd, '-machine', join(',', @$machineFlags)
4072 if scalar(@$machineFlags);
4073 push @$cmd, '-global', join(',', @$globalFlags)
4074 if scalar(@$globalFlags);
4076 if (my $vmstate = $conf->{vmstate
}) {
4077 my $statepath = PVE
::Storage
::path
($storecfg, $vmstate);
4078 PVE
::Storage
::activate_volumes
($storecfg, [$vmstate]);
4079 push @$cmd, '-loadstate', $statepath;
4083 if ($conf->{args
}) {
4084 my $aa = PVE
::Tools
::split_args
($conf->{args
});
4088 return wantarray ?
($cmd, $vollist, $spice_port) : $cmd;
4093 return "${var_run_tmpdir}/$vmid.vnc";
4099 my $res = vm_mon_cmd
($vmid, 'query-spice');
4101 return $res->{'tls-port'} || $res->{'port'} || die "no spice port\n";
4105 my ($vmid, $qga, $name) = @_;
4106 my $sockettype = $qga ?
'qga' : 'qmp';
4107 my $ext = $name ?
'-'.$name : '';
4108 return "${var_run_tmpdir}/$vmid$ext.$sockettype";
4113 return "${var_run_tmpdir}/$vmid.pid";
4116 sub vm_devices_list
{
4119 my $res = vm_mon_cmd
($vmid, 'query-pci');
4120 my $devices_to_check = [];
4122 foreach my $pcibus (@$res) {
4123 push @$devices_to_check, @{$pcibus->{devices
}},
4126 while (@$devices_to_check) {
4128 for my $d (@$devices_to_check) {
4129 $devices->{$d->{'qdev_id'}} = 1 if $d->{'qdev_id'};
4130 next if !$d->{'pci_bridge'};
4132 $devices->{$d->{'qdev_id'}} += scalar(@{$d->{'pci_bridge'}->{devices
}});
4133 push @$to_check, @{$d->{'pci_bridge'}->{devices
}};
4135 $devices_to_check = $to_check;
4138 my $resblock = vm_mon_cmd
($vmid, 'query-block');
4139 foreach my $block (@$resblock) {
4140 if($block->{device
} =~ m/^drive-(\S+)/){
4145 my $resmice = vm_mon_cmd
($vmid, 'query-mice');
4146 foreach my $mice (@$resmice) {
4147 if ($mice->{name
} eq 'QEMU HID Tablet') {
4148 $devices->{tablet
} = 1;
4153 # for usb devices there is no query-usb
4154 # but we can iterate over the entries in
4155 # qom-list path=/machine/peripheral
4156 my $resperipheral = vm_mon_cmd
($vmid, 'qom-list', path
=> '/machine/peripheral');
4157 foreach my $per (@$resperipheral) {
4158 if ($per->{name
} =~ m/^usb\d+$/) {
4159 $devices->{$per->{name
}} = 1;
4167 my ($storecfg, $conf, $vmid, $deviceid, $device, $arch, $machine_type) = @_;
4169 my $q35 = machine_type_is_q35
($conf);
4171 my $devices_list = vm_devices_list
($vmid);
4172 return 1 if defined($devices_list->{$deviceid});
4174 qemu_add_pci_bridge
($storecfg, $conf, $vmid, $deviceid, $arch, $machine_type); # add PCI bridge if we need it for the device
4176 if ($deviceid eq 'tablet') {
4178 qemu_deviceadd
($vmid, print_tabletdevice_full
($conf, $arch));
4180 } elsif ($deviceid eq 'keyboard') {
4182 qemu_deviceadd
($vmid, print_keyboarddevice_full
($conf, $arch));
4184 } elsif ($deviceid =~ m/^usb(\d+)$/) {
4186 die "usb hotplug currently not reliable\n";
4187 # since we can't reliably hot unplug all added usb devices
4188 # and usb passthrough disables live migration
4189 # we disable usb hotplugging for now
4190 qemu_deviceadd
($vmid, PVE
::QemuServer
::USB
::print_usbdevice_full
($conf, $deviceid, $device));
4192 } elsif ($deviceid =~ m/^(virtio)(\d+)$/) {
4194 qemu_iothread_add
($vmid, $deviceid, $device);
4196 qemu_driveadd
($storecfg, $vmid, $device);
4197 my $devicefull = print_drivedevice_full
($storecfg, $conf, $vmid, $device, $arch, $machine_type);
4199 qemu_deviceadd
($vmid, $devicefull);
4200 eval { qemu_deviceaddverify
($vmid, $deviceid); };
4202 eval { qemu_drivedel
($vmid, $deviceid); };
4207 } elsif ($deviceid =~ m/^(virtioscsi|scsihw)(\d+)$/) {
4210 my $scsihw = defined($conf->{scsihw
}) ?
$conf->{scsihw
} : "lsi";
4211 my $pciaddr = print_pci_addr
($deviceid, undef, $arch, $machine_type);
4212 my $scsihw_type = $scsihw eq 'virtio-scsi-single' ?
"virtio-scsi-pci" : $scsihw;
4214 my $devicefull = "$scsihw_type,id=$deviceid$pciaddr";
4216 if($deviceid =~ m/^virtioscsi(\d+)$/ && $device->{iothread
}) {
4217 qemu_iothread_add
($vmid, $deviceid, $device);
4218 $devicefull .= ",iothread=iothread-$deviceid";
4221 if($deviceid =~ m/^virtioscsi(\d+)$/ && $device->{queues
}) {
4222 $devicefull .= ",num_queues=$device->{queues}";
4225 qemu_deviceadd
($vmid, $devicefull);
4226 qemu_deviceaddverify
($vmid, $deviceid);
4228 } elsif ($deviceid =~ m/^(scsi)(\d+)$/) {
4230 qemu_findorcreatescsihw
($storecfg,$conf, $vmid, $device, $arch, $machine_type);
4231 qemu_driveadd
($storecfg, $vmid, $device);
4233 my $devicefull = print_drivedevice_full
($storecfg, $conf, $vmid, $device, $arch, $machine_type);
4234 eval { qemu_deviceadd
($vmid, $devicefull); };
4236 eval { qemu_drivedel
($vmid, $deviceid); };
4241 } elsif ($deviceid =~ m/^(net)(\d+)$/) {
4243 return undef if !qemu_netdevadd
($vmid, $conf, $arch, $device, $deviceid);
4245 my $machine_type = PVE
::QemuServer
::qemu_machine_pxe
($vmid, $conf);
4246 my $use_old_bios_files = undef;
4247 ($use_old_bios_files, $machine_type) = qemu_use_old_bios_files
($machine_type);
4249 my $netdevicefull = print_netdevice_full
($vmid, $conf, $device, $deviceid, undef, $use_old_bios_files, $arch, $machine_type);
4250 qemu_deviceadd
($vmid, $netdevicefull);
4252 qemu_deviceaddverify
($vmid, $deviceid);
4253 qemu_set_link_status
($vmid, $deviceid, !$device->{link_down
});
4256 eval { qemu_netdevdel
($vmid, $deviceid); };
4261 } elsif (!$q35 && $deviceid =~ m/^(pci\.)(\d+)$/) {
4264 my $pciaddr = print_pci_addr
($deviceid, undef, $arch, $machine_type);
4265 my $devicefull = "pci-bridge,id=pci.$bridgeid,chassis_nr=$bridgeid$pciaddr";
4267 qemu_deviceadd
($vmid, $devicefull);
4268 qemu_deviceaddverify
($vmid, $deviceid);
4271 die "can't hotplug device '$deviceid'\n";
4277 # fixme: this should raise exceptions on error!
4278 sub vm_deviceunplug
{
4279 my ($vmid, $conf, $deviceid) = @_;
4281 my $devices_list = vm_devices_list
($vmid);
4282 return 1 if !defined($devices_list->{$deviceid});
4284 die "can't unplug bootdisk" if $conf->{bootdisk
} && $conf->{bootdisk
} eq $deviceid;
4286 if ($deviceid eq 'tablet' || $deviceid eq 'keyboard') {
4288 qemu_devicedel
($vmid, $deviceid);
4290 } elsif ($deviceid =~ m/^usb\d+$/) {
4292 die "usb hotplug currently not reliable\n";
4293 # when unplugging usb devices this way,
4294 # there may be remaining usb controllers/hubs
4295 # so we disable it for now
4296 qemu_devicedel
($vmid, $deviceid);
4297 qemu_devicedelverify
($vmid, $deviceid);
4299 } elsif ($deviceid =~ m/^(virtio)(\d+)$/) {
4301 qemu_devicedel
($vmid, $deviceid);
4302 qemu_devicedelverify
($vmid, $deviceid);
4303 qemu_drivedel
($vmid, $deviceid);
4304 qemu_iothread_del
($conf, $vmid, $deviceid);
4306 } elsif ($deviceid =~ m/^(virtioscsi|scsihw)(\d+)$/) {
4308 qemu_devicedel
($vmid, $deviceid);
4309 qemu_devicedelverify
($vmid, $deviceid);
4310 qemu_iothread_del
($conf, $vmid, $deviceid);
4312 } elsif ($deviceid =~ m/^(scsi)(\d+)$/) {
4314 qemu_devicedel
($vmid, $deviceid);
4315 qemu_drivedel
($vmid, $deviceid);
4316 qemu_deletescsihw
($conf, $vmid, $deviceid);
4318 } elsif ($deviceid =~ m/^(net)(\d+)$/) {
4320 qemu_devicedel
($vmid, $deviceid);
4321 qemu_devicedelverify
($vmid, $deviceid);
4322 qemu_netdevdel
($vmid, $deviceid);
4325 die "can't unplug device '$deviceid'\n";
4331 sub qemu_deviceadd
{
4332 my ($vmid, $devicefull) = @_;
4334 $devicefull = "driver=".$devicefull;
4335 my %options = split(/[=,]/, $devicefull);
4337 vm_mon_cmd
($vmid, "device_add" , %options);
4340 sub qemu_devicedel
{
4341 my ($vmid, $deviceid) = @_;
4343 my $ret = vm_mon_cmd
($vmid, "device_del", id
=> $deviceid);
4346 sub qemu_iothread_add
{
4347 my($vmid, $deviceid, $device) = @_;
4349 if ($device->{iothread
}) {
4350 my $iothreads = vm_iothreads_list
($vmid);
4351 qemu_objectadd
($vmid, "iothread-$deviceid", "iothread") if !$iothreads->{"iothread-$deviceid"};
4355 sub qemu_iothread_del
{
4356 my($conf, $vmid, $deviceid) = @_;
4358 my $confid = $deviceid;
4359 if ($deviceid =~ m/^(?:virtioscsi|scsihw)(\d+)$/) {
4360 $confid = 'scsi' . $1;
4362 my $device = parse_drive
($confid, $conf->{$confid});
4363 if ($device->{iothread
}) {
4364 my $iothreads = vm_iothreads_list
($vmid);
4365 qemu_objectdel
($vmid, "iothread-$deviceid") if $iothreads->{"iothread-$deviceid"};
4369 sub qemu_objectadd
{
4370 my($vmid, $objectid, $qomtype) = @_;
4372 vm_mon_cmd
($vmid, "object-add", id
=> $objectid, "qom-type" => $qomtype);
4377 sub qemu_objectdel
{
4378 my($vmid, $objectid) = @_;
4380 vm_mon_cmd
($vmid, "object-del", id
=> $objectid);
4386 my ($storecfg, $vmid, $device) = @_;
4388 my $drive = print_drive_full
($storecfg, $vmid, $device);
4389 $drive =~ s/\\/\\\\/g;
4390 my $ret = vm_human_monitor_command
($vmid, "drive_add auto \"$drive\"");
4392 # If the command succeeds qemu prints: "OK
"
4393 return 1 if $ret =~ m/OK/s;
4395 die "adding drive failed
: $ret\n";
4399 my($vmid, $deviceid) = @_;
4401 my $ret = vm_human_monitor_command($vmid, "drive_del drive-
$deviceid");
4404 return 1 if $ret eq "";
4406 # NB: device not found errors mean the drive was auto-deleted and we ignore the error
4407 return 1 if $ret =~ m/Device \'.*?\' not found/s;
4409 die "deleting drive
$deviceid failed
: $ret\n";
4412 sub qemu_deviceaddverify {
4413 my ($vmid, $deviceid) = @_;
4415 for (my $i = 0; $i <= 5; $i++) {
4416 my $devices_list = vm_devices_list($vmid);
4417 return 1 if defined($devices_list->{$deviceid});
4421 die "error on hotplug device
'$deviceid'\n";
4425 sub qemu_devicedelverify {
4426 my ($vmid, $deviceid) = @_;
4428 # need to verify that the device is correctly removed as device_del
4429 # is async and empty return is not reliable
4431 for (my $i = 0; $i <= 5; $i++) {
4432 my $devices_list = vm_devices_list($vmid);
4433 return 1 if !defined($devices_list->{$deviceid});
4437 die "error on hot-unplugging device
'$deviceid'\n";
4440 sub qemu_findorcreatescsihw {
4441 my ($storecfg, $conf, $vmid, $device, $arch, $machine_type) = @_;
4443 my ($maxdev, $controller, $controller_prefix) = scsihw_infos($conf, $device);
4445 my $scsihwid="$controller_prefix$controller";
4446 my $devices_list = vm_devices_list($vmid);
4448 if(!defined($devices_list->{$scsihwid})) {
4449 vm_deviceplug($storecfg, $conf, $vmid, $scsihwid, $device, $arch, $machine_type);
4455 sub qemu_deletescsihw {
4456 my ($conf, $vmid, $opt) = @_;
4458 my $device = parse_drive($opt, $conf->{$opt});
4460 if ($conf->{scsihw} && ($conf->{scsihw} eq 'virtio-scsi-single')) {
4461 vm_deviceunplug($vmid, $conf, "virtioscsi
$device->{index}");
4465 my ($maxdev, $controller, $controller_prefix) = scsihw_infos($conf, $device);
4467 my $devices_list = vm_devices_list($vmid);
4468 foreach my $opt (keys %{$devices_list}) {
4469 if (PVE::QemuServer::is_valid_drivename($opt)) {
4470 my $drive = PVE::QemuServer::parse_drive($opt, $conf->{$opt});
4471 if($drive->{interface} eq 'scsi' && $drive->{index} < (($maxdev-1)*($controller+1))) {
4477 my $scsihwid="scsihw
$controller";
4479 vm_deviceunplug($vmid, $conf, $scsihwid);
4484 sub qemu_add_pci_bridge {
4485 my ($storecfg, $conf, $vmid, $device, $arch, $machine_type) = @_;
4491 print_pci_addr($device, $bridges, $arch, $machine_type);
4493 while (my ($k, $v) = each %$bridges) {
4496 return 1 if !defined($bridgeid) || $bridgeid < 1;
4498 my $bridge = "pci
.$bridgeid";
4499 my $devices_list = vm_devices_list($vmid);
4501 if (!defined($devices_list->{$bridge})) {
4502 vm_deviceplug($storecfg, $conf, $vmid, $bridge, $arch, $machine_type);
4508 sub qemu_set_link_status {
4509 my ($vmid, $device, $up) = @_;
4511 vm_mon_cmd($vmid, "set_link
", name => $device,
4512 up => $up ? JSON::true : JSON::false);
4515 sub qemu_netdevadd {
4516 my ($vmid, $conf, $arch, $device, $deviceid) = @_;
4518 my $netdev = print_netdev_full($vmid, $conf, $arch, $device, $deviceid, 1);
4519 my %options = split(/[=,]/, $netdev);
4521 vm_mon_cmd($vmid, "netdev_add
", %options);
4525 sub qemu_netdevdel {
4526 my ($vmid, $deviceid) = @_;
4528 vm_mon_cmd($vmid, "netdev_del
", id => $deviceid);
4531 sub qemu_usb_hotplug {
4532 my ($storecfg, $conf, $vmid, $deviceid, $device, $arch, $machine_type) = @_;
4536 # remove the old one first
4537 vm_deviceunplug($vmid, $conf, $deviceid);
4539 # check if xhci controller is necessary and available
4540 if ($device->{usb3}) {
4542 my $devicelist = vm_devices_list($vmid);
4544 if (!$devicelist->{xhci}) {
4545 my $pciaddr = print_pci_addr("xhci
", undef, $arch, $machine_type);
4546 qemu_deviceadd($vmid, "nec-usb-xhci
,id
=xhci
$pciaddr");
4549 my $d = parse_usb_device($device->{host});
4550 $d->{usb3} = $device->{usb3};
4553 vm_deviceplug($storecfg, $conf, $vmid, $deviceid, $d, $arch, $machine_type);
4556 sub qemu_cpu_hotplug {
4557 my ($vmid, $conf, $vcpus) = @_;
4559 my $machine_type = PVE::QemuServer::get_current_qemu_machine($vmid);
4562 $sockets = $conf->{smp} if $conf->{smp}; # old style - no longer iused
4563 $sockets = $conf->{sockets} if $conf->{sockets};
4564 my $cores = $conf->{cores} || 1;
4565 my $maxcpus = $sockets * $cores;
4567 $vcpus = $maxcpus if !$vcpus;
4569 die "you can
't add more vcpus than maxcpus\n"
4570 if $vcpus > $maxcpus;
4572 my $currentvcpus = $conf->{vcpus} || $maxcpus;
4574 if ($vcpus < $currentvcpus) {
4576 if (qemu_machine_feature_enabled ($machine_type, undef, 2, 7)) {
4578 for (my $i = $currentvcpus; $i > $vcpus; $i--) {
4579 qemu_devicedel($vmid, "cpu$i");
4581 my $currentrunningvcpus = undef;
4583 $currentrunningvcpus = vm_mon_cmd($vmid, "query-cpus");
4584 last if scalar(@{$currentrunningvcpus}) == $i-1;
4585 raise_param_exc({ vcpus => "error unplugging cpu$i" }) if $retry > 5;
4589 #update conf after each succesfull cpu unplug
4590 $conf->{vcpus} = scalar(@{$currentrunningvcpus});
4591 PVE::QemuConfig->write_config($vmid, $conf);
4594 die "cpu hot-unplugging requires qemu version 2.7 or higher\n";
4600 my $currentrunningvcpus = vm_mon_cmd($vmid, "query-cpus");
4601 die "vcpus in running vm does not match its configuration\n"
4602 if scalar(@{$currentrunningvcpus}) != $currentvcpus;
4604 if (qemu_machine_feature_enabled ($machine_type, undef, 2, 7)) {
4606 for (my $i = $currentvcpus+1; $i <= $vcpus; $i++) {
4607 my $cpustr = print_cpu_device($conf, $i);
4608 qemu_deviceadd($vmid, $cpustr);
4611 my $currentrunningvcpus = undef;
4613 $currentrunningvcpus = vm_mon_cmd($vmid, "query-cpus");
4614 last if scalar(@{$currentrunningvcpus}) == $i;
4615 raise_param_exc({ vcpus => "error hotplugging cpu$i" }) if $retry > 10;
4619 #update conf after each succesfull cpu hotplug
4620 $conf->{vcpus} = scalar(@{$currentrunningvcpus});
4621 PVE::QemuConfig->write_config($vmid, $conf);
4625 for (my $i = $currentvcpus; $i < $vcpus; $i++) {
4626 vm_mon_cmd($vmid, "cpu-add", id => int($i));
4631 sub qemu_block_set_io_throttle {
4632 my ($vmid, $deviceid,
4633 $bps, $bps_rd, $bps_wr, $iops, $iops_rd, $iops_wr,
4634 $bps_max, $bps_rd_max, $bps_wr_max, $iops_max, $iops_rd_max, $iops_wr_max,
4635 $bps_max_length, $bps_rd_max_length, $bps_wr_max_length,
4636 $iops_max_length, $iops_rd_max_length, $iops_wr_max_length) = @_;
4638 return if !check_running($vmid) ;
4640 vm_mon_cmd($vmid, "block_set_io_throttle", device => $deviceid,
4642 bps_rd => int($bps_rd),
4643 bps_wr => int($bps_wr),
4645 iops_rd => int($iops_rd),
4646 iops_wr => int($iops_wr),
4647 bps_max => int($bps_max),
4648 bps_rd_max => int($bps_rd_max),
4649 bps_wr_max => int($bps_wr_max),
4650 iops_max => int($iops_max),
4651 iops_rd_max => int($iops_rd_max),
4652 iops_wr_max => int($iops_wr_max),
4653 bps_max_length => int($bps_max_length),
4654 bps_rd_max_length => int($bps_rd_max_length),
4655 bps_wr_max_length => int($bps_wr_max_length),
4656 iops_max_length => int($iops_max_length),
4657 iops_rd_max_length => int($iops_rd_max_length),
4658 iops_wr_max_length => int($iops_wr_max_length),
4663 # old code, only used to shutdown old VM after update
4665 my ($fh, $timeout) = @_;
4667 my $sel = new IO::Select;
4674 while (scalar (@ready = $sel->can_read($timeout))) {
4676 if ($count = $fh->sysread($buf, 8192)) {
4677 if ($buf =~ /^(.*)\(qemu\) $/s) {
4684 if (!defined($count)) {
4691 die "monitor read timeout\n" if !scalar(@ready);
4696 sub qemu_block_resize {
4697 my ($vmid, $deviceid, $storecfg, $volid, $size) = @_;
4699 my $running = check_running($vmid);
4701 $size = 0 if !PVE::Storage::volume_resize($storecfg, $volid, $size, $running);
4703 return if !$running;
4705 vm_mon_cmd($vmid, "block_resize", device => $deviceid, size => int($size));
4709 sub qemu_volume_snapshot {
4710 my ($vmid, $deviceid, $storecfg, $volid, $snap) = @_;
4712 my $running = check_running($vmid);
4714 if ($running && do_snapshots_with_qemu($storecfg, $volid)){
4715 vm_mon_cmd($vmid, 'blockdev-snapshot-internal-sync
', device => $deviceid, name => $snap);
4717 PVE::Storage::volume_snapshot($storecfg, $volid, $snap);
4721 sub qemu_volume_snapshot_delete {
4722 my ($vmid, $deviceid, $storecfg, $volid, $snap) = @_;
4724 my $running = check_running($vmid);
4729 my $conf = PVE::QemuConfig->load_config($vmid);
4730 foreach_drive($conf, sub {
4731 my ($ds, $drive) = @_;
4732 $running = 1 if $drive->{file} eq $volid;
4736 if ($running && do_snapshots_with_qemu($storecfg, $volid)){
4737 vm_mon_cmd($vmid, 'blockdev-snapshot-delete-internal-sync
', device => $deviceid, name => $snap);
4739 PVE::Storage::volume_snapshot_delete($storecfg, $volid, $snap, $running);
4743 sub set_migration_caps {
4749 "auto-converge" => 1,
4751 "x-rdma-pin-all" => 0,
4756 my $supported_capabilities = vm_mon_cmd_nocheck($vmid, "query-migrate-capabilities");
4758 for my $supported_capability (@$supported_capabilities) {
4760 capability => $supported_capability->{capability},
4761 state => $enabled_cap->{$supported_capability->{capability}} ? JSON::true : JSON::false,
4765 vm_mon_cmd_nocheck($vmid, "migrate-set-capabilities", capabilities => $cap_ref);
4768 my $fast_plug_option = {
4776 'vmstatestorage
' => 1,
4780 # hotplug changes in [PENDING]
4781 # $selection hash can be used to only apply specified options, for
4782 # example: { cores => 1 } (only apply changed 'cores
')
4783 # $errors ref is used to return error messages
4784 sub vmconfig_hotplug_pending {
4785 my ($vmid, $conf, $storecfg, $selection, $errors) = @_;
4787 my $defaults = load_defaults();
4788 my ($arch, $machine_type) = get_basic_machine_info($conf, undef);
4790 # commit values which do not have any impact on running VM first
4791 # Note: those option cannot raise errors, we we do not care about
4792 # $selection and always apply them.
4794 my $add_error = sub {
4795 my ($opt, $msg) = @_;
4796 $errors->{$opt} = "hotplug problem - $msg";
4800 foreach my $opt (keys %{$conf->{pending}}) { # add/change
4801 if ($fast_plug_option->{$opt}) {
4802 $conf->{$opt} = $conf->{pending}->{$opt};
4803 delete $conf->{pending}->{$opt};
4809 PVE::QemuConfig->write_config($vmid, $conf);
4810 $conf = PVE::QemuConfig->load_config($vmid); # update/reload
4813 my $hotplug_features = parse_hotplug_features(defined($conf->{hotplug}) ? $conf->{hotplug} : '1');
4815 my $pending_delete_hash = split_flagged_list($conf->{pending}->{delete});
4816 while (my ($opt, $force) = each %$pending_delete_hash) {
4817 next if $selection && !$selection->{$opt};
4819 if ($opt eq 'hotplug
') {
4820 die "skip\n" if ($conf->{hotplug} =~ /memory/);
4821 } elsif ($opt eq 'tablet
') {
4822 die "skip\n" if !$hotplug_features->{usb};
4823 if ($defaults->{tablet}) {
4824 vm_deviceplug($storecfg, $conf, $vmid, 'tablet
', $arch, $machine_type);
4825 vm_deviceplug($storecfg, $conf, $vmid, 'keyboard
', $arch, $machine_type)
4826 if $arch eq 'aarch64
';
4828 vm_deviceunplug($vmid, $conf, 'tablet
');
4829 vm_deviceunplug($vmid, $conf, 'keyboard
') if $arch eq 'aarch64
';
4831 } elsif ($opt =~ m/^usb\d+/) {
4833 # since we cannot reliably hot unplug usb devices
4834 # we are disabling it
4835 die "skip\n" if !$hotplug_features->{usb} || $conf->{$opt} =~ m/spice/i;
4836 vm_deviceunplug($vmid, $conf, $opt);
4837 } elsif ($opt eq 'vcpus
') {
4838 die "skip\n" if !$hotplug_features->{cpu};
4839 qemu_cpu_hotplug($vmid, $conf, undef);
4840 } elsif ($opt eq 'balloon
') {
4841 # enable balloon device is not hotpluggable
4842 die "skip\n" if defined($conf->{balloon}) && $conf->{balloon} == 0;
4843 # here we reset the ballooning value to memory
4844 my $balloon = $conf->{memory} || $defaults->{memory};
4845 vm_mon_cmd($vmid, "balloon", value => $balloon*1024*1024);
4846 } elsif ($fast_plug_option->{$opt}) {
4848 } elsif ($opt =~ m/^net(\d+)$/) {
4849 die "skip\n" if !$hotplug_features->{network};
4850 vm_deviceunplug($vmid, $conf, $opt);
4851 } elsif (is_valid_drivename($opt)) {
4852 die "skip\n" if !$hotplug_features->{disk} || $opt =~ m/(ide|sata)(\d+)/;
4853 vm_deviceunplug($vmid, $conf, $opt);
4854 vmconfig_delete_or_detach_drive($vmid, $storecfg, $conf, $opt, $force);
4855 } elsif ($opt =~ m/^memory$/) {
4856 die "skip\n" if !$hotplug_features->{memory};
4857 PVE::QemuServer::Memory::qemu_memory_hotplug($vmid, $conf, $defaults, $opt);
4858 } elsif ($opt eq 'cpuunits
') {
4859 cgroups_write("cpu", $vmid, "cpu.shares", $defaults->{cpuunits});
4860 } elsif ($opt eq 'cpulimit
') {
4861 cgroups_write("cpu", $vmid, "cpu.cfs_quota_us", -1);
4867 &$add_error($opt, $err) if $err ne "skip\n";
4869 # save new config if hotplug was successful
4870 delete $conf->{$opt};
4871 vmconfig_undelete_pending_option($conf, $opt);
4872 PVE::QemuConfig->write_config($vmid, $conf);
4873 $conf = PVE::QemuConfig->load_config($vmid); # update/reload
4877 my $apply_pending_cloudinit;
4878 $apply_pending_cloudinit = sub {
4879 my ($key, $value) = @_;
4880 $apply_pending_cloudinit = sub {}; # once is enough
4882 my @cloudinit_opts = keys %$confdesc_cloudinit;
4883 foreach my $opt (keys %{$conf->{pending}}) {
4884 next if !grep { $_ eq $opt } @cloudinit_opts;
4885 $conf->{$opt} = delete $conf->{pending}->{$opt};
4888 my $new_conf = { %$conf };
4889 $new_conf->{$key} = $value;
4890 PVE::QemuServer::Cloudinit::generate_cloudinitconfig($new_conf, $vmid);
4893 foreach my $opt (keys %{$conf->{pending}}) {
4894 next if $selection && !$selection->{$opt};
4895 my $value = $conf->{pending}->{$opt};
4897 if ($opt eq 'hotplug
') {
4898 die "skip\n" if ($value =~ /memory/) || ($value !~ /memory/ && $conf->{hotplug} =~ /memory/);
4899 } elsif ($opt eq 'tablet
') {
4900 die "skip\n" if !$hotplug_features->{usb};
4902 vm_deviceplug($storecfg, $conf, $vmid, 'tablet
', $arch, $machine_type);
4903 vm_deviceplug($storecfg, $conf, $vmid, 'keyboard
', $arch, $machine_type)
4904 if $arch eq 'aarch64
';
4905 } elsif ($value == 0) {
4906 vm_deviceunplug($vmid, $conf, 'tablet
');
4907 vm_deviceunplug($vmid, $conf, 'keyboard
') if $arch eq 'aarch64
';
4909 } elsif ($opt =~ m/^usb\d+$/) {
4911 # since we cannot reliably hot unplug usb devices
4912 # we are disabling it
4913 die "skip\n" if !$hotplug_features->{usb} || $value =~ m/spice/i;
4914 my $d = eval { PVE::JSONSchema::parse_property_string($usbdesc->{format}, $value) };
4915 die "skip\n" if !$d;
4916 qemu_usb_hotplug($storecfg, $conf, $vmid, $opt, $d, $arch, $machine_type);
4917 } elsif ($opt eq 'vcpus
') {
4918 die "skip\n" if !$hotplug_features->{cpu};
4919 qemu_cpu_hotplug($vmid, $conf, $value);
4920 } elsif ($opt eq 'balloon
') {
4921 # enable/disable balloning device is not hotpluggable
4922 my $old_balloon_enabled = !!(!defined($conf->{balloon}) || $conf->{balloon});
4923 my $new_balloon_enabled = !!(!defined($conf->{pending}->{balloon}) || $conf->{pending}->{balloon});
4924 die "skip\n" if $old_balloon_enabled != $new_balloon_enabled;
4926 # allow manual ballooning if shares is set to zero
4927 if ((defined($conf->{shares}) && ($conf->{shares} == 0))) {
4928 my $balloon = $conf->{pending}->{balloon} || $conf->{memory} || $defaults->{memory};
4929 vm_mon_cmd($vmid, "balloon", value => $balloon*1024*1024);
4931 } elsif ($opt =~ m/^net(\d+)$/) {
4932 # some changes can be done without hotplug
4933 vmconfig_update_net($storecfg, $conf, $hotplug_features->{network},
4934 $vmid, $opt, $value, $arch, $machine_type);
4935 } elsif (is_valid_drivename($opt)) {
4936 # some changes can be done without hotplug
4937 my $drive = parse_drive($opt, $value);
4938 if (drive_is_cloudinit($drive)) {
4939 &$apply_pending_cloudinit($opt, $value);
4941 vmconfig_update_disk($storecfg, $conf, $hotplug_features->{disk},
4942 $vmid, $opt, $value, 1, $arch, $machine_type);
4943 } elsif ($opt =~ m/^memory$/) { #dimms
4944 die "skip\n" if !$hotplug_features->{memory};
4945 $value = PVE::QemuServer::Memory::qemu_memory_hotplug($vmid, $conf, $defaults, $opt, $value);
4946 } elsif ($opt eq 'cpuunits
') {
4947 cgroups_write("cpu", $vmid, "cpu.shares", $conf->{pending}->{$opt});
4948 } elsif ($opt eq 'cpulimit
') {
4949 my $cpulimit = $conf->{pending}->{$opt} == 0 ? -1 : int($conf->{pending}->{$opt} * 100000);
4950 cgroups_write("cpu", $vmid, "cpu.cfs_quota_us", $cpulimit);
4952 die "skip\n"; # skip non-hot-pluggable options
4956 &$add_error($opt, $err) if $err ne "skip\n";
4958 # save new config if hotplug was successful
4959 $conf->{$opt} = $value;
4960 delete $conf->{pending}->{$opt};
4961 PVE::QemuConfig->write_config($vmid, $conf);
4962 $conf = PVE::QemuConfig->load_config($vmid); # update/reload
4967 sub try_deallocate_drive {
4968 my ($storecfg, $vmid, $conf, $key, $drive, $rpcenv, $authuser, $force) = @_;
4970 if (($force || $key =~ /^unused/) && !drive_is_cdrom($drive, 1)) {
4971 my $volid = $drive->{file};
4972 if (vm_is_volid_owner($storecfg, $vmid, $volid)) {
4973 my $sid = PVE::Storage::parse_volume_id($volid);
4974 $rpcenv->check($authuser, "/storage/$sid", ['Datastore
.AllocateSpace
']);
4976 # check if the disk is really unused
4977 die "unable to delete '$volid' - volume is still in use (snapshot?)\n"
4978 if is_volume_in_use($storecfg, $conf, $key, $volid);
4979 PVE::Storage::vdisk_free($storecfg, $volid);
4982 # If vm is not owner of this disk remove from config
4990 sub vmconfig_delete_or_detach_drive {
4991 my ($vmid, $storecfg, $conf, $opt, $force) = @_;
4993 my $drive = parse_drive($opt, $conf->{$opt});
4995 my $rpcenv = PVE::RPCEnvironment::get();
4996 my $authuser = $rpcenv->get_user();
4999 $rpcenv->check_vm_perm($authuser, $vmid, undef, ['VM
.Config
.Disk
']);
5000 try_deallocate_drive($storecfg, $vmid, $conf, $opt, $drive, $rpcenv, $authuser, $force);
5002 vmconfig_register_unused_drive($storecfg, $vmid, $conf, $drive);
5006 sub vmconfig_apply_pending {
5007 my ($vmid, $conf, $storecfg) = @_;
5011 my $pending_delete_hash = split_flagged_list($conf->{pending}->{delete});
5012 while (my ($opt, $force) = each %$pending_delete_hash) {
5013 die "internal error" if $opt =~ m/^unused/;
5014 $conf = PVE::QemuConfig->load_config($vmid); # update/reload
5015 if (!defined($conf->{$opt})) {
5016 vmconfig_undelete_pending_option($conf, $opt);
5017 PVE::QemuConfig->write_config($vmid, $conf);
5018 } elsif (is_valid_drivename($opt)) {
5019 vmconfig_delete_or_detach_drive($vmid, $storecfg, $conf, $opt, $force);
5020 vmconfig_undelete_pending_option($conf, $opt);
5021 delete $conf->{$opt};
5022 PVE::QemuConfig->write_config($vmid, $conf);
5024 vmconfig_undelete_pending_option($conf, $opt);
5025 delete $conf->{$opt};
5026 PVE::QemuConfig->write_config($vmid, $conf);
5030 $conf = PVE::QemuConfig->load_config($vmid); # update/reload
5032 foreach my $opt (keys %{$conf->{pending}}) { # add/change
5033 $conf = PVE::QemuConfig->load_config($vmid); # update/reload
5035 if (defined($conf->{$opt}) && ($conf->{$opt} eq $conf->{pending}->{$opt})) {
5036 # skip if nothing changed
5037 } elsif (is_valid_drivename($opt)) {
5038 vmconfig_register_unused_drive($storecfg, $vmid, $conf, parse_drive($opt, $conf->{$opt}))
5039 if defined($conf->{$opt});
5040 $conf->{$opt} = $conf->{pending}->{$opt};
5042 $conf->{$opt} = $conf->{pending}->{$opt};
5045 delete $conf->{pending}->{$opt};
5046 PVE::QemuConfig->write_config($vmid, $conf);
5050 my $safe_num_ne = sub {
5053 return 0 if !defined($a) && !defined($b);
5054 return 1 if !defined($a);
5055 return 1 if !defined($b);
5060 my $safe_string_ne = sub {
5063 return 0 if !defined($a) && !defined($b);
5064 return 1 if !defined($a);
5065 return 1 if !defined($b);
5070 sub vmconfig_update_net {
5071 my ($storecfg, $conf, $hotplug, $vmid, $opt, $value, $arch, $machine_type) = @_;
5073 my $newnet = parse_net($value);
5075 if ($conf->{$opt}) {
5076 my $oldnet = parse_net($conf->{$opt});
5078 if (&$safe_string_ne($oldnet->{model}, $newnet->{model}) ||
5079 &$safe_string_ne($oldnet->{macaddr}, $newnet->{macaddr}) ||
5080 &$safe_num_ne($oldnet->{queues}, $newnet->{queues}) ||
5081 !($newnet->{bridge} && $oldnet->{bridge})) { # bridge/nat mode change
5083 # for non online change, we try to hot-unplug
5084 die "skip\n" if !$hotplug;
5085 vm_deviceunplug($vmid, $conf, $opt);
5088 die "internal error" if $opt !~ m/net(\d+)/;
5089 my $iface = "tap${vmid}i$1";
5091 if (&$safe_string_ne($oldnet->{bridge}, $newnet->{bridge}) ||
5092 &$safe_num_ne($oldnet->{tag}, $newnet->{tag}) ||
5093 &$safe_string_ne($oldnet->{trunks}, $newnet->{trunks}) ||
5094 &$safe_num_ne($oldnet->{firewall}, $newnet->{firewall})) {
5095 PVE::Network::tap_unplug($iface);
5096 PVE::Network::tap_plug($iface, $newnet->{bridge}, $newnet->{tag}, $newnet->{firewall}, $newnet->{trunks}, $newnet->{rate});
5097 } elsif (&$safe_num_ne($oldnet->{rate}, $newnet->{rate})) {
5098 # Rate can be applied on its own but any change above needs to
5099 # include the rate in tap_plug since OVS resets everything.
5100 PVE::Network::tap_rate_limit($iface, $newnet->{rate});
5103 if (&$safe_string_ne($oldnet->{link_down}, $newnet->{link_down})) {
5104 qemu_set_link_status($vmid, $opt, !$newnet->{link_down});
5112 vm_deviceplug($storecfg, $conf, $vmid, $opt, $newnet, $arch, $machine_type);
5118 sub vmconfig_update_disk {
5119 my ($storecfg, $conf, $hotplug, $vmid, $opt, $value, $force, $arch, $machine_type) = @_;
5121 # fixme: do we need force?
5123 my $drive = parse_drive($opt, $value);
5125 if ($conf->{$opt}) {
5127 if (my $old_drive = parse_drive($opt, $conf->{$opt})) {
5129 my $media = $drive->{media} || 'disk
';
5130 my $oldmedia = $old_drive->{media} || 'disk
';
5131 die "unable to change media type\n" if $media ne $oldmedia;
5133 if (!drive_is_cdrom($old_drive)) {
5135 if ($drive->{file} ne $old_drive->{file}) {
5137 die "skip\n" if !$hotplug;
5139 # unplug and register as unused
5140 vm_deviceunplug($vmid, $conf, $opt);
5141 vmconfig_register_unused_drive($storecfg, $vmid, $conf, $old_drive)
5144 # update existing disk
5146 # skip non hotpluggable value
5147 if (&$safe_string_ne($drive->{discard}, $old_drive->{discard}) ||
5148 &$safe_string_ne($drive->{iothread}, $old_drive->{iothread}) ||
5149 &$safe_string_ne($drive->{queues}, $old_drive->{queues}) ||
5150 &$safe_string_ne($drive->{cache}, $old_drive->{cache})) {
5155 if (&$safe_num_ne($drive->{mbps}, $old_drive->{mbps}) ||
5156 &$safe_num_ne($drive->{mbps_rd}, $old_drive->{mbps_rd}) ||
5157 &$safe_num_ne($drive->{mbps_wr}, $old_drive->{mbps_wr}) ||
5158 &$safe_num_ne($drive->{iops}, $old_drive->{iops}) ||
5159 &$safe_num_ne($drive->{iops_rd}, $old_drive->{iops_rd}) ||
5160 &$safe_num_ne($drive->{iops_wr}, $old_drive->{iops_wr}) ||
5161 &$safe_num_ne($drive->{mbps_max}, $old_drive->{mbps_max}) ||
5162 &$safe_num_ne($drive->{mbps_rd_max}, $old_drive->{mbps_rd_max}) ||
5163 &$safe_num_ne($drive->{mbps_wr_max}, $old_drive->{mbps_wr_max}) ||
5164 &$safe_num_ne($drive->{iops_max}, $old_drive->{iops_max}) ||
5165 &$safe_num_ne($drive->{iops_rd_max}, $old_drive->{iops_rd_max}) ||
5166 &$safe_num_ne($drive->{iops_wr_max}, $old_drive->{iops_wr_max}) ||
5167 &$safe_num_ne($drive->{bps_max_length}, $old_drive->{bps_max_length}) ||
5168 &$safe_num_ne($drive->{bps_rd_max_length}, $old_drive->{bps_rd_max_length}) ||
5169 &$safe_num_ne($drive->{bps_wr_max_length}, $old_drive->{bps_wr_max_length}) ||
5170 &$safe_num_ne($drive->{iops_max_length}, $old_drive->{iops_max_length}) ||
5171 &$safe_num_ne($drive->{iops_rd_max_length}, $old_drive->{iops_rd_max_length}) ||
5172 &$safe_num_ne($drive->{iops_wr_max_length}, $old_drive->{iops_wr_max_length})) {
5174 qemu_block_set_io_throttle($vmid,"drive-$opt",
5175 ($drive->{mbps} || 0)*1024*1024,
5176 ($drive->{mbps_rd} || 0)*1024*1024,
5177 ($drive->{mbps_wr} || 0)*1024*1024,
5178 $drive->{iops} || 0,
5179 $drive->{iops_rd} || 0,
5180 $drive->{iops_wr} || 0,
5181 ($drive->{mbps_max} || 0)*1024*1024,
5182 ($drive->{mbps_rd_max} || 0)*1024*1024,
5183 ($drive->{mbps_wr_max} || 0)*1024*1024,
5184 $drive->{iops_max} || 0,
5185 $drive->{iops_rd_max} || 0,
5186 $drive->{iops_wr_max} || 0,
5187 $drive->{bps_max_length} || 1,
5188 $drive->{bps_rd_max_length} || 1,
5189 $drive->{bps_wr_max_length} || 1,
5190 $drive->{iops_max_length} || 1,
5191 $drive->{iops_rd_max_length} || 1,
5192 $drive->{iops_wr_max_length} || 1);
5201 if ($drive->{file} eq 'none
') {
5202 vm_mon_cmd($vmid, "eject",force => JSON::true,device => "drive-$opt");
5203 if (drive_is_cloudinit($old_drive)) {
5204 vmconfig_register_unused_drive($storecfg, $vmid, $conf, $old_drive);
5207 my $path = get_iso_path($storecfg, $vmid, $drive->{file});
5208 vm_mon_cmd($vmid, "eject", force => JSON::true,device => "drive-$opt"); # force eject if locked
5209 vm_mon_cmd($vmid, "change", device => "drive-$opt",target => "$path") if $path;
5217 die "skip\n" if !$hotplug || $opt =~ m/(ide|sata)(\d+)/;
5219 PVE::Storage::activate_volumes($storecfg, [$drive->{file}]) if $drive->{file} !~ m|^/dev/.+|;
5220 vm_deviceplug($storecfg, $conf, $vmid, $opt, $drive, $arch, $machine_type);
5224 my ($storecfg, $vmid, $statefile, $skiplock, $migratedfrom, $paused,
5225 $forcemachine, $spice_ticket, $migration_network, $migration_type, $targetstorage) = @_;
5227 PVE::QemuConfig->lock_config($vmid, sub {
5228 my $conf = PVE::QemuConfig->load_config($vmid, $migratedfrom);
5230 die "you can't start a vm
if it
's a template\n" if PVE::QemuConfig->is_template($conf);
5232 my $is_suspended = PVE::QemuConfig->has_lock($conf, 'suspended
');
5234 PVE::QemuConfig->check_lock($conf)
5235 if !($skiplock || $is_suspended);
5237 die "VM $vmid already running\n" if check_running($vmid, undef, $migratedfrom);
5239 if (!$statefile && scalar(keys %{$conf->{pending}})) {
5240 vmconfig_apply_pending($vmid, $conf, $storecfg);
5241 $conf = PVE::QemuConfig->load_config($vmid); # update/reload
5244 PVE::QemuServer::Cloudinit::generate_cloudinitconfig($conf, $vmid);
5246 my $defaults = load_defaults();
5248 # set environment variable useful inside network script
5249 $ENV{PVE_MIGRATED_FROM} = $migratedfrom if $migratedfrom;
5251 my $local_volumes = {};
5253 if ($targetstorage) {
5254 foreach_drive($conf, sub {
5255 my ($ds, $drive) = @_;
5257 return if drive_is_cdrom($drive);
5259 my $volid = $drive->{file};
5263 my ($storeid, $volname) = PVE::Storage::parse_volume_id($volid);
5265 my $scfg = PVE::Storage::storage_config($storecfg, $storeid);
5266 return if $scfg->{shared};
5267 $local_volumes->{$ds} = [$volid, $storeid, $volname];
5272 foreach my $opt (sort keys %$local_volumes) {
5274 my ($volid, $storeid, $volname) = @{$local_volumes->{$opt}};
5275 my $drive = parse_drive($opt, $conf->{$opt});
5277 #if remote storage is specified, use default format
5278 if ($targetstorage && $targetstorage ne "1") {
5279 $storeid = $targetstorage;
5280 my ($defFormat, $validFormats) = PVE::Storage::storage_default_format($storecfg, $storeid);
5281 $format = $defFormat;
5283 #else we use same format than original
5284 my $scfg = PVE::Storage::storage_config($storecfg, $storeid);
5285 $format = qemu_img_format($scfg, $volid);
5288 my $newvolid = PVE::Storage::vdisk_alloc($storecfg, $storeid, $vmid, $format, undef, ($drive->{size}/1024));
5289 my $newdrive = $drive;
5290 $newdrive->{format} = $format;
5291 $newdrive->{file} = $newvolid;
5292 my $drivestr = PVE::QemuServer::print_drive($vmid, $newdrive);
5293 $local_volumes->{$opt} = $drivestr;
5294 #pass drive to conf for command line
5295 $conf->{$opt} = $drivestr;
5299 PVE::GuestHelpers::exec_hookscript($conf, $vmid, 'pre-start
', 1);
5301 if ($is_suspended) {
5302 # enforce machine type on suspended vm to ensure HW compatibility
5303 $forcemachine = $conf->{runningmachine};
5304 print "Resuming suspended VM\n";
5307 my ($cmd, $vollist, $spice_port) = config_to_command($storecfg, $vmid, $conf, $defaults, $forcemachine);
5309 my $migrate_port = 0;
5312 if ($statefile eq 'tcp
') {
5313 my $localip = "localhost";
5314 my $datacenterconf = PVE::Cluster::cfs_read_file('datacenter
.cfg
');
5315 my $nodename = PVE::INotify::nodename();
5317 if (!defined($migration_type)) {
5318 if (defined($datacenterconf->{migration}->{type})) {
5319 $migration_type = $datacenterconf->{migration}->{type};
5321 $migration_type = 'secure
';
5325 if ($migration_type eq 'insecure
') {
5326 my $migrate_network_addr = PVE::Cluster::get_local_migration_ip($migration_network);
5327 if ($migrate_network_addr) {
5328 $localip = $migrate_network_addr;
5330 $localip = PVE::Cluster::remote_node_ip($nodename, 1);
5333 $localip = "[$localip]" if Net::IP::ip_is_ipv6($localip);
5336 my $pfamily = PVE::Tools::get_host_address_family($nodename);
5337 $migrate_port = PVE::Tools::next_migrate_port($pfamily);
5338 $migrate_uri = "tcp:${localip}:${migrate_port}";
5339 push @$cmd, '-incoming
', $migrate_uri;
5342 } elsif ($statefile eq 'unix
') {
5343 # should be default for secure migrations as a ssh TCP forward
5344 # tunnel is not deterministic reliable ready and fails regurarly
5345 # to set up in time, so use UNIX socket forwards
5346 my $socket_addr = "/run/qemu-server/$vmid.migrate";
5347 unlink $socket_addr;
5349 $migrate_uri = "unix:$socket_addr";
5351 push @$cmd, '-incoming
', $migrate_uri;
5355 push @$cmd, '-loadstate
', $statefile;
5362 for (my $i = 0; $i < $MAX_HOSTPCI_DEVICES; $i++) {
5363 my $d = parse_hostpci($conf->{"hostpci$i"});
5365 my $pcidevices = $d->{pciid};
5366 foreach my $pcidevice (@$pcidevices) {
5367 my $pciid = $pcidevice->{id};
5369 my $info = PVE::SysFSTools::pci_device_info("0000:$pciid");
5370 die "IOMMU not present\n" if !PVE::SysFSTools::check_iommu_support();
5371 die "no pci device info for device '$pciid'\n" if !$info;
5374 my $uuid = PVE::SysFSTools::generate_mdev_uuid($vmid, $i);
5375 PVE::SysFSTools::pci_create_mdev_device($pciid, $uuid, $d->{mdev});
5377 die "can't unbind
/bind pci group to vfio
'$pciid'\n"
5378 if !PVE::SysFSTools::pci_dev_group_bind_to_vfio($pciid);
5379 die "can
't reset pci device '$pciid'\n"
5380 if $info->{has_fl_reset} and !PVE::SysFSTools::pci_dev_reset($info);
5385 PVE::Storage::activate_volumes($storecfg, $vollist);
5388 run_command(['/bin/systemctl
', 'stop
', "$vmid.scope"],
5389 outfunc => sub {}, errfunc => sub {});
5391 # Issues with the above 'stop
' not being fully completed are extremely rare, a very low
5392 # timeout should be more than enough here...
5393 PVE::Systemd::wait_for_unit_removed("$vmid.scope", 5);
5395 my $cpuunits = defined($conf->{cpuunits}) ? $conf->{cpuunits}
5396 : $defaults->{cpuunits};
5398 my $start_timeout = ($conf->{hugepages} || $is_suspended) ? 300 : 30;
5399 my %run_params = (timeout => $statefile ? undef : $start_timeout, umask => 0077);
5402 Slice => 'qemu
.slice
',
5404 CPUShares => $cpuunits
5407 if (my $cpulimit = $conf->{cpulimit}) {
5408 $properties{CPUQuota} = int($cpulimit * 100);
5410 $properties{timeout} = 10 if $statefile; # setting up the scope shoul be quick
5412 my $run_qemu = sub {
5413 PVE::Tools::run_fork sub {
5414 PVE::Systemd::enter_systemd_scope($vmid, "Proxmox VE VM $vmid", %properties);
5415 run_command($cmd, %run_params);
5419 if ($conf->{hugepages}) {
5422 my $hugepages_topology = PVE::QemuServer::Memory::hugepages_topology($conf);
5423 my $hugepages_host_topology = PVE::QemuServer::Memory::hugepages_host_topology();
5425 PVE::QemuServer::Memory::hugepages_mount();
5426 PVE::QemuServer::Memory::hugepages_allocate($hugepages_topology, $hugepages_host_topology);
5428 eval { $run_qemu->() };
5430 PVE::QemuServer::Memory::hugepages_reset($hugepages_host_topology);
5434 PVE::QemuServer::Memory::hugepages_pre_deallocate($hugepages_topology);
5436 eval { PVE::QemuServer::Memory::hugepages_update_locked($code); };
5439 eval { $run_qemu->() };
5443 # deactivate volumes if start fails
5444 eval { PVE::Storage::deactivate_volumes($storecfg, $vollist); };
5445 die "start failed: $err";
5448 print "migration listens on $migrate_uri\n" if $migrate_uri;
5450 if ($statefile && $statefile ne 'tcp
' && $statefile ne 'unix
') {
5451 eval { vm_mon_cmd_nocheck($vmid, "cont"); };
5455 #start nbd server for storage migration
5456 if ($targetstorage) {
5457 my $nodename = PVE::INotify::nodename();
5458 my $migrate_network_addr = PVE::Cluster::get_local_migration_ip($migration_network);
5459 my $localip = $migrate_network_addr ? $migrate_network_addr : PVE::Cluster::remote_node_ip($nodename, 1);
5460 my $pfamily = PVE::Tools::get_host_address_family($nodename);
5461 $migrate_port = PVE::Tools::next_migrate_port($pfamily);
5463 vm_mon_cmd_nocheck($vmid, "nbd-server-start", addr => { type => 'inet
', data => { host => "${localip}", port => "${migrate_port}" } } );
5465 $localip = "[$localip]" if Net::IP::ip_is_ipv6($localip);
5467 foreach my $opt (sort keys %$local_volumes) {
5468 my $volid = $local_volumes->{$opt};
5469 vm_mon_cmd_nocheck($vmid, "nbd-server-add", device => "drive-$opt", writable => JSON::true );
5470 my $migrate_storage_uri = "nbd:${localip}:${migrate_port}:exportname=drive-$opt";
5471 print "storage migration listens on $migrate_storage_uri volume:$volid\n";
5475 if ($migratedfrom) {
5477 set_migration_caps($vmid);
5482 print "spice listens on port $spice_port\n";
5483 if ($spice_ticket) {
5484 vm_mon_cmd_nocheck($vmid, "set_password", protocol => 'spice
', password => $spice_ticket);
5485 vm_mon_cmd_nocheck($vmid, "expire_password", protocol => 'spice
', time => "+30");
5490 vm_mon_cmd_nocheck($vmid, "balloon", value => $conf->{balloon}*1024*1024)
5491 if !$statefile && $conf->{balloon};
5493 foreach my $opt (keys %$conf) {
5494 next if $opt !~ m/^net\d+$/;
5495 my $nicconf = parse_net($conf->{$opt});
5496 qemu_set_link_status($vmid, $opt, 0) if $nicconf->{link_down};
5500 vm_mon_cmd_nocheck($vmid, 'qom-set
',
5501 path => "machine/peripheral/balloon0",
5502 property => "guest-stats-polling-interval",
5503 value => 2) if (!defined($conf->{balloon}) || $conf->{balloon});
5505 if ($is_suspended && (my $vmstate = $conf->{vmstate})) {
5506 print "Resumed VM, removing state\n";
5507 delete $conf->@{qw(lock vmstate runningmachine)};
5508 PVE
::Storage
::deactivate_volumes
($storecfg, [$vmstate]);
5509 PVE
::Storage
::vdisk_free
($storecfg, $vmstate);
5510 PVE
::QemuConfig-
>write_config($vmid, $conf);
5513 PVE
::GuestHelpers
::exec_hookscript
($conf, $vmid, 'post-start');
5518 my ($vmid, $execute, %params) = @_;
5520 my $cmd = { execute
=> $execute, arguments
=> \
%params };
5521 vm_qmp_command
($vmid, $cmd);
5524 sub vm_mon_cmd_nocheck
{
5525 my ($vmid, $execute, %params) = @_;
5527 my $cmd = { execute
=> $execute, arguments
=> \
%params };
5528 vm_qmp_command
($vmid, $cmd, 1);
5531 sub vm_qmp_command
{
5532 my ($vmid, $cmd, $nocheck) = @_;
5537 if ($cmd->{arguments
}) {
5538 $timeout = delete $cmd->{arguments
}->{timeout
};
5542 die "VM $vmid not running\n" if !check_running
($vmid, $nocheck);
5543 my $sname = qmp_socket
($vmid);
5544 if (-e
$sname) { # test if VM is reasonambe new and supports qmp/qga
5545 my $qmpclient = PVE
::QMPClient-
>new();
5547 $res = $qmpclient->cmd($vmid, $cmd, $timeout);
5549 die "unable to open monitor socket\n";
5553 syslog
("err", "VM $vmid qmp command failed - $err");
5560 sub vm_human_monitor_command
{
5561 my ($vmid, $cmdline) = @_;
5566 execute
=> 'human-monitor-command',
5567 arguments
=> { 'command-line' => $cmdline},
5570 return vm_qmp_command
($vmid, $cmd);
5573 sub vm_commandline
{
5574 my ($storecfg, $vmid, $snapname) = @_;
5576 my $conf = PVE
::QemuConfig-
>load_config($vmid);
5579 my $snapshot = $conf->{snapshots
}->{$snapname};
5580 die "snapshot '$snapname' does not exist\n" if !defined($snapshot);
5582 $snapshot->{digest
} = $conf->{digest
}; # keep file digest for API
5587 my $defaults = load_defaults
();
5589 my $cmd = config_to_command
($storecfg, $vmid, $conf, $defaults);
5591 return PVE
::Tools
::cmd2string
($cmd);
5595 my ($vmid, $skiplock) = @_;
5597 PVE
::QemuConfig-
>lock_config($vmid, sub {
5599 my $conf = PVE
::QemuConfig-
>load_config($vmid);
5601 PVE
::QemuConfig-
>check_lock($conf) if !$skiplock;
5603 vm_mon_cmd
($vmid, "system_reset");
5607 sub get_vm_volumes
{
5611 foreach_volid
($conf, sub {
5612 my ($volid, $attr) = @_;
5614 return if $volid =~ m
|^/|;
5616 my ($sid, $volname) = PVE
::Storage
::parse_volume_id
($volid, 1);
5619 push @$vollist, $volid;
5625 sub vm_stop_cleanup
{
5626 my ($storecfg, $vmid, $conf, $keepActive, $apply_pending_changes) = @_;
5631 my $vollist = get_vm_volumes
($conf);
5632 PVE
::Storage
::deactivate_volumes
($storecfg, $vollist);
5635 foreach my $ext (qw(mon qmp pid vnc qga)) {
5636 unlink "/var/run/qemu-server/${vmid}.$ext";
5639 if ($conf->{ivshmem
}) {
5640 my $ivshmem = PVE
::JSONSchema
::parse_property_string
($ivshmem_fmt, $conf->{ivshmem
});
5641 # just delete it for now, VMs which have this already open do not
5642 # are affected, but new VMs will get a separated one. If this
5643 # becomes an issue we either add some sort of ref-counting or just
5644 # add a "don't delete on stop" flag to the ivshmem format.
5645 unlink '/dev/shm/pve-shm-' . ($ivshmem->{name
} // $vmid);
5648 foreach my $key (keys %$conf) {
5649 next if $key !~ m/^hostpci(\d+)$/;
5650 my $hostpciindex = $1;
5651 my $d = parse_hostpci
($conf->{$key});
5652 my $uuid = PVE
::SysFSTools
::generate_mdev_uuid
($vmid, $hostpciindex);
5654 foreach my $pci (@{$d->{pciid
}}) {
5655 my $pciid = $pci->{id
};
5656 PVE
::SysFSTools
::pci_cleanup_mdev_device
($pciid, $uuid);
5660 vmconfig_apply_pending
($vmid, $conf, $storecfg) if $apply_pending_changes;
5662 warn $@ if $@; # avoid errors - just warn
5665 # Note: use $nockeck to skip tests if VM configuration file exists.
5666 # We need that when migration VMs to other nodes (files already moved)
5667 # Note: we set $keepActive in vzdump stop mode - volumes need to stay active
5669 my ($storecfg, $vmid, $skiplock, $nocheck, $timeout, $shutdown, $force, $keepActive, $migratedfrom) = @_;
5671 $force = 1 if !defined($force) && !$shutdown;
5674 my $pid = check_running
($vmid, $nocheck, $migratedfrom);
5675 kill 15, $pid if $pid;
5676 my $conf = PVE
::QemuConfig-
>load_config($vmid, $migratedfrom);
5677 vm_stop_cleanup
($storecfg, $vmid, $conf, $keepActive, 0);
5681 PVE
::QemuConfig-
>lock_config($vmid, sub {
5683 my $pid = check_running
($vmid, $nocheck);
5688 $conf = PVE
::QemuConfig-
>load_config($vmid);
5689 PVE
::QemuConfig-
>check_lock($conf) if !$skiplock;
5690 if (!defined($timeout) && $shutdown && $conf->{startup
}) {
5691 my $opts = PVE
::JSONSchema
::pve_parse_startup_order
($conf->{startup
});
5692 $timeout = $opts->{down
} if $opts->{down
};
5694 PVE
::GuestHelpers
::exec_hookscript
($conf, $vmid, 'pre-stop');
5699 if (defined($conf) && parse_guest_agent
($conf)->{enabled
}) {
5700 vm_qmp_command
($vmid, {
5701 execute
=> "guest-shutdown",
5702 arguments
=> { timeout
=> $timeout }
5705 vm_qmp_command
($vmid, { execute
=> "system_powerdown" }, $nocheck);
5708 vm_qmp_command
($vmid, { execute
=> "quit" }, $nocheck);
5714 $timeout = 60 if !defined($timeout);
5717 while (($count < $timeout) && check_running
($vmid, $nocheck)) {
5722 if ($count >= $timeout) {
5724 warn "VM still running - terminating now with SIGTERM\n";
5727 die "VM quit/powerdown failed - got timeout\n";
5730 vm_stop_cleanup
($storecfg, $vmid, $conf, $keepActive, 1) if $conf;
5735 warn "VM quit/powerdown failed - terminating now with SIGTERM\n";
5738 die "VM quit/powerdown failed\n";
5746 while (($count < $timeout) && check_running
($vmid, $nocheck)) {
5751 if ($count >= $timeout) {
5752 warn "VM still running - terminating now with SIGKILL\n";
5757 vm_stop_cleanup
($storecfg, $vmid, $conf, $keepActive, 1) if $conf;
5762 my ($vmid, $skiplock, $includestate, $statestorage) = @_;
5769 PVE
::QemuConfig-
>lock_config($vmid, sub {
5771 $conf = PVE
::QemuConfig-
>load_config($vmid);
5773 my $is_backing_up = PVE
::QemuConfig-
>has_lock($conf, 'backup');
5774 PVE
::QemuConfig-
>check_lock($conf)
5775 if !($skiplock || $is_backing_up);
5777 die "cannot suspend to disk during backup\n"
5778 if $is_backing_up && $includestate;
5780 if ($includestate) {
5781 $conf->{lock} = 'suspending';
5782 my $date = strftime
("%Y-%m-%d", localtime(time()));
5783 $storecfg = PVE
::Storage
::config
();
5784 $vmstate = PVE
::QemuConfig-
>__snapshot_save_vmstate($vmid, $conf, "suspend-$date", $storecfg, $statestorage, 1);
5785 $path = PVE
::Storage
::path
($storecfg, $vmstate);
5786 PVE
::QemuConfig-
>write_config($vmid, $conf);
5788 vm_mon_cmd
($vmid, "stop");
5792 if ($includestate) {
5794 PVE
::Storage
::activate_volumes
($storecfg, [$vmstate]);
5797 vm_mon_cmd
($vmid, "savevm-start", statefile
=> $path);
5799 my $state = vm_mon_cmd_nocheck
($vmid, "query-savevm");
5800 if (!$state->{status
}) {
5801 die "savevm not active\n";
5802 } elsif ($state->{status
} eq 'active') {
5805 } elsif ($state->{status
} eq 'completed') {
5806 print "State saved, quitting\n";
5808 } elsif ($state->{status
} eq 'failed' && $state->{error
}) {
5809 die "query-savevm failed with error '$state->{error}'\n"
5811 die "query-savevm returned status '$state->{status}'\n";
5817 PVE
::QemuConfig-
>lock_config($vmid, sub {
5818 $conf = PVE
::QemuConfig-
>load_config($vmid);
5820 # cleanup, but leave suspending lock, to indicate something went wrong
5822 vm_mon_cmd
($vmid, "savevm-end");
5823 PVE
::Storage
::deactivate_volumes
($storecfg, [$vmstate]);
5824 PVE
::Storage
::vdisk_free
($storecfg, $vmstate);
5825 delete $conf->@{qw(vmstate runningmachine)};
5826 PVE
::QemuConfig-
>write_config($vmid, $conf);
5832 die "lock changed unexpectedly\n"
5833 if !PVE
::QemuConfig-
>has_lock($conf, 'suspending');
5835 vm_qmp_command
($vmid, { execute
=> "quit" });
5836 $conf->{lock} = 'suspended';
5837 PVE
::QemuConfig-
>write_config($vmid, $conf);
5843 my ($vmid, $skiplock, $nocheck) = @_;
5845 PVE
::QemuConfig-
>lock_config($vmid, sub {
5846 my $vm_mon_cmd = $nocheck ? \
&vm_mon_cmd_nocheck
: \
&vm_mon_cmd
;
5847 my $res = $vm_mon_cmd->($vmid, 'query-status');
5848 my $resume_cmd = 'cont';
5850 if ($res->{status
} && $res->{status
} eq 'suspended') {
5851 $resume_cmd = 'system_wakeup';
5856 my $conf = PVE
::QemuConfig-
>load_config($vmid);
5858 PVE
::QemuConfig-
>check_lock($conf)
5859 if !($skiplock || PVE
::QemuConfig-
>has_lock($conf, 'backup'));
5862 $vm_mon_cmd->($vmid, $resume_cmd);
5867 my ($vmid, $skiplock, $key) = @_;
5869 PVE
::QemuConfig-
>lock_config($vmid, sub {
5871 my $conf = PVE
::QemuConfig-
>load_config($vmid);
5873 # there is no qmp command, so we use the human monitor command
5874 vm_human_monitor_command
($vmid, "sendkey $key");
5879 my ($storecfg, $vmid, $skiplock) = @_;
5881 PVE
::QemuConfig-
>lock_config($vmid, sub {
5883 my $conf = PVE
::QemuConfig-
>load_config($vmid);
5885 if (!check_running
($vmid)) {
5886 destroy_vm
($storecfg, $vmid, undef, $skiplock);
5888 die "VM $vmid is running - destroy failed\n";
5893 # vzdump restore implementaion
5895 sub tar_archive_read_firstfile
{
5896 my $archive = shift;
5898 die "ERROR: file '$archive' does not exist\n" if ! -f
$archive;
5900 # try to detect archive type first
5901 my $pid = open (my $fh, '-|', 'tar', 'tf', $archive) ||
5902 die "unable to open file '$archive'\n";
5903 my $firstfile = <$fh>;
5907 die "ERROR: archive contaions no data\n" if !$firstfile;
5913 sub tar_restore_cleanup
{
5914 my ($storecfg, $statfile) = @_;
5916 print STDERR
"starting cleanup\n";
5918 if (my $fd = IO
::File-
>new($statfile, "r")) {
5919 while (defined(my $line = <$fd>)) {
5920 if ($line =~ m/vzdump:([^\s:]*):(\S+)$/) {
5923 if ($volid =~ m
|^/|) {
5924 unlink $volid || die 'unlink failed\n';
5926 PVE
::Storage
::vdisk_free
($storecfg, $volid);
5928 print STDERR
"temporary volume '$volid' sucessfuly removed\n";
5930 print STDERR
"unable to cleanup '$volid' - $@" if $@;
5932 print STDERR
"unable to parse line in statfile - $line";
5939 sub restore_archive
{
5940 my ($archive, $vmid, $user, $opts) = @_;
5942 my $format = $opts->{format
};
5945 if ($archive =~ m/\.tgz$/ || $archive =~ m/\.tar\.gz$/) {
5946 $format = 'tar' if !$format;
5948 } elsif ($archive =~ m/\.tar$/) {
5949 $format = 'tar' if !$format;
5950 } elsif ($archive =~ m/.tar.lzo$/) {
5951 $format = 'tar' if !$format;
5953 } elsif ($archive =~ m/\.vma$/) {
5954 $format = 'vma' if !$format;
5955 } elsif ($archive =~ m/\.vma\.gz$/) {
5956 $format = 'vma' if !$format;
5958 } elsif ($archive =~ m/\.vma\.lzo$/) {
5959 $format = 'vma' if !$format;
5962 $format = 'vma' if !$format; # default
5965 # try to detect archive format
5966 if ($format eq 'tar') {
5967 return restore_tar_archive
($archive, $vmid, $user, $opts);
5969 return restore_vma_archive
($archive, $vmid, $user, $opts, $comp);
5973 sub restore_update_config_line
{
5974 my ($outfd, $cookie, $vmid, $map, $line, $unique) = @_;
5976 return if $line =~ m/^\#qmdump\#/;
5977 return if $line =~ m/^\#vzdump\#/;
5978 return if $line =~ m/^lock:/;
5979 return if $line =~ m/^unused\d+:/;
5980 return if $line =~ m/^parent:/;
5982 my $dc = PVE
::Cluster
::cfs_read_file
('datacenter.cfg');
5983 if (($line =~ m/^(vlan(\d+)):\s*(\S+)\s*$/)) {
5984 # try to convert old 1.X settings
5985 my ($id, $ind, $ethcfg) = ($1, $2, $3);
5986 foreach my $devconfig (PVE
::Tools
::split_list
($ethcfg)) {
5987 my ($model, $macaddr) = split(/\=/, $devconfig);
5988 $macaddr = PVE
::Tools
::random_ether_addr
($dc->{mac_prefix
}) if !$macaddr || $unique;
5991 bridge
=> "vmbr$ind",
5992 macaddr
=> $macaddr,
5994 my $netstr = print_net
($net);
5996 print $outfd "net$cookie->{netcount}: $netstr\n";
5997 $cookie->{netcount
}++;
5999 } elsif (($line =~ m/^(net\d+):\s*(\S+)\s*$/) && $unique) {
6000 my ($id, $netstr) = ($1, $2);
6001 my $net = parse_net
($netstr);
6002 $net->{macaddr
} = PVE
::Tools
::random_ether_addr
($dc->{mac_prefix
}) if $net->{macaddr
};
6003 $netstr = print_net
($net);
6004 print $outfd "$id: $netstr\n";
6005 } elsif ($line =~ m/^((ide|scsi|virtio|sata|efidisk)\d+):\s*(\S+)\s*$/) {
6008 my $di = parse_drive
($virtdev, $value);
6009 if (defined($di->{backup
}) && !$di->{backup
}) {
6010 print $outfd "#$line";
6011 } elsif ($map->{$virtdev}) {
6012 delete $di->{format
}; # format can change on restore
6013 $di->{file
} = $map->{$virtdev};
6014 $value = print_drive
($vmid, $di);
6015 print $outfd "$virtdev: $value\n";
6019 } elsif (($line =~ m/^vmgenid: (.*)/)) {
6021 if ($vmgenid ne '0') {
6022 # always generate a new vmgenid if there was a valid one setup
6023 $vmgenid = generate_uuid
();
6025 print $outfd "vmgenid: $vmgenid\n";
6026 } elsif (($line =~ m/^(smbios1: )(.*)/) && $unique) {
6027 my ($uuid, $uuid_str);
6028 UUID
::generate
($uuid);
6029 UUID
::unparse
($uuid, $uuid_str);
6030 my $smbios1 = parse_smbios1
($2);
6031 $smbios1->{uuid
} = $uuid_str;
6032 print $outfd $1.print_smbios1
($smbios1)."\n";
6039 my ($cfg, $vmid) = @_;
6041 my $info = PVE
::Storage
::vdisk_list
($cfg, undef, $vmid);
6043 my $volid_hash = {};
6044 foreach my $storeid (keys %$info) {
6045 foreach my $item (@{$info->{$storeid}}) {
6046 next if !($item->{volid
} && $item->{size
});
6047 $item->{path
} = PVE
::Storage
::path
($cfg, $item->{volid
});
6048 $volid_hash->{$item->{volid
}} = $item;
6055 sub is_volume_in_use
{
6056 my ($storecfg, $conf, $skip_drive, $volid) = @_;
6058 my $path = PVE
::Storage
::path
($storecfg, $volid);
6060 my $scan_config = sub {
6061 my ($cref, $snapname) = @_;
6063 foreach my $key (keys %$cref) {
6064 my $value = $cref->{$key};
6065 if (is_valid_drivename
($key)) {
6066 next if $skip_drive && $key eq $skip_drive;
6067 my $drive = parse_drive
($key, $value);
6068 next if !$drive || !$drive->{file
} || drive_is_cdrom
($drive);
6069 return 1 if $volid eq $drive->{file
};
6070 if ($drive->{file
} =~ m!^/!) {
6071 return 1 if $drive->{file
} eq $path;
6073 my ($storeid, $volname) = PVE
::Storage
::parse_volume_id
($drive->{file
}, 1);
6075 my $scfg = PVE
::Storage
::storage_config
($storecfg, $storeid, 1);
6077 return 1 if $path eq PVE
::Storage
::path
($storecfg, $drive->{file
}, $snapname);
6085 return 1 if &$scan_config($conf);
6089 foreach my $snapname (keys %{$conf->{snapshots
}}) {
6090 return 1 if &$scan_config($conf->{snapshots
}->{$snapname}, $snapname);
6096 sub update_disksize
{
6097 my ($vmid, $conf, $volid_hash) = @_;
6100 my $prefix = "VM $vmid:";
6102 # used and unused disks
6103 my $referenced = {};
6105 # Note: it is allowed to define multiple storages with same path (alias), so
6106 # we need to check both 'volid' and real 'path' (two different volid can point
6107 # to the same path).
6109 my $referencedpath = {};
6112 foreach my $opt (keys %$conf) {
6113 if (is_valid_drivename
($opt)) {
6114 my $drive = parse_drive
($opt, $conf->{$opt});
6115 my $volid = $drive->{file
};
6118 $referenced->{$volid} = 1;
6119 if ($volid_hash->{$volid} &&
6120 (my $path = $volid_hash->{$volid}->{path
})) {
6121 $referencedpath->{$path} = 1;
6124 next if drive_is_cdrom
($drive);
6125 next if !$volid_hash->{$volid};
6127 $drive->{size
} = $volid_hash->{$volid}->{size
};
6128 my $new = print_drive
($vmid, $drive);
6129 if ($new ne $conf->{$opt}) {
6131 $conf->{$opt} = $new;
6132 print "$prefix update disk '$opt' information.\n";
6137 # remove 'unusedX' entry if volume is used
6138 foreach my $opt (keys %$conf) {
6139 next if $opt !~ m/^unused\d+$/;
6140 my $volid = $conf->{$opt};
6141 my $path = $volid_hash->{$volid}->{path
} if $volid_hash->{$volid};
6142 if ($referenced->{$volid} || ($path && $referencedpath->{$path})) {
6143 print "$prefix remove entry '$opt', its volume '$volid' is in use.\n";
6145 delete $conf->{$opt};
6148 $referenced->{$volid} = 1;
6149 $referencedpath->{$path} = 1 if $path;
6152 foreach my $volid (sort keys %$volid_hash) {
6153 next if $volid =~ m/vm-$vmid-state-/;
6154 next if $referenced->{$volid};
6155 my $path = $volid_hash->{$volid}->{path
};
6156 next if !$path; # just to be sure
6157 next if $referencedpath->{$path};
6159 my $key = PVE
::QemuConfig-
>add_unused_volume($conf, $volid);
6160 print "$prefix add unreferenced volume '$volid' as '$key' to config.\n";
6161 $referencedpath->{$path} = 1; # avoid to add more than once (aliases)
6168 my ($vmid, $nolock, $dryrun) = @_;
6170 my $cfg = PVE
::Storage
::config
();
6172 # FIXME: Remove once our RBD plugin can handle CT and VM on a single storage
6173 # see: https://pve.proxmox.com/pipermail/pve-devel/2018-July/032900.html
6174 foreach my $stor (keys %{$cfg->{ids
}}) {
6175 delete($cfg->{ids
}->{$stor}) if ! $cfg->{ids
}->{$stor}->{content
}->{images
};
6178 print "rescan volumes...\n";
6179 my $volid_hash = scan_volids
($cfg, $vmid);
6181 my $updatefn = sub {
6184 my $conf = PVE
::QemuConfig-
>load_config($vmid);
6186 PVE
::QemuConfig-
>check_lock($conf);
6189 foreach my $volid (keys %$volid_hash) {
6190 my $info = $volid_hash->{$volid};
6191 $vm_volids->{$volid} = $info if $info->{vmid
} && $info->{vmid
} == $vmid;
6194 my $changes = update_disksize
($vmid, $conf, $vm_volids);
6196 PVE
::QemuConfig-
>write_config($vmid, $conf) if $changes && !$dryrun;
6199 if (defined($vmid)) {
6203 PVE
::QemuConfig-
>lock_config($vmid, $updatefn, $vmid);
6206 my $vmlist = config_list
();
6207 foreach my $vmid (keys %$vmlist) {
6211 PVE
::QemuConfig-
>lock_config($vmid, $updatefn, $vmid);
6217 sub restore_vma_archive
{
6218 my ($archive, $vmid, $user, $opts, $comp) = @_;
6220 my $readfrom = $archive;
6222 my $cfg = PVE
::Storage
::config
();
6224 my $bwlimit = $opts->{bwlimit
};
6226 my $dbg_cmdstring = '';
6227 my $add_pipe = sub {
6229 push @$commands, $cmd;
6230 $dbg_cmdstring .= ' | ' if length($dbg_cmdstring);
6231 $dbg_cmdstring .= PVE
::Tools
::cmd2string
($cmd);
6236 if ($archive eq '-') {
6239 # If we use a backup from a PVE defined storage we also consider that
6240 # storage's rate limit:
6241 my (undef, $volid) = PVE
::Storage
::path_to_volume_id
($cfg, $archive);
6242 if (defined($volid)) {
6243 my ($sid, undef) = PVE
::Storage
::parse_volume_id
($volid);
6244 my $readlimit = PVE
::Storage
::get_bandwidth_limit
('restore', [$sid], $bwlimit);
6246 print STDERR
"applying read rate limit: $readlimit\n";
6247 my $cstream = ['cstream', '-t', $readlimit*1024, '--', $readfrom];
6248 $add_pipe->($cstream);
6255 if ($comp eq 'gzip') {
6256 $cmd = ['zcat', $readfrom];
6257 } elsif ($comp eq 'lzop') {
6258 $cmd = ['lzop', '-d', '-c', $readfrom];
6260 die "unknown compression method '$comp'\n";
6265 my $tmpdir = "/var/tmp/vzdumptmp$$";
6268 # disable interrupts (always do cleanups)
6272 local $SIG{HUP
} = sub { warn "got interrupt - ignored\n"; };
6274 my $mapfifo = "/var/tmp/vzdumptmp$$.fifo";
6275 POSIX
::mkfifo
($mapfifo, 0600);
6278 my $openfifo = sub {
6279 open($fifofh, '>', $mapfifo) || die $!;
6282 $add_pipe->(['vma', 'extract', '-v', '-r', $mapfifo, $readfrom, $tmpdir]);
6289 my $rpcenv = PVE
::RPCEnvironment
::get
();
6291 my $conffile = PVE
::QemuConfig-
>config_file($vmid);
6292 my $tmpfn = "$conffile.$$.tmp";
6294 # Note: $oldconf is undef if VM does not exists
6295 my $cfs_path = PVE
::QemuConfig-
>cfs_config_path($vmid);
6296 my $oldconf = PVE
::Cluster
::cfs_read_file
($cfs_path);
6300 my $print_devmap = sub {
6301 my $virtdev_hash = {};
6303 my $cfgfn = "$tmpdir/qemu-server.conf";
6305 # we can read the config - that is already extracted
6306 my $fh = IO
::File-
>new($cfgfn, "r") ||
6307 "unable to read qemu-server.conf - $!\n";
6309 my $fwcfgfn = "$tmpdir/qemu-server.fw";
6311 my $pve_firewall_dir = '/etc/pve/firewall';
6312 mkdir $pve_firewall_dir; # make sure the dir exists
6313 PVE
::Tools
::file_copy
($fwcfgfn, "${pve_firewall_dir}/$vmid.fw");
6316 while (defined(my $line = <$fh>)) {
6317 if ($line =~ m/^\#qmdump\#map:(\S+):(\S+):(\S*):(\S*):$/) {
6318 my ($virtdev, $devname, $storeid, $format) = ($1, $2, $3, $4);
6319 die "archive does not contain data for drive '$virtdev'\n"
6320 if !$devinfo->{$devname};
6321 if (defined($opts->{storage
})) {
6322 $storeid = $opts->{storage
} || 'local';
6323 } elsif (!$storeid) {
6326 $format = 'raw' if !$format;
6327 $devinfo->{$devname}->{devname
} = $devname;
6328 $devinfo->{$devname}->{virtdev
} = $virtdev;
6329 $devinfo->{$devname}->{format
} = $format;
6330 $devinfo->{$devname}->{storeid
} = $storeid;
6332 # check permission on storage
6333 my $pool = $opts->{pool
}; # todo: do we need that?
6334 if ($user ne 'root@pam') {
6335 $rpcenv->check($user, "/storage/$storeid", ['Datastore.AllocateSpace']);
6338 $storage_limits{$storeid} = $bwlimit;
6340 $virtdev_hash->{$virtdev} = $devinfo->{$devname};
6341 } elsif ($line =~ m/^((?:ide|sata|scsi)\d+):\s*(.*)\s*$/) {
6343 my $drive = parse_drive
($virtdev, $2);
6344 if (drive_is_cloudinit
($drive)) {
6345 my ($storeid, $volname) = PVE
::Storage
::parse_volume_id
($drive->{file
});
6346 my $scfg = PVE
::Storage
::storage_config
($cfg, $storeid);
6347 my $format = qemu_img_format
($scfg, $volname); # has 'raw' fallback
6351 storeid
=> $opts->{storage
} // $storeid,
6352 size
=> PVE
::QemuServer
::Cloudinit
::CLOUDINIT_DISK_SIZE
,
6353 file
=> $drive->{file
}, # to make drive_is_cloudinit check possible
6354 name
=> "vm-$vmid-cloudinit",
6357 $virtdev_hash->{$virtdev} = $d;
6362 foreach my $key (keys %storage_limits) {
6363 my $limit = PVE
::Storage
::get_bandwidth_limit
('restore', [$key], $bwlimit);
6365 print STDERR
"rate limit for storage $key: $limit KiB/s\n";
6366 $storage_limits{$key} = $limit * 1024;
6369 foreach my $devname (keys %$devinfo) {
6370 die "found no device mapping information for device '$devname'\n"
6371 if !$devinfo->{$devname}->{virtdev
};
6374 # create empty/temp config
6376 PVE
::Tools
::file_set_contents
($conffile, "memory: 128\n");
6377 foreach_drive
($oldconf, sub {
6378 my ($ds, $drive) = @_;
6380 return if !$drive->{is_cloudinit
} && drive_is_cdrom
($drive);
6382 my $volid = $drive->{file
};
6383 return if !$volid || $volid =~ m
|^/|;
6385 my ($path, $owner) = PVE
::Storage
::path
($cfg, $volid);
6386 return if !$path || !$owner || ($owner != $vmid);
6388 # Note: only delete disk we want to restore
6389 # other volumes will become unused
6390 if ($virtdev_hash->{$ds}) {
6391 eval { PVE
::Storage
::vdisk_free
($cfg, $volid); };
6398 # delete vmstate files, after the restore we have no snapshots anymore
6399 foreach my $snapname (keys %{$oldconf->{snapshots
}}) {
6400 my $snap = $oldconf->{snapshots
}->{$snapname};
6401 if ($snap->{vmstate
}) {
6402 eval { PVE
::Storage
::vdisk_free
($cfg, $snap->{vmstate
}); };
6411 foreach my $virtdev (sort keys %$virtdev_hash) {
6412 my $d = $virtdev_hash->{$virtdev};
6413 my $alloc_size = int(($d->{size
} + 1024 - 1)/1024);
6414 my $storeid = $d->{storeid
};
6415 my $scfg = PVE
::Storage
::storage_config
($cfg, $storeid);
6418 if (my $limit = $storage_limits{$storeid}) {
6419 $map_opts .= "throttling.bps=$limit:throttling.group=$storeid:";
6422 # test if requested format is supported
6423 my ($defFormat, $validFormats) = PVE
::Storage
::storage_default_format
($cfg, $storeid);
6424 my $supported = grep { $_ eq $d->{format
} } @$validFormats;
6425 $d->{format
} = $defFormat if !$supported;
6428 if ($d->{is_cloudinit
}) {
6430 $name .= ".$d->{format}" if $d->{format
} ne 'raw';
6433 my $volid = PVE
::Storage
::vdisk_alloc
($cfg, $storeid, $vmid, $d->{format
}, $name, $alloc_size);
6434 print STDERR
"new volume ID is '$volid'\n";
6435 $d->{volid
} = $volid;
6437 PVE
::Storage
::activate_volumes
($cfg, [$volid]);
6439 my $write_zeros = 1;
6440 if (PVE
::Storage
::volume_has_feature
($cfg, 'sparseinit', $volid)) {
6444 if (!$d->{is_cloudinit
}) {
6445 my $path = PVE
::Storage
::path
($cfg, $volid);
6447 print $fifofh "${map_opts}format=$d->{format}:${write_zeros}:$d->{devname}=$path\n";
6449 print "map '$d->{devname}' to '$path' (write zeros = ${write_zeros})\n";
6451 $map->{$virtdev} = $volid;
6454 $fh->seek(0, 0) || die "seek failed - $!\n";
6456 my $outfd = new IO
::File
($tmpfn, "w") ||
6457 die "unable to write config for VM $vmid\n";
6459 my $cookie = { netcount
=> 0 };
6460 while (defined(my $line = <$fh>)) {
6461 restore_update_config_line
($outfd, $cookie, $vmid, $map, $line, $opts->{unique
});
6474 local $SIG{PIPE
} = sub { die "interrupted by signal\n"; };
6475 local $SIG{ALRM
} = sub { die "got timeout\n"; };
6477 $oldtimeout = alarm($timeout);
6484 if ($line =~ m/^DEV:\sdev_id=(\d+)\ssize:\s(\d+)\sdevname:\s(\S+)$/) {
6485 my ($dev_id, $size, $devname) = ($1, $2, $3);
6486 $devinfo->{$devname} = { size
=> $size, dev_id
=> $dev_id };
6487 } elsif ($line =~ m/^CTIME: /) {
6488 # we correctly received the vma config, so we can disable
6489 # the timeout now for disk allocation (set to 10 minutes, so
6490 # that we always timeout if something goes wrong)
6493 print $fifofh "done\n";
6494 my $tmp = $oldtimeout || 0;
6495 $oldtimeout = undef;
6501 print "restore vma archive: $dbg_cmdstring\n";
6502 run_command
($commands, input
=> $input, outfunc
=> $parser, afterfork
=> $openfifo);
6506 alarm($oldtimeout) if $oldtimeout;
6509 foreach my $devname (keys %$devinfo) {
6510 my $volid = $devinfo->{$devname}->{volid
};
6511 push @$vollist, $volid if $volid;
6514 PVE
::Storage
::deactivate_volumes
($cfg, $vollist);
6522 foreach my $devname (keys %$devinfo) {
6523 my $volid = $devinfo->{$devname}->{volid
};
6526 if ($volid =~ m
|^/|) {
6527 unlink $volid || die 'unlink failed\n';
6529 PVE
::Storage
::vdisk_free
($cfg, $volid);
6531 print STDERR
"temporary volume '$volid' sucessfuly removed\n";
6533 print STDERR
"unable to cleanup '$volid' - $@" if $@;
6540 rename($tmpfn, $conffile) ||
6541 die "unable to commit configuration file '$conffile'\n";
6543 PVE
::Cluster
::cfs_update
(); # make sure we read new file
6545 eval { rescan
($vmid, 1); };
6549 sub restore_tar_archive
{
6550 my ($archive, $vmid, $user, $opts) = @_;
6552 if ($archive ne '-') {
6553 my $firstfile = tar_archive_read_firstfile
($archive);
6554 die "ERROR: file '$archive' dos not lock like a QemuServer vzdump backup\n"
6555 if $firstfile ne 'qemu-server.conf';
6558 my $storecfg = PVE
::Storage
::config
();
6560 # destroy existing data - keep empty config
6561 my $vmcfgfn = PVE
::QemuConfig-
>config_file($vmid);
6562 destroy_vm
($storecfg, $vmid, 1) if -f
$vmcfgfn;
6564 my $tocmd = "/usr/lib/qemu-server/qmextract";
6566 $tocmd .= " --storage " . PVE
::Tools
::shellquote
($opts->{storage
}) if $opts->{storage
};
6567 $tocmd .= " --pool " . PVE
::Tools
::shellquote
($opts->{pool
}) if $opts->{pool
};
6568 $tocmd .= ' --prealloc' if $opts->{prealloc
};
6569 $tocmd .= ' --info' if $opts->{info
};
6571 # tar option "xf" does not autodetect compression when read from STDIN,
6572 # so we pipe to zcat
6573 my $cmd = "zcat -f|tar xf " . PVE
::Tools
::shellquote
($archive) . " " .
6574 PVE
::Tools
::shellquote
("--to-command=$tocmd");
6576 my $tmpdir = "/var/tmp/vzdumptmp$$";
6579 local $ENV{VZDUMP_TMPDIR
} = $tmpdir;
6580 local $ENV{VZDUMP_VMID
} = $vmid;
6581 local $ENV{VZDUMP_USER
} = $user;
6583 my $conffile = PVE
::QemuConfig-
>config_file($vmid);
6584 my $tmpfn = "$conffile.$$.tmp";
6586 # disable interrupts (always do cleanups)
6590 local $SIG{HUP
} = sub { print STDERR
"got interrupt - ignored\n"; };
6598 local $SIG{PIPE
} = sub { die "interrupted by signal\n"; };
6600 if ($archive eq '-') {
6601 print "extracting archive from STDIN\n";
6602 run_command
($cmd, input
=> "<&STDIN");
6604 print "extracting archive '$archive'\n";
6608 return if $opts->{info
};
6612 my $statfile = "$tmpdir/qmrestore.stat";
6613 if (my $fd = IO
::File-
>new($statfile, "r")) {
6614 while (defined (my $line = <$fd>)) {
6615 if ($line =~ m/vzdump:([^\s:]*):(\S+)$/) {
6616 $map->{$1} = $2 if $1;
6618 print STDERR
"unable to parse line in statfile - $line\n";
6624 my $confsrc = "$tmpdir/qemu-server.conf";
6626 my $srcfd = new IO
::File
($confsrc, "r") ||
6627 die "unable to open file '$confsrc'\n";
6629 my $outfd = new IO
::File
($tmpfn, "w") ||
6630 die "unable to write config for VM $vmid\n";
6632 my $cookie = { netcount
=> 0 };
6633 while (defined (my $line = <$srcfd>)) {
6634 restore_update_config_line
($outfd, $cookie, $vmid, $map, $line, $opts->{unique
});
6646 tar_restore_cleanup
($storecfg, "$tmpdir/qmrestore.stat") if !$opts->{info
};
6653 rename $tmpfn, $conffile ||
6654 die "unable to commit configuration file '$conffile'\n";
6656 PVE
::Cluster
::cfs_update
(); # make sure we read new file
6658 eval { rescan
($vmid, 1); };
6662 sub foreach_storage_used_by_vm
{
6663 my ($conf, $func) = @_;
6667 foreach_drive
($conf, sub {
6668 my ($ds, $drive) = @_;
6669 return if drive_is_cdrom
($drive);
6671 my $volid = $drive->{file
};
6673 my ($sid, $volname) = PVE
::Storage
::parse_volume_id
($volid, 1);
6674 $sidhash->{$sid} = $sid if $sid;
6677 foreach my $sid (sort keys %$sidhash) {
6682 sub do_snapshots_with_qemu
{
6683 my ($storecfg, $volid) = @_;
6685 my $storage_name = PVE
::Storage
::parse_volume_id
($volid);
6686 my $scfg = $storecfg->{ids
}->{$storage_name};
6688 if ($qemu_snap_storage->{$scfg->{type
}} && !$scfg->{krbd
}){
6692 if ($volid =~ m/\.(qcow2|qed)$/){
6699 sub qga_check_running
{
6700 my ($vmid, $nowarn) = @_;
6702 eval { vm_mon_cmd
($vmid, "guest-ping", timeout
=> 3); };
6704 warn "Qemu Guest Agent is not running - $@" if !$nowarn;
6710 sub template_create
{
6711 my ($vmid, $conf, $disk) = @_;
6713 my $storecfg = PVE
::Storage
::config
();
6715 foreach_drive
($conf, sub {
6716 my ($ds, $drive) = @_;
6718 return if drive_is_cdrom
($drive);
6719 return if $disk && $ds ne $disk;
6721 my $volid = $drive->{file
};
6722 return if !PVE
::Storage
::volume_has_feature
($storecfg, 'template', $volid);
6724 my $voliddst = PVE
::Storage
::vdisk_create_base
($storecfg, $volid);
6725 $drive->{file
} = $voliddst;
6726 $conf->{$ds} = print_drive
($vmid, $drive);
6727 PVE
::QemuConfig-
>write_config($vmid, $conf);
6731 sub convert_iscsi_path
{
6734 if ($path =~ m
|^iscsi
://([^/]+)/([^/]+)/(.+)$|) {
6739 my $initiator_name = get_initiator_name
();
6741 return "file.driver=iscsi,file.transport=tcp,file.initiator-name=$initiator_name,".
6742 "file.portal=$portal,file.target=$target,file.lun=$lun,driver=raw";
6745 die "cannot convert iscsi path '$path', unkown format\n";
6748 sub qemu_img_convert
{
6749 my ($src_volid, $dst_volid, $size, $snapname, $is_zero_initialized) = @_;
6751 my $storecfg = PVE
::Storage
::config
();
6752 my ($src_storeid, $src_volname) = PVE
::Storage
::parse_volume_id
($src_volid, 1);
6753 my ($dst_storeid, $dst_volname) = PVE
::Storage
::parse_volume_id
($dst_volid, 1);
6755 if ($src_storeid && $dst_storeid) {
6757 PVE
::Storage
::activate_volumes
($storecfg, [$src_volid], $snapname);
6759 my $src_scfg = PVE
::Storage
::storage_config
($storecfg, $src_storeid);
6760 my $dst_scfg = PVE
::Storage
::storage_config
($storecfg, $dst_storeid);
6762 my $src_format = qemu_img_format
($src_scfg, $src_volname);
6763 my $dst_format = qemu_img_format
($dst_scfg, $dst_volname);
6765 my $src_path = PVE
::Storage
::path
($storecfg, $src_volid, $snapname);
6766 my $dst_path = PVE
::Storage
::path
($storecfg, $dst_volid);
6768 my $src_is_iscsi = ($src_path =~ m
|^iscsi
://|);
6769 my $dst_is_iscsi = ($dst_path =~ m
|^iscsi
://|);
6772 push @$cmd, '/usr/bin/qemu-img', 'convert', '-p', '-n';
6773 push @$cmd, '-l', "snapshot.name=$snapname" if($snapname && $src_format eq "qcow2");
6774 push @$cmd, '-t', 'none' if $dst_scfg->{type
} eq 'zfspool';
6775 push @$cmd, '-T', 'none' if $src_scfg->{type
} eq 'zfspool';
6777 if ($src_is_iscsi) {
6778 push @$cmd, '--image-opts';
6779 $src_path = convert_iscsi_path
($src_path);
6781 push @$cmd, '-f', $src_format;
6784 if ($dst_is_iscsi) {
6785 push @$cmd, '--target-image-opts';
6786 $dst_path = convert_iscsi_path
($dst_path);
6788 push @$cmd, '-O', $dst_format;
6791 push @$cmd, $src_path;
6793 if (!$dst_is_iscsi && $is_zero_initialized) {
6794 push @$cmd, "zeroinit:$dst_path";
6796 push @$cmd, $dst_path;
6801 if($line =~ m/\((\S+)\/100\
%\)/){
6803 my $transferred = int($size * $percent / 100);
6804 my $remaining = $size - $transferred;
6806 print "transferred: $transferred bytes remaining: $remaining bytes total: $size bytes progression: $percent %\n";
6811 eval { run_command
($cmd, timeout
=> undef, outfunc
=> $parser); };
6813 die "copy failed: $err" if $err;
6817 sub qemu_img_format
{
6818 my ($scfg, $volname) = @_;
6820 if ($scfg->{path
} && $volname =~ m/\.($QEMU_FORMAT_RE)$/) {
6827 sub qemu_drive_mirror
{
6828 my ($vmid, $drive, $dst_volid, $vmiddst, $is_zero_initialized, $jobs, $skipcomplete, $qga, $bwlimit) = @_;
6830 $jobs = {} if !$jobs;
6834 $jobs->{"drive-$drive"} = {};
6836 if ($dst_volid =~ /^nbd:/) {
6837 $qemu_target = $dst_volid;
6840 my $storecfg = PVE
::Storage
::config
();
6841 my ($dst_storeid, $dst_volname) = PVE
::Storage
::parse_volume_id
($dst_volid);
6843 my $dst_scfg = PVE
::Storage
::storage_config
($storecfg, $dst_storeid);
6845 $format = qemu_img_format
($dst_scfg, $dst_volname);
6847 my $dst_path = PVE
::Storage
::path
($storecfg, $dst_volid);
6849 $qemu_target = $is_zero_initialized ?
"zeroinit:$dst_path" : $dst_path;
6852 my $opts = { timeout
=> 10, device
=> "drive-$drive", mode
=> "existing", sync
=> "full", target
=> $qemu_target };
6853 $opts->{format
} = $format if $format;
6855 if (defined($bwlimit)) {
6856 $opts->{speed
} = $bwlimit * 1024;
6857 print "drive mirror is starting for drive-$drive with bandwidth limit: ${bwlimit} KB/s\n";
6859 print "drive mirror is starting for drive-$drive\n";
6862 # if a job already runs for this device we get an error, catch it for cleanup
6863 eval { vm_mon_cmd
($vmid, "drive-mirror", %$opts); };
6865 eval { PVE
::QemuServer
::qemu_blockjobs_cancel
($vmid, $jobs) };
6867 die "mirroring error: $err\n";
6870 qemu_drive_mirror_monitor
($vmid, $vmiddst, $jobs, $skipcomplete, $qga);
6873 sub qemu_drive_mirror_monitor
{
6874 my ($vmid, $vmiddst, $jobs, $skipcomplete, $qga) = @_;
6877 my $err_complete = 0;
6880 die "storage migration timed out\n" if $err_complete > 300;
6882 my $stats = vm_mon_cmd
($vmid, "query-block-jobs");
6884 my $running_mirror_jobs = {};
6885 foreach my $stat (@$stats) {
6886 next if $stat->{type
} ne 'mirror';
6887 $running_mirror_jobs->{$stat->{device
}} = $stat;
6890 my $readycounter = 0;
6892 foreach my $job (keys %$jobs) {
6894 if(defined($jobs->{$job}->{complete
}) && !defined($running_mirror_jobs->{$job})) {
6895 print "$job : finished\n";
6896 delete $jobs->{$job};
6900 die "$job: mirroring has been cancelled\n" if !defined($running_mirror_jobs->{$job});
6902 my $busy = $running_mirror_jobs->{$job}->{busy
};
6903 my $ready = $running_mirror_jobs->{$job}->{ready
};
6904 if (my $total = $running_mirror_jobs->{$job}->{len
}) {
6905 my $transferred = $running_mirror_jobs->{$job}->{offset
} || 0;
6906 my $remaining = $total - $transferred;
6907 my $percent = sprintf "%.2f", ($transferred * 100 / $total);
6909 print "$job: transferred: $transferred bytes remaining: $remaining bytes total: $total bytes progression: $percent % busy: $busy ready: $ready \n";
6912 $readycounter++ if $running_mirror_jobs->{$job}->{ready
};
6915 last if scalar(keys %$jobs) == 0;
6917 if ($readycounter == scalar(keys %$jobs)) {
6918 print "all mirroring jobs are ready \n";
6919 last if $skipcomplete; #do the complete later
6921 if ($vmiddst && $vmiddst != $vmid) {
6922 my $agent_running = $qga && qga_check_running
($vmid);
6923 if ($agent_running) {
6924 print "freeze filesystem\n";
6925 eval { PVE
::QemuServer
::vm_mon_cmd
($vmid, "guest-fsfreeze-freeze"); };
6927 print "suspend vm\n";
6928 eval { PVE
::QemuServer
::vm_suspend
($vmid, 1); };
6931 # if we clone a disk for a new target vm, we don't switch the disk
6932 PVE
::QemuServer
::qemu_blockjobs_cancel
($vmid, $jobs);
6934 if ($agent_running) {
6935 print "unfreeze filesystem\n";
6936 eval { PVE
::QemuServer
::vm_mon_cmd
($vmid, "guest-fsfreeze-thaw"); };
6938 print "resume vm\n";
6939 eval { PVE
::QemuServer
::vm_resume
($vmid, 1, 1); };
6945 foreach my $job (keys %$jobs) {
6946 # try to switch the disk if source and destination are on the same guest
6947 print "$job: Completing block job...\n";
6949 eval { vm_mon_cmd
($vmid, "block-job-complete", device
=> $job) };
6950 if ($@ =~ m/cannot be completed/) {
6951 print "$job: Block job cannot be completed, try again.\n";
6954 print "$job: Completed successfully.\n";
6955 $jobs->{$job}->{complete
} = 1;
6966 eval { PVE
::QemuServer
::qemu_blockjobs_cancel
($vmid, $jobs) };
6967 die "mirroring error: $err";
6972 sub qemu_blockjobs_cancel
{
6973 my ($vmid, $jobs) = @_;
6975 foreach my $job (keys %$jobs) {
6976 print "$job: Cancelling block job\n";
6977 eval { vm_mon_cmd
($vmid, "block-job-cancel", device
=> $job); };
6978 $jobs->{$job}->{cancel
} = 1;
6982 my $stats = vm_mon_cmd
($vmid, "query-block-jobs");
6984 my $running_jobs = {};
6985 foreach my $stat (@$stats) {
6986 $running_jobs->{$stat->{device
}} = $stat;
6989 foreach my $job (keys %$jobs) {
6991 if (defined($jobs->{$job}->{cancel
}) && !defined($running_jobs->{$job})) {
6992 print "$job: Done.\n";
6993 delete $jobs->{$job};
6997 last if scalar(keys %$jobs) == 0;
7004 my ($storecfg, $vmid, $running, $drivename, $drive, $snapname,
7005 $newvmid, $storage, $format, $full, $newvollist, $jobs, $skipcomplete, $qga, $bwlimit) = @_;
7010 print "create linked clone of drive $drivename ($drive->{file})\n";
7011 $newvolid = PVE
::Storage
::vdisk_clone
($storecfg, $drive->{file
}, $newvmid, $snapname);
7012 push @$newvollist, $newvolid;
7015 my ($storeid, $volname) = PVE
::Storage
::parse_volume_id
($drive->{file
});
7016 $storeid = $storage if $storage;
7018 my $dst_format = resolve_dst_disk_format
($storecfg, $storeid, $volname, $format);
7019 my ($size) = PVE
::Storage
::volume_size_info
($storecfg, $drive->{file
}, 3);
7021 print "create full clone of drive $drivename ($drive->{file})\n";
7023 if (drive_is_cloudinit
($drive)) {
7024 $name = "vm-$newvmid-cloudinit";
7026 # we only get here if it's supported by QEMU_FORMAT_RE, so just accept
7027 if ($dst_format ne 'raw') {
7028 $name .= ".$dst_format";
7031 $newvolid = PVE
::Storage
::vdisk_alloc
($storecfg, $storeid, $newvmid, $dst_format, $name, ($size/1024));
7032 push @$newvollist, $newvolid;
7034 PVE
::Storage
::activate_volumes
($storecfg, [$newvolid]);
7036 my $sparseinit = PVE
::Storage
::volume_has_feature
($storecfg, 'sparseinit', $newvolid);
7037 if (!$running || $snapname) {
7038 # TODO: handle bwlimits
7039 qemu_img_convert
($drive->{file
}, $newvolid, $size, $snapname, $sparseinit);
7042 my $kvmver = get_running_qemu_version
($vmid);
7043 if (!qemu_machine_feature_enabled
(undef, $kvmver, 2, 7)) {
7044 die "drive-mirror with iothread requires qemu version 2.7 or higher\n"
7045 if $drive->{iothread
};
7048 qemu_drive_mirror
($vmid, $drivename, $newvolid, $newvmid, $sparseinit, $jobs, $skipcomplete, $qga, $bwlimit);
7052 my ($size) = PVE
::Storage
::volume_size_info
($storecfg, $newvolid, 3);
7055 $disk->{format
} = undef;
7056 $disk->{file
} = $newvolid;
7057 $disk->{size
} = $size;
7062 # this only works if VM is running
7063 sub get_current_qemu_machine
{
7066 my $cmd = { execute
=> 'query-machines', arguments
=> {} };
7067 my $res = vm_qmp_command
($vmid, $cmd);
7069 my ($current, $default);
7070 foreach my $e (@$res) {
7071 $default = $e->{name
} if $e->{'is-default'};
7072 $current = $e->{name
} if $e->{'is-current'};
7075 # fallback to the default machine if current is not supported by qemu
7076 return $current || $default || 'pc';
7079 sub get_running_qemu_version
{
7081 my $cmd = { execute
=> 'query-version', arguments
=> {} };
7082 my $res = vm_qmp_command
($vmid, $cmd);
7083 return "$res->{qemu}->{major}.$res->{qemu}->{minor}";
7086 sub qemu_machine_feature_enabled
{
7087 my ($machine, $kvmver, $version_major, $version_minor) = @_;
7092 if ($machine && $machine =~ m/^((?:pc(-i440fx|-q35)?|virt)-(\d+)\.(\d+))/) {
7094 $current_major = $3;
7095 $current_minor = $4;
7097 } elsif ($kvmver =~ m/^(\d+)\.(\d+)/) {
7099 $current_major = $1;
7100 $current_minor = $2;
7103 return 1 if $current_major > $version_major ||
7104 ($current_major == $version_major &&
7105 $current_minor >= $version_minor);
7108 sub qemu_machine_pxe
{
7109 my ($vmid, $conf, $machine) = @_;
7111 $machine = PVE
::QemuServer
::get_current_qemu_machine
($vmid) if !$machine;
7113 if ($conf->{machine
} && $conf->{machine
} =~ m/\.pxe$/) {
7120 sub qemu_use_old_bios_files
{
7121 my ($machine_type) = @_;
7123 return if !$machine_type;
7125 my $use_old_bios_files = undef;
7127 if ($machine_type =~ m/^(\S+)\.pxe$/) {
7129 $use_old_bios_files = 1;
7131 my $kvmver = kvm_user_version
();
7132 # Note: kvm version < 2.4 use non-efi pxe files, and have problems when we
7133 # load new efi bios files on migration. So this hack is required to allow
7134 # live migration from qemu-2.2 to qemu-2.4, which is sometimes used when
7135 # updrading from proxmox-ve-3.X to proxmox-ve 4.0
7136 $use_old_bios_files = !qemu_machine_feature_enabled
($machine_type, $kvmver, 2, 4);
7139 return ($use_old_bios_files, $machine_type);
7142 sub create_efidisk
($$$$$) {
7143 my ($storecfg, $storeid, $vmid, $fmt, $arch) = @_;
7145 my (undef, $ovmf_vars) = get_ovmf_files
($arch);
7146 die "EFI vars default image not found\n" if ! -f
$ovmf_vars;
7148 my $vars_size = PVE
::Tools
::convert_size
(-s
$ovmf_vars, 'b' => 'kb');
7149 my $volid = PVE
::Storage
::vdisk_alloc
($storecfg, $storeid, $vmid, $fmt, undef, $vars_size);
7150 PVE
::Storage
::activate_volumes
($storecfg, [$volid]);
7152 my $path = PVE
::Storage
::path
($storecfg, $volid);
7154 run_command
(['/usr/bin/qemu-img', 'convert', '-n', '-f', 'raw', '-O', $fmt, $ovmf_vars, $path]);
7156 die "Copying EFI vars image failed: $@" if $@;
7158 return ($volid, $vars_size);
7161 sub vm_iothreads_list
{
7164 my $res = vm_mon_cmd
($vmid, 'query-iothreads');
7167 foreach my $iothread (@$res) {
7168 $iothreads->{ $iothread->{id
} } = $iothread->{"thread-id"};
7175 my ($conf, $drive) = @_;
7179 if (!$conf->{scsihw
} || ($conf->{scsihw
} =~ m/^lsi/)) {
7181 } elsif ($conf->{scsihw
} && ($conf->{scsihw
} eq 'virtio-scsi-single')) {
7187 my $controller = int($drive->{index} / $maxdev);
7188 my $controller_prefix = ($conf->{scsihw
} && $conf->{scsihw
} eq 'virtio-scsi-single') ?
"virtioscsi" : "scsihw";
7190 return ($maxdev, $controller, $controller_prefix);
7193 sub add_hyperv_enlightenments
{
7194 my ($cpuFlags, $winversion, $machine_type, $kvmver, $bios, $gpu_passthrough, $hv_vendor_id) = @_;
7196 return if $winversion < 6;
7197 return if $bios && $bios eq 'ovmf' && $winversion < 8;
7199 if ($gpu_passthrough || defined($hv_vendor_id)) {
7200 $hv_vendor_id //= 'proxmox';
7201 push @$cpuFlags , "hv_vendor_id=$hv_vendor_id";
7204 if (qemu_machine_feature_enabled
($machine_type, $kvmver, 2, 3)) {
7205 push @$cpuFlags , 'hv_spinlocks=0x1fff';
7206 push @$cpuFlags , 'hv_vapic';
7207 push @$cpuFlags , 'hv_time';
7209 push @$cpuFlags , 'hv_spinlocks=0xffff';
7212 if (qemu_machine_feature_enabled
($machine_type, $kvmver, 2, 6)) {
7213 push @$cpuFlags , 'hv_reset';
7214 push @$cpuFlags , 'hv_vpindex';
7215 push @$cpuFlags , 'hv_runtime';
7218 if ($winversion >= 7) {
7219 push @$cpuFlags , 'hv_relaxed';
7221 if (qemu_machine_feature_enabled
($machine_type, $kvmver, 2, 12)) {
7222 push @$cpuFlags , 'hv_synic';
7223 push @$cpuFlags , 'hv_stimer';
7226 if (qemu_machine_feature_enabled
($machine_type, $kvmver, 3, 1)) {
7227 push @$cpuFlags , 'hv_tlbflush';
7228 push @$cpuFlags , 'hv_ipi';
7229 # FIXME: AMD does not supports this currently, only add with special flag??
7230 #push @$cpuFlags , 'hv_evmcs';
7235 sub windows_version
{
7238 return 0 if !$ostype;
7242 if($ostype eq 'wxp' || $ostype eq 'w2k3' || $ostype eq 'w2k') {
7244 } elsif($ostype eq 'w2k8' || $ostype eq 'wvista') {
7246 } elsif ($ostype =~ m/^win(\d+)$/) {
7253 sub resolve_dst_disk_format
{
7254 my ($storecfg, $storeid, $src_volname, $format) = @_;
7255 my ($defFormat, $validFormats) = PVE
::Storage
::storage_default_format
($storecfg, $storeid);
7258 # if no target format is specified, use the source disk format as hint
7260 my $scfg = PVE
::Storage
::storage_config
($storecfg, $storeid);
7261 $format = qemu_img_format
($scfg, $src_volname);
7267 # test if requested format is supported - else use default
7268 my $supported = grep { $_ eq $format } @$validFormats;
7269 $format = $defFormat if !$supported;
7273 sub resolve_first_disk
{
7275 my @disks = PVE
::QemuServer
::valid_drive_names
();
7277 foreach my $ds (reverse @disks) {
7278 next if !$conf->{$ds};
7279 my $disk = PVE
::QemuServer
::parse_drive
($ds, $conf->{$ds});
7280 next if PVE
::QemuServer
::drive_is_cdrom
($disk);
7287 my ($uuid, $uuid_str);
7288 UUID
::generate
($uuid);
7289 UUID
::unparse
($uuid, $uuid_str);
7293 sub generate_smbios1_uuid
{
7294 return "uuid=".generate_uuid
();
7300 vm_mon_cmd
($vmid, 'nbd-server-stop');
7303 # bash completion helper
7305 sub complete_backup_archives
{
7306 my ($cmdname, $pname, $cvalue) = @_;
7308 my $cfg = PVE
::Storage
::config
();
7312 if ($cvalue =~ m/^([^:]+):/) {
7316 my $data = PVE
::Storage
::template_list
($cfg, $storeid, 'backup');
7319 foreach my $id (keys %$data) {
7320 foreach my $item (@{$data->{$id}}) {
7321 next if $item->{format
} !~ m/^vma\.(gz|lzo)$/;
7322 push @$res, $item->{volid
} if defined($item->{volid
});
7329 my $complete_vmid_full = sub {
7332 my $idlist = vmstatus
();
7336 foreach my $id (keys %$idlist) {
7337 my $d = $idlist->{$id};
7338 if (defined($running)) {
7339 next if $d->{template
};
7340 next if $running && $d->{status
} ne 'running';
7341 next if !$running && $d->{status
} eq 'running';
7350 return &$complete_vmid_full();
7353 sub complete_vmid_stopped
{
7354 return &$complete_vmid_full(0);
7357 sub complete_vmid_running
{
7358 return &$complete_vmid_full(1);
7361 sub complete_storage
{
7363 my $cfg = PVE
::Storage
::config
();
7364 my $ids = $cfg->{ids
};
7367 foreach my $sid (keys %$ids) {
7368 next if !PVE
::Storage
::storage_check_enabled
($cfg, $sid, undef, 1);
7369 next if !$ids->{$sid}->{content
}->{images
};