]>
Commit | Line | Data |
---|---|---|
c40cc0a0 MR |
1 | /* |
2 | * Input Visitor | |
3 | * | |
08f9541d | 4 | * Copyright (C) 2012-2016 Red Hat, Inc. |
c40cc0a0 MR |
5 | * Copyright IBM, Corp. 2011 |
6 | * | |
7 | * Authors: | |
8 | * Anthony Liguori <[email protected]> | |
9 | * | |
10 | * This work is licensed under the terms of the GNU LGPL, version 2.1 or later. | |
11 | * See the COPYING.LIB file in the top-level directory. | |
12 | * | |
13 | */ | |
14 | ||
cbf21151 | 15 | #include "qemu/osdep.h" |
da34e65c | 16 | #include "qapi/error.h" |
b3db211f | 17 | #include "qapi/qobject-input-visitor.h" |
7b1b5d19 | 18 | #include "qapi/visitor-impl.h" |
1de7afc9 | 19 | #include "qemu/queue.h" |
c40cc0a0 | 20 | #include "qemu-common.h" |
7b1b5d19 PB |
21 | #include "qapi/qmp/types.h" |
22 | #include "qapi/qmp/qerror.h" | |
c40cc0a0 MR |
23 | |
24 | #define QIV_STACK_SIZE 1024 | |
25 | ||
26 | typedef struct StackObject | |
27 | { | |
b471d012 | 28 | QObject *obj; /* Object being visited */ |
1158bb2a | 29 | void *qapi; /* sanity check that caller uses same pointer */ |
b471d012 EB |
30 | |
31 | GHashTable *h; /* If obj is dict: unvisited keys */ | |
32 | const QListEntry *entry; /* If obj is list: unvisited tail */ | |
3d344c2a PB |
33 | |
34 | QSLIST_ENTRY(StackObject) node; | |
c40cc0a0 MR |
35 | } StackObject; |
36 | ||
09e68369 | 37 | struct QObjectInputVisitor |
c40cc0a0 MR |
38 | { |
39 | Visitor visitor; | |
b471d012 | 40 | |
ce140b17 EB |
41 | /* Root of visit at visitor creation. */ |
42 | QObject *root; | |
43 | ||
44 | /* Stack of objects being visited (all entries will be either | |
45 | * QDict or QList). */ | |
3d344c2a | 46 | QSLIST_HEAD(, StackObject) stack; |
b471d012 EB |
47 | |
48 | /* True to reject parse in visit_end_struct() if unvisited keys remain. */ | |
e38ac962 | 49 | bool strict; |
c40cc0a0 MR |
50 | }; |
51 | ||
09e68369 | 52 | static QObjectInputVisitor *to_qiv(Visitor *v) |
c40cc0a0 | 53 | { |
09e68369 | 54 | return container_of(v, QObjectInputVisitor, visitor); |
c40cc0a0 MR |
55 | } |
56 | ||
09e68369 DB |
57 | static QObject *qobject_input_get_object(QObjectInputVisitor *qiv, |
58 | const char *name, | |
59 | bool consume, Error **errp) | |
c40cc0a0 | 60 | { |
ce140b17 EB |
61 | StackObject *tos; |
62 | QObject *qobj; | |
e5826a2f | 63 | QObject *ret; |
b471d012 | 64 | |
3d344c2a | 65 | if (QSLIST_EMPTY(&qiv->stack)) { |
ce140b17 | 66 | /* Starting at root, name is ignored. */ |
5d0cbbcf | 67 | assert(qiv->root); |
ce140b17 EB |
68 | return qiv->root; |
69 | } | |
70 | ||
71 | /* We are in a container; find the next element. */ | |
3d344c2a | 72 | tos = QSLIST_FIRST(&qiv->stack); |
ce140b17 | 73 | qobj = tos->obj; |
b471d012 EB |
74 | assert(qobj); |
75 | ||
ce140b17 EB |
76 | if (qobject_type(qobj) == QTYPE_QDICT) { |
77 | assert(name); | |
e5826a2f EB |
78 | ret = qdict_get(qobject_to_qdict(qobj), name); |
79 | if (tos->h && consume && ret) { | |
80 | bool removed = g_hash_table_remove(tos->h, name); | |
81 | assert(removed); | |
47c6d3ec | 82 | } |
1382d4ab MAL |
83 | if (!ret) { |
84 | error_setg(errp, QERR_MISSING_PARAMETER, name); | |
85 | } | |
ce140b17 | 86 | } else { |
b471d012 | 87 | assert(qobject_type(qobj) == QTYPE_QLIST); |
ce140b17 EB |
88 | assert(!name); |
89 | ret = qlist_entry_obj(tos->entry); | |
eac8e79f | 90 | assert(ret); |
fcf3cb21 EB |
91 | if (consume) { |
92 | tos->entry = qlist_next(tos->entry); | |
93 | } | |
c40cc0a0 MR |
94 | } |
95 | ||
ce140b17 | 96 | return ret; |
c40cc0a0 MR |
97 | } |
98 | ||
e38ac962 PB |
99 | static void qdict_add_key(const char *key, QObject *obj, void *opaque) |
100 | { | |
101 | GHashTable *h = opaque; | |
102 | g_hash_table_insert(h, (gpointer) key, NULL); | |
103 | } | |
104 | ||
09e68369 DB |
105 | static const QListEntry *qobject_input_push(QObjectInputVisitor *qiv, |
106 | QObject *obj, void *qapi, | |
107 | Error **errp) | |
c40cc0a0 | 108 | { |
e38ac962 | 109 | GHashTable *h; |
3d344c2a | 110 | StackObject *tos = g_new0(StackObject, 1); |
c40cc0a0 | 111 | |
b471d012 | 112 | assert(obj); |
b471d012 | 113 | tos->obj = obj; |
1158bb2a | 114 | tos->qapi = qapi; |
e38ac962 PB |
115 | |
116 | if (qiv->strict && qobject_type(obj) == QTYPE_QDICT) { | |
117 | h = g_hash_table_new(g_str_hash, g_str_equal); | |
118 | qdict_iter(qobject_to_qdict(obj), qdict_add_key, h); | |
b471d012 | 119 | tos->h = h; |
fcf3cb21 EB |
120 | } else if (qobject_type(obj) == QTYPE_QLIST) { |
121 | tos->entry = qlist_first(qobject_to_qlist(obj)); | |
e38ac962 PB |
122 | } |
123 | ||
3d344c2a | 124 | QSLIST_INSERT_HEAD(&qiv->stack, tos, node); |
d9f62dde | 125 | return tos->entry; |
c40cc0a0 MR |
126 | } |
127 | ||
57a33d89 | 128 | |
09e68369 | 129 | static void qobject_input_check_struct(Visitor *v, Error **errp) |
c40cc0a0 | 130 | { |
09e68369 | 131 | QObjectInputVisitor *qiv = to_qiv(v); |
3d344c2a | 132 | StackObject *tos = QSLIST_FIRST(&qiv->stack); |
e38ac962 | 133 | |
3d344c2a | 134 | assert(tos && !tos->entry); |
57a33d89 | 135 | if (qiv->strict) { |
fcf3cb21 | 136 | GHashTable *const top_ht = tos->h; |
57a33d89 | 137 | if (top_ht) { |
f96493b1 EB |
138 | GHashTableIter iter; |
139 | const char *key; | |
140 | ||
141 | g_hash_table_iter_init(&iter, top_ht); | |
142 | if (g_hash_table_iter_next(&iter, (void **)&key, NULL)) { | |
910f738b | 143 | error_setg(errp, "Parameter '%s' is unexpected", key); |
57a33d89 | 144 | } |
15c2f669 EB |
145 | } |
146 | } | |
147 | } | |
148 | ||
09e68369 | 149 | static void qobject_input_stack_object_free(StackObject *tos) |
15c2f669 | 150 | { |
3d344c2a PB |
151 | if (tos->h) { |
152 | g_hash_table_unref(tos->h); | |
153 | } | |
15c2f669 | 154 | |
3d344c2a PB |
155 | g_free(tos); |
156 | } | |
15c2f669 | 157 | |
09e68369 | 158 | static void qobject_input_pop(Visitor *v, void **obj) |
3d344c2a | 159 | { |
09e68369 | 160 | QObjectInputVisitor *qiv = to_qiv(v); |
3d344c2a | 161 | StackObject *tos = QSLIST_FIRST(&qiv->stack); |
e38ac962 | 162 | |
3d344c2a PB |
163 | assert(tos && tos->qapi == obj); |
164 | QSLIST_REMOVE_HEAD(&qiv->stack, node); | |
09e68369 | 165 | qobject_input_stack_object_free(tos); |
c40cc0a0 MR |
166 | } |
167 | ||
09e68369 DB |
168 | static void qobject_input_start_struct(Visitor *v, const char *name, void **obj, |
169 | size_t size, Error **errp) | |
c40cc0a0 | 170 | { |
09e68369 DB |
171 | QObjectInputVisitor *qiv = to_qiv(v); |
172 | QObject *qobj = qobject_input_get_object(qiv, name, true, errp); | |
8b714d37 | 173 | Error *err = NULL; |
c40cc0a0 | 174 | |
e58d695e EB |
175 | if (obj) { |
176 | *obj = NULL; | |
177 | } | |
1382d4ab MAL |
178 | if (!qobj) { |
179 | return; | |
180 | } | |
181 | if (qobject_type(qobj) != QTYPE_QDICT) { | |
c6bd8c70 MA |
182 | error_setg(errp, QERR_INVALID_PARAMETER_TYPE, name ? name : "null", |
183 | "QDict"); | |
c40cc0a0 MR |
184 | return; |
185 | } | |
186 | ||
09e68369 | 187 | qobject_input_push(qiv, qobj, obj, &err); |
8b714d37 PB |
188 | if (err) { |
189 | error_propagate(errp, err); | |
c40cc0a0 MR |
190 | return; |
191 | } | |
192 | ||
193 | if (obj) { | |
7267c094 | 194 | *obj = g_malloc0(size); |
c40cc0a0 MR |
195 | } |
196 | } | |
197 | ||
c40cc0a0 | 198 | |
09e68369 DB |
199 | static void qobject_input_start_list(Visitor *v, const char *name, |
200 | GenericList **list, size_t size, | |
201 | Error **errp) | |
c40cc0a0 | 202 | { |
09e68369 DB |
203 | QObjectInputVisitor *qiv = to_qiv(v); |
204 | QObject *qobj = qobject_input_get_object(qiv, name, true, errp); | |
d9f62dde | 205 | const QListEntry *entry; |
c40cc0a0 | 206 | |
1382d4ab MAL |
207 | if (!qobj) { |
208 | return; | |
209 | } | |
210 | if (qobject_type(qobj) != QTYPE_QLIST) { | |
d9f62dde EB |
211 | if (list) { |
212 | *list = NULL; | |
213 | } | |
c6bd8c70 MA |
214 | error_setg(errp, QERR_INVALID_PARAMETER_TYPE, name ? name : "null", |
215 | "list"); | |
c40cc0a0 MR |
216 | return; |
217 | } | |
218 | ||
09e68369 | 219 | entry = qobject_input_push(qiv, qobj, list, errp); |
d9f62dde EB |
220 | if (list) { |
221 | if (entry) { | |
222 | *list = g_malloc0(size); | |
223 | } else { | |
224 | *list = NULL; | |
225 | } | |
226 | } | |
c40cc0a0 MR |
227 | } |
228 | ||
09e68369 DB |
229 | static GenericList *qobject_input_next_list(Visitor *v, GenericList *tail, |
230 | size_t size) | |
c40cc0a0 | 231 | { |
09e68369 | 232 | QObjectInputVisitor *qiv = to_qiv(v); |
3d344c2a | 233 | StackObject *so = QSLIST_FIRST(&qiv->stack); |
c40cc0a0 | 234 | |
fcf3cb21 | 235 | if (!so->entry) { |
c40cc0a0 MR |
236 | return NULL; |
237 | } | |
d9f62dde EB |
238 | tail->next = g_malloc0(size); |
239 | return tail->next; | |
c40cc0a0 MR |
240 | } |
241 | ||
c40cc0a0 | 242 | |
09e68369 DB |
243 | static void qobject_input_start_alternate(Visitor *v, const char *name, |
244 | GenericAlternate **obj, size_t size, | |
245 | bool promote_int, Error **errp) | |
69dd62df | 246 | { |
09e68369 DB |
247 | QObjectInputVisitor *qiv = to_qiv(v); |
248 | QObject *qobj = qobject_input_get_object(qiv, name, false, errp); | |
69dd62df KW |
249 | |
250 | if (!qobj) { | |
dbf11922 | 251 | *obj = NULL; |
69dd62df KW |
252 | return; |
253 | } | |
dbf11922 EB |
254 | *obj = g_malloc0(size); |
255 | (*obj)->type = qobject_type(qobj); | |
256 | if (promote_int && (*obj)->type == QTYPE_QINT) { | |
257 | (*obj)->type = QTYPE_QFLOAT; | |
d00341af | 258 | } |
69dd62df KW |
259 | } |
260 | ||
09e68369 DB |
261 | static void qobject_input_type_int64(Visitor *v, const char *name, int64_t *obj, |
262 | Error **errp) | |
c40cc0a0 | 263 | { |
09e68369 DB |
264 | QObjectInputVisitor *qiv = to_qiv(v); |
265 | QObject *qobj = qobject_input_get_object(qiv, name, true, errp); | |
1382d4ab | 266 | QInt *qint; |
c40cc0a0 | 267 | |
1382d4ab MAL |
268 | if (!qobj) { |
269 | return; | |
270 | } | |
271 | qint = qobject_to_qint(qobj); | |
fcf73f66 | 272 | if (!qint) { |
c6bd8c70 MA |
273 | error_setg(errp, QERR_INVALID_PARAMETER_TYPE, name ? name : "null", |
274 | "integer"); | |
c40cc0a0 MR |
275 | return; |
276 | } | |
277 | ||
fcf73f66 | 278 | *obj = qint_get_int(qint); |
c40cc0a0 MR |
279 | } |
280 | ||
09e68369 DB |
281 | static void qobject_input_type_uint64(Visitor *v, const char *name, |
282 | uint64_t *obj, Error **errp) | |
f755dea7 EB |
283 | { |
284 | /* FIXME: qobject_to_qint mishandles values over INT64_MAX */ | |
09e68369 DB |
285 | QObjectInputVisitor *qiv = to_qiv(v); |
286 | QObject *qobj = qobject_input_get_object(qiv, name, true, errp); | |
1382d4ab | 287 | QInt *qint; |
f755dea7 | 288 | |
1382d4ab MAL |
289 | if (!qobj) { |
290 | return; | |
291 | } | |
292 | qint = qobject_to_qint(qobj); | |
f755dea7 EB |
293 | if (!qint) { |
294 | error_setg(errp, QERR_INVALID_PARAMETER_TYPE, name ? name : "null", | |
295 | "integer"); | |
296 | return; | |
297 | } | |
298 | ||
299 | *obj = qint_get_int(qint); | |
300 | } | |
301 | ||
09e68369 DB |
302 | static void qobject_input_type_bool(Visitor *v, const char *name, bool *obj, |
303 | Error **errp) | |
c40cc0a0 | 304 | { |
09e68369 DB |
305 | QObjectInputVisitor *qiv = to_qiv(v); |
306 | QObject *qobj = qobject_input_get_object(qiv, name, true, errp); | |
1382d4ab | 307 | QBool *qbool; |
c40cc0a0 | 308 | |
1382d4ab MAL |
309 | if (!qobj) { |
310 | return; | |
311 | } | |
312 | qbool = qobject_to_qbool(qobj); | |
14b61600 | 313 | if (!qbool) { |
c6bd8c70 MA |
314 | error_setg(errp, QERR_INVALID_PARAMETER_TYPE, name ? name : "null", |
315 | "boolean"); | |
c40cc0a0 MR |
316 | return; |
317 | } | |
318 | ||
14b61600 | 319 | *obj = qbool_get_bool(qbool); |
c40cc0a0 MR |
320 | } |
321 | ||
09e68369 DB |
322 | static void qobject_input_type_str(Visitor *v, const char *name, char **obj, |
323 | Error **errp) | |
c40cc0a0 | 324 | { |
09e68369 DB |
325 | QObjectInputVisitor *qiv = to_qiv(v); |
326 | QObject *qobj = qobject_input_get_object(qiv, name, true, errp); | |
1382d4ab | 327 | QString *qstr; |
c40cc0a0 | 328 | |
1382d4ab MAL |
329 | *obj = NULL; |
330 | if (!qobj) { | |
331 | return; | |
332 | } | |
333 | qstr = qobject_to_qstring(qobj); | |
7f027843 | 334 | if (!qstr) { |
c6bd8c70 MA |
335 | error_setg(errp, QERR_INVALID_PARAMETER_TYPE, name ? name : "null", |
336 | "string"); | |
c40cc0a0 MR |
337 | return; |
338 | } | |
339 | ||
7f027843 | 340 | *obj = g_strdup(qstring_get_str(qstr)); |
c40cc0a0 MR |
341 | } |
342 | ||
09e68369 DB |
343 | static void qobject_input_type_number(Visitor *v, const char *name, double *obj, |
344 | Error **errp) | |
c40cc0a0 | 345 | { |
09e68369 DB |
346 | QObjectInputVisitor *qiv = to_qiv(v); |
347 | QObject *qobj = qobject_input_get_object(qiv, name, true, errp); | |
fcf73f66 MA |
348 | QInt *qint; |
349 | QFloat *qfloat; | |
c40cc0a0 | 350 | |
1382d4ab MAL |
351 | if (!qobj) { |
352 | return; | |
353 | } | |
fcf73f66 MA |
354 | qint = qobject_to_qint(qobj); |
355 | if (qint) { | |
356 | *obj = qint_get_int(qobject_to_qint(qobj)); | |
c40cc0a0 MR |
357 | return; |
358 | } | |
359 | ||
fcf73f66 MA |
360 | qfloat = qobject_to_qfloat(qobj); |
361 | if (qfloat) { | |
1ee51876 | 362 | *obj = qfloat_get_double(qobject_to_qfloat(qobj)); |
fcf73f66 | 363 | return; |
1ee51876 | 364 | } |
fcf73f66 MA |
365 | |
366 | error_setg(errp, QERR_INVALID_PARAMETER_TYPE, name ? name : "null", | |
367 | "number"); | |
c40cc0a0 MR |
368 | } |
369 | ||
09e68369 DB |
370 | static void qobject_input_type_any(Visitor *v, const char *name, QObject **obj, |
371 | Error **errp) | |
28770e05 | 372 | { |
09e68369 DB |
373 | QObjectInputVisitor *qiv = to_qiv(v); |
374 | QObject *qobj = qobject_input_get_object(qiv, name, true, errp); | |
28770e05 | 375 | |
1382d4ab | 376 | *obj = NULL; |
c4897802 | 377 | if (!qobj) { |
c4897802 MAL |
378 | return; |
379 | } | |
380 | ||
28770e05 MA |
381 | qobject_incref(qobj); |
382 | *obj = qobj; | |
383 | } | |
384 | ||
09e68369 | 385 | static void qobject_input_type_null(Visitor *v, const char *name, Error **errp) |
3bc97fd5 | 386 | { |
09e68369 DB |
387 | QObjectInputVisitor *qiv = to_qiv(v); |
388 | QObject *qobj = qobject_input_get_object(qiv, name, true, errp); | |
3df016f1 | 389 | |
c4897802 | 390 | if (!qobj) { |
c4897802 MAL |
391 | return; |
392 | } | |
393 | ||
3df016f1 EB |
394 | if (qobject_type(qobj) != QTYPE_QNULL) { |
395 | error_setg(errp, QERR_INVALID_PARAMETER_TYPE, name ? name : "null", | |
396 | "null"); | |
397 | } | |
3bc97fd5 EB |
398 | } |
399 | ||
09e68369 | 400 | static void qobject_input_optional(Visitor *v, const char *name, bool *present) |
c40cc0a0 | 401 | { |
09e68369 DB |
402 | QObjectInputVisitor *qiv = to_qiv(v); |
403 | QObject *qobj = qobject_input_get_object(qiv, name, false, NULL); | |
c40cc0a0 MR |
404 | |
405 | if (!qobj) { | |
406 | *present = false; | |
407 | return; | |
408 | } | |
409 | ||
410 | *present = true; | |
411 | } | |
412 | ||
09e68369 | 413 | static void qobject_input_free(Visitor *v) |
2c0ef9f4 | 414 | { |
09e68369 | 415 | QObjectInputVisitor *qiv = to_qiv(v); |
3d344c2a PB |
416 | while (!QSLIST_EMPTY(&qiv->stack)) { |
417 | StackObject *tos = QSLIST_FIRST(&qiv->stack); | |
418 | ||
419 | QSLIST_REMOVE_HEAD(&qiv->stack, node); | |
09e68369 | 420 | qobject_input_stack_object_free(tos); |
3d344c2a | 421 | } |
2c0ef9f4 | 422 | |
b70ce101 EB |
423 | qobject_decref(qiv->root); |
424 | g_free(qiv); | |
2c0ef9f4 EB |
425 | } |
426 | ||
09e68369 | 427 | Visitor *qobject_input_visitor_new(QObject *obj, bool strict) |
c40cc0a0 | 428 | { |
09e68369 | 429 | QObjectInputVisitor *v; |
c40cc0a0 | 430 | |
5d0cbbcf | 431 | assert(obj); |
7267c094 | 432 | v = g_malloc0(sizeof(*v)); |
c40cc0a0 | 433 | |
983f52d4 | 434 | v->visitor.type = VISITOR_INPUT; |
09e68369 DB |
435 | v->visitor.start_struct = qobject_input_start_struct; |
436 | v->visitor.check_struct = qobject_input_check_struct; | |
437 | v->visitor.end_struct = qobject_input_pop; | |
438 | v->visitor.start_list = qobject_input_start_list; | |
439 | v->visitor.next_list = qobject_input_next_list; | |
440 | v->visitor.end_list = qobject_input_pop; | |
441 | v->visitor.start_alternate = qobject_input_start_alternate; | |
442 | v->visitor.type_int64 = qobject_input_type_int64; | |
443 | v->visitor.type_uint64 = qobject_input_type_uint64; | |
444 | v->visitor.type_bool = qobject_input_type_bool; | |
445 | v->visitor.type_str = qobject_input_type_str; | |
446 | v->visitor.type_number = qobject_input_type_number; | |
447 | v->visitor.type_any = qobject_input_type_any; | |
448 | v->visitor.type_null = qobject_input_type_null; | |
449 | v->visitor.optional = qobject_input_optional; | |
450 | v->visitor.free = qobject_input_free; | |
fc471c18 | 451 | v->strict = strict; |
c40cc0a0 | 452 | |
ce140b17 | 453 | v->root = obj; |
4faaec6a | 454 | qobject_incref(obj); |
c40cc0a0 | 455 | |
b70ce101 | 456 | return &v->visitor; |
c40cc0a0 | 457 | } |