]>
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 <aliguori@us.ibm.com> | |
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" |
7b1b5d19 PB |
17 | #include "qapi/qmp-input-visitor.h" |
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 | { | |
4faaec6a PB |
28 | QObject *obj; |
29 | const QListEntry *entry; | |
e38ac962 | 30 | GHashTable *h; |
c40cc0a0 MR |
31 | } StackObject; |
32 | ||
33 | struct QmpInputVisitor | |
34 | { | |
35 | Visitor visitor; | |
c40cc0a0 MR |
36 | StackObject stack[QIV_STACK_SIZE]; |
37 | int nb_stack; | |
e38ac962 | 38 | bool strict; |
c40cc0a0 MR |
39 | }; |
40 | ||
41 | static QmpInputVisitor *to_qiv(Visitor *v) | |
42 | { | |
43 | return container_of(v, QmpInputVisitor, visitor); | |
44 | } | |
45 | ||
4faaec6a | 46 | static QObject *qmp_input_get_object(QmpInputVisitor *qiv, |
e8316d7e KW |
47 | const char *name, |
48 | bool consume) | |
c40cc0a0 | 49 | { |
4faaec6a | 50 | QObject *qobj = qiv->stack[qiv->nb_stack - 1].obj; |
c40cc0a0 | 51 | |
47c6d3ec PB |
52 | if (qobj) { |
53 | if (name && qobject_type(qobj) == QTYPE_QDICT) { | |
e8316d7e | 54 | if (qiv->stack[qiv->nb_stack - 1].h && consume) { |
e38ac962 PB |
55 | g_hash_table_remove(qiv->stack[qiv->nb_stack - 1].h, name); |
56 | } | |
47c6d3ec | 57 | return qdict_get(qobject_to_qdict(qobj), name); |
4faaec6a | 58 | } else if (qiv->stack[qiv->nb_stack - 1].entry) { |
47c6d3ec PB |
59 | return qlist_entry_obj(qiv->stack[qiv->nb_stack - 1].entry); |
60 | } | |
c40cc0a0 MR |
61 | } |
62 | ||
63 | return qobj; | |
64 | } | |
65 | ||
e38ac962 PB |
66 | static void qdict_add_key(const char *key, QObject *obj, void *opaque) |
67 | { | |
68 | GHashTable *h = opaque; | |
69 | g_hash_table_insert(h, (gpointer) key, NULL); | |
70 | } | |
71 | ||
4faaec6a | 72 | static void qmp_input_push(QmpInputVisitor *qiv, QObject *obj, Error **errp) |
c40cc0a0 | 73 | { |
e38ac962 | 74 | GHashTable *h; |
c40cc0a0 MR |
75 | |
76 | if (qiv->nb_stack >= QIV_STACK_SIZE) { | |
f231b88d | 77 | error_setg(errp, "An internal buffer overran"); |
c40cc0a0 MR |
78 | return; |
79 | } | |
e38ac962 PB |
80 | |
81 | qiv->stack[qiv->nb_stack].obj = obj; | |
82 | qiv->stack[qiv->nb_stack].entry = NULL; | |
83 | qiv->stack[qiv->nb_stack].h = NULL; | |
84 | ||
85 | if (qiv->strict && qobject_type(obj) == QTYPE_QDICT) { | |
86 | h = g_hash_table_new(g_str_hash, g_str_equal); | |
87 | qdict_iter(qobject_to_qdict(obj), qdict_add_key, h); | |
88 | qiv->stack[qiv->nb_stack].h = h; | |
89 | } | |
90 | ||
91 | qiv->nb_stack++; | |
c40cc0a0 MR |
92 | } |
93 | ||
57a33d89 | 94 | |
c40cc0a0 MR |
95 | static void qmp_input_pop(QmpInputVisitor *qiv, Error **errp) |
96 | { | |
57a33d89 | 97 | assert(qiv->nb_stack > 0); |
e38ac962 | 98 | |
57a33d89 NK |
99 | if (qiv->strict) { |
100 | GHashTable * const top_ht = qiv->stack[qiv->nb_stack - 1].h; | |
101 | if (top_ht) { | |
f96493b1 EB |
102 | GHashTableIter iter; |
103 | const char *key; | |
104 | ||
105 | g_hash_table_iter_init(&iter, top_ht); | |
106 | if (g_hash_table_iter_next(&iter, (void **)&key, NULL)) { | |
c6bd8c70 | 107 | error_setg(errp, QERR_QMP_EXTRA_MEMBER, key); |
57a33d89 NK |
108 | } |
109 | g_hash_table_unref(top_ht); | |
e38ac962 | 110 | } |
e38ac962 PB |
111 | } |
112 | ||
c40cc0a0 | 113 | qiv->nb_stack--; |
c40cc0a0 MR |
114 | } |
115 | ||
0b2a0d6b | 116 | static void qmp_input_start_struct(Visitor *v, const char *name, void **obj, |
337283df | 117 | size_t size, Error **errp) |
c40cc0a0 MR |
118 | { |
119 | QmpInputVisitor *qiv = to_qiv(v); | |
e8316d7e | 120 | QObject *qobj = qmp_input_get_object(qiv, name, true); |
8b714d37 | 121 | Error *err = NULL; |
c40cc0a0 MR |
122 | |
123 | if (!qobj || qobject_type(qobj) != QTYPE_QDICT) { | |
c6bd8c70 MA |
124 | error_setg(errp, QERR_INVALID_PARAMETER_TYPE, name ? name : "null", |
125 | "QDict"); | |
c40cc0a0 MR |
126 | return; |
127 | } | |
128 | ||
8b714d37 PB |
129 | qmp_input_push(qiv, qobj, &err); |
130 | if (err) { | |
131 | error_propagate(errp, err); | |
c40cc0a0 MR |
132 | return; |
133 | } | |
134 | ||
135 | if (obj) { | |
7267c094 | 136 | *obj = g_malloc0(size); |
c40cc0a0 MR |
137 | } |
138 | } | |
139 | ||
140 | static void qmp_input_end_struct(Visitor *v, Error **errp) | |
141 | { | |
142 | QmpInputVisitor *qiv = to_qiv(v); | |
143 | ||
144 | qmp_input_pop(qiv, errp); | |
145 | } | |
146 | ||
147 | static void qmp_input_start_list(Visitor *v, const char *name, Error **errp) | |
148 | { | |
149 | QmpInputVisitor *qiv = to_qiv(v); | |
e8316d7e | 150 | QObject *qobj = qmp_input_get_object(qiv, name, true); |
c40cc0a0 MR |
151 | |
152 | if (!qobj || qobject_type(qobj) != QTYPE_QLIST) { | |
c6bd8c70 MA |
153 | error_setg(errp, QERR_INVALID_PARAMETER_TYPE, name ? name : "null", |
154 | "list"); | |
c40cc0a0 MR |
155 | return; |
156 | } | |
157 | ||
158 | qmp_input_push(qiv, qobj, errp); | |
159 | } | |
160 | ||
e65d89bf EB |
161 | static GenericList *qmp_input_next_list(Visitor *v, GenericList **list, |
162 | size_t size) | |
c40cc0a0 MR |
163 | { |
164 | QmpInputVisitor *qiv = to_qiv(v); | |
165 | GenericList *entry; | |
166 | StackObject *so = &qiv->stack[qiv->nb_stack - 1]; | |
3a86a0fa PB |
167 | bool first; |
168 | ||
169 | if (so->entry == NULL) { | |
170 | so->entry = qlist_first(qobject_to_qlist(so->obj)); | |
171 | first = true; | |
172 | } else { | |
173 | so->entry = qlist_next(so->entry); | |
174 | first = false; | |
175 | } | |
c40cc0a0 MR |
176 | |
177 | if (so->entry == NULL) { | |
178 | return NULL; | |
179 | } | |
180 | ||
e65d89bf | 181 | entry = g_malloc0(size); |
3a86a0fa PB |
182 | if (first) { |
183 | *list = entry; | |
184 | } else { | |
c40cc0a0 MR |
185 | (*list)->next = entry; |
186 | } | |
c40cc0a0 MR |
187 | |
188 | return entry; | |
189 | } | |
190 | ||
08f9541d | 191 | static void qmp_input_end_list(Visitor *v) |
c40cc0a0 MR |
192 | { |
193 | QmpInputVisitor *qiv = to_qiv(v); | |
194 | ||
bdd8e6b5 | 195 | qmp_input_pop(qiv, &error_abort); |
c40cc0a0 MR |
196 | } |
197 | ||
dbf11922 EB |
198 | static void qmp_input_start_alternate(Visitor *v, const char *name, |
199 | GenericAlternate **obj, size_t size, | |
200 | bool promote_int, Error **errp) | |
69dd62df KW |
201 | { |
202 | QmpInputVisitor *qiv = to_qiv(v); | |
203 | QObject *qobj = qmp_input_get_object(qiv, name, false); | |
204 | ||
205 | if (!qobj) { | |
dbf11922 | 206 | *obj = NULL; |
c6bd8c70 | 207 | error_setg(errp, QERR_MISSING_PARAMETER, name ? name : "null"); |
69dd62df KW |
208 | return; |
209 | } | |
dbf11922 EB |
210 | *obj = g_malloc0(size); |
211 | (*obj)->type = qobject_type(qobj); | |
212 | if (promote_int && (*obj)->type == QTYPE_QINT) { | |
213 | (*obj)->type = QTYPE_QFLOAT; | |
d00341af | 214 | } |
69dd62df KW |
215 | } |
216 | ||
0b2a0d6b | 217 | static void qmp_input_type_int64(Visitor *v, const char *name, int64_t *obj, |
4c40314a | 218 | Error **errp) |
c40cc0a0 MR |
219 | { |
220 | QmpInputVisitor *qiv = to_qiv(v); | |
fcf73f66 | 221 | QInt *qint = qobject_to_qint(qmp_input_get_object(qiv, name, true)); |
c40cc0a0 | 222 | |
fcf73f66 | 223 | if (!qint) { |
c6bd8c70 MA |
224 | error_setg(errp, QERR_INVALID_PARAMETER_TYPE, name ? name : "null", |
225 | "integer"); | |
c40cc0a0 MR |
226 | return; |
227 | } | |
228 | ||
fcf73f66 | 229 | *obj = qint_get_int(qint); |
c40cc0a0 MR |
230 | } |
231 | ||
0b2a0d6b | 232 | static void qmp_input_type_uint64(Visitor *v, const char *name, uint64_t *obj, |
f755dea7 EB |
233 | Error **errp) |
234 | { | |
235 | /* FIXME: qobject_to_qint mishandles values over INT64_MAX */ | |
236 | QmpInputVisitor *qiv = to_qiv(v); | |
237 | QInt *qint = qobject_to_qint(qmp_input_get_object(qiv, name, true)); | |
238 | ||
239 | if (!qint) { | |
240 | error_setg(errp, QERR_INVALID_PARAMETER_TYPE, name ? name : "null", | |
241 | "integer"); | |
242 | return; | |
243 | } | |
244 | ||
245 | *obj = qint_get_int(qint); | |
246 | } | |
247 | ||
0b2a0d6b | 248 | static void qmp_input_type_bool(Visitor *v, const char *name, bool *obj, |
c40cc0a0 MR |
249 | Error **errp) |
250 | { | |
251 | QmpInputVisitor *qiv = to_qiv(v); | |
14b61600 | 252 | QBool *qbool = qobject_to_qbool(qmp_input_get_object(qiv, name, true)); |
c40cc0a0 | 253 | |
14b61600 | 254 | if (!qbool) { |
c6bd8c70 MA |
255 | error_setg(errp, QERR_INVALID_PARAMETER_TYPE, name ? name : "null", |
256 | "boolean"); | |
c40cc0a0 MR |
257 | return; |
258 | } | |
259 | ||
14b61600 | 260 | *obj = qbool_get_bool(qbool); |
c40cc0a0 MR |
261 | } |
262 | ||
0b2a0d6b | 263 | static void qmp_input_type_str(Visitor *v, const char *name, char **obj, |
c40cc0a0 MR |
264 | Error **errp) |
265 | { | |
266 | QmpInputVisitor *qiv = to_qiv(v); | |
7f027843 | 267 | QString *qstr = qobject_to_qstring(qmp_input_get_object(qiv, name, true)); |
c40cc0a0 | 268 | |
7f027843 | 269 | if (!qstr) { |
c6bd8c70 MA |
270 | error_setg(errp, QERR_INVALID_PARAMETER_TYPE, name ? name : "null", |
271 | "string"); | |
c40cc0a0 MR |
272 | return; |
273 | } | |
274 | ||
7f027843 | 275 | *obj = g_strdup(qstring_get_str(qstr)); |
c40cc0a0 MR |
276 | } |
277 | ||
0b2a0d6b | 278 | static void qmp_input_type_number(Visitor *v, const char *name, double *obj, |
c40cc0a0 MR |
279 | Error **errp) |
280 | { | |
281 | QmpInputVisitor *qiv = to_qiv(v); | |
e8316d7e | 282 | QObject *qobj = qmp_input_get_object(qiv, name, true); |
fcf73f66 MA |
283 | QInt *qint; |
284 | QFloat *qfloat; | |
c40cc0a0 | 285 | |
fcf73f66 MA |
286 | qint = qobject_to_qint(qobj); |
287 | if (qint) { | |
288 | *obj = qint_get_int(qobject_to_qint(qobj)); | |
c40cc0a0 MR |
289 | return; |
290 | } | |
291 | ||
fcf73f66 MA |
292 | qfloat = qobject_to_qfloat(qobj); |
293 | if (qfloat) { | |
1ee51876 | 294 | *obj = qfloat_get_double(qobject_to_qfloat(qobj)); |
fcf73f66 | 295 | return; |
1ee51876 | 296 | } |
fcf73f66 MA |
297 | |
298 | error_setg(errp, QERR_INVALID_PARAMETER_TYPE, name ? name : "null", | |
299 | "number"); | |
c40cc0a0 MR |
300 | } |
301 | ||
0b2a0d6b | 302 | static void qmp_input_type_any(Visitor *v, const char *name, QObject **obj, |
28770e05 MA |
303 | Error **errp) |
304 | { | |
305 | QmpInputVisitor *qiv = to_qiv(v); | |
306 | QObject *qobj = qmp_input_get_object(qiv, name, true); | |
307 | ||
308 | qobject_incref(qobj); | |
309 | *obj = qobj; | |
310 | } | |
311 | ||
0b2a0d6b | 312 | static void qmp_input_optional(Visitor *v, const char *name, bool *present) |
c40cc0a0 MR |
313 | { |
314 | QmpInputVisitor *qiv = to_qiv(v); | |
e8316d7e | 315 | QObject *qobj = qmp_input_get_object(qiv, name, true); |
c40cc0a0 MR |
316 | |
317 | if (!qobj) { | |
318 | *present = false; | |
319 | return; | |
320 | } | |
321 | ||
322 | *present = true; | |
323 | } | |
324 | ||
c40cc0a0 MR |
325 | Visitor *qmp_input_get_visitor(QmpInputVisitor *v) |
326 | { | |
327 | return &v->visitor; | |
328 | } | |
329 | ||
330 | void qmp_input_visitor_cleanup(QmpInputVisitor *v) | |
331 | { | |
4faaec6a | 332 | qobject_decref(v->stack[0].obj); |
7267c094 | 333 | g_free(v); |
c40cc0a0 MR |
334 | } |
335 | ||
336 | QmpInputVisitor *qmp_input_visitor_new(QObject *obj) | |
337 | { | |
338 | QmpInputVisitor *v; | |
339 | ||
7267c094 | 340 | v = g_malloc0(sizeof(*v)); |
c40cc0a0 MR |
341 | |
342 | v->visitor.start_struct = qmp_input_start_struct; | |
343 | v->visitor.end_struct = qmp_input_end_struct; | |
344 | v->visitor.start_list = qmp_input_start_list; | |
345 | v->visitor.next_list = qmp_input_next_list; | |
346 | v->visitor.end_list = qmp_input_end_list; | |
dbf11922 | 347 | v->visitor.start_alternate = qmp_input_start_alternate; |
0f71a1e0 | 348 | v->visitor.type_enum = input_type_enum; |
4c40314a | 349 | v->visitor.type_int64 = qmp_input_type_int64; |
f755dea7 | 350 | v->visitor.type_uint64 = qmp_input_type_uint64; |
c40cc0a0 MR |
351 | v->visitor.type_bool = qmp_input_type_bool; |
352 | v->visitor.type_str = qmp_input_type_str; | |
353 | v->visitor.type_number = qmp_input_type_number; | |
28770e05 | 354 | v->visitor.type_any = qmp_input_type_any; |
e2cd0f4f | 355 | v->visitor.optional = qmp_input_optional; |
c40cc0a0 | 356 | |
4faaec6a PB |
357 | qmp_input_push(v, obj, NULL); |
358 | qobject_incref(obj); | |
c40cc0a0 MR |
359 | |
360 | return v; | |
361 | } | |
e38ac962 PB |
362 | |
363 | QmpInputVisitor *qmp_input_visitor_new_strict(QObject *obj) | |
364 | { | |
365 | QmpInputVisitor *v; | |
366 | ||
367 | v = qmp_input_visitor_new(obj); | |
368 | v->strict = true; | |
369 | ||
370 | return v; | |
371 | } |