qapi.py 60 KB

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