[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PATCH v5 17/20] console: make screendump asynchronous
From: |
Marc-André Lureau |
Subject: |
[Qemu-devel] [PATCH v5 17/20] console: make screendump asynchronous |
Date: |
Mon, 15 Jul 2019 23:09:58 +0400 |
Make screendump asynchronous to provide correct screendumps.
For now, HMP doesn't have async support, so it has to remain
synchronous and potentially incorrect to avoid races (following
patches will add HMP asynchronous commands)
Fixes:
https://bugzilla.redhat.com/show_bug.cgi?id=1230527
Signed-off-by: Marc-André Lureau <address@hidden>
---
include/ui/console.h | 3 ++
monitor/hmp-cmds.c | 2 +-
qapi/ui.json | 3 +-
ui/console.c | 103 +++++++++++++++++++++++++++++++++++++++----
4 files changed, 100 insertions(+), 11 deletions(-)
diff --git a/include/ui/console.h b/include/ui/console.h
index 281f9c145b..a1935557cc 100644
--- a/include/ui/console.h
+++ b/include/ui/console.h
@@ -74,6 +74,9 @@ typedef struct MouseTransformInfo {
} MouseTransformInfo;
void hmp_mouse_set(Monitor *mon, const QDict *qdict);
+void hmp_screendump_sync(const char *filename,
+ bool has_device, const char *device,
+ bool has_head, int64_t head, Error **errp);
/* keysym is a unicode code except for special keys (see QEMU_KEY_xxx
constants) */
diff --git a/monitor/hmp-cmds.c b/monitor/hmp-cmds.c
index 5ca3ebe942..50a25a1ddc 100644
--- a/monitor/hmp-cmds.c
+++ b/monitor/hmp-cmds.c
@@ -2341,7 +2341,7 @@ void hmp_screendump(Monitor *mon, const QDict *qdict)
int64_t head = qdict_get_try_int(qdict, "head", 0);
Error *err = NULL;
- qmp_screendump(filename, id != NULL, id, id != NULL, head, &err);
+ hmp_screendump_sync(filename, id != NULL, id, id != NULL, head, &err);
hmp_handle_error(mon, &err);
}
diff --git a/qapi/ui.json b/qapi/ui.json
index 59e412139a..cbb3979172 100644
--- a/qapi/ui.json
+++ b/qapi/ui.json
@@ -96,7 +96,8 @@
#
##
{ 'command': 'screendump',
- 'data': {'filename': 'str', '*device': 'str', '*head': 'int'} }
+ 'data': {'filename': 'str', '*device': 'str', '*head': 'int'},
+ 'async': true }
##
# == Spice
diff --git a/ui/console.c b/ui/console.c
index 3c941528d2..29c850c31c 100644
--- a/ui/console.c
+++ b/ui/console.c
@@ -33,6 +33,7 @@
#include "chardev/char-fe.h"
#include "trace.h"
#include "exec/memory.h"
+#include "monitor/monitor.h"
#define DEFAULT_BACKSCROLL 512
#define CONSOLE_CURSOR_PERIOD 500
@@ -117,6 +118,12 @@ typedef enum {
TEXT_CONSOLE_FIXED_SIZE
} console_type_t;
+struct qmp_screendump {
+ gchar *filename;
+ QmpReturn *ret;
+ QLIST_ENTRY(qmp_screendump) link;
+};
+
struct QemuConsole {
Object parent;
@@ -167,6 +174,8 @@ struct QemuConsole {
uint8_t out_fifo_buf[16];
QEMUTimer *kbd_timer;
+ QLIST_HEAD(, qmp_screendump) qmp_screendumps;
+
QTAILQ_ENTRY(QemuConsole) next;
};
@@ -193,6 +202,8 @@ static void dpy_refresh(DisplayState *s);
static DisplayState *get_alloc_displaystate(void);
static void text_console_update_cursor_timer(void);
static void text_console_update_cursor(void *opaque);
+static void ppm_save(const char *filename, DisplaySurface *ds,
+ Error **errp);
static void gui_update(void *opaque)
{
@@ -259,8 +270,48 @@ static void gui_setup_refresh(DisplayState *ds)
ds->have_text = have_text;
}
+static void qmp_screendump_finish(QemuConsole *con, struct qmp_screendump
*dump)
+{
+ Error *err = NULL;
+ DisplaySurface *surface;
+ Monitor *prev_mon = cur_mon;
+
+ if (qmp_return_is_cancelled(dump->ret)) {
+ goto cleanup;
+ }
+
+ cur_mon = qmp_return_get_monitor(dump->ret);
+ surface = qemu_console_surface(con);
+ if (!surface) {
+ error_setg(&err, "no surface");
+ } else {
+ /*
+ * FIXME: async save with coroutine? it would have to copy or
+ * lock the surface.
+ */
+ ppm_save(dump->filename, surface, &err);
+ }
+
+ if (err) {
+ qmp_return_error(dump->ret, err);
+ } else {
+ qmp_screendump_return(dump->ret);
+ }
+ cur_mon = prev_mon;
+
+cleanup:
+ g_free(dump->filename);
+ QLIST_REMOVE(dump, link);
+ g_free(dump);
+}
+
void graphic_hw_update_done(QemuConsole *con)
{
+ struct qmp_screendump *dump, *next;
+
+ QLIST_FOREACH_SAFE(dump, &con->qmp_screendumps, link, next) {
+ qmp_screendump_finish(con, dump);
+ }
}
void graphic_hw_update(QemuConsole *con)
@@ -356,30 +407,41 @@ write_err:
goto out;
}
-void qmp_screendump(const char *filename, bool has_device, const char *device,
- bool has_head, int64_t head, Error **errp)
+
+static QemuConsole *get_console(bool has_device, const char *device,
+ bool has_head, int64_t head, Error **errp)
{
- QemuConsole *con;
- DisplaySurface *surface;
+ QemuConsole *con = NULL;
if (has_device) {
con = qemu_console_lookup_by_device_name(device, has_head ? head : 0,
errp);
- if (!con) {
- return;
- }
} else {
if (has_head) {
error_setg(errp, "'head' must be specified together with
'device'");
- return;
+ return NULL;
}
con = qemu_console_lookup_by_index(0);
if (!con) {
error_setg(errp, "There is no console to take a screendump from");
- return;
}
}
+ return con;
+}
+
+void hmp_screendump_sync(const char *filename,
+ bool has_device, const char *device,
+ bool has_head, int64_t head, Error **errp)
+{
+ DisplaySurface *surface;
+ QemuConsole *con = get_console(has_device, device, has_head, head, errp);
+
+ if (!con) {
+ return;
+ }
+ /* This may not complete the drawing with Spice, you may have
+ * glitches or outdated dumps, use qmp instead! */
graphic_hw_update(con);
surface = qemu_console_surface(con);
if (!surface) {
@@ -390,6 +452,28 @@ void qmp_screendump(const char *filename, bool has_device,
const char *device,
ppm_save(filename, surface, errp);
}
+void qmp_screendump(const char *filename,
+ bool has_device, const char *device,
+ bool has_head, int64_t head,
+ QmpReturn *qret)
+{
+ Error *err = NULL;
+ struct qmp_screendump *dump = NULL;
+ QemuConsole *con = get_console(has_device, device, has_head, head, &err);
+
+ if (!con) {
+ qmp_return_error(qret, err);
+ return;
+ }
+
+ dump = g_new(struct qmp_screendump, 1);
+ dump->filename = g_strdup(filename);
+ dump->ret = qret;
+ QLIST_INSERT_HEAD(&con->qmp_screendumps, dump, link);
+
+ graphic_hw_update(con);
+}
+
void graphic_hw_text_update(QemuConsole *con, console_ch_t *chardata)
{
if (!con) {
@@ -1300,6 +1384,7 @@ static QemuConsole *new_console(DisplayState *ds,
console_type_t console_type,
obj = object_new(TYPE_QEMU_CONSOLE);
s = QEMU_CONSOLE(obj);
s->head = head;
+ QLIST_INIT(&s->qmp_screendumps);
object_property_add_link(obj, "device", TYPE_DEVICE,
(Object **)&s->device,
object_property_allow_set_link,
--
2.22.0.428.g6d5b264208
- [Qemu-devel] [PATCH v5 07/20] qga: simplify dispatch_return_cb, (continued)
- [Qemu-devel] [PATCH v5 07/20] qga: simplify dispatch_return_cb, Marc-André Lureau, 2019/07/15
- [Qemu-devel] [PATCH v5 08/20] QmpSession: introduce QmpReturn, Marc-André Lureau, 2019/07/15
- [Qemu-devel] [PATCH v5 09/20] qmp: simplify qmp_return_error(), Marc-André Lureau, 2019/07/15
- [Qemu-devel] [PATCH v5 10/20] QmpSession: keep a queue of pending commands, Marc-André Lureau, 2019/07/15
- [Qemu-devel] [PATCH v5 11/20] QmpSession: return orderly, Marc-André Lureau, 2019/07/15
- [Qemu-devel] [PATCH v5 12/20] qmp: introduce asynchronous command type, Marc-André Lureau, 2019/07/15
- [Qemu-devel] [PATCH v5 13/20] scripts: learn 'async' qapi commands, Marc-André Lureau, 2019/07/15
- [Qemu-devel] [PATCH v5 14/20] qmp: add qmp_return_is_cancelled(), Marc-André Lureau, 2019/07/15
- [Qemu-devel] [PATCH v5 15/20] monitor: add qmp_return_get_monitor(), Marc-André Lureau, 2019/07/15
- [Qemu-devel] [PATCH v5 16/20] console: add graphic_hw_update_done(), Marc-André Lureau, 2019/07/15
- [Qemu-devel] [PATCH v5 17/20] console: make screendump asynchronous,
Marc-André Lureau <=
- [Qemu-devel] [PATCH v5 18/20] monitor: start making qmp_human_monitor_command() asynchronous, Marc-André Lureau, 2019/07/15
- [Qemu-devel] [PATCH v5 19/20] monitor: teach HMP about asynchronous commands, Marc-André Lureau, 2019/07/15
- [Qemu-devel] [PATCH v5 20/20] hmp: call the asynchronous QMP screendump to fix outdated/glitches, Marc-André Lureau, 2019/07/15