schema.py 41 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146
  1. # -*- coding: utf-8 -*-
  2. #
  3. # QAPI schema internal representation
  4. #
  5. # Copyright (c) 2015-2019 Red Hat Inc.
  6. #
  7. # Authors:
  8. # Markus Armbruster <armbru@redhat.com>
  9. # Eric Blake <eblake@redhat.com>
  10. # Marc-André Lureau <marcandre.lureau@redhat.com>
  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. # TODO catching name collisions in generated code would be nice
  15. from collections import OrderedDict
  16. import os
  17. import re
  18. from typing import Optional
  19. from .common import POINTER_SUFFIX, c_name
  20. from .error import QAPIError, QAPISemError
  21. from .expr import check_exprs
  22. from .parser import QAPISchemaParser
  23. class QAPISchemaEntity:
  24. meta: Optional[str] = None
  25. def __init__(self, name, info, doc, ifcond=None, features=None):
  26. assert name is None or isinstance(name, str)
  27. for f in features or []:
  28. assert isinstance(f, QAPISchemaFeature)
  29. f.set_defined_in(name)
  30. self.name = name
  31. self._module = None
  32. # For explicitly defined entities, info points to the (explicit)
  33. # definition. For builtins (and their arrays), info is None.
  34. # For implicitly defined entities, info points to a place that
  35. # triggered the implicit definition (there may be more than one
  36. # such place).
  37. self.info = info
  38. self.doc = doc
  39. self._ifcond = ifcond or []
  40. self.features = features or []
  41. self._checked = False
  42. def c_name(self):
  43. return c_name(self.name)
  44. def check(self, schema):
  45. assert not self._checked
  46. seen = {}
  47. for f in self.features:
  48. f.check_clash(self.info, seen)
  49. self._checked = True
  50. def connect_doc(self, doc=None):
  51. doc = doc or self.doc
  52. if doc:
  53. for f in self.features:
  54. doc.connect_feature(f)
  55. def check_doc(self):
  56. if self.doc:
  57. self.doc.check()
  58. def _set_module(self, schema, info):
  59. assert self._checked
  60. self._module = schema.module_by_fname(info and info.fname)
  61. self._module.add_entity(self)
  62. def set_module(self, schema):
  63. self._set_module(schema, self.info)
  64. @property
  65. def ifcond(self):
  66. assert self._checked
  67. return self._ifcond
  68. def is_implicit(self):
  69. return not self.info
  70. def visit(self, visitor):
  71. assert self._checked
  72. def describe(self):
  73. assert self.meta
  74. return "%s '%s'" % (self.meta, self.name)
  75. class QAPISchemaVisitor:
  76. def visit_begin(self, schema):
  77. pass
  78. def visit_end(self):
  79. pass
  80. def visit_module(self, name):
  81. pass
  82. def visit_needed(self, entity):
  83. # Default to visiting everything
  84. return True
  85. def visit_include(self, name, info):
  86. pass
  87. def visit_builtin_type(self, name, info, json_type):
  88. pass
  89. def visit_enum_type(self, name, info, ifcond, features, members, prefix):
  90. pass
  91. def visit_array_type(self, name, info, ifcond, element_type):
  92. pass
  93. def visit_object_type(self, name, info, ifcond, features,
  94. base, members, variants):
  95. pass
  96. def visit_object_type_flat(self, name, info, ifcond, features,
  97. members, variants):
  98. pass
  99. def visit_alternate_type(self, name, info, ifcond, features, variants):
  100. pass
  101. def visit_command(self, name, info, ifcond, features,
  102. arg_type, ret_type, gen, success_response, boxed,
  103. allow_oob, allow_preconfig, coroutine):
  104. pass
  105. def visit_event(self, name, info, ifcond, features, arg_type, boxed):
  106. pass
  107. class QAPISchemaModule:
  108. def __init__(self, name):
  109. self.name = name
  110. self._entity_list = []
  111. def add_entity(self, ent):
  112. self._entity_list.append(ent)
  113. def visit(self, visitor):
  114. visitor.visit_module(self.name)
  115. for entity in self._entity_list:
  116. if visitor.visit_needed(entity):
  117. entity.visit(visitor)
  118. class QAPISchemaInclude(QAPISchemaEntity):
  119. def __init__(self, sub_module, info):
  120. super().__init__(None, info, None)
  121. self._sub_module = sub_module
  122. def visit(self, visitor):
  123. super().visit(visitor)
  124. visitor.visit_include(self._sub_module.name, self.info)
  125. class QAPISchemaType(QAPISchemaEntity):
  126. # Return the C type for common use.
  127. # For the types we commonly box, this is a pointer type.
  128. def c_type(self):
  129. pass
  130. # Return the C type to be used in a parameter list.
  131. def c_param_type(self):
  132. return self.c_type()
  133. # Return the C type to be used where we suppress boxing.
  134. def c_unboxed_type(self):
  135. return self.c_type()
  136. def json_type(self):
  137. pass
  138. def alternate_qtype(self):
  139. json2qtype = {
  140. 'null': 'QTYPE_QNULL',
  141. 'string': 'QTYPE_QSTRING',
  142. 'number': 'QTYPE_QNUM',
  143. 'int': 'QTYPE_QNUM',
  144. 'boolean': 'QTYPE_QBOOL',
  145. 'object': 'QTYPE_QDICT'
  146. }
  147. return json2qtype.get(self.json_type())
  148. def doc_type(self):
  149. if self.is_implicit():
  150. return None
  151. return self.name
  152. def check(self, schema):
  153. QAPISchemaEntity.check(self, schema)
  154. if 'deprecated' in [f.name for f in self.features]:
  155. raise QAPISemError(
  156. self.info, "feature 'deprecated' is not supported for types")
  157. def describe(self):
  158. assert self.meta
  159. return "%s type '%s'" % (self.meta, self.name)
  160. class QAPISchemaBuiltinType(QAPISchemaType):
  161. meta = 'built-in'
  162. def __init__(self, name, json_type, c_type):
  163. super().__init__(name, None, None)
  164. assert not c_type or isinstance(c_type, str)
  165. assert json_type in ('string', 'number', 'int', 'boolean', 'null',
  166. 'value')
  167. self._json_type_name = json_type
  168. self._c_type_name = c_type
  169. def c_name(self):
  170. return self.name
  171. def c_type(self):
  172. return self._c_type_name
  173. def c_param_type(self):
  174. if self.name == 'str':
  175. return 'const ' + self._c_type_name
  176. return self._c_type_name
  177. def json_type(self):
  178. return self._json_type_name
  179. def doc_type(self):
  180. return self.json_type()
  181. def visit(self, visitor):
  182. super().visit(visitor)
  183. visitor.visit_builtin_type(self.name, self.info, self.json_type())
  184. class QAPISchemaEnumType(QAPISchemaType):
  185. meta = 'enum'
  186. def __init__(self, name, info, doc, ifcond, features, members, prefix):
  187. super().__init__(name, info, doc, ifcond, features)
  188. for m in members:
  189. assert isinstance(m, QAPISchemaEnumMember)
  190. m.set_defined_in(name)
  191. assert prefix is None or isinstance(prefix, str)
  192. self.members = members
  193. self.prefix = prefix
  194. def check(self, schema):
  195. super().check(schema)
  196. seen = {}
  197. for m in self.members:
  198. m.check_clash(self.info, seen)
  199. def connect_doc(self, doc=None):
  200. super().connect_doc(doc)
  201. doc = doc or self.doc
  202. for m in self.members:
  203. m.connect_doc(doc)
  204. def is_implicit(self):
  205. # See QAPISchema._make_implicit_enum_type() and ._def_predefineds()
  206. return self.name.endswith('Kind') or self.name == 'QType'
  207. def c_type(self):
  208. return c_name(self.name)
  209. def member_names(self):
  210. return [m.name for m in self.members]
  211. def json_type(self):
  212. return 'string'
  213. def visit(self, visitor):
  214. super().visit(visitor)
  215. visitor.visit_enum_type(
  216. self.name, self.info, self.ifcond, self.features,
  217. self.members, self.prefix)
  218. class QAPISchemaArrayType(QAPISchemaType):
  219. meta = 'array'
  220. def __init__(self, name, info, element_type):
  221. super().__init__(name, info, None)
  222. assert isinstance(element_type, str)
  223. self._element_type_name = element_type
  224. self.element_type = None
  225. def check(self, schema):
  226. super().check(schema)
  227. self.element_type = schema.resolve_type(
  228. self._element_type_name, self.info,
  229. self.info and self.info.defn_meta)
  230. assert not isinstance(self.element_type, QAPISchemaArrayType)
  231. def set_module(self, schema):
  232. self._set_module(schema, self.element_type.info)
  233. @property
  234. def ifcond(self):
  235. assert self._checked
  236. return self.element_type.ifcond
  237. def is_implicit(self):
  238. return True
  239. def c_type(self):
  240. return c_name(self.name) + POINTER_SUFFIX
  241. def json_type(self):
  242. return 'array'
  243. def doc_type(self):
  244. elt_doc_type = self.element_type.doc_type()
  245. if not elt_doc_type:
  246. return None
  247. return 'array of ' + elt_doc_type
  248. def visit(self, visitor):
  249. super().visit(visitor)
  250. visitor.visit_array_type(self.name, self.info, self.ifcond,
  251. self.element_type)
  252. def describe(self):
  253. assert self.meta
  254. return "%s type ['%s']" % (self.meta, self._element_type_name)
  255. class QAPISchemaObjectType(QAPISchemaType):
  256. def __init__(self, name, info, doc, ifcond, features,
  257. base, local_members, variants):
  258. # struct has local_members, optional base, and no variants
  259. # flat union has base, variants, and no local_members
  260. # simple union has local_members, variants, and no base
  261. super().__init__(name, info, doc, ifcond, features)
  262. self.meta = 'union' if variants else 'struct'
  263. assert base is None or isinstance(base, str)
  264. for m in local_members:
  265. assert isinstance(m, QAPISchemaObjectTypeMember)
  266. m.set_defined_in(name)
  267. if variants is not None:
  268. assert isinstance(variants, QAPISchemaVariants)
  269. variants.set_defined_in(name)
  270. self._base_name = base
  271. self.base = None
  272. self.local_members = local_members
  273. self.variants = variants
  274. self.members = None
  275. def check(self, schema):
  276. # This calls another type T's .check() exactly when the C
  277. # struct emitted by gen_object() contains that T's C struct
  278. # (pointers don't count).
  279. if self.members is not None:
  280. # A previous .check() completed: nothing to do
  281. return
  282. if self._checked:
  283. # Recursed: C struct contains itself
  284. raise QAPISemError(self.info,
  285. "object %s contains itself" % self.name)
  286. super().check(schema)
  287. assert self._checked and self.members is None
  288. seen = OrderedDict()
  289. if self._base_name:
  290. self.base = schema.resolve_type(self._base_name, self.info,
  291. "'base'")
  292. if (not isinstance(self.base, QAPISchemaObjectType)
  293. or self.base.variants):
  294. raise QAPISemError(
  295. self.info,
  296. "'base' requires a struct type, %s isn't"
  297. % self.base.describe())
  298. self.base.check(schema)
  299. self.base.check_clash(self.info, seen)
  300. for m in self.local_members:
  301. m.check(schema)
  302. m.check_clash(self.info, seen)
  303. members = seen.values()
  304. if self.variants:
  305. self.variants.check(schema, seen)
  306. self.variants.check_clash(self.info, seen)
  307. self.members = members # mark completed
  308. # Check that the members of this type do not cause duplicate JSON members,
  309. # and update seen to track the members seen so far. Report any errors
  310. # on behalf of info, which is not necessarily self.info
  311. def check_clash(self, info, seen):
  312. assert self._checked
  313. assert not self.variants # not implemented
  314. for m in self.members:
  315. m.check_clash(info, seen)
  316. def connect_doc(self, doc=None):
  317. super().connect_doc(doc)
  318. doc = doc or self.doc
  319. if self.base and self.base.is_implicit():
  320. self.base.connect_doc(doc)
  321. for m in self.local_members:
  322. m.connect_doc(doc)
  323. @property
  324. def ifcond(self):
  325. assert self._checked
  326. if isinstance(self._ifcond, QAPISchemaType):
  327. # Simple union wrapper type inherits from wrapped type;
  328. # see _make_implicit_object_type()
  329. return self._ifcond.ifcond
  330. return self._ifcond
  331. def is_implicit(self):
  332. # See QAPISchema._make_implicit_object_type(), as well as
  333. # _def_predefineds()
  334. return self.name.startswith('q_')
  335. def is_empty(self):
  336. assert self.members is not None
  337. return not self.members and not self.variants
  338. def c_name(self):
  339. assert self.name != 'q_empty'
  340. return super().c_name()
  341. def c_type(self):
  342. assert not self.is_implicit()
  343. return c_name(self.name) + POINTER_SUFFIX
  344. def c_unboxed_type(self):
  345. return c_name(self.name)
  346. def json_type(self):
  347. return 'object'
  348. def visit(self, visitor):
  349. super().visit(visitor)
  350. visitor.visit_object_type(
  351. self.name, self.info, self.ifcond, self.features,
  352. self.base, self.local_members, self.variants)
  353. visitor.visit_object_type_flat(
  354. self.name, self.info, self.ifcond, self.features,
  355. self.members, self.variants)
  356. class QAPISchemaAlternateType(QAPISchemaType):
  357. meta = 'alternate'
  358. def __init__(self, name, info, doc, ifcond, features, variants):
  359. super().__init__(name, info, doc, ifcond, features)
  360. assert isinstance(variants, QAPISchemaVariants)
  361. assert variants.tag_member
  362. variants.set_defined_in(name)
  363. variants.tag_member.set_defined_in(self.name)
  364. self.variants = variants
  365. def check(self, schema):
  366. super().check(schema)
  367. self.variants.tag_member.check(schema)
  368. # Not calling self.variants.check_clash(), because there's nothing
  369. # to clash with
  370. self.variants.check(schema, {})
  371. # Alternate branch names have no relation to the tag enum values;
  372. # so we have to check for potential name collisions ourselves.
  373. seen = {}
  374. types_seen = {}
  375. for v in self.variants.variants:
  376. v.check_clash(self.info, seen)
  377. qtype = v.type.alternate_qtype()
  378. if not qtype:
  379. raise QAPISemError(
  380. self.info,
  381. "%s cannot use %s"
  382. % (v.describe(self.info), v.type.describe()))
  383. conflicting = set([qtype])
  384. if qtype == 'QTYPE_QSTRING':
  385. if isinstance(v.type, QAPISchemaEnumType):
  386. for m in v.type.members:
  387. if m.name in ['on', 'off']:
  388. conflicting.add('QTYPE_QBOOL')
  389. if re.match(r'[-+0-9.]', m.name):
  390. # lazy, could be tightened
  391. conflicting.add('QTYPE_QNUM')
  392. else:
  393. conflicting.add('QTYPE_QNUM')
  394. conflicting.add('QTYPE_QBOOL')
  395. for qt in conflicting:
  396. if qt in types_seen:
  397. raise QAPISemError(
  398. self.info,
  399. "%s can't be distinguished from '%s'"
  400. % (v.describe(self.info), types_seen[qt]))
  401. types_seen[qt] = v.name
  402. def connect_doc(self, doc=None):
  403. super().connect_doc(doc)
  404. doc = doc or self.doc
  405. for v in self.variants.variants:
  406. v.connect_doc(doc)
  407. def c_type(self):
  408. return c_name(self.name) + POINTER_SUFFIX
  409. def json_type(self):
  410. return 'value'
  411. def visit(self, visitor):
  412. super().visit(visitor)
  413. visitor.visit_alternate_type(
  414. self.name, self.info, self.ifcond, self.features, self.variants)
  415. class QAPISchemaVariants:
  416. def __init__(self, tag_name, info, tag_member, variants):
  417. # Flat unions pass tag_name but not tag_member.
  418. # Simple unions and alternates pass tag_member but not tag_name.
  419. # After check(), tag_member is always set, and tag_name remains
  420. # a reliable witness of being used by a flat union.
  421. assert bool(tag_member) != bool(tag_name)
  422. assert (isinstance(tag_name, str) or
  423. isinstance(tag_member, QAPISchemaObjectTypeMember))
  424. for v in variants:
  425. assert isinstance(v, QAPISchemaVariant)
  426. self._tag_name = tag_name
  427. self.info = info
  428. self.tag_member = tag_member
  429. self.variants = variants
  430. def set_defined_in(self, name):
  431. for v in self.variants:
  432. v.set_defined_in(name)
  433. def check(self, schema, seen):
  434. if not self.tag_member: # flat union
  435. self.tag_member = seen.get(c_name(self._tag_name))
  436. base = "'base'"
  437. # Pointing to the base type when not implicit would be
  438. # nice, but we don't know it here
  439. if not self.tag_member or self._tag_name != self.tag_member.name:
  440. raise QAPISemError(
  441. self.info,
  442. "discriminator '%s' is not a member of %s"
  443. % (self._tag_name, base))
  444. # Here we do:
  445. base_type = schema.lookup_type(self.tag_member.defined_in)
  446. assert base_type
  447. if not base_type.is_implicit():
  448. base = "base type '%s'" % self.tag_member.defined_in
  449. if not isinstance(self.tag_member.type, QAPISchemaEnumType):
  450. raise QAPISemError(
  451. self.info,
  452. "discriminator member '%s' of %s must be of enum type"
  453. % (self._tag_name, base))
  454. if self.tag_member.optional:
  455. raise QAPISemError(
  456. self.info,
  457. "discriminator member '%s' of %s must not be optional"
  458. % (self._tag_name, base))
  459. if self.tag_member.ifcond:
  460. raise QAPISemError(
  461. self.info,
  462. "discriminator member '%s' of %s must not be conditional"
  463. % (self._tag_name, base))
  464. else: # simple union
  465. assert isinstance(self.tag_member.type, QAPISchemaEnumType)
  466. assert not self.tag_member.optional
  467. assert self.tag_member.ifcond == []
  468. if self._tag_name: # flat union
  469. # branches that are not explicitly covered get an empty type
  470. cases = {v.name for v in self.variants}
  471. for m in self.tag_member.type.members:
  472. if m.name not in cases:
  473. v = QAPISchemaVariant(m.name, self.info,
  474. 'q_empty', m.ifcond)
  475. v.set_defined_in(self.tag_member.defined_in)
  476. self.variants.append(v)
  477. if not self.variants:
  478. raise QAPISemError(self.info, "union has no branches")
  479. for v in self.variants:
  480. v.check(schema)
  481. # Union names must match enum values; alternate names are
  482. # checked separately. Use 'seen' to tell the two apart.
  483. if seen:
  484. if v.name not in self.tag_member.type.member_names():
  485. raise QAPISemError(
  486. self.info,
  487. "branch '%s' is not a value of %s"
  488. % (v.name, self.tag_member.type.describe()))
  489. if (not isinstance(v.type, QAPISchemaObjectType)
  490. or v.type.variants):
  491. raise QAPISemError(
  492. self.info,
  493. "%s cannot use %s"
  494. % (v.describe(self.info), v.type.describe()))
  495. v.type.check(schema)
  496. def check_clash(self, info, seen):
  497. for v in self.variants:
  498. # Reset seen map for each variant, since qapi names from one
  499. # branch do not affect another branch
  500. v.type.check_clash(info, dict(seen))
  501. class QAPISchemaMember:
  502. """ Represents object members, enum members and features """
  503. role = 'member'
  504. def __init__(self, name, info, ifcond=None):
  505. assert isinstance(name, str)
  506. self.name = name
  507. self.info = info
  508. self.ifcond = ifcond or []
  509. self.defined_in = None
  510. def set_defined_in(self, name):
  511. assert not self.defined_in
  512. self.defined_in = name
  513. def check_clash(self, info, seen):
  514. cname = c_name(self.name)
  515. if cname in seen:
  516. raise QAPISemError(
  517. info,
  518. "%s collides with %s"
  519. % (self.describe(info), seen[cname].describe(info)))
  520. seen[cname] = self
  521. def connect_doc(self, doc):
  522. if doc:
  523. doc.connect_member(self)
  524. def describe(self, info):
  525. role = self.role
  526. defined_in = self.defined_in
  527. assert defined_in
  528. if defined_in.startswith('q_obj_'):
  529. # See QAPISchema._make_implicit_object_type() - reverse the
  530. # mapping there to create a nice human-readable description
  531. defined_in = defined_in[6:]
  532. if defined_in.endswith('-arg'):
  533. # Implicit type created for a command's dict 'data'
  534. assert role == 'member'
  535. role = 'parameter'
  536. elif defined_in.endswith('-base'):
  537. # Implicit type created for a flat union's dict 'base'
  538. role = 'base ' + role
  539. else:
  540. # Implicit type created for a simple union's branch
  541. assert defined_in.endswith('-wrapper')
  542. # Unreachable and not implemented
  543. assert False
  544. elif defined_in.endswith('Kind'):
  545. # See QAPISchema._make_implicit_enum_type()
  546. # Implicit enum created for simple union's branches
  547. assert role == 'value'
  548. role = 'branch'
  549. elif defined_in != info.defn_name:
  550. return "%s '%s' of type '%s'" % (role, self.name, defined_in)
  551. return "%s '%s'" % (role, self.name)
  552. class QAPISchemaEnumMember(QAPISchemaMember):
  553. role = 'value'
  554. class QAPISchemaFeature(QAPISchemaMember):
  555. role = 'feature'
  556. class QAPISchemaObjectTypeMember(QAPISchemaMember):
  557. def __init__(self, name, info, typ, optional, ifcond=None, features=None):
  558. super().__init__(name, info, ifcond)
  559. assert isinstance(typ, str)
  560. assert isinstance(optional, bool)
  561. for f in features or []:
  562. assert isinstance(f, QAPISchemaFeature)
  563. f.set_defined_in(name)
  564. self._type_name = typ
  565. self.type = None
  566. self.optional = optional
  567. self.features = features or []
  568. def check(self, schema):
  569. assert self.defined_in
  570. self.type = schema.resolve_type(self._type_name, self.info,
  571. self.describe)
  572. seen = {}
  573. for f in self.features:
  574. f.check_clash(self.info, seen)
  575. def connect_doc(self, doc):
  576. super().connect_doc(doc)
  577. if doc:
  578. for f in self.features:
  579. doc.connect_feature(f)
  580. class QAPISchemaVariant(QAPISchemaObjectTypeMember):
  581. role = 'branch'
  582. def __init__(self, name, info, typ, ifcond=None):
  583. super().__init__(name, info, typ, False, ifcond)
  584. class QAPISchemaCommand(QAPISchemaEntity):
  585. meta = 'command'
  586. def __init__(self, name, info, doc, ifcond, features,
  587. arg_type, ret_type,
  588. gen, success_response, boxed, allow_oob, allow_preconfig,
  589. coroutine):
  590. super().__init__(name, info, doc, ifcond, features)
  591. assert not arg_type or isinstance(arg_type, str)
  592. assert not ret_type or isinstance(ret_type, str)
  593. self._arg_type_name = arg_type
  594. self.arg_type = None
  595. self._ret_type_name = ret_type
  596. self.ret_type = None
  597. self.gen = gen
  598. self.success_response = success_response
  599. self.boxed = boxed
  600. self.allow_oob = allow_oob
  601. self.allow_preconfig = allow_preconfig
  602. self.coroutine = coroutine
  603. def check(self, schema):
  604. super().check(schema)
  605. if self._arg_type_name:
  606. self.arg_type = schema.resolve_type(
  607. self._arg_type_name, self.info, "command's 'data'")
  608. if not isinstance(self.arg_type, QAPISchemaObjectType):
  609. raise QAPISemError(
  610. self.info,
  611. "command's 'data' cannot take %s"
  612. % self.arg_type.describe())
  613. if self.arg_type.variants and not self.boxed:
  614. raise QAPISemError(
  615. self.info,
  616. "command's 'data' can take %s only with 'boxed': true"
  617. % self.arg_type.describe())
  618. if self._ret_type_name:
  619. self.ret_type = schema.resolve_type(
  620. self._ret_type_name, self.info, "command's 'returns'")
  621. if self.name not in self.info.pragma.returns_whitelist:
  622. typ = self.ret_type
  623. if isinstance(typ, QAPISchemaArrayType):
  624. typ = self.ret_type.element_type
  625. assert typ
  626. if not isinstance(typ, QAPISchemaObjectType):
  627. raise QAPISemError(
  628. self.info,
  629. "command's 'returns' cannot take %s"
  630. % self.ret_type.describe())
  631. def connect_doc(self, doc=None):
  632. super().connect_doc(doc)
  633. doc = doc or self.doc
  634. if doc:
  635. if self.arg_type and self.arg_type.is_implicit():
  636. self.arg_type.connect_doc(doc)
  637. def visit(self, visitor):
  638. super().visit(visitor)
  639. visitor.visit_command(
  640. self.name, self.info, self.ifcond, self.features,
  641. self.arg_type, self.ret_type, self.gen, self.success_response,
  642. self.boxed, self.allow_oob, self.allow_preconfig,
  643. self.coroutine)
  644. class QAPISchemaEvent(QAPISchemaEntity):
  645. meta = 'event'
  646. def __init__(self, name, info, doc, ifcond, features, arg_type, boxed):
  647. super().__init__(name, info, doc, ifcond, features)
  648. assert not arg_type or isinstance(arg_type, str)
  649. self._arg_type_name = arg_type
  650. self.arg_type = None
  651. self.boxed = boxed
  652. def check(self, schema):
  653. super().check(schema)
  654. if self._arg_type_name:
  655. self.arg_type = schema.resolve_type(
  656. self._arg_type_name, self.info, "event's 'data'")
  657. if not isinstance(self.arg_type, QAPISchemaObjectType):
  658. raise QAPISemError(
  659. self.info,
  660. "event's 'data' cannot take %s"
  661. % self.arg_type.describe())
  662. if self.arg_type.variants and not self.boxed:
  663. raise QAPISemError(
  664. self.info,
  665. "event's 'data' can take %s only with 'boxed': true"
  666. % self.arg_type.describe())
  667. def connect_doc(self, doc=None):
  668. super().connect_doc(doc)
  669. doc = doc or self.doc
  670. if doc:
  671. if self.arg_type and self.arg_type.is_implicit():
  672. self.arg_type.connect_doc(doc)
  673. def visit(self, visitor):
  674. super().visit(visitor)
  675. visitor.visit_event(
  676. self.name, self.info, self.ifcond, self.features,
  677. self.arg_type, self.boxed)
  678. class QAPISchema:
  679. def __init__(self, fname):
  680. self.fname = fname
  681. parser = QAPISchemaParser(fname)
  682. exprs = check_exprs(parser.exprs)
  683. self.docs = parser.docs
  684. self._entity_list = []
  685. self._entity_dict = {}
  686. self._module_dict = OrderedDict()
  687. self._schema_dir = os.path.dirname(fname)
  688. self._make_module(None) # built-ins
  689. self._make_module(fname)
  690. self._predefining = True
  691. self._def_predefineds()
  692. self._predefining = False
  693. self._def_exprs(exprs)
  694. self.check()
  695. def _def_entity(self, ent):
  696. # Only the predefined types are allowed to not have info
  697. assert ent.info or self._predefining
  698. self._entity_list.append(ent)
  699. if ent.name is None:
  700. return
  701. # TODO reject names that differ only in '_' vs. '.' vs. '-',
  702. # because they're liable to clash in generated C.
  703. other_ent = self._entity_dict.get(ent.name)
  704. if other_ent:
  705. if other_ent.info:
  706. where = QAPIError(other_ent.info, None, "previous definition")
  707. raise QAPISemError(
  708. ent.info,
  709. "'%s' is already defined\n%s" % (ent.name, where))
  710. raise QAPISemError(
  711. ent.info, "%s is already defined" % other_ent.describe())
  712. self._entity_dict[ent.name] = ent
  713. def lookup_entity(self, name, typ=None):
  714. ent = self._entity_dict.get(name)
  715. if typ and not isinstance(ent, typ):
  716. return None
  717. return ent
  718. def lookup_type(self, name):
  719. return self.lookup_entity(name, QAPISchemaType)
  720. def resolve_type(self, name, info, what):
  721. typ = self.lookup_type(name)
  722. if not typ:
  723. if callable(what):
  724. what = what(info)
  725. raise QAPISemError(
  726. info, "%s uses unknown type '%s'" % (what, name))
  727. return typ
  728. def _module_name(self, fname):
  729. if fname is None:
  730. return None
  731. return os.path.relpath(fname, self._schema_dir)
  732. def _make_module(self, fname):
  733. name = self._module_name(fname)
  734. if name not in self._module_dict:
  735. self._module_dict[name] = QAPISchemaModule(name)
  736. return self._module_dict[name]
  737. def module_by_fname(self, fname):
  738. name = self._module_name(fname)
  739. assert name in self._module_dict
  740. return self._module_dict[name]
  741. def _def_include(self, expr, info, doc):
  742. include = expr['include']
  743. assert doc is None
  744. self._def_entity(QAPISchemaInclude(self._make_module(include), info))
  745. def _def_builtin_type(self, name, json_type, c_type):
  746. self._def_entity(QAPISchemaBuiltinType(name, json_type, c_type))
  747. # Instantiating only the arrays that are actually used would
  748. # be nice, but we can't as long as their generated code
  749. # (qapi-builtin-types.[ch]) may be shared by some other
  750. # schema.
  751. self._make_array_type(name, None)
  752. def _def_predefineds(self):
  753. for t in [('str', 'string', 'char' + POINTER_SUFFIX),
  754. ('number', 'number', 'double'),
  755. ('int', 'int', 'int64_t'),
  756. ('int8', 'int', 'int8_t'),
  757. ('int16', 'int', 'int16_t'),
  758. ('int32', 'int', 'int32_t'),
  759. ('int64', 'int', 'int64_t'),
  760. ('uint8', 'int', 'uint8_t'),
  761. ('uint16', 'int', 'uint16_t'),
  762. ('uint32', 'int', 'uint32_t'),
  763. ('uint64', 'int', 'uint64_t'),
  764. ('size', 'int', 'uint64_t'),
  765. ('bool', 'boolean', 'bool'),
  766. ('any', 'value', 'QObject' + POINTER_SUFFIX),
  767. ('null', 'null', 'QNull' + POINTER_SUFFIX)]:
  768. self._def_builtin_type(*t)
  769. self.the_empty_object_type = QAPISchemaObjectType(
  770. 'q_empty', None, None, None, None, None, [], None)
  771. self._def_entity(self.the_empty_object_type)
  772. qtypes = ['none', 'qnull', 'qnum', 'qstring', 'qdict', 'qlist',
  773. 'qbool']
  774. qtype_values = self._make_enum_members(
  775. [{'name': n} for n in qtypes], None)
  776. self._def_entity(QAPISchemaEnumType('QType', None, None, None, None,
  777. qtype_values, 'QTYPE'))
  778. def _make_features(self, features, info):
  779. if features is None:
  780. return []
  781. return [QAPISchemaFeature(f['name'], info, f.get('if'))
  782. for f in features]
  783. def _make_enum_members(self, values, info):
  784. return [QAPISchemaEnumMember(v['name'], info, v.get('if'))
  785. for v in values]
  786. def _make_implicit_enum_type(self, name, info, ifcond, values):
  787. # See also QAPISchemaObjectTypeMember.describe()
  788. name = name + 'Kind' # reserved by check_defn_name_str()
  789. self._def_entity(QAPISchemaEnumType(
  790. name, info, None, ifcond, None,
  791. self._make_enum_members(values, info),
  792. None))
  793. return name
  794. def _make_array_type(self, element_type, info):
  795. name = element_type + 'List' # reserved by check_defn_name_str()
  796. if not self.lookup_type(name):
  797. self._def_entity(QAPISchemaArrayType(name, info, element_type))
  798. return name
  799. def _make_implicit_object_type(self, name, info, ifcond, role, members):
  800. if not members:
  801. return None
  802. # See also QAPISchemaObjectTypeMember.describe()
  803. name = 'q_obj_%s-%s' % (name, role)
  804. typ = self.lookup_entity(name, QAPISchemaObjectType)
  805. if typ:
  806. # The implicit object type has multiple users. This can
  807. # happen only for simple unions' implicit wrapper types.
  808. # Its ifcond should be the disjunction of its user's
  809. # ifconds. Not implemented. Instead, we always pass the
  810. # wrapped type's ifcond, which is trivially the same for all
  811. # users. It's also necessary for the wrapper to compile.
  812. # But it's not tight: the disjunction need not imply it. We
  813. # may end up compiling useless wrapper types.
  814. # TODO kill simple unions or implement the disjunction
  815. # pylint: disable=protected-access
  816. assert (ifcond or []) == typ._ifcond
  817. else:
  818. self._def_entity(QAPISchemaObjectType(
  819. name, info, None, ifcond, None, None, members, None))
  820. return name
  821. def _def_enum_type(self, expr, info, doc):
  822. name = expr['enum']
  823. data = expr['data']
  824. prefix = expr.get('prefix')
  825. ifcond = expr.get('if')
  826. features = self._make_features(expr.get('features'), info)
  827. self._def_entity(QAPISchemaEnumType(
  828. name, info, doc, ifcond, features,
  829. self._make_enum_members(data, info), prefix))
  830. def _make_member(self, name, typ, ifcond, features, info):
  831. optional = False
  832. if name.startswith('*'):
  833. name = name[1:]
  834. optional = True
  835. if isinstance(typ, list):
  836. assert len(typ) == 1
  837. typ = self._make_array_type(typ[0], info)
  838. return QAPISchemaObjectTypeMember(name, info, typ, optional, ifcond,
  839. self._make_features(features, info))
  840. def _make_members(self, data, info):
  841. return [self._make_member(key, value['type'], value.get('if'),
  842. value.get('features'), info)
  843. for (key, value) in data.items()]
  844. def _def_struct_type(self, expr, info, doc):
  845. name = expr['struct']
  846. base = expr.get('base')
  847. data = expr['data']
  848. ifcond = expr.get('if')
  849. features = self._make_features(expr.get('features'), info)
  850. self._def_entity(QAPISchemaObjectType(
  851. name, info, doc, ifcond, features, base,
  852. self._make_members(data, info),
  853. None))
  854. def _make_variant(self, case, typ, ifcond, info):
  855. return QAPISchemaVariant(case, info, typ, ifcond)
  856. def _make_simple_variant(self, case, typ, ifcond, info):
  857. if isinstance(typ, list):
  858. assert len(typ) == 1
  859. typ = self._make_array_type(typ[0], info)
  860. typ = self._make_implicit_object_type(
  861. typ, info, self.lookup_type(typ),
  862. 'wrapper', [self._make_member('data', typ, None, None, info)])
  863. return QAPISchemaVariant(case, info, typ, ifcond)
  864. def _def_union_type(self, expr, info, doc):
  865. name = expr['union']
  866. data = expr['data']
  867. base = expr.get('base')
  868. ifcond = expr.get('if')
  869. features = self._make_features(expr.get('features'), info)
  870. tag_name = expr.get('discriminator')
  871. tag_member = None
  872. if isinstance(base, dict):
  873. base = self._make_implicit_object_type(
  874. name, info, ifcond,
  875. 'base', self._make_members(base, info))
  876. if tag_name:
  877. variants = [self._make_variant(key, value['type'],
  878. value.get('if'), info)
  879. for (key, value) in data.items()]
  880. members = []
  881. else:
  882. variants = [self._make_simple_variant(key, value['type'],
  883. value.get('if'), info)
  884. for (key, value) in data.items()]
  885. enum = [{'name': v.name, 'if': v.ifcond} for v in variants]
  886. typ = self._make_implicit_enum_type(name, info, ifcond, enum)
  887. tag_member = QAPISchemaObjectTypeMember('type', info, typ, False)
  888. members = [tag_member]
  889. self._def_entity(
  890. QAPISchemaObjectType(name, info, doc, ifcond, features,
  891. base, members,
  892. QAPISchemaVariants(
  893. tag_name, info, tag_member, variants)))
  894. def _def_alternate_type(self, expr, info, doc):
  895. name = expr['alternate']
  896. data = expr['data']
  897. ifcond = expr.get('if')
  898. features = self._make_features(expr.get('features'), info)
  899. variants = [self._make_variant(key, value['type'], value.get('if'),
  900. info)
  901. for (key, value) in data.items()]
  902. tag_member = QAPISchemaObjectTypeMember('type', info, 'QType', False)
  903. self._def_entity(
  904. QAPISchemaAlternateType(name, info, doc, ifcond, features,
  905. QAPISchemaVariants(
  906. None, info, tag_member, variants)))
  907. def _def_command(self, expr, info, doc):
  908. name = expr['command']
  909. data = expr.get('data')
  910. rets = expr.get('returns')
  911. gen = expr.get('gen', True)
  912. success_response = expr.get('success-response', True)
  913. boxed = expr.get('boxed', False)
  914. allow_oob = expr.get('allow-oob', False)
  915. allow_preconfig = expr.get('allow-preconfig', False)
  916. coroutine = expr.get('coroutine', False)
  917. ifcond = expr.get('if')
  918. features = self._make_features(expr.get('features'), info)
  919. if isinstance(data, OrderedDict):
  920. data = self._make_implicit_object_type(
  921. name, info, ifcond,
  922. 'arg', self._make_members(data, info))
  923. if isinstance(rets, list):
  924. assert len(rets) == 1
  925. rets = self._make_array_type(rets[0], info)
  926. self._def_entity(QAPISchemaCommand(name, info, doc, ifcond, features,
  927. data, rets,
  928. gen, success_response,
  929. boxed, allow_oob, allow_preconfig,
  930. coroutine))
  931. def _def_event(self, expr, info, doc):
  932. name = expr['event']
  933. data = expr.get('data')
  934. boxed = expr.get('boxed', False)
  935. ifcond = expr.get('if')
  936. features = self._make_features(expr.get('features'), info)
  937. if isinstance(data, OrderedDict):
  938. data = self._make_implicit_object_type(
  939. name, info, ifcond,
  940. 'arg', self._make_members(data, info))
  941. self._def_entity(QAPISchemaEvent(name, info, doc, ifcond, features,
  942. data, boxed))
  943. def _def_exprs(self, exprs):
  944. for expr_elem in exprs:
  945. expr = expr_elem['expr']
  946. info = expr_elem['info']
  947. doc = expr_elem.get('doc')
  948. if 'enum' in expr:
  949. self._def_enum_type(expr, info, doc)
  950. elif 'struct' in expr:
  951. self._def_struct_type(expr, info, doc)
  952. elif 'union' in expr:
  953. self._def_union_type(expr, info, doc)
  954. elif 'alternate' in expr:
  955. self._def_alternate_type(expr, info, doc)
  956. elif 'command' in expr:
  957. self._def_command(expr, info, doc)
  958. elif 'event' in expr:
  959. self._def_event(expr, info, doc)
  960. elif 'include' in expr:
  961. self._def_include(expr, info, doc)
  962. else:
  963. assert False
  964. def check(self):
  965. for ent in self._entity_list:
  966. ent.check(self)
  967. ent.connect_doc()
  968. ent.check_doc()
  969. for ent in self._entity_list:
  970. ent.set_module(self)
  971. def visit(self, visitor):
  972. visitor.visit_begin(self)
  973. for mod in self._module_dict.values():
  974. mod.visit(visitor)
  975. visitor.visit_end()