schema.py 43 KB

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