4 * Copyright (C) 2012-2016 Red Hat, Inc.
5 * Copyright IBM, Corp. 2011
8 * Anthony Liguori <aliguori@us.ibm.com>
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.
15 #include "qemu/osdep.h"
16 #include "qapi/error.h"
17 #include "qapi/qmp-input-visitor.h"
18 #include "qapi/visitor-impl.h"
19 #include "qemu/queue.h"
20 #include "qemu-common.h"
21 #include "qapi/qmp/types.h"
22 #include "qapi/qmp/qerror.h"
24 #define QIV_STACK_SIZE 1024
26 typedef struct StackObject
29 const QListEntry
*entry
;
33 struct QmpInputVisitor
36 StackObject stack
[QIV_STACK_SIZE
];
41 static QmpInputVisitor
*to_qiv(Visitor
*v
)
43 return container_of(v
, QmpInputVisitor
, visitor
);
46 static QObject
*qmp_input_get_object(QmpInputVisitor
*qiv
,
50 QObject
*qobj
= qiv
->stack
[qiv
->nb_stack
- 1].obj
;
53 if (name
&& qobject_type(qobj
) == QTYPE_QDICT
) {
54 if (qiv
->stack
[qiv
->nb_stack
- 1].h
&& consume
) {
55 g_hash_table_remove(qiv
->stack
[qiv
->nb_stack
- 1].h
, name
);
57 return qdict_get(qobject_to_qdict(qobj
), name
);
58 } else if (qiv
->stack
[qiv
->nb_stack
- 1].entry
) {
59 return qlist_entry_obj(qiv
->stack
[qiv
->nb_stack
- 1].entry
);
66 static void qdict_add_key(const char *key
, QObject
*obj
, void *opaque
)
68 GHashTable
*h
= opaque
;
69 g_hash_table_insert(h
, (gpointer
) key
, NULL
);
72 static void qmp_input_push(QmpInputVisitor
*qiv
, QObject
*obj
, Error
**errp
)
76 if (qiv
->nb_stack
>= QIV_STACK_SIZE
) {
77 error_setg(errp
, "An internal buffer overran");
81 qiv
->stack
[qiv
->nb_stack
].obj
= obj
;
82 qiv
->stack
[qiv
->nb_stack
].entry
= NULL
;
83 qiv
->stack
[qiv
->nb_stack
].h
= NULL
;
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
;
95 static void qmp_input_pop(QmpInputVisitor
*qiv
, Error
**errp
)
97 assert(qiv
->nb_stack
> 0);
100 GHashTable
* const top_ht
= qiv
->stack
[qiv
->nb_stack
- 1].h
;
105 g_hash_table_iter_init(&iter
, top_ht
);
106 if (g_hash_table_iter_next(&iter
, (void **)&key
, NULL
)) {
107 error_setg(errp
, QERR_QMP_EXTRA_MEMBER
, key
);
109 g_hash_table_unref(top_ht
);
116 static void qmp_input_start_struct(Visitor
*v
, const char *name
, void **obj
,
117 size_t size
, Error
**errp
)
119 QmpInputVisitor
*qiv
= to_qiv(v
);
120 QObject
*qobj
= qmp_input_get_object(qiv
, name
, true);
126 if (!qobj
|| qobject_type(qobj
) != QTYPE_QDICT
) {
127 error_setg(errp
, QERR_INVALID_PARAMETER_TYPE
, name
? name
: "null",
132 qmp_input_push(qiv
, qobj
, &err
);
134 error_propagate(errp
, err
);
139 *obj
= g_malloc0(size
);
143 static void qmp_input_end_struct(Visitor
*v
, Error
**errp
)
145 QmpInputVisitor
*qiv
= to_qiv(v
);
147 qmp_input_pop(qiv
, errp
);
150 static void qmp_input_start_list(Visitor
*v
, const char *name
, Error
**errp
)
152 QmpInputVisitor
*qiv
= to_qiv(v
);
153 QObject
*qobj
= qmp_input_get_object(qiv
, name
, true);
155 if (!qobj
|| qobject_type(qobj
) != QTYPE_QLIST
) {
156 error_setg(errp
, QERR_INVALID_PARAMETER_TYPE
, name
? name
: "null",
161 qmp_input_push(qiv
, qobj
, errp
);
164 static GenericList
*qmp_input_next_list(Visitor
*v
, GenericList
**list
,
167 QmpInputVisitor
*qiv
= to_qiv(v
);
169 StackObject
*so
= &qiv
->stack
[qiv
->nb_stack
- 1];
172 if (so
->entry
== NULL
) {
173 so
->entry
= qlist_first(qobject_to_qlist(so
->obj
));
176 so
->entry
= qlist_next(so
->entry
);
180 if (so
->entry
== NULL
) {
184 entry
= g_malloc0(size
);
188 (*list
)->next
= entry
;
194 static void qmp_input_end_list(Visitor
*v
)
196 QmpInputVisitor
*qiv
= to_qiv(v
);
198 qmp_input_pop(qiv
, &error_abort
);
201 static void qmp_input_start_alternate(Visitor
*v
, const char *name
,
202 GenericAlternate
**obj
, size_t size
,
203 bool promote_int
, Error
**errp
)
205 QmpInputVisitor
*qiv
= to_qiv(v
);
206 QObject
*qobj
= qmp_input_get_object(qiv
, name
, false);
210 error_setg(errp
, QERR_MISSING_PARAMETER
, name
? name
: "null");
213 *obj
= g_malloc0(size
);
214 (*obj
)->type
= qobject_type(qobj
);
215 if (promote_int
&& (*obj
)->type
== QTYPE_QINT
) {
216 (*obj
)->type
= QTYPE_QFLOAT
;
220 static void qmp_input_type_int64(Visitor
*v
, const char *name
, int64_t *obj
,
223 QmpInputVisitor
*qiv
= to_qiv(v
);
224 QInt
*qint
= qobject_to_qint(qmp_input_get_object(qiv
, name
, true));
227 error_setg(errp
, QERR_INVALID_PARAMETER_TYPE
, name
? name
: "null",
232 *obj
= qint_get_int(qint
);
235 static void qmp_input_type_uint64(Visitor
*v
, const char *name
, uint64_t *obj
,
238 /* FIXME: qobject_to_qint mishandles values over INT64_MAX */
239 QmpInputVisitor
*qiv
= to_qiv(v
);
240 QInt
*qint
= qobject_to_qint(qmp_input_get_object(qiv
, name
, true));
243 error_setg(errp
, QERR_INVALID_PARAMETER_TYPE
, name
? name
: "null",
248 *obj
= qint_get_int(qint
);
251 static void qmp_input_type_bool(Visitor
*v
, const char *name
, bool *obj
,
254 QmpInputVisitor
*qiv
= to_qiv(v
);
255 QBool
*qbool
= qobject_to_qbool(qmp_input_get_object(qiv
, name
, true));
258 error_setg(errp
, QERR_INVALID_PARAMETER_TYPE
, name
? name
: "null",
263 *obj
= qbool_get_bool(qbool
);
266 static void qmp_input_type_str(Visitor
*v
, const char *name
, char **obj
,
269 QmpInputVisitor
*qiv
= to_qiv(v
);
270 QString
*qstr
= qobject_to_qstring(qmp_input_get_object(qiv
, name
, true));
274 error_setg(errp
, QERR_INVALID_PARAMETER_TYPE
, name
? name
: "null",
279 *obj
= g_strdup(qstring_get_str(qstr
));
282 static void qmp_input_type_number(Visitor
*v
, const char *name
, double *obj
,
285 QmpInputVisitor
*qiv
= to_qiv(v
);
286 QObject
*qobj
= qmp_input_get_object(qiv
, name
, true);
290 qint
= qobject_to_qint(qobj
);
292 *obj
= qint_get_int(qobject_to_qint(qobj
));
296 qfloat
= qobject_to_qfloat(qobj
);
298 *obj
= qfloat_get_double(qobject_to_qfloat(qobj
));
302 error_setg(errp
, QERR_INVALID_PARAMETER_TYPE
, name
? name
: "null",
306 static void qmp_input_type_any(Visitor
*v
, const char *name
, QObject
**obj
,
309 QmpInputVisitor
*qiv
= to_qiv(v
);
310 QObject
*qobj
= qmp_input_get_object(qiv
, name
, true);
312 qobject_incref(qobj
);
316 static void qmp_input_optional(Visitor
*v
, const char *name
, bool *present
)
318 QmpInputVisitor
*qiv
= to_qiv(v
);
319 QObject
*qobj
= qmp_input_get_object(qiv
, name
, true);
329 Visitor
*qmp_input_get_visitor(QmpInputVisitor
*v
)
334 void qmp_input_visitor_cleanup(QmpInputVisitor
*v
)
336 qobject_decref(v
->stack
[0].obj
);
340 QmpInputVisitor
*qmp_input_visitor_new(QObject
*obj
)
344 v
= g_malloc0(sizeof(*v
));
346 v
->visitor
.type
= VISITOR_INPUT
;
347 v
->visitor
.start_struct
= qmp_input_start_struct
;
348 v
->visitor
.end_struct
= qmp_input_end_struct
;
349 v
->visitor
.start_list
= qmp_input_start_list
;
350 v
->visitor
.next_list
= qmp_input_next_list
;
351 v
->visitor
.end_list
= qmp_input_end_list
;
352 v
->visitor
.start_alternate
= qmp_input_start_alternate
;
353 v
->visitor
.type_int64
= qmp_input_type_int64
;
354 v
->visitor
.type_uint64
= qmp_input_type_uint64
;
355 v
->visitor
.type_bool
= qmp_input_type_bool
;
356 v
->visitor
.type_str
= qmp_input_type_str
;
357 v
->visitor
.type_number
= qmp_input_type_number
;
358 v
->visitor
.type_any
= qmp_input_type_any
;
359 v
->visitor
.optional
= qmp_input_optional
;
361 qmp_input_push(v
, obj
, NULL
);
367 QmpInputVisitor
*qmp_input_visitor_new_strict(QObject
*obj
)
371 v
= qmp_input_visitor_new(obj
);