qapi.py 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366
  1. #
  2. # QAPI helper library
  3. #
  4. # Copyright IBM, Corp. 2011
  5. # Copyright (c) 2013 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 GPLv2.
  12. # See the COPYING.LIB file in the top-level directory.
  13. from ordereddict import OrderedDict
  14. import sys
  15. builtin_types = [
  16. 'str', 'int', 'number', 'bool',
  17. 'int8', 'int16', 'int32', 'int64',
  18. 'uint8', 'uint16', 'uint32', 'uint64'
  19. ]
  20. builtin_type_qtypes = {
  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. }
  34. class QAPISchemaError(Exception):
  35. def __init__(self, schema, msg):
  36. self.fp = schema.fp
  37. self.msg = msg
  38. self.line = self.col = 1
  39. for ch in schema.src[0:schema.pos]:
  40. if ch == '\n':
  41. self.line += 1
  42. self.col = 1
  43. elif ch == '\t':
  44. self.col = (self.col + 7) % 8 + 1
  45. else:
  46. self.col += 1
  47. def __str__(self):
  48. return "%s:%s:%s: %s" % (self.fp.name, self.line, self.col, self.msg)
  49. class QAPISchema:
  50. def __init__(self, fp):
  51. self.fp = fp
  52. self.src = fp.read()
  53. if self.src == '' or self.src[-1] != '\n':
  54. self.src += '\n'
  55. self.cursor = 0
  56. self.exprs = []
  57. self.accept()
  58. while self.tok != None:
  59. self.exprs.append(self.get_expr(False))
  60. def accept(self):
  61. while True:
  62. bol = self.cursor == 0 or self.src[self.cursor-1] == '\n'
  63. self.tok = self.src[self.cursor]
  64. self.pos = self.cursor
  65. self.cursor += 1
  66. self.val = None
  67. if self.tok == '#' and bol:
  68. self.cursor = self.src.find('\n', self.cursor)
  69. elif self.tok in ['{', '}', ':', ',', '[', ']']:
  70. return
  71. elif self.tok == "'":
  72. string = ''
  73. esc = False
  74. while True:
  75. ch = self.src[self.cursor]
  76. self.cursor += 1
  77. if ch == '\n':
  78. raise QAPISchemaError(self,
  79. 'Missing terminating "\'"')
  80. if esc:
  81. string += ch
  82. esc = False
  83. elif ch == "\\":
  84. esc = True
  85. elif ch == "'":
  86. self.val = string
  87. return
  88. else:
  89. string += ch
  90. elif self.tok == '\n':
  91. if self.cursor == len(self.src):
  92. self.tok = None
  93. return
  94. elif not self.tok.isspace():
  95. raise QAPISchemaError(self, 'Stray "%s"' % self.tok)
  96. def get_members(self):
  97. expr = OrderedDict()
  98. if self.tok == '}':
  99. self.accept()
  100. return expr
  101. if self.tok != "'":
  102. raise QAPISchemaError(self, 'Expected string or "}"')
  103. while True:
  104. key = self.val
  105. self.accept()
  106. if self.tok != ':':
  107. raise QAPISchemaError(self, 'Expected ":"')
  108. self.accept()
  109. expr[key] = self.get_expr(True)
  110. if self.tok == '}':
  111. self.accept()
  112. return expr
  113. if self.tok != ',':
  114. raise QAPISchemaError(self, 'Expected "," or "}"')
  115. self.accept()
  116. if self.tok != "'":
  117. raise QAPISchemaError(self, 'Expected string')
  118. def get_values(self):
  119. expr = []
  120. if self.tok == ']':
  121. self.accept()
  122. return expr
  123. if not self.tok in [ '{', '[', "'" ]:
  124. raise QAPISchemaError(self, 'Expected "{", "[", "]" or string')
  125. while True:
  126. expr.append(self.get_expr(True))
  127. if self.tok == ']':
  128. self.accept()
  129. return expr
  130. if self.tok != ',':
  131. raise QAPISchemaError(self, 'Expected "," or "]"')
  132. self.accept()
  133. def get_expr(self, nested):
  134. if self.tok != '{' and not nested:
  135. raise QAPISchemaError(self, 'Expected "{"')
  136. if self.tok == '{':
  137. self.accept()
  138. expr = self.get_members()
  139. elif self.tok == '[':
  140. self.accept()
  141. expr = self.get_values()
  142. elif self.tok == "'":
  143. expr = self.val
  144. self.accept()
  145. else:
  146. raise QAPISchemaError(self, 'Expected "{", "[" or string')
  147. return expr
  148. def parse_schema(fp):
  149. try:
  150. schema = QAPISchema(fp)
  151. except QAPISchemaError as e:
  152. print >>sys.stderr, e
  153. exit(1)
  154. exprs = []
  155. for expr in schema.exprs:
  156. if expr.has_key('enum'):
  157. add_enum(expr['enum'])
  158. elif expr.has_key('union'):
  159. add_union(expr)
  160. add_enum('%sKind' % expr['union'])
  161. elif expr.has_key('type'):
  162. add_struct(expr)
  163. exprs.append(expr)
  164. return exprs
  165. def parse_args(typeinfo):
  166. if isinstance(typeinfo, basestring):
  167. struct = find_struct(typeinfo)
  168. assert struct != None
  169. typeinfo = struct['data']
  170. for member in typeinfo:
  171. argname = member
  172. argentry = typeinfo[member]
  173. optional = False
  174. structured = False
  175. if member.startswith('*'):
  176. argname = member[1:]
  177. optional = True
  178. if isinstance(argentry, OrderedDict):
  179. structured = True
  180. yield (argname, argentry, optional, structured)
  181. def de_camel_case(name):
  182. new_name = ''
  183. for ch in name:
  184. if ch.isupper() and new_name:
  185. new_name += '_'
  186. if ch == '-':
  187. new_name += '_'
  188. else:
  189. new_name += ch.lower()
  190. return new_name
  191. def camel_case(name):
  192. new_name = ''
  193. first = True
  194. for ch in name:
  195. if ch in ['_', '-']:
  196. first = True
  197. elif first:
  198. new_name += ch.upper()
  199. first = False
  200. else:
  201. new_name += ch.lower()
  202. return new_name
  203. def c_var(name, protect=True):
  204. # ANSI X3J11/88-090, 3.1.1
  205. c89_words = set(['auto', 'break', 'case', 'char', 'const', 'continue',
  206. 'default', 'do', 'double', 'else', 'enum', 'extern', 'float',
  207. 'for', 'goto', 'if', 'int', 'long', 'register', 'return',
  208. 'short', 'signed', 'sizeof', 'static', 'struct', 'switch',
  209. 'typedef', 'union', 'unsigned', 'void', 'volatile', 'while'])
  210. # ISO/IEC 9899:1999, 6.4.1
  211. c99_words = set(['inline', 'restrict', '_Bool', '_Complex', '_Imaginary'])
  212. # ISO/IEC 9899:2011, 6.4.1
  213. c11_words = set(['_Alignas', '_Alignof', '_Atomic', '_Generic', '_Noreturn',
  214. '_Static_assert', '_Thread_local'])
  215. # GCC http://gcc.gnu.org/onlinedocs/gcc-4.7.1/gcc/C-Extensions.html
  216. # excluding _.*
  217. gcc_words = set(['asm', 'typeof'])
  218. # namespace pollution:
  219. polluted_words = set(['unix'])
  220. if protect and (name in c89_words | c99_words | c11_words | gcc_words | polluted_words):
  221. return "q_" + name
  222. return name.replace('-', '_').lstrip("*")
  223. def c_fun(name, protect=True):
  224. return c_var(name, protect).replace('.', '_')
  225. def c_list_type(name):
  226. return '%sList' % name
  227. def type_name(name):
  228. if type(name) == list:
  229. return c_list_type(name[0])
  230. return name
  231. enum_types = []
  232. struct_types = []
  233. union_types = []
  234. def add_struct(definition):
  235. global struct_types
  236. struct_types.append(definition)
  237. def find_struct(name):
  238. global struct_types
  239. for struct in struct_types:
  240. if struct['type'] == name:
  241. return struct
  242. return None
  243. def add_union(definition):
  244. global union_types
  245. union_types.append(definition)
  246. def find_union(name):
  247. global union_types
  248. for union in union_types:
  249. if union['union'] == name:
  250. return union
  251. return None
  252. def add_enum(name):
  253. global enum_types
  254. enum_types.append(name)
  255. def is_enum(name):
  256. global enum_types
  257. return (name in enum_types)
  258. def c_type(name):
  259. if name == 'str':
  260. return 'char *'
  261. elif name == 'int':
  262. return 'int64_t'
  263. elif (name == 'int8' or name == 'int16' or name == 'int32' or
  264. name == 'int64' or name == 'uint8' or name == 'uint16' or
  265. name == 'uint32' or name == 'uint64'):
  266. return name + '_t'
  267. elif name == 'size':
  268. return 'uint64_t'
  269. elif name == 'bool':
  270. return 'bool'
  271. elif name == 'number':
  272. return 'double'
  273. elif type(name) == list:
  274. return '%s *' % c_list_type(name[0])
  275. elif is_enum(name):
  276. return name
  277. elif name == None or len(name) == 0:
  278. return 'void'
  279. elif name == name.upper():
  280. return '%sEvent *' % camel_case(name)
  281. else:
  282. return '%s *' % name
  283. def genindent(count):
  284. ret = ""
  285. for i in range(count):
  286. ret += " "
  287. return ret
  288. indent_level = 0
  289. def push_indent(indent_amount=4):
  290. global indent_level
  291. indent_level += indent_amount
  292. def pop_indent(indent_amount=4):
  293. global indent_level
  294. indent_level -= indent_amount
  295. def cgen(code, **kwds):
  296. indent = genindent(indent_level)
  297. lines = code.split('\n')
  298. lines = map(lambda x: indent + x, lines)
  299. return '\n'.join(lines) % kwds + '\n'
  300. def mcgen(code, **kwds):
  301. return cgen('\n'.join(code.split('\n')[1:-1]), **kwds)
  302. def basename(filename):
  303. return filename.split("/")[-1]
  304. def guardname(filename):
  305. guard = basename(filename).rsplit(".", 1)[0]
  306. for substr in [".", " ", "-"]:
  307. guard = guard.replace(substr, "_")
  308. return guard.upper() + '_H'
  309. def guardstart(name):
  310. return mcgen('''
  311. #ifndef %(name)s
  312. #define %(name)s
  313. ''',
  314. name=guardname(name))
  315. def guardend(name):
  316. return mcgen('''
  317. #endif /* %(name)s */
  318. ''',
  319. name=guardname(name))