[pve-devel] [PATCH qemu-server 3/6] qmevent: call qm disk blockextend when write_threshold event is received

[Alexandre Derumier via pve-devel <pve-devel@lists.proxmox.com>]

[-- Attachment #1: Type: message/rfc822, Size: 3977 bytes --]

From: Alexandre Derumier <alexandre.derumier@groupe-cyllene.com>
To: pve-devel@lists.proxmox.com
Subject: [PATCH qemu-server 3/6] qmevent: call qm disk blockextend when write_threshold event is received
Date: Mon, 26 Aug 2024 13:00:25 +0200
Message-ID: <20240826110030.1744732-8-alexandre.derumier@groupe-cyllene.com>

Signed-off-by: Alexandre Derumier <alexandre.derumier@groupe-cyllene.com>
---
 qmeventd/qmeventd.c | 27 +++++++++++++++++++++++++++
 1 file changed, 27 insertions(+)

diff --git a/qmeventd/qmeventd.c b/qmeventd/qmeventd.c
index d8f3ee7..4f45b6f 100644
--- a/qmeventd/qmeventd.c
+++ b/qmeventd/qmeventd.c
@@ -229,6 +229,33 @@ handle_qmp_event(struct Client *client, struct json_object *obj)
 
 	// check if a backup is running and kill QEMU process if not
 	terminate_check(client);
+    } else if (!strcmp(json_object_get_string(event), "BLOCK_WRITE_THRESHOLD")) {
+
+	struct json_object *data;
+	struct json_object *nodename;
+	if (json_object_object_get_ex(obj, "data", &data) &&
+	    json_object_object_get_ex(data, "node-name", &nodename))
+	{
+	    int pid = fork();
+	    if (pid < 0) {
+		fprintf(stderr, "fork failed: %s\n", strerror(errno));
+		return;
+	    }
+	    if (pid == 0) {
+		char *script = "/usr/sbin/qm";
+		char *args[] = {
+		    script,
+		    "disk",
+		    "blockextend",
+		    client->qemu.vmid,
+		    (char *)json_object_get_string(nodename),
+		    NULL
+		};
+		execvp(script, args);
+		perror("execvp");
+		_exit(1);
+	    }
+	}
     }
 }
 
-- 
2.39.2



[-- Attachment #2: Type: text/plain, Size: 160 bytes --]

_______________________________________________
pve-devel mailing list
pve-devel@lists.proxmox.com
https://lists.proxmox.com/cgi-bin/mailman/listinfo/pve-devel