[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PULL for-4.0 6/7] qga: process_event() simplification
From: |
Michael Roth |
Subject: |
[Qemu-devel] [PULL for-4.0 6/7] qga: process_event() simplification |
Date: |
Mon, 18 Mar 2019 11:24:09 -0500 |
From: Marc-André Lureau <address@hidden>
Simplify the code around qmp_dispatch():
- rely on qmp_dispatch/check_obj() for message checking
- have a single send_response() point
- constify send_response() argument
It changes a couple of error messages:
* When @req isn't a dictionary, from
Invalid JSON syntax
to
QMP input must be a JSON object
* When @req lacks member "execute", from
this feature or command is not currently supported
to
QMP input lacks member 'execute'
CC: Michael Roth <address@hidden>
Signed-off-by: Marc-André Lureau <address@hidden>
Signed-off-by: Michael Roth <address@hidden>
Reviewed-by: Eric Blake <address@hidden>
---
qga/main.c | 47 +++++++++--------------------------------------
1 file changed, 9 insertions(+), 38 deletions(-)
diff --git a/qga/main.c b/qga/main.c
index 87a0711c14..c0d77c79c4 100644
--- a/qga/main.c
+++ b/qga/main.c
@@ -523,15 +523,15 @@ fail:
#endif
}
-static int send_response(GAState *s, QDict *payload)
+static int send_response(GAState *s, const QDict *rsp)
{
const char *buf;
QString *payload_qstr, *response_qstr;
GIOStatus status;
- g_assert(payload && s->channel);
+ g_assert(rsp && s->channel);
- payload_qstr = qobject_to_json(QOBJECT(payload));
+ payload_qstr = qobject_to_json(QOBJECT(rsp));
if (!payload_qstr) {
return -EINVAL;
}
@@ -557,53 +557,24 @@ static int send_response(GAState *s, QDict *payload)
return 0;
}
-static void process_command(GAState *s, QDict *req)
-{
- QDict *rsp;
- int ret;
-
- g_assert(req);
- g_debug("processing command");
- rsp = qmp_dispatch(&ga_commands, QOBJECT(req), false);
- if (rsp) {
- ret = send_response(s, rsp);
- if (ret < 0) {
- g_warning("error sending response: %s", strerror(-ret));
- }
- qobject_unref(rsp);
- }
-}
-
/* handle requests/control events coming in over the channel */
static void process_event(void *opaque, QObject *obj, Error *err)
{
GAState *s = opaque;
- QDict *req, *rsp;
+ QDict *rsp;
int ret;
g_debug("process_event: called");
assert(!obj != !err);
if (err) {
- goto err;
- }
- req = qobject_to(QDict, obj);
- if (!req) {
- error_setg(&err, "Input must be a JSON object");
- goto err;
- }
- if (!qdict_haskey(req, "execute")) {
- g_warning("unrecognized payload format");
- error_setg(&err, QERR_UNSUPPORTED);
- goto err;
+ rsp = qmp_error_response(err);
+ goto end;
}
- process_command(s, req);
- qobject_unref(obj);
- return;
+ g_debug("processing command");
+ rsp = qmp_dispatch(&ga_commands, obj, false);
-err:
- g_warning("failed to parse event: %s", error_get_pretty(err));
- rsp = qmp_error_response(err);
+end:
ret = send_response(s, rsp);
if (ret < 0) {
g_warning("error sending error response: %s", strerror(-ret));
--
2.17.1
- [Qemu-devel] [PULL for-4.0 0/7] qemu-ga patch queue for 4.0, Michael Roth, 2019/03/18
- [Qemu-devel] [PULL for-4.0 2/7] qga-win: Adding support for Windows Server 2019 get-osinfo command, Michael Roth, 2019/03/18
- [Qemu-devel] [PULL for-4.0 4/7] qga-win: fix VSS build breakage due to unintended gnu99 C++ flag, Michael Roth, 2019/03/18
- [Qemu-devel] [PULL for-4.0 3/7] qga-win: include glib when building VSS DLL, Michael Roth, 2019/03/18
- [Qemu-devel] [PULL for-4.0 6/7] qga: process_event() simplification,
Michael Roth <=
- [Qemu-devel] [PULL for-4.0 7/7] qmp: common 'id' handling & make QGA conform to QMP spec, Michael Roth, 2019/03/18
- [Qemu-devel] [PULL for-4.0 1/7] qga: update docs with systemd suspend support info, Michael Roth, 2019/03/18
- [Qemu-devel] [PULL for-4.0 5/7] qga: Fix guest-get-fsinfo PCI address collection in Windows, Michael Roth, 2019/03/18
- Re: [Qemu-devel] [PULL for-4.0 0/7] qemu-ga patch queue for 4.0, no-reply, 2019/03/18
- Re: [Qemu-devel] [PULL for-4.0 0/7] qemu-ga patch queue for 4.0, Peter Maydell, 2019/03/19