qapi.py 61 KB

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