2
0

schema.py 42 KB

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