]>
Commit | Line | Data |
---|---|---|
5ddeec83 MA |
1 | """ |
2 | QAPI command marshaller generator | |
3 | ||
4 | Copyright IBM, Corp. 2011 | |
5 | Copyright (C) 2014-2018 Red Hat, Inc. | |
6 | ||
7 | Authors: | |
8 | Anthony Liguori <[email protected]> | |
9 | Michael Roth <[email protected]> | |
10 | Markus Armbruster <[email protected]> | |
11 | ||
12 | This work is licensed under the terms of the GNU GPL, version 2. | |
13 | See the COPYING file in the top-level directory. | |
14 | """ | |
c17d9908 | 15 | |
fb0bc835 | 16 | from qapi.common import * |
c17d9908 | 17 | |
e98859a9 | 18 | |
48825ca4 | 19 | def gen_command_decl(name, arg_type, boxed, ret_type): |
c17d9908 | 20 | return mcgen(''' |
03b4367a | 21 | %(c_type)s qmp_%(c_name)s(%(params)s); |
c17d9908 | 22 | ''', |
e98859a9 MA |
23 | c_type=(ret_type and ret_type.c_type()) or 'void', |
24 | c_name=c_name(name), | |
086ee7a6 | 25 | params=build_params(arg_type, boxed, 'Error **errp')) |
e98859a9 | 26 | |
c17d9908 | 27 | |
48825ca4 | 28 | def gen_call(name, arg_type, boxed, ret_type): |
e98859a9 MA |
29 | ret = '' |
30 | ||
31 | argstr = '' | |
48825ca4 | 32 | if boxed: |
675b214b | 33 | assert arg_type |
c818408e | 34 | argstr = '&arg, ' |
48825ca4 | 35 | elif arg_type: |
29f6bd15 | 36 | assert not arg_type.variants |
e98859a9 | 37 | for memb in arg_type.members: |
ee446028 | 38 | if memb.optional: |
386230a2 EB |
39 | argstr += 'arg.has_%s, ' % c_name(memb.name) |
40 | argstr += 'arg.%s, ' % c_name(memb.name) | |
e98859a9 MA |
41 | |
42 | lhs = '' | |
43 | if ret_type: | |
44 | lhs = 'retval = ' | |
45 | ||
c17d9908 | 46 | ret = mcgen(''' |
f1538019 | 47 | |
05372f70 | 48 | %(lhs)sqmp_%(c_name)s(%(args)s&err); |
c17d9908 | 49 | ''', |
e98859a9 | 50 | c_name=c_name(name), args=argstr, lhs=lhs) |
c17d9908 | 51 | if ret_type: |
e02bca28 | 52 | ret += mcgen(''' |
fa274ed6 EB |
53 | if (err) { |
54 | goto out; | |
55 | } | |
e02bca28 | 56 | |
05372f70 | 57 | qmp_marshal_output_%(c_name)s(retval, ret, &err); |
c17d9908 | 58 | ''', |
56d92b00 | 59 | c_name=ret_type.c_name()) |
1f9a7a1a | 60 | return ret |
c17d9908 | 61 | |
e98859a9 | 62 | |
56d92b00 | 63 | def gen_marshal_output(ret_type): |
f1538019 | 64 | return mcgen(''' |
ee446028 | 65 | |
56d92b00 | 66 | static void qmp_marshal_output_%(c_name)s(%(c_type)s ret_in, QObject **ret_out, Error **errp) |
c17d9908 | 67 | { |
2a0f50e8 | 68 | Error *err = NULL; |
c17d9908 MR |
69 | Visitor *v; |
70 | ||
7d5e199a | 71 | v = qobject_output_visitor_new(ret_out); |
51e72bc1 | 72 | visit_type_%(c_name)s(v, "unused", &ret_in, &err); |
3b098d56 EB |
73 | if (!err) { |
74 | visit_complete(v, ret_out); | |
c17d9908 | 75 | } |
2a0f50e8 | 76 | error_propagate(errp, err); |
2c0ef9f4 EB |
77 | visit_free(v); |
78 | v = qapi_dealloc_visitor_new(); | |
51e72bc1 | 79 | visit_type_%(c_name)s(v, "unused", &ret_in, NULL); |
2c0ef9f4 | 80 | visit_free(v); |
c17d9908 MR |
81 | } |
82 | ''', | |
56d92b00 | 83 | c_type=ret_type.c_type(), c_name=ret_type.c_name()) |
c17d9908 | 84 | |
e98859a9 | 85 | |
086ee7a6 | 86 | def build_marshal_proto(name): |
c2613949 MA |
87 | return ('void qmp_marshal_%s(QDict *args, QObject **ret, Error **errp)' |
88 | % c_name(name)) | |
776574d6 | 89 | |
e98859a9 | 90 | |
f1538019 MA |
91 | def gen_marshal_decl(name): |
92 | return mcgen(''' | |
93 | %(proto)s; | |
94 | ''', | |
086ee7a6 | 95 | proto=build_marshal_proto(name)) |
f1538019 | 96 | |
776574d6 | 97 | |
48825ca4 | 98 | def gen_marshal(name, arg_type, boxed, ret_type): |
675b214b | 99 | have_args = boxed or (arg_type and not arg_type.is_empty()) |
a0067da1 | 100 | |
c17d9908 | 101 | ret = mcgen(''' |
ee446028 | 102 | |
f1538019 | 103 | %(proto)s |
c17d9908 | 104 | { |
c1ff0e6c | 105 | Error *err = NULL; |
c17d9908 | 106 | ''', |
086ee7a6 | 107 | proto=build_marshal_proto(name)) |
c17d9908 | 108 | |
c1ff0e6c EB |
109 | if ret_type: |
110 | ret += mcgen(''' | |
111 | %(c_type)s retval; | |
112 | ''', | |
113 | c_type=ret_type.c_type()) | |
114 | ||
a0067da1 MAL |
115 | if have_args: |
116 | visit_members = ('visit_type_%s_members(v, &arg, &err);' | |
117 | % arg_type.c_name()) | |
c1ff0e6c | 118 | ret += mcgen(''' |
c1ff0e6c EB |
119 | Visitor *v; |
120 | %(c_name)s arg = {0}; | |
121 | ||
a0067da1 MAL |
122 | ''', |
123 | c_name=arg_type.c_name()) | |
124 | else: | |
125 | visit_members = '' | |
126 | ret += mcgen(''' | |
127 | Visitor *v = NULL; | |
128 | ||
129 | if (args) { | |
130 | ''') | |
131 | push_indent() | |
132 | ||
133 | ret += mcgen(''' | |
048abb7b | 134 | v = qobject_input_visitor_new(QOBJECT(args)); |
ed841535 EB |
135 | visit_start_struct(v, NULL, NULL, 0, &err); |
136 | if (err) { | |
137 | goto out; | |
138 | } | |
a0067da1 | 139 | %(visit_members)s |
15c2f669 EB |
140 | if (!err) { |
141 | visit_check_struct(v, &err); | |
142 | } | |
1158bb2a | 143 | visit_end_struct(v, NULL); |
c1ff0e6c EB |
144 | if (err) { |
145 | goto out; | |
146 | } | |
147 | ''', | |
a0067da1 | 148 | visit_members=visit_members) |
c1ff0e6c | 149 | |
a0067da1 MAL |
150 | if not have_args: |
151 | pop_indent() | |
c1ff0e6c | 152 | ret += mcgen(''' |
a0067da1 | 153 | } |
c1ff0e6c EB |
154 | ''') |
155 | ||
48825ca4 | 156 | ret += gen_call(name, arg_type, boxed, ret_type) |
1f9a7a1a | 157 | |
a0067da1 | 158 | ret += mcgen(''' |
c17d9908 MR |
159 | |
160 | out: | |
2a0f50e8 | 161 | error_propagate(errp, err); |
a0067da1 | 162 | visit_free(v); |
1f9a7a1a | 163 | ''') |
a0067da1 MAL |
164 | |
165 | if have_args: | |
166 | visit_members = ('visit_type_%s_members(v, &arg, NULL);' | |
167 | % arg_type.c_name()) | |
168 | else: | |
169 | visit_members = '' | |
c1ff0e6c | 170 | ret += mcgen(''' |
a0067da1 MAL |
171 | if (args) { |
172 | ''') | |
173 | push_indent() | |
174 | ||
175 | ret += mcgen(''' | |
2c0ef9f4 | 176 | v = qapi_dealloc_visitor_new(); |
ed841535 | 177 | visit_start_struct(v, NULL, NULL, 0, NULL); |
a0067da1 | 178 | %(visit_members)s |
1158bb2a | 179 | visit_end_struct(v, NULL); |
2c0ef9f4 | 180 | visit_free(v); |
c1ff0e6c | 181 | ''', |
a0067da1 MAL |
182 | visit_members=visit_members) |
183 | ||
184 | if not have_args: | |
185 | pop_indent() | |
186 | ret += mcgen(''' | |
187 | } | |
188 | ''') | |
c1ff0e6c | 189 | |
1f9a7a1a | 190 | ret += mcgen(''' |
485febc6 | 191 | } |
1f9a7a1a | 192 | ''') |
c17d9908 MR |
193 | return ret |
194 | ||
e98859a9 | 195 | |
d6fe3d02 | 196 | def gen_register_command(name, success_response, allow_oob, allow_preconfig): |
876c6751 PX |
197 | options = [] |
198 | ||
ee446028 | 199 | if not success_response: |
876c6751 PX |
200 | options += ['QCO_NO_SUCCESS_RESP'] |
201 | if allow_oob: | |
202 | options += ['QCO_ALLOW_OOB'] | |
d6fe3d02 IM |
203 | if allow_preconfig: |
204 | options += ['QCO_ALLOW_PRECONFIG'] | |
876c6751 PX |
205 | |
206 | if not options: | |
207 | options = ['QCO_NO_OPTIONS'] | |
208 | ||
209 | options = " | ".join(options) | |
d34b867d | 210 | |
ee446028 | 211 | ret = mcgen(''' |
c2613949 | 212 | qmp_register_command(cmds, "%(name)s", |
1527badb | 213 | qmp_marshal_%(c_name)s, %(opts)s); |
c17d9908 | 214 | ''', |
e98859a9 MA |
215 | name=name, c_name=c_name(name), |
216 | opts=options) | |
ee446028 MA |
217 | return ret |
218 | ||
e98859a9 | 219 | |
93b564c4 | 220 | def gen_registry(registry, prefix): |
c17d9908 | 221 | ret = mcgen(''' |
ee446028 | 222 | |
1527badb | 223 | void %(c_prefix)sqmp_init_marshal(QmpCommandList *cmds) |
c17d9908 | 224 | { |
1527badb MA |
225 | QTAILQ_INIT(cmds); |
226 | ||
227 | ''', | |
228 | c_prefix=c_name(prefix, protect=False)) | |
1f9a7a1a MA |
229 | ret += registry |
230 | ret += mcgen(''' | |
c17d9908 | 231 | } |
1f9a7a1a | 232 | ''') |
c17d9908 MR |
233 | return ret |
234 | ||
ee446028 | 235 | |
252dc310 | 236 | class QAPISchemaGenCommandVisitor(QAPISchemaModularCVisitor): |
71b3f045 | 237 | |
93b564c4 | 238 | def __init__(self, prefix): |
252dc310 MA |
239 | QAPISchemaModularCVisitor.__init__( |
240 | self, prefix, 'qapi-commands', | |
71b3f045 | 241 | ' * Schema-defined QAPI/QMP commands', __doc__) |
dddee4d7 | 242 | self._regy = QAPIGenCCode(None) |
252dc310 MA |
243 | self._visited_ret_types = {} |
244 | ||
dcac6471 | 245 | def _begin_user_module(self, name): |
252dc310 | 246 | self._visited_ret_types[self._genc] = set() |
9af23989 MA |
247 | commands = self._module_basename('qapi-commands', name) |
248 | types = self._module_basename('qapi-types', name) | |
249 | visit = self._module_basename('qapi-visit', name) | |
71b3f045 | 250 | self._genc.add(mcgen(''' |
9167ebd9 | 251 | #include "qemu/osdep.h" |
4180978c | 252 | #include "qapi/visitor.h" |
452fcdbc | 253 | #include "qapi/qmp/qdict.h" |
b3db211f DB |
254 | #include "qapi/qobject-output-visitor.h" |
255 | #include "qapi/qobject-input-visitor.h" | |
4180978c | 256 | #include "qapi/dealloc-visitor.h" |
e688df6b | 257 | #include "qapi/error.h" |
9af23989 MA |
258 | #include "%(visit)s.h" |
259 | #include "%(commands)s.h" | |
4180978c MA |
260 | |
261 | ''', | |
9af23989 | 262 | commands=commands, visit=visit)) |
71b3f045 | 263 | self._genh.add(mcgen(''' |
9af23989 | 264 | #include "%(types)s.h" |
1527badb | 265 | #include "qapi/qmp/dispatch.h" |
4180978c MA |
266 | |
267 | ''', | |
9af23989 | 268 | types=types)) |
71b3f045 MA |
269 | |
270 | def visit_end(self): | |
252dc310 MA |
271 | (genc, genh) = self._module[self._main_module] |
272 | genh.add(mcgen(''' | |
273 | void %(c_prefix)sqmp_init_marshal(QmpCommandList *cmds); | |
274 | ''', | |
275 | c_prefix=c_name(self._prefix, protect=False))) | |
1f7b9f31 | 276 | genc.add(gen_registry(self._regy.get_content(), self._prefix)) |
71b3f045 | 277 | |
fbf09a2f | 278 | def visit_command(self, name, info, ifcond, arg_type, ret_type, gen, |
d6fe3d02 | 279 | success_response, boxed, allow_oob, allow_preconfig): |
71b3f045 MA |
280 | if not gen: |
281 | return | |
1f7b9f31 MAL |
282 | # FIXME: If T is a user-defined type, the user is responsible |
283 | # for making this work, i.e. to make T's condition the | |
284 | # conjunction of the T-returning commands' conditions. If T | |
285 | # is a built-in type, this isn't possible: the | |
286 | # qmp_marshal_output_T() will be generated unconditionally. | |
252dc310 MA |
287 | if ret_type and ret_type not in self._visited_ret_types[self._genc]: |
288 | self._visited_ret_types[self._genc].add(ret_type) | |
1f7b9f31 MAL |
289 | with ifcontext(ret_type.ifcond, |
290 | self._genh, self._genc, self._regy): | |
291 | self._genc.add(gen_marshal_output(ret_type)) | |
292 | with ifcontext(ifcond, self._genh, self._genc, self._regy): | |
293 | self._genh.add(gen_command_decl(name, arg_type, boxed, ret_type)) | |
294 | self._genh.add(gen_marshal_decl(name)) | |
295 | self._genc.add(gen_marshal(name, arg_type, boxed, ret_type)) | |
296 | self._regy.add(gen_register_command(name, success_response, | |
297 | allow_oob, allow_preconfig)) | |
71b3f045 | 298 | |
26df4e7f | 299 | |
71b3f045 | 300 | def gen_commands(schema, output_dir, prefix): |
26df4e7f MA |
301 | vis = QAPISchemaGenCommandVisitor(prefix) |
302 | schema.visit(vis) | |
71b3f045 | 303 | vis.write(output_dir) |