|
 |
383d26 |
From d6d700d511612f621c0b6dcbd3d7996126f3da80 Mon Sep 17 00:00:00 2001
|
|
|
383d26 |
From: Paolo Bonzini <pbonzini@redhat.com>
|
|
|
383d26 |
Date: Fri, 6 Jul 2018 17:56:56 +0200
|
|
|
383d26 |
Subject: [PATCH 22/89] pr-manager-helper: report event on
|
|
|
383d26 |
connection/disconnection
|
|
|
383d26 |
|
|
|
383d26 |
RH-Author: Paolo Bonzini <pbonzini@redhat.com>
|
|
|
383d26 |
Message-id: <20180706175659.30615-7-pbonzini@redhat.com>
|
|
|
383d26 |
Patchwork-id: 81247
|
|
|
383d26 |
O-Subject: [RHEL7.6 qemu-kvm-rhev PATCH 6/9] pr-manager-helper: report event on connection/disconnection
|
|
|
383d26 |
Bugzilla: 1533158
|
|
|
383d26 |
RH-Acked-by: Laurent Vivier <lvivier@redhat.com>
|
|
|
383d26 |
RH-Acked-by: Stefan Hajnoczi <stefanha@redhat.com>
|
|
|
383d26 |
RH-Acked-by: Michal Privoznik <mprivozn@redhat.com>
|
|
|
383d26 |
|
|
|
383d26 |
Let management know if there were any problems communicating with
|
|
|
383d26 |
qemu-pr-helper. The event is edge-triggered, and is sent every time
|
|
|
383d26 |
the connection status of the pr-manager-helper object changes.
|
|
|
383d26 |
|
|
|
383d26 |
Signed-off-by: Paolo Bonzini <pbonzini@redhat.com>
|
|
|
383d26 |
(cherry picked from commit e2c81a45101fdddfd47477a1805806f2c76639bf)
|
|
|
383d26 |
Signed-off-by: Miroslav Rezanina <mrezanin@redhat.com>
|
|
|
383d26 |
---
|
|
|
383d26 |
qapi/block.json | 24 ++++++++++++++++++++++++
|
|
|
383d26 |
scsi/pr-manager-helper.c | 14 ++++++++++++++
|
|
|
383d26 |
2 files changed, 38 insertions(+)
|
|
|
383d26 |
|
|
|
383d26 |
diff --git a/qapi/block.json b/qapi/block.json
|
|
|
383d26 |
index c636354..f05b91a 100644
|
|
|
383d26 |
--- a/qapi/block.json
|
|
|
383d26 |
+++ b/qapi/block.json
|
|
|
383d26 |
@@ -403,6 +403,30 @@
|
|
|
383d26 |
'data': { 'device': 'str', 'id': 'str', 'tray-open': 'bool' } }
|
|
|
383d26 |
|
|
|
383d26 |
##
|
|
|
383d26 |
+# @PR_MANAGER_STATUS_CHANGED:
|
|
|
383d26 |
+#
|
|
|
383d26 |
+# Emitted whenever the connected status of a persistent reservation
|
|
|
383d26 |
+# manager changes.
|
|
|
383d26 |
+#
|
|
|
383d26 |
+# @id: The id of the PR manager object
|
|
|
383d26 |
+#
|
|
|
383d26 |
+# @connected: true if the PR manager is connected to a backend
|
|
|
383d26 |
+#
|
|
|
383d26 |
+# Since: 3.0
|
|
|
383d26 |
+#
|
|
|
383d26 |
+# Example:
|
|
|
383d26 |
+#
|
|
|
383d26 |
+# <- { "event": "PR_MANAGER_STATUS_CHANGED",
|
|
|
383d26 |
+# "data": { "id": "pr-helper0",
|
|
|
383d26 |
+# "connected": true
|
|
|
383d26 |
+# },
|
|
|
383d26 |
+# "timestamp": { "seconds": 1519840375, "microseconds": 450486 } }
|
|
|
383d26 |
+#
|
|
|
383d26 |
+##
|
|
|
383d26 |
+{ 'event': 'PR_MANAGER_STATUS_CHANGED',
|
|
|
383d26 |
+ 'data': { 'id': 'str', 'connected': 'bool' } }
|
|
|
383d26 |
+
|
|
|
383d26 |
+##
|
|
|
383d26 |
# @QuorumOpType:
|
|
|
383d26 |
#
|
|
|
383d26 |
# An enumeration of the quorum operation types
|
|
|
383d26 |
diff --git a/scsi/pr-manager-helper.c b/scsi/pr-manager-helper.c
|
|
|
383d26 |
index b11481b..519a296 100644
|
|
|
383d26 |
--- a/scsi/pr-manager-helper.c
|
|
|
383d26 |
+++ b/scsi/pr-manager-helper.c
|
|
|
383d26 |
@@ -17,6 +17,7 @@
|
|
|
383d26 |
#include "io/channel.h"
|
|
|
383d26 |
#include "io/channel-socket.h"
|
|
|
383d26 |
#include "pr-helper.h"
|
|
|
383d26 |
+#include "qapi/qapi-events-block.h"
|
|
|
383d26 |
|
|
|
383d26 |
#include <scsi/sg.h>
|
|
|
383d26 |
|
|
|
383d26 |
@@ -38,6 +39,16 @@ typedef struct PRManagerHelper {
|
|
|
383d26 |
QIOChannel *ioc;
|
|
|
383d26 |
} PRManagerHelper;
|
|
|
383d26 |
|
|
|
383d26 |
+static void pr_manager_send_status_changed_event(PRManagerHelper *pr_mgr)
|
|
|
383d26 |
+{
|
|
|
383d26 |
+ char *id = object_get_canonical_path_component(OBJECT(pr_mgr));
|
|
|
383d26 |
+
|
|
|
383d26 |
+ if (id) {
|
|
|
383d26 |
+ qapi_event_send_pr_manager_status_changed(id, !!pr_mgr->ioc,
|
|
|
383d26 |
+ &error_abort);
|
|
|
383d26 |
+ }
|
|
|
383d26 |
+}
|
|
|
383d26 |
+
|
|
|
383d26 |
/* Called with lock held. */
|
|
|
383d26 |
static int pr_manager_helper_read(PRManagerHelper *pr_mgr,
|
|
|
383d26 |
void *buf, int sz, Error **errp)
|
|
|
383d26 |
@@ -47,6 +58,7 @@ static int pr_manager_helper_read(PRManagerHelper *pr_mgr,
|
|
|
383d26 |
if (r < 0) {
|
|
|
383d26 |
object_unref(OBJECT(pr_mgr->ioc));
|
|
|
383d26 |
pr_mgr->ioc = NULL;
|
|
|
383d26 |
+ pr_manager_send_status_changed_event(pr_mgr);
|
|
|
383d26 |
return -EINVAL;
|
|
|
383d26 |
}
|
|
|
383d26 |
|
|
|
383d26 |
@@ -72,6 +84,7 @@ static int pr_manager_helper_write(PRManagerHelper *pr_mgr,
|
|
|
383d26 |
assert(n_written != QIO_CHANNEL_ERR_BLOCK);
|
|
|
383d26 |
object_unref(OBJECT(pr_mgr->ioc));
|
|
|
383d26 |
pr_mgr->ioc = NULL;
|
|
|
383d26 |
+ pr_manager_send_status_changed_event(pr_mgr);
|
|
|
383d26 |
return n_written < 0 ? -EINVAL : 0;
|
|
|
383d26 |
}
|
|
|
383d26 |
|
|
|
383d26 |
@@ -127,6 +140,7 @@ static int pr_manager_helper_initialize(PRManagerHelper *pr_mgr,
|
|
|
383d26 |
goto out_close;
|
|
|
383d26 |
}
|
|
|
383d26 |
|
|
|
383d26 |
+ pr_manager_send_status_changed_event(pr_mgr);
|
|
|
383d26 |
return 0;
|
|
|
383d26 |
|
|
|
383d26 |
out_close:
|
|
|
383d26 |
--
|
|
|
383d26 |
1.8.3.1
|
|
|
383d26 |
|