qapi.py 59 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762
  1. #
  2. # QAPI helper library
  3. #
  4. # Copyright IBM, Corp. 2011
  5. # Copyright (c) 2013-2016 Red Hat Inc.
  6. #
  7. # Authors:
  8. # Anthony Liguori <aliguori@us.ibm.com>
  9. # Markus Armbruster <armbru@redhat.com>
  10. #
  11. # This work is licensed under the terms of the GNU GPL, version 2.
  12. # See the COPYING file in the top-level directory.
  13. import re
  14. from ordereddict import OrderedDict
  15. import errno
  16. import getopt
  17. import os
  18. import sys
  19. import string
  20. builtin_types = {
  21. 'str': 'QTYPE_QSTRING',
  22. 'int': 'QTYPE_QINT',
  23. 'number': 'QTYPE_QFLOAT',
  24. 'bool': 'QTYPE_QBOOL',
  25. 'int8': 'QTYPE_QINT',
  26. 'int16': 'QTYPE_QINT',
  27. 'int32': 'QTYPE_QINT',
  28. 'int64': 'QTYPE_QINT',
  29. 'uint8': 'QTYPE_QINT',
  30. 'uint16': 'QTYPE_QINT',
  31. 'uint32': 'QTYPE_QINT',
  32. 'uint64': 'QTYPE_QINT',
  33. 'size': 'QTYPE_QINT',
  34. 'any': None, # any QType possible, actually
  35. 'QType': 'QTYPE_QSTRING',
  36. }
  37. # Whitelist of commands allowed to return a non-dictionary
  38. returns_whitelist = [
  39. # From QMP:
  40. 'human-monitor-command',
  41. 'qom-get',
  42. 'query-migrate-cache-size',
  43. 'query-tpm-models',
  44. 'query-tpm-types',
  45. 'ringbuf-read',
  46. # From QGA:
  47. 'guest-file-open',
  48. 'guest-fsfreeze-freeze',
  49. 'guest-fsfreeze-freeze-list',
  50. 'guest-fsfreeze-status',
  51. 'guest-fsfreeze-thaw',
  52. 'guest-get-time',
  53. 'guest-set-vcpus',
  54. 'guest-sync',
  55. 'guest-sync-delimited',
  56. ]
  57. # Whitelist of entities allowed to violate case conventions
  58. case_whitelist = [
  59. # From QMP:
  60. 'ACPISlotType', # DIMM, visible through query-acpi-ospm-status
  61. 'CpuInfoMIPS', # PC, visible through query-cpu
  62. 'CpuInfoTricore', # PC, visible through query-cpu
  63. 'QapiErrorClass', # all members, visible through errors
  64. 'UuidInfo', # UUID, visible through query-uuid
  65. 'X86CPURegister32', # all members, visible indirectly through qom-get
  66. 'q_obj_CpuInfo-base', # CPU, visible through query-cpu
  67. ]
  68. enum_types = []
  69. struct_types = []
  70. union_types = []
  71. events = []
  72. all_names = {}
  73. #
  74. # Parsing the schema into expressions
  75. #
  76. def error_path(parent):
  77. res = ""
  78. while parent:
  79. res = ("In file included from %s:%d:\n" % (parent['file'],
  80. parent['line'])) + res
  81. parent = parent['parent']
  82. return res
  83. class QAPISchemaError(Exception):
  84. def __init__(self, schema, msg):
  85. Exception.__init__(self)
  86. self.fname = schema.fname
  87. self.msg = msg
  88. self.col = 1
  89. self.line = schema.line
  90. for ch in schema.src[schema.line_pos:schema.pos]:
  91. if ch == '\t':
  92. self.col = (self.col + 7) % 8 + 1
  93. else:
  94. self.col += 1
  95. self.info = schema.incl_info
  96. def __str__(self):
  97. return error_path(self.info) + \
  98. "%s:%d:%d: %s" % (self.fname, self.line, self.col, self.msg)
  99. class QAPIExprError(Exception):
  100. def __init__(self, expr_info, msg):
  101. Exception.__init__(self)
  102. assert expr_info
  103. self.info = expr_info
  104. self.msg = msg
  105. def __str__(self):
  106. return error_path(self.info['parent']) + \
  107. "%s:%d: %s" % (self.info['file'], self.info['line'], self.msg)
  108. class QAPISchemaParser(object):
  109. def __init__(self, fp, previously_included=[], incl_info=None):
  110. abs_fname = os.path.abspath(fp.name)
  111. fname = fp.name
  112. self.fname = fname
  113. previously_included.append(abs_fname)
  114. self.incl_info = incl_info
  115. self.src = fp.read()
  116. if self.src == '' or self.src[-1] != '\n':
  117. self.src += '\n'
  118. self.cursor = 0
  119. self.line = 1
  120. self.line_pos = 0
  121. self.exprs = []
  122. self.accept()
  123. while self.tok is not None:
  124. expr_info = {'file': fname, 'line': self.line,
  125. 'parent': self.incl_info}
  126. expr = self.get_expr(False)
  127. if isinstance(expr, dict) and "include" in expr:
  128. if len(expr) != 1:
  129. raise QAPIExprError(expr_info,
  130. "Invalid 'include' directive")
  131. include = expr["include"]
  132. if not isinstance(include, str):
  133. raise QAPIExprError(expr_info,
  134. "Value of 'include' must be a string")
  135. incl_abs_fname = os.path.join(os.path.dirname(abs_fname),
  136. include)
  137. # catch inclusion cycle
  138. inf = expr_info
  139. while inf:
  140. if incl_abs_fname == os.path.abspath(inf['file']):
  141. raise QAPIExprError(expr_info, "Inclusion loop for %s"
  142. % include)
  143. inf = inf['parent']
  144. # skip multiple include of the same file
  145. if incl_abs_fname in previously_included:
  146. continue
  147. try:
  148. fobj = open(incl_abs_fname, 'r')
  149. except IOError as e:
  150. raise QAPIExprError(expr_info,
  151. '%s: %s' % (e.strerror, include))
  152. exprs_include = QAPISchemaParser(fobj, previously_included,
  153. expr_info)
  154. self.exprs.extend(exprs_include.exprs)
  155. else:
  156. expr_elem = {'expr': expr,
  157. 'info': expr_info}
  158. self.exprs.append(expr_elem)
  159. def accept(self):
  160. while True:
  161. self.tok = self.src[self.cursor]
  162. self.pos = self.cursor
  163. self.cursor += 1
  164. self.val = None
  165. if self.tok == '#':
  166. self.cursor = self.src.find('\n', self.cursor)
  167. elif self.tok in "{}:,[]":
  168. return
  169. elif self.tok == "'":
  170. string = ''
  171. esc = False
  172. while True:
  173. ch = self.src[self.cursor]
  174. self.cursor += 1
  175. if ch == '\n':
  176. raise QAPISchemaError(self,
  177. 'Missing terminating "\'"')
  178. if esc:
  179. if ch == 'b':
  180. string += '\b'
  181. elif ch == 'f':
  182. string += '\f'
  183. elif ch == 'n':
  184. string += '\n'
  185. elif ch == 'r':
  186. string += '\r'
  187. elif ch == 't':
  188. string += '\t'
  189. elif ch == 'u':
  190. value = 0
  191. for _ in range(0, 4):
  192. ch = self.src[self.cursor]
  193. self.cursor += 1
  194. if ch not in "0123456789abcdefABCDEF":
  195. raise QAPISchemaError(self,
  196. '\\u escape needs 4 '
  197. 'hex digits')
  198. value = (value << 4) + int(ch, 16)
  199. # If Python 2 and 3 didn't disagree so much on
  200. # how to handle Unicode, then we could allow
  201. # Unicode string defaults. But most of QAPI is
  202. # ASCII-only, so we aren't losing much for now.
  203. if not value or value > 0x7f:
  204. raise QAPISchemaError(self,
  205. 'For now, \\u escape '
  206. 'only supports non-zero '
  207. 'values up to \\u007f')
  208. string += chr(value)
  209. elif ch in "\\/'\"":
  210. string += ch
  211. else:
  212. raise QAPISchemaError(self,
  213. "Unknown escape \\%s" % ch)
  214. esc = False
  215. elif ch == "\\":
  216. esc = True
  217. elif ch == "'":
  218. self.val = string
  219. return
  220. else:
  221. string += ch
  222. elif self.src.startswith("true", self.pos):
  223. self.val = True
  224. self.cursor += 3
  225. return
  226. elif self.src.startswith("false", self.pos):
  227. self.val = False
  228. self.cursor += 4
  229. return
  230. elif self.src.startswith("null", self.pos):
  231. self.val = None
  232. self.cursor += 3
  233. return
  234. elif self.tok == '\n':
  235. if self.cursor == len(self.src):
  236. self.tok = None
  237. return
  238. self.line += 1
  239. self.line_pos = self.cursor
  240. elif not self.tok.isspace():
  241. raise QAPISchemaError(self, 'Stray "%s"' % self.tok)
  242. def get_members(self):
  243. expr = OrderedDict()
  244. if self.tok == '}':
  245. self.accept()
  246. return expr
  247. if self.tok != "'":
  248. raise QAPISchemaError(self, 'Expected string or "}"')
  249. while True:
  250. key = self.val
  251. self.accept()
  252. if self.tok != ':':
  253. raise QAPISchemaError(self, 'Expected ":"')
  254. self.accept()
  255. if key in expr:
  256. raise QAPISchemaError(self, 'Duplicate key "%s"' % key)
  257. expr[key] = self.get_expr(True)
  258. if self.tok == '}':
  259. self.accept()
  260. return expr
  261. if self.tok != ',':
  262. raise QAPISchemaError(self, 'Expected "," or "}"')
  263. self.accept()
  264. if self.tok != "'":
  265. raise QAPISchemaError(self, 'Expected string')
  266. def get_values(self):
  267. expr = []
  268. if self.tok == ']':
  269. self.accept()
  270. return expr
  271. if self.tok not in "{['tfn":
  272. raise QAPISchemaError(self, 'Expected "{", "[", "]", string, '
  273. 'boolean or "null"')
  274. while True:
  275. expr.append(self.get_expr(True))
  276. if self.tok == ']':
  277. self.accept()
  278. return expr
  279. if self.tok != ',':
  280. raise QAPISchemaError(self, 'Expected "," or "]"')
  281. self.accept()
  282. def get_expr(self, nested):
  283. if self.tok != '{' and not nested:
  284. raise QAPISchemaError(self, 'Expected "{"')
  285. if self.tok == '{':
  286. self.accept()
  287. expr = self.get_members()
  288. elif self.tok == '[':
  289. self.accept()
  290. expr = self.get_values()
  291. elif self.tok in "'tfn":
  292. expr = self.val
  293. self.accept()
  294. else:
  295. raise QAPISchemaError(self, 'Expected "{", "[" or string')
  296. return expr
  297. #
  298. # Semantic analysis of schema expressions
  299. # TODO fold into QAPISchema
  300. # TODO catching name collisions in generated code would be nice
  301. #
  302. def find_base_members(base):
  303. if isinstance(base, dict):
  304. return base
  305. base_struct_define = find_struct(base)
  306. if not base_struct_define:
  307. return None
  308. return base_struct_define['data']
  309. # Return the qtype of an alternate branch, or None on error.
  310. def find_alternate_member_qtype(qapi_type):
  311. if qapi_type in builtin_types:
  312. return builtin_types[qapi_type]
  313. elif find_struct(qapi_type):
  314. return "QTYPE_QDICT"
  315. elif find_enum(qapi_type):
  316. return "QTYPE_QSTRING"
  317. elif find_union(qapi_type):
  318. return "QTYPE_QDICT"
  319. return None
  320. # Return the discriminator enum define if discriminator is specified as an
  321. # enum type, otherwise return None.
  322. def discriminator_find_enum_define(expr):
  323. base = expr.get('base')
  324. discriminator = expr.get('discriminator')
  325. if not (discriminator and base):
  326. return None
  327. base_members = find_base_members(base)
  328. if not base_members:
  329. return None
  330. discriminator_type = base_members.get(discriminator)
  331. if not discriminator_type:
  332. return None
  333. return find_enum(discriminator_type)
  334. # Names must be letters, numbers, -, and _. They must start with letter,
  335. # except for downstream extensions which must start with __RFQDN_.
  336. # Dots are only valid in the downstream extension prefix.
  337. valid_name = re.compile('^(__[a-zA-Z0-9.-]+_)?'
  338. '[a-zA-Z][a-zA-Z0-9_-]*$')
  339. def check_name(expr_info, source, name, allow_optional=False,
  340. enum_member=False):
  341. global valid_name
  342. membername = name
  343. if not isinstance(name, str):
  344. raise QAPIExprError(expr_info,
  345. "%s requires a string name" % source)
  346. if name.startswith('*'):
  347. membername = name[1:]
  348. if not allow_optional:
  349. raise QAPIExprError(expr_info,
  350. "%s does not allow optional name '%s'"
  351. % (source, name))
  352. # Enum members can start with a digit, because the generated C
  353. # code always prefixes it with the enum name
  354. if enum_member and membername[0].isdigit():
  355. membername = 'D' + membername
  356. # Reserve the entire 'q_' namespace for c_name(), and for 'q_empty'
  357. # and 'q_obj_*' implicit type names.
  358. if not valid_name.match(membername) or \
  359. c_name(membername, False).startswith('q_'):
  360. raise QAPIExprError(expr_info,
  361. "%s uses invalid name '%s'" % (source, name))
  362. def add_name(name, info, meta, implicit=False):
  363. global all_names
  364. check_name(info, "'%s'" % meta, name)
  365. # FIXME should reject names that differ only in '_' vs. '.'
  366. # vs. '-', because they're liable to clash in generated C.
  367. if name in all_names:
  368. raise QAPIExprError(info,
  369. "%s '%s' is already defined"
  370. % (all_names[name], name))
  371. if not implicit and (name.endswith('Kind') or name.endswith('List')):
  372. raise QAPIExprError(info,
  373. "%s '%s' should not end in '%s'"
  374. % (meta, name, name[-4:]))
  375. all_names[name] = meta
  376. def add_struct(definition, info):
  377. global struct_types
  378. name = definition['struct']
  379. add_name(name, info, 'struct')
  380. struct_types.append(definition)
  381. def find_struct(name):
  382. global struct_types
  383. for struct in struct_types:
  384. if struct['struct'] == name:
  385. return struct
  386. return None
  387. def add_union(definition, info):
  388. global union_types
  389. name = definition['union']
  390. add_name(name, info, 'union')
  391. union_types.append(definition)
  392. def find_union(name):
  393. global union_types
  394. for union in union_types:
  395. if union['union'] == name:
  396. return union
  397. return None
  398. def add_enum(name, info, enum_values=None, implicit=False):
  399. global enum_types
  400. add_name(name, info, 'enum', implicit)
  401. enum_types.append({"enum_name": name, "enum_values": enum_values})
  402. def find_enum(name):
  403. global enum_types
  404. for enum in enum_types:
  405. if enum['enum_name'] == name:
  406. return enum
  407. return None
  408. def is_enum(name):
  409. return find_enum(name) is not None
  410. def check_type(expr_info, source, value, allow_array=False,
  411. allow_dict=False, allow_optional=False,
  412. allow_metas=[]):
  413. global all_names
  414. if value is None:
  415. return
  416. # Check if array type for value is okay
  417. if isinstance(value, list):
  418. if not allow_array:
  419. raise QAPIExprError(expr_info,
  420. "%s cannot be an array" % source)
  421. if len(value) != 1 or not isinstance(value[0], str):
  422. raise QAPIExprError(expr_info,
  423. "%s: array type must contain single type name"
  424. % source)
  425. value = value[0]
  426. # Check if type name for value is okay
  427. if isinstance(value, str):
  428. if value not in all_names:
  429. raise QAPIExprError(expr_info,
  430. "%s uses unknown type '%s'"
  431. % (source, value))
  432. if not all_names[value] in allow_metas:
  433. raise QAPIExprError(expr_info,
  434. "%s cannot use %s type '%s'"
  435. % (source, all_names[value], value))
  436. return
  437. if not allow_dict:
  438. raise QAPIExprError(expr_info,
  439. "%s should be a type name" % source)
  440. if not isinstance(value, OrderedDict):
  441. raise QAPIExprError(expr_info,
  442. "%s should be a dictionary or type name" % source)
  443. # value is a dictionary, check that each member is okay
  444. for (key, arg) in value.items():
  445. check_name(expr_info, "Member of %s" % source, key,
  446. allow_optional=allow_optional)
  447. if c_name(key, False) == 'u' or c_name(key, False).startswith('has_'):
  448. raise QAPIExprError(expr_info,
  449. "Member of %s uses reserved name '%s'"
  450. % (source, key))
  451. # Todo: allow dictionaries to represent default values of
  452. # an optional argument.
  453. check_type(expr_info, "Member '%s' of %s" % (key, source), arg,
  454. allow_array=True,
  455. allow_metas=['built-in', 'union', 'alternate', 'struct',
  456. 'enum'])
  457. def check_command(expr, expr_info):
  458. name = expr['command']
  459. check_type(expr_info, "'data' for command '%s'" % name,
  460. expr.get('data'), allow_dict=True, allow_optional=True,
  461. allow_metas=['struct'])
  462. returns_meta = ['union', 'struct']
  463. if name in returns_whitelist:
  464. returns_meta += ['built-in', 'alternate', 'enum']
  465. check_type(expr_info, "'returns' for command '%s'" % name,
  466. expr.get('returns'), allow_array=True,
  467. allow_optional=True, allow_metas=returns_meta)
  468. def check_event(expr, expr_info):
  469. global events
  470. name = expr['event']
  471. events.append(name)
  472. check_type(expr_info, "'data' for event '%s'" % name,
  473. expr.get('data'), allow_dict=True, allow_optional=True,
  474. allow_metas=['struct'])
  475. def check_union(expr, expr_info):
  476. name = expr['union']
  477. base = expr.get('base')
  478. discriminator = expr.get('discriminator')
  479. members = expr['data']
  480. # Two types of unions, determined by discriminator.
  481. # With no discriminator it is a simple union.
  482. if discriminator is None:
  483. enum_define = None
  484. allow_metas = ['built-in', 'union', 'alternate', 'struct', 'enum']
  485. if base is not None:
  486. raise QAPIExprError(expr_info,
  487. "Simple union '%s' must not have a base"
  488. % name)
  489. # Else, it's a flat union.
  490. else:
  491. # The object must have a string or dictionary 'base'.
  492. check_type(expr_info, "'base' for union '%s'" % name,
  493. base, allow_dict=True, allow_optional=True,
  494. allow_metas=['struct'])
  495. if not base:
  496. raise QAPIExprError(expr_info,
  497. "Flat union '%s' must have a base"
  498. % name)
  499. base_members = find_base_members(base)
  500. assert base_members
  501. # The value of member 'discriminator' must name a non-optional
  502. # member of the base struct.
  503. check_name(expr_info, "Discriminator of flat union '%s'" % name,
  504. discriminator)
  505. discriminator_type = base_members.get(discriminator)
  506. if not discriminator_type:
  507. raise QAPIExprError(expr_info,
  508. "Discriminator '%s' is not a member of base "
  509. "struct '%s'"
  510. % (discriminator, base))
  511. enum_define = find_enum(discriminator_type)
  512. allow_metas = ['struct']
  513. # Do not allow string discriminator
  514. if not enum_define:
  515. raise QAPIExprError(expr_info,
  516. "Discriminator '%s' must be of enumeration "
  517. "type" % discriminator)
  518. # Check every branch; don't allow an empty union
  519. if len(members) == 0:
  520. raise QAPIExprError(expr_info,
  521. "Union '%s' cannot have empty 'data'" % name)
  522. for (key, value) in members.items():
  523. check_name(expr_info, "Member of union '%s'" % name, key)
  524. # Each value must name a known type
  525. check_type(expr_info, "Member '%s' of union '%s'" % (key, name),
  526. value, allow_array=not base, allow_metas=allow_metas)
  527. # If the discriminator names an enum type, then all members
  528. # of 'data' must also be members of the enum type.
  529. if enum_define:
  530. if key not in enum_define['enum_values']:
  531. raise QAPIExprError(expr_info,
  532. "Discriminator value '%s' is not found in "
  533. "enum '%s'" %
  534. (key, enum_define["enum_name"]))
  535. # If discriminator is user-defined, ensure all values are covered
  536. if enum_define:
  537. for value in enum_define['enum_values']:
  538. if value not in members.keys():
  539. raise QAPIExprError(expr_info,
  540. "Union '%s' data missing '%s' branch"
  541. % (name, value))
  542. def check_alternate(expr, expr_info):
  543. name = expr['alternate']
  544. members = expr['data']
  545. types_seen = {}
  546. # Check every branch; require at least two branches
  547. if len(members) < 2:
  548. raise QAPIExprError(expr_info,
  549. "Alternate '%s' should have at least two branches "
  550. "in 'data'" % name)
  551. for (key, value) in members.items():
  552. check_name(expr_info, "Member of alternate '%s'" % name, key)
  553. # Ensure alternates have no type conflicts.
  554. check_type(expr_info, "Member '%s' of alternate '%s'" % (key, name),
  555. value,
  556. allow_metas=['built-in', 'union', 'struct', 'enum'])
  557. qtype = find_alternate_member_qtype(value)
  558. if not qtype:
  559. raise QAPIExprError(expr_info,
  560. "Alternate '%s' member '%s' cannot use "
  561. "type '%s'" % (name, key, value))
  562. if qtype in types_seen:
  563. raise QAPIExprError(expr_info,
  564. "Alternate '%s' member '%s' can't "
  565. "be distinguished from member '%s'"
  566. % (name, key, types_seen[qtype]))
  567. types_seen[qtype] = key
  568. def check_enum(expr, expr_info):
  569. name = expr['enum']
  570. members = expr.get('data')
  571. prefix = expr.get('prefix')
  572. if not isinstance(members, list):
  573. raise QAPIExprError(expr_info,
  574. "Enum '%s' requires an array for 'data'" % name)
  575. if prefix is not None and not isinstance(prefix, str):
  576. raise QAPIExprError(expr_info,
  577. "Enum '%s' requires a string for 'prefix'" % name)
  578. for member in members:
  579. check_name(expr_info, "Member of enum '%s'" % name, member,
  580. enum_member=True)
  581. def check_struct(expr, expr_info):
  582. name = expr['struct']
  583. members = expr['data']
  584. check_type(expr_info, "'data' for struct '%s'" % name, members,
  585. allow_dict=True, allow_optional=True)
  586. check_type(expr_info, "'base' for struct '%s'" % name, expr.get('base'),
  587. allow_metas=['struct'])
  588. def check_keys(expr_elem, meta, required, optional=[]):
  589. expr = expr_elem['expr']
  590. info = expr_elem['info']
  591. name = expr[meta]
  592. if not isinstance(name, str):
  593. raise QAPIExprError(info,
  594. "'%s' key must have a string value" % meta)
  595. required = required + [meta]
  596. for (key, value) in expr.items():
  597. if key not in required and key not in optional:
  598. raise QAPIExprError(info,
  599. "Unknown key '%s' in %s '%s'"
  600. % (key, meta, name))
  601. if (key == 'gen' or key == 'success-response') and value is not False:
  602. raise QAPIExprError(info,
  603. "'%s' of %s '%s' should only use false value"
  604. % (key, meta, name))
  605. for key in required:
  606. if key not in expr:
  607. raise QAPIExprError(info,
  608. "Key '%s' is missing from %s '%s'"
  609. % (key, meta, name))
  610. def check_exprs(exprs):
  611. global all_names
  612. # Learn the types and check for valid expression keys
  613. for builtin in builtin_types.keys():
  614. all_names[builtin] = 'built-in'
  615. for expr_elem in exprs:
  616. expr = expr_elem['expr']
  617. info = expr_elem['info']
  618. if 'enum' in expr:
  619. check_keys(expr_elem, 'enum', ['data'], ['prefix'])
  620. add_enum(expr['enum'], info, expr['data'])
  621. elif 'union' in expr:
  622. check_keys(expr_elem, 'union', ['data'],
  623. ['base', 'discriminator'])
  624. add_union(expr, info)
  625. elif 'alternate' in expr:
  626. check_keys(expr_elem, 'alternate', ['data'])
  627. add_name(expr['alternate'], info, 'alternate')
  628. elif 'struct' in expr:
  629. check_keys(expr_elem, 'struct', ['data'], ['base'])
  630. add_struct(expr, info)
  631. elif 'command' in expr:
  632. check_keys(expr_elem, 'command', [],
  633. ['data', 'returns', 'gen', 'success-response'])
  634. add_name(expr['command'], info, 'command')
  635. elif 'event' in expr:
  636. check_keys(expr_elem, 'event', [], ['data'])
  637. add_name(expr['event'], info, 'event')
  638. else:
  639. raise QAPIExprError(expr_elem['info'],
  640. "Expression is missing metatype")
  641. # Try again for hidden UnionKind enum
  642. for expr_elem in exprs:
  643. expr = expr_elem['expr']
  644. if 'union' in expr:
  645. if not discriminator_find_enum_define(expr):
  646. add_enum('%sKind' % expr['union'], expr_elem['info'],
  647. implicit=True)
  648. elif 'alternate' in expr:
  649. add_enum('%sKind' % expr['alternate'], expr_elem['info'],
  650. implicit=True)
  651. # Validate that exprs make sense
  652. for expr_elem in exprs:
  653. expr = expr_elem['expr']
  654. info = expr_elem['info']
  655. if 'enum' in expr:
  656. check_enum(expr, info)
  657. elif 'union' in expr:
  658. check_union(expr, info)
  659. elif 'alternate' in expr:
  660. check_alternate(expr, info)
  661. elif 'struct' in expr:
  662. check_struct(expr, info)
  663. elif 'command' in expr:
  664. check_command(expr, info)
  665. elif 'event' in expr:
  666. check_event(expr, info)
  667. else:
  668. assert False, 'unexpected meta type'
  669. return exprs
  670. #
  671. # Schema compiler frontend
  672. #
  673. class QAPISchemaEntity(object):
  674. def __init__(self, name, info):
  675. assert isinstance(name, str)
  676. self.name = name
  677. # For explicitly defined entities, info points to the (explicit)
  678. # definition. For builtins (and their arrays), info is None.
  679. # For implicitly defined entities, info points to a place that
  680. # triggered the implicit definition (there may be more than one
  681. # such place).
  682. self.info = info
  683. def c_name(self):
  684. return c_name(self.name)
  685. def check(self, schema):
  686. pass
  687. def is_implicit(self):
  688. return not self.info
  689. def visit(self, visitor):
  690. pass
  691. class QAPISchemaVisitor(object):
  692. def visit_begin(self, schema):
  693. pass
  694. def visit_end(self):
  695. pass
  696. def visit_needed(self, entity):
  697. # Default to visiting everything
  698. return True
  699. def visit_builtin_type(self, name, info, json_type):
  700. pass
  701. def visit_enum_type(self, name, info, values, prefix):
  702. pass
  703. def visit_array_type(self, name, info, element_type):
  704. pass
  705. def visit_object_type(self, name, info, base, members, variants):
  706. pass
  707. def visit_object_type_flat(self, name, info, members, variants):
  708. pass
  709. def visit_alternate_type(self, name, info, variants):
  710. pass
  711. def visit_command(self, name, info, arg_type, ret_type,
  712. gen, success_response):
  713. pass
  714. def visit_event(self, name, info, arg_type):
  715. pass
  716. class QAPISchemaType(QAPISchemaEntity):
  717. # Return the C type for common use.
  718. # For the types we commonly box, this is a pointer type.
  719. def c_type(self):
  720. pass
  721. # Return the C type to be used in a parameter list.
  722. def c_param_type(self):
  723. return self.c_type()
  724. # Return the C type to be used where we suppress boxing.
  725. def c_unboxed_type(self):
  726. return self.c_type()
  727. def json_type(self):
  728. pass
  729. def alternate_qtype(self):
  730. json2qtype = {
  731. 'string': 'QTYPE_QSTRING',
  732. 'number': 'QTYPE_QFLOAT',
  733. 'int': 'QTYPE_QINT',
  734. 'boolean': 'QTYPE_QBOOL',
  735. 'object': 'QTYPE_QDICT'
  736. }
  737. return json2qtype.get(self.json_type())
  738. class QAPISchemaBuiltinType(QAPISchemaType):
  739. def __init__(self, name, json_type, c_type):
  740. QAPISchemaType.__init__(self, name, None)
  741. assert not c_type or isinstance(c_type, str)
  742. assert json_type in ('string', 'number', 'int', 'boolean', 'null',
  743. 'value')
  744. self._json_type_name = json_type
  745. self._c_type_name = c_type
  746. def c_name(self):
  747. return self.name
  748. def c_type(self):
  749. return self._c_type_name
  750. def c_param_type(self):
  751. if self.name == 'str':
  752. return 'const ' + self._c_type_name
  753. return self._c_type_name
  754. def json_type(self):
  755. return self._json_type_name
  756. def visit(self, visitor):
  757. visitor.visit_builtin_type(self.name, self.info, self.json_type())
  758. class QAPISchemaEnumType(QAPISchemaType):
  759. def __init__(self, name, info, values, prefix):
  760. QAPISchemaType.__init__(self, name, info)
  761. for v in values:
  762. assert isinstance(v, QAPISchemaMember)
  763. v.set_owner(name)
  764. assert prefix is None or isinstance(prefix, str)
  765. self.values = values
  766. self.prefix = prefix
  767. def check(self, schema):
  768. seen = {}
  769. for v in self.values:
  770. v.check_clash(self.info, seen)
  771. def is_implicit(self):
  772. # See QAPISchema._make_implicit_enum_type()
  773. return self.name.endswith('Kind')
  774. def c_type(self):
  775. return c_name(self.name)
  776. def member_names(self):
  777. return [v.name for v in self.values]
  778. def json_type(self):
  779. return 'string'
  780. def visit(self, visitor):
  781. visitor.visit_enum_type(self.name, self.info,
  782. self.member_names(), self.prefix)
  783. class QAPISchemaArrayType(QAPISchemaType):
  784. def __init__(self, name, info, element_type):
  785. QAPISchemaType.__init__(self, name, info)
  786. assert isinstance(element_type, str)
  787. self._element_type_name = element_type
  788. self.element_type = None
  789. def check(self, schema):
  790. self.element_type = schema.lookup_type(self._element_type_name)
  791. assert self.element_type
  792. def is_implicit(self):
  793. return True
  794. def c_type(self):
  795. return c_name(self.name) + pointer_suffix
  796. def json_type(self):
  797. return 'array'
  798. def visit(self, visitor):
  799. visitor.visit_array_type(self.name, self.info, self.element_type)
  800. class QAPISchemaObjectType(QAPISchemaType):
  801. def __init__(self, name, info, base, local_members, variants):
  802. # struct has local_members, optional base, and no variants
  803. # flat union has base, variants, and no local_members
  804. # simple union has local_members, variants, and no base
  805. QAPISchemaType.__init__(self, name, info)
  806. assert base is None or isinstance(base, str)
  807. for m in local_members:
  808. assert isinstance(m, QAPISchemaObjectTypeMember)
  809. m.set_owner(name)
  810. if variants is not None:
  811. assert isinstance(variants, QAPISchemaObjectTypeVariants)
  812. variants.set_owner(name)
  813. self._base_name = base
  814. self.base = None
  815. self.local_members = local_members
  816. self.variants = variants
  817. self.members = None
  818. def check(self, schema):
  819. if self.members is False: # check for cycles
  820. raise QAPIExprError(self.info,
  821. "Object %s contains itself" % self.name)
  822. if self.members:
  823. return
  824. self.members = False # mark as being checked
  825. seen = OrderedDict()
  826. if self._base_name:
  827. self.base = schema.lookup_type(self._base_name)
  828. assert isinstance(self.base, QAPISchemaObjectType)
  829. self.base.check(schema)
  830. self.base.check_clash(schema, self.info, seen)
  831. for m in self.local_members:
  832. m.check(schema)
  833. m.check_clash(self.info, seen)
  834. self.members = seen.values()
  835. if self.variants:
  836. self.variants.check(schema, seen)
  837. assert self.variants.tag_member in self.members
  838. self.variants.check_clash(schema, self.info, seen)
  839. # Check that the members of this type do not cause duplicate JSON members,
  840. # and update seen to track the members seen so far. Report any errors
  841. # on behalf of info, which is not necessarily self.info
  842. def check_clash(self, schema, info, seen):
  843. assert not self.variants # not implemented
  844. for m in self.members:
  845. m.check_clash(info, seen)
  846. def is_implicit(self):
  847. # See QAPISchema._make_implicit_object_type(), as well as
  848. # _def_predefineds()
  849. return self.name.startswith('q_')
  850. def is_empty(self):
  851. assert self.members is not None
  852. return not self.members and not self.variants
  853. def c_name(self):
  854. assert self.name != 'q_empty'
  855. return QAPISchemaType.c_name(self)
  856. def c_type(self):
  857. assert not self.is_implicit()
  858. return c_name(self.name) + pointer_suffix
  859. def c_unboxed_type(self):
  860. return c_name(self.name)
  861. def json_type(self):
  862. return 'object'
  863. def visit(self, visitor):
  864. visitor.visit_object_type(self.name, self.info,
  865. self.base, self.local_members, self.variants)
  866. visitor.visit_object_type_flat(self.name, self.info,
  867. self.members, self.variants)
  868. class QAPISchemaMember(object):
  869. role = 'member'
  870. def __init__(self, name):
  871. assert isinstance(name, str)
  872. self.name = name
  873. self.owner = None
  874. def set_owner(self, name):
  875. assert not self.owner
  876. self.owner = name
  877. def check_clash(self, info, seen):
  878. cname = c_name(self.name)
  879. if cname.lower() != cname and self.owner not in case_whitelist:
  880. raise QAPIExprError(info,
  881. "%s should not use uppercase" % self.describe())
  882. if cname in seen:
  883. raise QAPIExprError(info,
  884. "%s collides with %s"
  885. % (self.describe(), seen[cname].describe()))
  886. seen[cname] = self
  887. def _pretty_owner(self):
  888. owner = self.owner
  889. if owner.startswith('q_obj_'):
  890. # See QAPISchema._make_implicit_object_type() - reverse the
  891. # mapping there to create a nice human-readable description
  892. owner = owner[6:]
  893. if owner.endswith('-arg'):
  894. return '(parameter of %s)' % owner[:-4]
  895. elif owner.endswith('-base'):
  896. return '(base of %s)' % owner[:-5]
  897. else:
  898. assert owner.endswith('-wrapper')
  899. # Unreachable and not implemented
  900. assert False
  901. if owner.endswith('Kind'):
  902. # See QAPISchema._make_implicit_enum_type()
  903. return '(branch of %s)' % owner[:-4]
  904. return '(%s of %s)' % (self.role, owner)
  905. def describe(self):
  906. return "'%s' %s" % (self.name, self._pretty_owner())
  907. class QAPISchemaObjectTypeMember(QAPISchemaMember):
  908. def __init__(self, name, typ, optional):
  909. QAPISchemaMember.__init__(self, name)
  910. assert isinstance(typ, str)
  911. assert isinstance(optional, bool)
  912. self._type_name = typ
  913. self.type = None
  914. self.optional = optional
  915. def check(self, schema):
  916. assert self.owner
  917. self.type = schema.lookup_type(self._type_name)
  918. assert self.type
  919. class QAPISchemaObjectTypeVariants(object):
  920. def __init__(self, tag_name, tag_member, variants):
  921. # Flat unions pass tag_name but not tag_member.
  922. # Simple unions and alternates pass tag_member but not tag_name.
  923. # After check(), tag_member is always set, and tag_name remains
  924. # a reliable witness of being used by a flat union.
  925. assert bool(tag_member) != bool(tag_name)
  926. assert (isinstance(tag_name, str) or
  927. isinstance(tag_member, QAPISchemaObjectTypeMember))
  928. assert len(variants) > 0
  929. for v in variants:
  930. assert isinstance(v, QAPISchemaObjectTypeVariant)
  931. self._tag_name = tag_name
  932. self.tag_member = tag_member
  933. self.variants = variants
  934. def set_owner(self, name):
  935. for v in self.variants:
  936. v.set_owner(name)
  937. def check(self, schema, seen):
  938. if not self.tag_member: # flat union
  939. self.tag_member = seen[c_name(self._tag_name)]
  940. assert self._tag_name == self.tag_member.name
  941. assert isinstance(self.tag_member.type, QAPISchemaEnumType)
  942. for v in self.variants:
  943. v.check(schema)
  944. # Union names must match enum values; alternate names are
  945. # checked separately. Use 'seen' to tell the two apart.
  946. if seen:
  947. assert v.name in self.tag_member.type.member_names()
  948. assert isinstance(v.type, QAPISchemaObjectType)
  949. v.type.check(schema)
  950. def check_clash(self, schema, info, seen):
  951. for v in self.variants:
  952. # Reset seen map for each variant, since qapi names from one
  953. # branch do not affect another branch
  954. assert isinstance(v.type, QAPISchemaObjectType)
  955. v.type.check_clash(schema, info, dict(seen))
  956. class QAPISchemaObjectTypeVariant(QAPISchemaObjectTypeMember):
  957. role = 'branch'
  958. def __init__(self, name, typ):
  959. QAPISchemaObjectTypeMember.__init__(self, name, typ, False)
  960. class QAPISchemaAlternateType(QAPISchemaType):
  961. def __init__(self, name, info, variants):
  962. QAPISchemaType.__init__(self, name, info)
  963. assert isinstance(variants, QAPISchemaObjectTypeVariants)
  964. assert variants.tag_member
  965. variants.set_owner(name)
  966. variants.tag_member.set_owner(self.name)
  967. self.variants = variants
  968. def check(self, schema):
  969. self.variants.tag_member.check(schema)
  970. # Not calling self.variants.check_clash(), because there's nothing
  971. # to clash with
  972. self.variants.check(schema, {})
  973. # Alternate branch names have no relation to the tag enum values;
  974. # so we have to check for potential name collisions ourselves.
  975. seen = {}
  976. for v in self.variants.variants:
  977. v.check_clash(self.info, seen)
  978. def c_type(self):
  979. return c_name(self.name) + pointer_suffix
  980. def json_type(self):
  981. return 'value'
  982. def visit(self, visitor):
  983. visitor.visit_alternate_type(self.name, self.info, self.variants)
  984. class QAPISchemaCommand(QAPISchemaEntity):
  985. def __init__(self, name, info, arg_type, ret_type, gen, success_response):
  986. QAPISchemaEntity.__init__(self, name, info)
  987. assert not arg_type or isinstance(arg_type, str)
  988. assert not ret_type or isinstance(ret_type, str)
  989. self._arg_type_name = arg_type
  990. self.arg_type = None
  991. self._ret_type_name = ret_type
  992. self.ret_type = None
  993. self.gen = gen
  994. self.success_response = success_response
  995. def check(self, schema):
  996. if self._arg_type_name:
  997. self.arg_type = schema.lookup_type(self._arg_type_name)
  998. assert isinstance(self.arg_type, QAPISchemaObjectType)
  999. assert not self.arg_type.variants # not implemented
  1000. if self._ret_type_name:
  1001. self.ret_type = schema.lookup_type(self._ret_type_name)
  1002. assert isinstance(self.ret_type, QAPISchemaType)
  1003. def visit(self, visitor):
  1004. visitor.visit_command(self.name, self.info,
  1005. self.arg_type, self.ret_type,
  1006. self.gen, self.success_response)
  1007. class QAPISchemaEvent(QAPISchemaEntity):
  1008. def __init__(self, name, info, arg_type):
  1009. QAPISchemaEntity.__init__(self, name, info)
  1010. assert not arg_type or isinstance(arg_type, str)
  1011. self._arg_type_name = arg_type
  1012. self.arg_type = None
  1013. def check(self, schema):
  1014. if self._arg_type_name:
  1015. self.arg_type = schema.lookup_type(self._arg_type_name)
  1016. assert isinstance(self.arg_type, QAPISchemaObjectType)
  1017. assert not self.arg_type.variants # not implemented
  1018. def visit(self, visitor):
  1019. visitor.visit_event(self.name, self.info, self.arg_type)
  1020. class QAPISchema(object):
  1021. def __init__(self, fname):
  1022. try:
  1023. self.exprs = check_exprs(QAPISchemaParser(open(fname, "r")).exprs)
  1024. self._entity_dict = {}
  1025. self._predefining = True
  1026. self._def_predefineds()
  1027. self._predefining = False
  1028. self._def_exprs()
  1029. self.check()
  1030. except (QAPISchemaError, QAPIExprError) as err:
  1031. print >>sys.stderr, err
  1032. exit(1)
  1033. def _def_entity(self, ent):
  1034. # Only the predefined types are allowed to not have info
  1035. assert ent.info or self._predefining
  1036. assert ent.name not in self._entity_dict
  1037. self._entity_dict[ent.name] = ent
  1038. def lookup_entity(self, name, typ=None):
  1039. ent = self._entity_dict.get(name)
  1040. if typ and not isinstance(ent, typ):
  1041. return None
  1042. return ent
  1043. def lookup_type(self, name):
  1044. return self.lookup_entity(name, QAPISchemaType)
  1045. def _def_builtin_type(self, name, json_type, c_type):
  1046. self._def_entity(QAPISchemaBuiltinType(name, json_type, c_type))
  1047. # TODO As long as we have QAPI_TYPES_BUILTIN to share multiple
  1048. # qapi-types.h from a single .c, all arrays of builtins must be
  1049. # declared in the first file whether or not they are used. Nicer
  1050. # would be to use lazy instantiation, while figuring out how to
  1051. # avoid compilation issues with multiple qapi-types.h.
  1052. self._make_array_type(name, None)
  1053. def _def_predefineds(self):
  1054. for t in [('str', 'string', 'char' + pointer_suffix),
  1055. ('number', 'number', 'double'),
  1056. ('int', 'int', 'int64_t'),
  1057. ('int8', 'int', 'int8_t'),
  1058. ('int16', 'int', 'int16_t'),
  1059. ('int32', 'int', 'int32_t'),
  1060. ('int64', 'int', 'int64_t'),
  1061. ('uint8', 'int', 'uint8_t'),
  1062. ('uint16', 'int', 'uint16_t'),
  1063. ('uint32', 'int', 'uint32_t'),
  1064. ('uint64', 'int', 'uint64_t'),
  1065. ('size', 'int', 'uint64_t'),
  1066. ('bool', 'boolean', 'bool'),
  1067. ('any', 'value', 'QObject' + pointer_suffix)]:
  1068. self._def_builtin_type(*t)
  1069. self.the_empty_object_type = QAPISchemaObjectType('q_empty', None,
  1070. None, [], None)
  1071. self._def_entity(self.the_empty_object_type)
  1072. qtype_values = self._make_enum_members(['none', 'qnull', 'qint',
  1073. 'qstring', 'qdict', 'qlist',
  1074. 'qfloat', 'qbool'])
  1075. self._def_entity(QAPISchemaEnumType('QType', None, qtype_values,
  1076. 'QTYPE'))
  1077. def _make_enum_members(self, values):
  1078. return [QAPISchemaMember(v) for v in values]
  1079. def _make_implicit_enum_type(self, name, info, values):
  1080. # See also QAPISchemaObjectTypeMember._pretty_owner()
  1081. name = name + 'Kind' # Use namespace reserved by add_name()
  1082. self._def_entity(QAPISchemaEnumType(
  1083. name, info, self._make_enum_members(values), None))
  1084. return name
  1085. def _make_array_type(self, element_type, info):
  1086. name = element_type + 'List' # Use namespace reserved by add_name()
  1087. if not self.lookup_type(name):
  1088. self._def_entity(QAPISchemaArrayType(name, info, element_type))
  1089. return name
  1090. def _make_implicit_object_type(self, name, info, role, members):
  1091. if not members:
  1092. return None
  1093. # See also QAPISchemaObjectTypeMember._pretty_owner()
  1094. name = 'q_obj_%s-%s' % (name, role)
  1095. if not self.lookup_entity(name, QAPISchemaObjectType):
  1096. self._def_entity(QAPISchemaObjectType(name, info, None,
  1097. members, None))
  1098. return name
  1099. def _def_enum_type(self, expr, info):
  1100. name = expr['enum']
  1101. data = expr['data']
  1102. prefix = expr.get('prefix')
  1103. self._def_entity(QAPISchemaEnumType(
  1104. name, info, self._make_enum_members(data), prefix))
  1105. def _make_member(self, name, typ, info):
  1106. optional = False
  1107. if name.startswith('*'):
  1108. name = name[1:]
  1109. optional = True
  1110. if isinstance(typ, list):
  1111. assert len(typ) == 1
  1112. typ = self._make_array_type(typ[0], info)
  1113. return QAPISchemaObjectTypeMember(name, typ, optional)
  1114. def _make_members(self, data, info):
  1115. return [self._make_member(key, value, info)
  1116. for (key, value) in data.iteritems()]
  1117. def _def_struct_type(self, expr, info):
  1118. name = expr['struct']
  1119. base = expr.get('base')
  1120. data = expr['data']
  1121. self._def_entity(QAPISchemaObjectType(name, info, base,
  1122. self._make_members(data, info),
  1123. None))
  1124. def _make_variant(self, case, typ):
  1125. return QAPISchemaObjectTypeVariant(case, typ)
  1126. def _make_simple_variant(self, case, typ, info):
  1127. if isinstance(typ, list):
  1128. assert len(typ) == 1
  1129. typ = self._make_array_type(typ[0], info)
  1130. typ = self._make_implicit_object_type(
  1131. typ, info, 'wrapper', [self._make_member('data', typ, info)])
  1132. return QAPISchemaObjectTypeVariant(case, typ)
  1133. def _def_union_type(self, expr, info):
  1134. name = expr['union']
  1135. data = expr['data']
  1136. base = expr.get('base')
  1137. tag_name = expr.get('discriminator')
  1138. tag_member = None
  1139. if isinstance(base, dict):
  1140. base = (self._make_implicit_object_type(
  1141. name, info, 'base', self._make_members(base, info)))
  1142. if tag_name:
  1143. variants = [self._make_variant(key, value)
  1144. for (key, value) in data.iteritems()]
  1145. members = []
  1146. else:
  1147. variants = [self._make_simple_variant(key, value, info)
  1148. for (key, value) in data.iteritems()]
  1149. typ = self._make_implicit_enum_type(name, info,
  1150. [v.name for v in variants])
  1151. tag_member = QAPISchemaObjectTypeMember('type', typ, False)
  1152. members = [tag_member]
  1153. self._def_entity(
  1154. QAPISchemaObjectType(name, info, base, members,
  1155. QAPISchemaObjectTypeVariants(tag_name,
  1156. tag_member,
  1157. variants)))
  1158. def _def_alternate_type(self, expr, info):
  1159. name = expr['alternate']
  1160. data = expr['data']
  1161. variants = [self._make_variant(key, value)
  1162. for (key, value) in data.iteritems()]
  1163. tag_member = QAPISchemaObjectTypeMember('type', 'QType', False)
  1164. self._def_entity(
  1165. QAPISchemaAlternateType(name, info,
  1166. QAPISchemaObjectTypeVariants(None,
  1167. tag_member,
  1168. variants)))
  1169. def _def_command(self, expr, info):
  1170. name = expr['command']
  1171. data = expr.get('data')
  1172. rets = expr.get('returns')
  1173. gen = expr.get('gen', True)
  1174. success_response = expr.get('success-response', True)
  1175. if isinstance(data, OrderedDict):
  1176. data = self._make_implicit_object_type(
  1177. name, info, 'arg', self._make_members(data, info))
  1178. if isinstance(rets, list):
  1179. assert len(rets) == 1
  1180. rets = self._make_array_type(rets[0], info)
  1181. self._def_entity(QAPISchemaCommand(name, info, data, rets, gen,
  1182. success_response))
  1183. def _def_event(self, expr, info):
  1184. name = expr['event']
  1185. data = expr.get('data')
  1186. if isinstance(data, OrderedDict):
  1187. data = self._make_implicit_object_type(
  1188. name, info, 'arg', self._make_members(data, info))
  1189. self._def_entity(QAPISchemaEvent(name, info, data))
  1190. def _def_exprs(self):
  1191. for expr_elem in self.exprs:
  1192. expr = expr_elem['expr']
  1193. info = expr_elem['info']
  1194. if 'enum' in expr:
  1195. self._def_enum_type(expr, info)
  1196. elif 'struct' in expr:
  1197. self._def_struct_type(expr, info)
  1198. elif 'union' in expr:
  1199. self._def_union_type(expr, info)
  1200. elif 'alternate' in expr:
  1201. self._def_alternate_type(expr, info)
  1202. elif 'command' in expr:
  1203. self._def_command(expr, info)
  1204. elif 'event' in expr:
  1205. self._def_event(expr, info)
  1206. else:
  1207. assert False
  1208. def check(self):
  1209. for ent in self._entity_dict.values():
  1210. ent.check(self)
  1211. def visit(self, visitor):
  1212. visitor.visit_begin(self)
  1213. for (name, entity) in sorted(self._entity_dict.items()):
  1214. if visitor.visit_needed(entity):
  1215. entity.visit(visitor)
  1216. visitor.visit_end()
  1217. #
  1218. # Code generation helpers
  1219. #
  1220. def camel_case(name):
  1221. new_name = ''
  1222. first = True
  1223. for ch in name:
  1224. if ch in ['_', '-']:
  1225. first = True
  1226. elif first:
  1227. new_name += ch.upper()
  1228. first = False
  1229. else:
  1230. new_name += ch.lower()
  1231. return new_name
  1232. # ENUMName -> ENUM_NAME, EnumName1 -> ENUM_NAME1
  1233. # ENUM_NAME -> ENUM_NAME, ENUM_NAME1 -> ENUM_NAME1, ENUM_Name2 -> ENUM_NAME2
  1234. # ENUM24_Name -> ENUM24_NAME
  1235. def camel_to_upper(value):
  1236. c_fun_str = c_name(value, False)
  1237. if value.isupper():
  1238. return c_fun_str
  1239. new_name = ''
  1240. l = len(c_fun_str)
  1241. for i in range(l):
  1242. c = c_fun_str[i]
  1243. # When c is upper and no "_" appears before, do more checks
  1244. if c.isupper() and (i > 0) and c_fun_str[i - 1] != "_":
  1245. if i < l - 1 and c_fun_str[i + 1].islower():
  1246. new_name += '_'
  1247. elif c_fun_str[i - 1].isdigit():
  1248. new_name += '_'
  1249. new_name += c
  1250. return new_name.lstrip('_').upper()
  1251. def c_enum_const(type_name, const_name, prefix=None):
  1252. if prefix is not None:
  1253. type_name = prefix
  1254. return camel_to_upper(type_name) + '_' + c_name(const_name, False).upper()
  1255. c_name_trans = string.maketrans('.-', '__')
  1256. # Map @name to a valid C identifier.
  1257. # If @protect, avoid returning certain ticklish identifiers (like
  1258. # C keywords) by prepending "q_".
  1259. #
  1260. # Used for converting 'name' from a 'name':'type' qapi definition
  1261. # into a generated struct member, as well as converting type names
  1262. # into substrings of a generated C function name.
  1263. # '__a.b_c' -> '__a_b_c', 'x-foo' -> 'x_foo'
  1264. # protect=True: 'int' -> 'q_int'; protect=False: 'int' -> 'int'
  1265. def c_name(name, protect=True):
  1266. # ANSI X3J11/88-090, 3.1.1
  1267. c89_words = set(['auto', 'break', 'case', 'char', 'const', 'continue',
  1268. 'default', 'do', 'double', 'else', 'enum', 'extern',
  1269. 'float', 'for', 'goto', 'if', 'int', 'long', 'register',
  1270. 'return', 'short', 'signed', 'sizeof', 'static',
  1271. 'struct', 'switch', 'typedef', 'union', 'unsigned',
  1272. 'void', 'volatile', 'while'])
  1273. # ISO/IEC 9899:1999, 6.4.1
  1274. c99_words = set(['inline', 'restrict', '_Bool', '_Complex', '_Imaginary'])
  1275. # ISO/IEC 9899:2011, 6.4.1
  1276. c11_words = set(['_Alignas', '_Alignof', '_Atomic', '_Generic',
  1277. '_Noreturn', '_Static_assert', '_Thread_local'])
  1278. # GCC http://gcc.gnu.org/onlinedocs/gcc-4.7.1/gcc/C-Extensions.html
  1279. # excluding _.*
  1280. gcc_words = set(['asm', 'typeof'])
  1281. # C++ ISO/IEC 14882:2003 2.11
  1282. cpp_words = set(['bool', 'catch', 'class', 'const_cast', 'delete',
  1283. 'dynamic_cast', 'explicit', 'false', 'friend', 'mutable',
  1284. 'namespace', 'new', 'operator', 'private', 'protected',
  1285. 'public', 'reinterpret_cast', 'static_cast', 'template',
  1286. 'this', 'throw', 'true', 'try', 'typeid', 'typename',
  1287. 'using', 'virtual', 'wchar_t',
  1288. # alternative representations
  1289. 'and', 'and_eq', 'bitand', 'bitor', 'compl', 'not',
  1290. 'not_eq', 'or', 'or_eq', 'xor', 'xor_eq'])
  1291. # namespace pollution:
  1292. polluted_words = set(['unix', 'errno', 'mips', 'sparc'])
  1293. name = name.translate(c_name_trans)
  1294. if protect and (name in c89_words | c99_words | c11_words | gcc_words
  1295. | cpp_words | polluted_words):
  1296. return "q_" + name
  1297. return name
  1298. eatspace = '\033EATSPACE.'
  1299. pointer_suffix = ' *' + eatspace
  1300. def genindent(count):
  1301. ret = ""
  1302. for _ in range(count):
  1303. ret += " "
  1304. return ret
  1305. indent_level = 0
  1306. def push_indent(indent_amount=4):
  1307. global indent_level
  1308. indent_level += indent_amount
  1309. def pop_indent(indent_amount=4):
  1310. global indent_level
  1311. indent_level -= indent_amount
  1312. # Generate @code with @kwds interpolated.
  1313. # Obey indent_level, and strip eatspace.
  1314. def cgen(code, **kwds):
  1315. raw = code % kwds
  1316. if indent_level:
  1317. indent = genindent(indent_level)
  1318. # re.subn() lacks flags support before Python 2.7, use re.compile()
  1319. raw = re.subn(re.compile("^.", re.MULTILINE),
  1320. indent + r'\g<0>', raw)
  1321. raw = raw[0]
  1322. return re.sub(re.escape(eatspace) + ' *', '', raw)
  1323. def mcgen(code, **kwds):
  1324. if code[0] == '\n':
  1325. code = code[1:]
  1326. return cgen(code, **kwds)
  1327. def guardname(filename):
  1328. return c_name(filename, protect=False).upper()
  1329. def guardstart(name):
  1330. return mcgen('''
  1331. #ifndef %(name)s
  1332. #define %(name)s
  1333. ''',
  1334. name=guardname(name))
  1335. def guardend(name):
  1336. return mcgen('''
  1337. #endif /* %(name)s */
  1338. ''',
  1339. name=guardname(name))
  1340. def gen_enum_lookup(name, values, prefix=None):
  1341. ret = mcgen('''
  1342. const char *const %(c_name)s_lookup[] = {
  1343. ''',
  1344. c_name=c_name(name))
  1345. for value in values:
  1346. index = c_enum_const(name, value, prefix)
  1347. ret += mcgen('''
  1348. [%(index)s] = "%(value)s",
  1349. ''',
  1350. index=index, value=value)
  1351. max_index = c_enum_const(name, '_MAX', prefix)
  1352. ret += mcgen('''
  1353. [%(max_index)s] = NULL,
  1354. };
  1355. ''',
  1356. max_index=max_index)
  1357. return ret
  1358. def gen_enum(name, values, prefix=None):
  1359. # append automatically generated _MAX value
  1360. enum_values = values + ['_MAX']
  1361. ret = mcgen('''
  1362. typedef enum %(c_name)s {
  1363. ''',
  1364. c_name=c_name(name))
  1365. i = 0
  1366. for value in enum_values:
  1367. ret += mcgen('''
  1368. %(c_enum)s = %(i)d,
  1369. ''',
  1370. c_enum=c_enum_const(name, value, prefix),
  1371. i=i)
  1372. i += 1
  1373. ret += mcgen('''
  1374. } %(c_name)s;
  1375. ''',
  1376. c_name=c_name(name))
  1377. ret += mcgen('''
  1378. extern const char *const %(c_name)s_lookup[];
  1379. ''',
  1380. c_name=c_name(name))
  1381. return ret
  1382. def gen_params(arg_type, extra):
  1383. if not arg_type:
  1384. return extra
  1385. assert not arg_type.variants
  1386. ret = ''
  1387. sep = ''
  1388. for memb in arg_type.members:
  1389. ret += sep
  1390. sep = ', '
  1391. if memb.optional:
  1392. ret += 'bool has_%s, ' % c_name(memb.name)
  1393. ret += '%s %s' % (memb.type.c_param_type(), c_name(memb.name))
  1394. if extra:
  1395. ret += sep + extra
  1396. return ret
  1397. #
  1398. # Common command line parsing
  1399. #
  1400. def parse_command_line(extra_options="", extra_long_options=[]):
  1401. try:
  1402. opts, args = getopt.gnu_getopt(sys.argv[1:],
  1403. "chp:o:" + extra_options,
  1404. ["source", "header", "prefix=",
  1405. "output-dir="] + extra_long_options)
  1406. except getopt.GetoptError as err:
  1407. print >>sys.stderr, "%s: %s" % (sys.argv[0], str(err))
  1408. sys.exit(1)
  1409. output_dir = ""
  1410. prefix = ""
  1411. do_c = False
  1412. do_h = False
  1413. extra_opts = []
  1414. for oa in opts:
  1415. o, a = oa
  1416. if o in ("-p", "--prefix"):
  1417. match = re.match('([A-Za-z_.-][A-Za-z0-9_.-]*)?', a)
  1418. if match.end() != len(a):
  1419. print >>sys.stderr, \
  1420. "%s: 'funny character '%s' in argument of --prefix" \
  1421. % (sys.argv[0], a[match.end()])
  1422. sys.exit(1)
  1423. prefix = a
  1424. elif o in ("-o", "--output-dir"):
  1425. output_dir = a + "/"
  1426. elif o in ("-c", "--source"):
  1427. do_c = True
  1428. elif o in ("-h", "--header"):
  1429. do_h = True
  1430. else:
  1431. extra_opts.append(oa)
  1432. if not do_c and not do_h:
  1433. do_c = True
  1434. do_h = True
  1435. if len(args) != 1:
  1436. print >>sys.stderr, "%s: need exactly one argument" % sys.argv[0]
  1437. sys.exit(1)
  1438. fname = args[0]
  1439. return (fname, output_dir, do_c, do_h, prefix, extra_opts)
  1440. #
  1441. # Generate output files with boilerplate
  1442. #
  1443. def open_output(output_dir, do_c, do_h, prefix, c_file, h_file,
  1444. c_comment, h_comment):
  1445. guard = guardname(prefix + h_file)
  1446. c_file = output_dir + prefix + c_file
  1447. h_file = output_dir + prefix + h_file
  1448. if output_dir:
  1449. try:
  1450. os.makedirs(output_dir)
  1451. except os.error as e:
  1452. if e.errno != errno.EEXIST:
  1453. raise
  1454. def maybe_open(really, name, opt):
  1455. if really:
  1456. return open(name, opt)
  1457. else:
  1458. import StringIO
  1459. return StringIO.StringIO()
  1460. fdef = maybe_open(do_c, c_file, 'w')
  1461. fdecl = maybe_open(do_h, h_file, 'w')
  1462. fdef.write(mcgen('''
  1463. /* AUTOMATICALLY GENERATED, DO NOT MODIFY */
  1464. %(comment)s
  1465. ''',
  1466. comment=c_comment))
  1467. fdecl.write(mcgen('''
  1468. /* AUTOMATICALLY GENERATED, DO NOT MODIFY */
  1469. %(comment)s
  1470. #ifndef %(guard)s
  1471. #define %(guard)s
  1472. ''',
  1473. comment=h_comment, guard=guard))
  1474. return (fdef, fdecl)
  1475. def close_output(fdef, fdecl):
  1476. fdecl.write('''
  1477. #endif
  1478. ''')
  1479. fdecl.close()
  1480. fdef.close()