From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from firstgate.proxmox.com (firstgate.proxmox.com [IPv6:2a01:7e0:0:424::9]) by lore.proxmox.com (Postfix) with ESMTPS id 993D31FF183 for ; Wed, 3 Dec 2025 14:31:14 +0100 (CET) Received: from firstgate.proxmox.com (localhost [127.0.0.1]) by firstgate.proxmox.com (Proxmox) with ESMTP id 808FBA250; Wed, 3 Dec 2025 14:30:31 +0100 (CET) From: Fiona Ebner To: pve-devel@lists.proxmox.com Date: Wed, 3 Dec 2025 14:26:31 +0100 Message-ID: <20251203132949.109685-6-f.ebner@proxmox.com> X-Mailer: git-send-email 2.47.3 In-Reply-To: <20251203132949.109685-1-f.ebner@proxmox.com> References: <20251203132949.109685-1-f.ebner@proxmox.com> MIME-Version: 1.0 X-Bm-Milter-Handled: 55990f41-d878-4baa-be0a-ee34c49e34d2 X-Bm-Transport-Timestamp: 1764768548610 X-SPAM-LEVEL: Spam detection results: 0 AWL -0.017 Adjusted score from AWL reputation of From: address BAYES_00 -1.9 Bayes spam probability is 0 to 1% DMARC_MISSING 0.1 Missing DMARC policy KAM_DMARC_STATUS 0.01 Test Rule for DKIM or SPF Failure with Strict Alignment SPF_HELO_NONE 0.001 SPF: HELO does not publish an SPF Record SPF_PASS -0.001 SPF: sender matches SPF record Subject: [pve-devel] [PATCH qemu-server 05/18] monitor: add qsd_peer() helper X-BeenThere: pve-devel@lists.proxmox.com X-Mailman-Version: 2.1.29 Precedence: list List-Id: Proxmox VE development discussion List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Reply-To: Proxmox VE development discussion Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: 7bit Errors-To: pve-devel-bounces@lists.proxmox.com Sender: "pve-devel" Avoid duplicating this information to ensure consistency and improve readability. Signed-off-by: Fiona Ebner --- src/PVE/QemuServer/Blockdev.pm | 9 ++------- src/PVE/QemuServer/Monitor.pm | 10 ++++++++-- src/PVE/QemuServer/QSD.pm | 11 ++++------- 3 files changed, 14 insertions(+), 16 deletions(-) diff --git a/src/PVE/QemuServer/Blockdev.pm b/src/PVE/QemuServer/Blockdev.pm index 17a4c8a0..966bbc0d 100644 --- a/src/PVE/QemuServer/Blockdev.pm +++ b/src/PVE/QemuServer/Blockdev.pm @@ -16,7 +16,7 @@ use PVE::QemuServer::BlockJob; use PVE::QemuServer::Drive qw(drive_is_cdrom); use PVE::QemuServer::Helpers; use PVE::QemuServer::Machine; -use PVE::QemuServer::Monitor qw(mon_cmd qmp_cmd vm_qmp_peer); +use PVE::QemuServer::Monitor qw(mon_cmd qmp_cmd qsd_peer vm_qmp_peer); # gives ($host, $port, $export) my $NBD_TCP_PATH_RE_3 = qr/nbd:(\S+):(\d+):exportname=(\S+)/; @@ -579,12 +579,7 @@ state image. sub attach { my ($storecfg, $id, $drive, $options) = @_; - my $qmp_peer; - if ($options->{qsd}) { - $qmp_peer = { name => "QEMU storage daemon $id", id => $id, type => 'qsd' }; - } else { - $qmp_peer = vm_qmp_peer($id); - } + my $qmp_peer = $options->{qsd} ? qsd_peer($id) : vm_qmp_peer($id); my $machine_version; if ($options->{qsd}) { # qemu-storage-daemon runs with the installed binary version diff --git a/src/PVE/QemuServer/Monitor.pm b/src/PVE/QemuServer/Monitor.pm index 7ad0f7db..8d2c2270 100644 --- a/src/PVE/QemuServer/Monitor.pm +++ b/src/PVE/QemuServer/Monitor.pm @@ -11,6 +11,7 @@ use base 'Exporter'; our @EXPORT_OK = qw( mon_cmd qmp_cmd + qsd_peer vm_qmp_peer ); @@ -109,11 +110,16 @@ sub vm_qmp_peer { return { name => "VM $vmid", id => $vmid, type => 'qmp' }; } +sub qsd_peer { + my ($id) = @_; + + return { name => "QEMU storage daemon $id", id => $id, type => 'qsd' }; +} + sub qsd_cmd { my ($id, $execute, %params) = @_; - return qmp_cmd({ name => "QEMU storage daemon $id", id => $id, type => 'qsd' }, - $execute, %params); + return qmp_cmd(qsd_peer($id), $execute, %params); } sub mon_cmd { diff --git a/src/PVE/QemuServer/QSD.pm b/src/PVE/QemuServer/QSD.pm index 9c30f7fd..bb85085a 100644 --- a/src/PVE/QemuServer/QSD.pm +++ b/src/PVE/QemuServer/QSD.pm @@ -11,7 +11,7 @@ use PVE::Tools; use PVE::QemuServer::Blockdev; use PVE::QemuServer::Helpers; -use PVE::QemuServer::Monitor; +use PVE::QemuServer::Monitor qw(qsd_peer); =head3 start @@ -22,13 +22,10 @@ Start a QEMU storage daemon instance with ID C<$id>. =cut sub start($id) { - my $name = "QEMU storage daemon $id"; - # If something is still mounted, that could block the new instance, try to clean up first. PVE::QemuServer::Helpers::qsd_fuse_export_cleanup_files($id); - my $qmp_socket_path = - PVE::QemuServer::Helpers::qmp_socket({ name => $name, id => $id, type => 'qsd' }); + my $qmp_socket_path = PVE::QemuServer::Helpers::qmp_socket(qsd_peer($id)); my $pidfile = PVE::QemuServer::Helpers::qsd_pidfile_name($id); my $cmd = [ @@ -45,7 +42,7 @@ sub start($id) { PVE::Tools::run_command($cmd); my $pid = PVE::QemuServer::Helpers::qsd_running_locally($id); - syslog("info", "$name started with PID $pid."); + syslog("info", "QEMU storage daemon $id started with PID $pid."); return; } @@ -134,7 +131,7 @@ sub quit($id) { } unlink PVE::QemuServer::Helpers::qsd_pidfile_name($id); - unlink PVE::QemuServer::Helpers::qmp_socket({ name => $name, id => $id, type => 'qsd' }); + unlink PVE::QemuServer::Helpers::qmp_socket(qsd_peer($id)); PVE::QemuServer::Helpers::qsd_fuse_export_cleanup_files($id); -- 2.47.3 _______________________________________________ pve-devel mailing list pve-devel@lists.proxmox.com https://lists.proxmox.com/cgi-bin/mailman/listinfo/pve-devel