1 #include "qemu/osdep.h"
2 #include "../libqtest.h"
5 #include "qapi/qmp/qdict.h"
7 /*** Test Setup & Teardown ***/
10 * Launch QEMU with the given command line,
11 * and then set up interrupts and our guest malloc interface.
13 * Terminates the application in case an error is encountered.
15 QOSState
*qtest_vboot(QOSOps
*ops
, const char *cmdline_fmt
, va_list ap
)
19 QOSState
*qs
= g_new0(QOSState
, 1);
21 cmdline
= g_strdup_vprintf(cmdline_fmt
, ap
);
22 qs
->qts
= qtest_init(cmdline
);
25 ops
->alloc_init(&qs
->alloc
, qs
->qts
, ALLOC_NO_FLAGS
);
26 qs
->pcibus
= ops
->qpci_new(qs
->qts
, &qs
->alloc
);
34 * Launch QEMU with the given command line,
35 * and then set up interrupts and our guest malloc interface.
37 QOSState
*qtest_boot(QOSOps
*ops
, const char *cmdline_fmt
, ...)
42 va_start(ap
, cmdline_fmt
);
43 qs
= qtest_vboot(ops
, cmdline_fmt
, ap
);
50 * Tear down the QEMU instance.
52 void qtest_common_shutdown(QOSState
*qs
)
55 if (qs
->pcibus
&& qs
->ops
->qpci_free
) {
56 qs
->ops
->qpci_free(qs
->pcibus
);
60 alloc_destroy(&qs
->alloc
);
65 void qtest_shutdown(QOSState
*qs
)
67 if (qs
->ops
&& qs
->ops
->shutdown
) {
68 qs
->ops
->shutdown(qs
);
70 qtest_common_shutdown(qs
);
74 static QDict
*qmp_execute(QTestState
*qts
, const char *command
)
76 return qtest_qmp(qts
, "{ 'execute': %s }", command
);
79 void migrate(QOSState
*from
, QOSState
*to
, const char *uri
)
85 /* Is the machine currently running? */
86 rsp
= qmp_execute(from
->qts
, "query-status");
87 g_assert(qdict_haskey(rsp
, "return"));
88 sub
= qdict_get_qdict(rsp
, "return");
89 g_assert(qdict_haskey(sub
, "running"));
90 running
= qdict_get_bool(sub
, "running");
93 /* Issue the migrate command. */
94 rsp
= qtest_qmp(from
->qts
,
95 "{ 'execute': 'migrate', 'arguments': { 'uri': %s }}",
97 g_assert(qdict_haskey(rsp
, "return"));
100 /* Wait for STOP event, but only if we were running: */
102 qtest_qmp_eventwait(from
->qts
, "STOP");
105 /* If we were running, we can wait for an event. */
107 migrate_allocator(&from
->alloc
, &to
->alloc
);
108 qtest_qmp_eventwait(to
->qts
, "RESUME");
112 /* Otherwise, we need to wait: poll until migration is completed. */
114 rsp
= qmp_execute(from
->qts
, "query-migrate");
115 g_assert(qdict_haskey(rsp
, "return"));
116 sub
= qdict_get_qdict(rsp
, "return");
117 g_assert(qdict_haskey(sub
, "status"));
118 st
= qdict_get_str(sub
, "status");
120 /* "setup", "active", "completed", "failed", "cancelled" */
121 if (strcmp(st
, "completed") == 0) {
126 if ((strcmp(st
, "setup") == 0) || (strcmp(st
, "active") == 0)
127 || (strcmp(st
, "wait-unplug") == 0)) {
133 fprintf(stderr
, "Migration did not complete, status: %s\n", st
);
134 g_assert_not_reached();
137 migrate_allocator(&from
->alloc
, &to
->alloc
);
140 bool have_qemu_img(void)
143 const char *path
= getenv("QTEST_QEMU_IMG");
148 rpath
= realpath(path
, NULL
);
157 void mkimg(const char *file
, const char *fmt
, unsigned size_mb
)
165 char *qemu_img_abs_path
;
167 qemu_img_path
= getenv("QTEST_QEMU_IMG");
168 g_assert(qemu_img_path
);
169 qemu_img_abs_path
= realpath(qemu_img_path
, NULL
);
170 g_assert(qemu_img_abs_path
);
172 cli
= g_strdup_printf("%s create -f %s %s %uM", qemu_img_abs_path
,
174 ret
= g_spawn_command_line_sync(cli
, &out
, &out2
, &rc
, &err
);
175 if (err
|| !g_spawn_check_exit_status(rc
, &err
)) {
176 fprintf(stderr
, "%s\n", err
->message
);
179 g_assert(ret
&& !err
);
184 free(qemu_img_abs_path
);
187 void mkqcow2(const char *file
, unsigned size_mb
)
189 return mkimg(file
, "qcow2", size_mb
);
192 void prepare_blkdebug_script(const char *debug_fn
, const char *event
)
194 FILE *debug_file
= fopen(debug_fn
, "w");
197 fprintf(debug_file
, "[inject-error]\n");
198 fprintf(debug_file
, "event = \"%s\"\n", event
);
199 fprintf(debug_file
, "errno = \"5\"\n");
200 fprintf(debug_file
, "state = \"1\"\n");
201 fprintf(debug_file
, "immediately = \"off\"\n");
202 fprintf(debug_file
, "once = \"on\"\n");
204 fprintf(debug_file
, "[set-state]\n");
205 fprintf(debug_file
, "event = \"%s\"\n", event
);
206 fprintf(debug_file
, "new_state = \"2\"\n");
208 g_assert(!ferror(debug_file
));
210 ret
= fclose(debug_file
);
214 void generate_pattern(void *buffer
, size_t len
, size_t cycle_len
)
217 unsigned char *tx
= (unsigned char *)buffer
;
221 /* Write an indicative pattern that varies and is unique per-cycle */
223 for (i
= 0; i
< len
; i
++) {
225 if (i
% cycle_len
== 0) {
230 /* force uniqueness by writing an id per-cycle */
231 for (i
= 0; i
< len
/ cycle_len
; i
++) {
233 if (j
+ sizeof(*sx
) <= len
) {
234 sx
= (size_t *)&tx
[j
];