libqtest: rename qmp() to qmp_discard_response()

Existing qmp() callers do not expect a response object.  In order to
implement real QMP test cases it will be necessary to inspect the
response object.

Rename qmp() to qmp_discard_response().  Later patches will introduce a
qmp() function that returns the response object and tests that use it.

Signed-off-by: Stefan Hajnoczi <stefanha@redhat.com>
Reviewed-by: Eric Blake <eblake@redhat.com>
Reviewed-by: Andreas Färber <afaerber@suse.de>
This commit is contained in:
Stefan Hajnoczi 2013-10-30 14:54:32 +01:00
parent ec9c10d29c
commit 0d1aa05e9e
5 changed files with 32 additions and 27 deletions

View File

@ -41,12 +41,12 @@ static void test_a_boot_order(const char *machine,
qtest_start(args); qtest_start(args);
actual = read_boot_order(); actual = read_boot_order();
g_assert_cmphex(actual, ==, expected_boot); g_assert_cmphex(actual, ==, expected_boot);
qmp("{ 'execute': 'system_reset' }"); qmp_discard_response("{ 'execute': 'system_reset' }");
/* /*
* system_reset only requests reset. We get a RESET event after * system_reset only requests reset. We get a RESET event after
* the actual reset completes. Need to wait for that. * the actual reset completes. Need to wait for that.
*/ */
qmp(""); /* HACK: wait for event */ qmp_discard_response(""); /* HACK: wait for event */
actual = read_boot_order(); actual = read_boot_order();
g_assert_cmphex(actual, ==, expected_reboot); g_assert_cmphex(actual, ==, expected_reboot);
qtest_quit(global_qtest); qtest_quit(global_qtest);

View File

@ -290,10 +290,12 @@ static void test_media_insert(void)
/* Insert media in drive. DSKCHK should not be reset until a step pulse /* Insert media in drive. DSKCHK should not be reset until a step pulse
* is sent. */ * is sent. */
qmp("{'execute':'change', 'arguments':{ 'device':'floppy0', " qmp_discard_response("{'execute':'change', 'arguments':{"
"'target': '%s' }}", test_image); " 'device':'floppy0', 'target': '%s' }}",
qmp(""); /* ignore event (FIXME open -> open transition?!) */ test_image);
qmp(""); /* ignore event */ qmp_discard_response(""); /* ignore event
(FIXME open -> open transition?!) */
qmp_discard_response(""); /* ignore event */
dir = inb(FLOPPY_BASE + reg_dir); dir = inb(FLOPPY_BASE + reg_dir);
assert_bit_set(dir, DSKCHG); assert_bit_set(dir, DSKCHG);
@ -322,8 +324,9 @@ static void test_media_change(void)
/* Eject the floppy and check that DSKCHG is set. Reading it out doesn't /* Eject the floppy and check that DSKCHG is set. Reading it out doesn't
* reset the bit. */ * reset the bit. */
qmp("{'execute':'eject', 'arguments':{ 'device':'floppy0' }}"); qmp_discard_response("{'execute':'eject', 'arguments':{"
qmp(""); /* ignore event */ " 'device':'floppy0' }}");
qmp_discard_response(""); /* ignore event */
dir = inb(FLOPPY_BASE + reg_dir); dir = inb(FLOPPY_BASE + reg_dir);
assert_bit_set(dir, DSKCHG); assert_bit_set(dir, DSKCHG);

View File

@ -460,8 +460,9 @@ static void test_flush(void)
tmp_path); tmp_path);
/* Delay the completion of the flush request until we explicitly do it */ /* Delay the completion of the flush request until we explicitly do it */
qmp("{'execute':'human-monitor-command', 'arguments': { " qmp_discard_response("{'execute':'human-monitor-command', 'arguments': {"
"'command-line': 'qemu-io ide0-hd0 \"break flush_to_os A\"'} }"); " 'command-line':"
" 'qemu-io ide0-hd0 \"break flush_to_os A\"'} }");
/* FLUSH CACHE command on device 0*/ /* FLUSH CACHE command on device 0*/
outb(IDE_BASE + reg_device, 0); outb(IDE_BASE + reg_device, 0);
@ -473,8 +474,9 @@ static void test_flush(void)
assert_bit_clear(data, DF | ERR | DRQ); assert_bit_clear(data, DF | ERR | DRQ);
/* Complete the command */ /* Complete the command */
qmp("{'execute':'human-monitor-command', 'arguments': { " qmp_discard_response("{'execute':'human-monitor-command', 'arguments': {"
"'command-line': 'qemu-io ide0-hd0 \"resume A\"'} }"); " 'command-line':"
" 'qemu-io ide0-hd0 \"resume A\"'} }");
/* Check registers */ /* Check registers */
data = inb(IDE_BASE + reg_device); data = inb(IDE_BASE + reg_device);

View File

@ -151,8 +151,8 @@ QTestState *qtest_init(const char *extra_args)
} }
/* Read the QMP greeting and then do the handshake */ /* Read the QMP greeting and then do the handshake */
qtest_qmp(s, ""); qtest_qmp_discard_response(s, "");
qtest_qmp(s, "{ 'execute': 'qmp_capabilities' }"); qtest_qmp_discard_response(s, "{ 'execute': 'qmp_capabilities' }");
if (getenv("QTEST_STOP")) { if (getenv("QTEST_STOP")) {
kill(qtest_qemu_pid(s), SIGSTOP); kill(qtest_qemu_pid(s), SIGSTOP);
@ -291,7 +291,7 @@ redo:
return words; return words;
} }
void qtest_qmpv(QTestState *s, const char *fmt, va_list ap) void qtest_qmpv_discard_response(QTestState *s, const char *fmt, va_list ap)
{ {
bool has_reply = false; bool has_reply = false;
int nesting = 0; int nesting = 0;
@ -326,12 +326,12 @@ void qtest_qmpv(QTestState *s, const char *fmt, va_list ap)
} }
} }
void qtest_qmp(QTestState *s, const char *fmt, ...) void qtest_qmp_discard_response(QTestState *s, const char *fmt, ...)
{ {
va_list ap; va_list ap;
va_start(ap, fmt); va_start(ap, fmt);
qtest_qmpv(s, fmt, ap); qtest_qmpv_discard_response(s, fmt, ap);
va_end(ap); va_end(ap);
} }

View File

@ -44,23 +44,23 @@ QTestState *qtest_init(const char *extra_args);
void qtest_quit(QTestState *s); void qtest_quit(QTestState *s);
/** /**
* qtest_qmp: * qtest_qmp_discard_response:
* @s: #QTestState instance to operate on. * @s: #QTestState instance to operate on.
* @fmt...: QMP message to send to qemu * @fmt...: QMP message to send to qemu
* *
* Sends a QMP message to QEMU * Sends a QMP message to QEMU and consumes the response.
*/ */
void qtest_qmp(QTestState *s, const char *fmt, ...); void qtest_qmp_discard_response(QTestState *s, const char *fmt, ...);
/** /**
* qtest_qmpv: * qtest_qmpv_discard_response:
* @s: #QTestState instance to operate on. * @s: #QTestState instance to operate on.
* @fmt: QMP message to send to QEMU * @fmt: QMP message to send to QEMU
* @ap: QMP message arguments * @ap: QMP message arguments
* *
* Sends a QMP message to QEMU. * Sends a QMP message to QEMU and consumes the response.
*/ */
void qtest_qmpv(QTestState *s, const char *fmt, va_list ap); void qtest_qmpv_discard_response(QTestState *s, const char *fmt, va_list ap);
/** /**
* qtest_get_irq: * qtest_get_irq:
@ -331,17 +331,17 @@ static inline void qtest_end(void)
} }
/** /**
* qmp: * qmp_discard_response:
* @fmt...: QMP message to send to qemu * @fmt...: QMP message to send to qemu
* *
* Sends a QMP message to QEMU * Sends a QMP message to QEMU and consumes the response.
*/ */
static inline void qmp(const char *fmt, ...) static inline void qmp_discard_response(const char *fmt, ...)
{ {
va_list ap; va_list ap;
va_start(ap, fmt); va_start(ap, fmt);
qtest_qmpv(global_qtest, fmt, ap); qtest_qmpv_discard_response(global_qtest, fmt, ap);
va_end(ap); va_end(ap);
} }