qapi.py 57.3 KB
Newer Older
1 2 3 4
#
# QAPI helper library
#
# Copyright IBM, Corp. 2011
E
Eric Blake 已提交
5
# Copyright (c) 2013-2015 Red Hat Inc.
6 7 8
#
# Authors:
#  Anthony Liguori <aliguori@us.ibm.com>
9
#  Markus Armbruster <armbru@redhat.com>
10
#
11 12
# This work is licensed under the terms of the GNU GPL, version 2.
# See the COPYING file in the top-level directory.
13

14
import re
15
from ordereddict import OrderedDict
16
import errno
17
import getopt
18
import os
19
import sys
20
import string
21

22
builtin_types = {
K
Kevin Wolf 已提交
23 24 25 26 27 28 29 30 31 32 33 34
    'str':      'QTYPE_QSTRING',
    'int':      'QTYPE_QINT',
    'number':   'QTYPE_QFLOAT',
    'bool':     'QTYPE_QBOOL',
    'int8':     'QTYPE_QINT',
    'int16':    'QTYPE_QINT',
    'int32':    'QTYPE_QINT',
    'int64':    'QTYPE_QINT',
    'uint8':    'QTYPE_QINT',
    'uint16':   'QTYPE_QINT',
    'uint32':   'QTYPE_QINT',
    'uint64':   'QTYPE_QINT',
35
    'size':     'QTYPE_QINT',
36
    'any':      None,           # any qtype_code possible, actually
K
Kevin Wolf 已提交
37 38
}

39 40 41 42
# Whitelist of commands allowed to return a non-dictionary
returns_whitelist = [
    # From QMP:
    'human-monitor-command',
43
    'qom-get',
44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60
    'query-migrate-cache-size',
    'query-tpm-models',
    'query-tpm-types',
    'ringbuf-read',

    # From QGA:
    'guest-file-open',
    'guest-fsfreeze-freeze',
    'guest-fsfreeze-freeze-list',
    'guest-fsfreeze-status',
    'guest-fsfreeze-thaw',
    'guest-get-time',
    'guest-set-vcpus',
    'guest-sync',
    'guest-sync-delimited',
]

61 62 63 64 65 66
enum_types = []
struct_types = []
union_types = []
events = []
all_names = {}

67 68 69 70
#
# Parsing the schema into expressions
#

E
Eric Blake 已提交
71

72 73 74 75 76 77 78 79
def error_path(parent):
    res = ""
    while parent:
        res = ("In file included from %s:%d:\n" % (parent['file'],
                                                   parent['line'])) + res
        parent = parent['parent']
    return res

E
Eric Blake 已提交
80

81 82
class QAPISchemaError(Exception):
    def __init__(self, schema, msg):
83
        Exception.__init__(self)
84
        self.fname = schema.fname
85
        self.msg = msg
86 87 88 89
        self.col = 1
        self.line = schema.line
        for ch in schema.src[schema.line_pos:schema.pos]:
            if ch == '\t':
90 91 92
                self.col = (self.col + 7) % 8 + 1
            else:
                self.col += 1
93
        self.info = schema.incl_info
94 95

    def __str__(self):
96
        return error_path(self.info) + \
97
            "%s:%d:%d: %s" % (self.fname, self.line, self.col, self.msg)
98

E
Eric Blake 已提交
99

100 101
class QAPIExprError(Exception):
    def __init__(self, expr_info, msg):
102
        Exception.__init__(self)
103
        assert expr_info
104
        self.info = expr_info
105 106 107
        self.msg = msg

    def __str__(self):
108 109
        return error_path(self.info['parent']) + \
            "%s:%d: %s" % (self.info['file'], self.info['line'], self.msg)
110

E
Eric Blake 已提交
111

112
class QAPISchemaParser(object):
113

E
Eric Blake 已提交
114
    def __init__(self, fp, previously_included=[], incl_info=None):
115
        abs_fname = os.path.abspath(fp.name)
116
        fname = fp.name
117 118 119
        self.fname = fname
        previously_included.append(abs_fname)
        self.incl_info = incl_info
120 121 122 123
        self.src = fp.read()
        if self.src == '' or self.src[-1] != '\n':
            self.src += '\n'
        self.cursor = 0
124 125
        self.line = 1
        self.line_pos = 0
126 127 128
        self.exprs = []
        self.accept()

E
Eric Blake 已提交
129
        while self.tok is not None:
130 131
            expr_info = {'file': fname, 'line': self.line,
                         'parent': self.incl_info}
132 133 134
            expr = self.get_expr(False)
            if isinstance(expr, dict) and "include" in expr:
                if len(expr) != 1:
E
Eric Blake 已提交
135 136
                    raise QAPIExprError(expr_info,
                                        "Invalid 'include' directive")
137 138 139
                include = expr["include"]
                if not isinstance(include, str):
                    raise QAPIExprError(expr_info,
E
Eric Blake 已提交
140
                                        "Value of 'include' must be a string")
141 142
                incl_abs_fname = os.path.join(os.path.dirname(abs_fname),
                                              include)
143 144 145 146
                # catch inclusion cycle
                inf = expr_info
                while inf:
                    if incl_abs_fname == os.path.abspath(inf['file']):
147 148
                        raise QAPIExprError(expr_info, "Inclusion loop for %s"
                                            % include)
149
                    inf = inf['parent']
B
Benoît Canet 已提交
150
                # skip multiple include of the same file
151
                if incl_abs_fname in previously_included:
B
Benoît Canet 已提交
152
                    continue
153
                try:
154
                    fobj = open(incl_abs_fname, 'r')
155
                except IOError, e:
156 157
                    raise QAPIExprError(expr_info,
                                        '%s: %s' % (e.strerror, include))
158 159
                exprs_include = QAPISchemaParser(fobj, previously_included,
                                                 expr_info)
160 161 162 163 164
                self.exprs.extend(exprs_include.exprs)
            else:
                expr_elem = {'expr': expr,
                             'info': expr_info}
                self.exprs.append(expr_elem)
165 166 167 168

    def accept(self):
        while True:
            self.tok = self.src[self.cursor]
169
            self.pos = self.cursor
170 171 172
            self.cursor += 1
            self.val = None

173
            if self.tok == '#':
174
                self.cursor = self.src.find('\n', self.cursor)
175
            elif self.tok in "{}:,[]":
176 177 178 179 180 181 182 183
                return
            elif self.tok == "'":
                string = ''
                esc = False
                while True:
                    ch = self.src[self.cursor]
                    self.cursor += 1
                    if ch == '\n':
184 185
                        raise QAPISchemaError(self,
                                              'Missing terminating "\'"')
186
                    if esc:
187 188 189 190 191 192 193 194 195 196 197 198
                        if ch == 'b':
                            string += '\b'
                        elif ch == 'f':
                            string += '\f'
                        elif ch == 'n':
                            string += '\n'
                        elif ch == 'r':
                            string += '\r'
                        elif ch == 't':
                            string += '\t'
                        elif ch == 'u':
                            value = 0
E
Eric Blake 已提交
199
                            for _ in range(0, 4):
200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220
                                ch = self.src[self.cursor]
                                self.cursor += 1
                                if ch not in "0123456789abcdefABCDEF":
                                    raise QAPISchemaError(self,
                                                          '\\u escape needs 4 '
                                                          'hex digits')
                                value = (value << 4) + int(ch, 16)
                            # If Python 2 and 3 didn't disagree so much on
                            # how to handle Unicode, then we could allow
                            # Unicode string defaults.  But most of QAPI is
                            # ASCII-only, so we aren't losing much for now.
                            if not value or value > 0x7f:
                                raise QAPISchemaError(self,
                                                      'For now, \\u escape '
                                                      'only supports non-zero '
                                                      'values up to \\u007f')
                            string += chr(value)
                        elif ch in "\\/'\"":
                            string += ch
                        else:
                            raise QAPISchemaError(self,
E
Eric Blake 已提交
221
                                                  "Unknown escape \\%s" % ch)
222 223 224 225 226 227 228 229
                        esc = False
                    elif ch == "\\":
                        esc = True
                    elif ch == "'":
                        self.val = string
                        return
                    else:
                        string += ch
230 231 232 233 234 235 236 237 238 239 240 241
            elif self.src.startswith("true", self.pos):
                self.val = True
                self.cursor += 3
                return
            elif self.src.startswith("false", self.pos):
                self.val = False
                self.cursor += 4
                return
            elif self.src.startswith("null", self.pos):
                self.val = None
                self.cursor += 3
                return
242 243 244 245
            elif self.tok == '\n':
                if self.cursor == len(self.src):
                    self.tok = None
                    return
246 247
                self.line += 1
                self.line_pos = self.cursor
248 249
            elif not self.tok.isspace():
                raise QAPISchemaError(self, 'Stray "%s"' % self.tok)
250 251 252

    def get_members(self):
        expr = OrderedDict()
253 254 255 256 257 258
        if self.tok == '}':
            self.accept()
            return expr
        if self.tok != "'":
            raise QAPISchemaError(self, 'Expected string or "}"')
        while True:
259 260
            key = self.val
            self.accept()
261 262 263
            if self.tok != ':':
                raise QAPISchemaError(self, 'Expected ":"')
            self.accept()
264 265
            if key in expr:
                raise QAPISchemaError(self, 'Duplicate key "%s"' % key)
266
            expr[key] = self.get_expr(True)
267
            if self.tok == '}':
268
                self.accept()
269 270 271 272 273 274
                return expr
            if self.tok != ',':
                raise QAPISchemaError(self, 'Expected "," or "}"')
            self.accept()
            if self.tok != "'":
                raise QAPISchemaError(self, 'Expected string')
275 276 277

    def get_values(self):
        expr = []
278 279 280
        if self.tok == ']':
            self.accept()
            return expr
E
Eric Blake 已提交
281
        if self.tok not in "{['tfn":
282 283
            raise QAPISchemaError(self, 'Expected "{", "[", "]", string, '
                                  'boolean or "null"')
284
        while True:
285
            expr.append(self.get_expr(True))
286
            if self.tok == ']':
287
                self.accept()
288 289 290 291
                return expr
            if self.tok != ',':
                raise QAPISchemaError(self, 'Expected "," or "]"')
            self.accept()
292

293 294 295
    def get_expr(self, nested):
        if self.tok != '{' and not nested:
            raise QAPISchemaError(self, 'Expected "{"')
296 297 298 299 300 301
        if self.tok == '{':
            self.accept()
            expr = self.get_members()
        elif self.tok == '[':
            self.accept()
            expr = self.get_values()
302
        elif self.tok in "'tfn":
303 304
            expr = self.val
            self.accept()
305 306
        else:
            raise QAPISchemaError(self, 'Expected "{", "[" or string')
307
        return expr
K
Kevin Wolf 已提交
308

309 310
#
# Semantic analysis of schema expressions
311 312
# TODO fold into QAPISchema
# TODO catching name collisions in generated code would be nice
313 314
#

E
Eric Blake 已提交
315

316 317 318 319 320 321
def find_base_fields(base):
    base_struct_define = find_struct(base)
    if not base_struct_define:
        return None
    return base_struct_define['data']

E
Eric Blake 已提交
322

323 324
# Return the qtype of an alternate branch, or None on error.
def find_alternate_member_qtype(qapi_type):
E
Eric Blake 已提交
325
    if qapi_type in builtin_types:
E
Eric Blake 已提交
326 327 328 329 330
        return builtin_types[qapi_type]
    elif find_struct(qapi_type):
        return "QTYPE_QDICT"
    elif find_enum(qapi_type):
        return "QTYPE_QSTRING"
331 332
    elif find_union(qapi_type):
        return "QTYPE_QDICT"
E
Eric Blake 已提交
333 334
    return None

E
Eric Blake 已提交
335

336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354
# Return the discriminator enum define if discriminator is specified as an
# enum type, otherwise return None.
def discriminator_find_enum_define(expr):
    base = expr.get('base')
    discriminator = expr.get('discriminator')

    if not (discriminator and base):
        return None

    base_fields = find_base_fields(base)
    if not base_fields:
        return None

    discriminator_type = base_fields.get(discriminator)
    if not discriminator_type:
        return None

    return find_enum(discriminator_type)

E
Eric Blake 已提交
355

356 357
# FIXME should enforce "other than downstream extensions [...], all
# names should begin with a letter".
E
Eric Blake 已提交
358
valid_name = re.compile('^[a-zA-Z_][a-zA-Z0-9_.-]*$')
E
Eric Blake 已提交
359 360 361 362


def check_name(expr_info, source, name, allow_optional=False,
               enum_member=False):
E
Eric Blake 已提交
363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378
    global valid_name
    membername = name

    if not isinstance(name, str):
        raise QAPIExprError(expr_info,
                            "%s requires a string name" % source)
    if name.startswith('*'):
        membername = name[1:]
        if not allow_optional:
            raise QAPIExprError(expr_info,
                                "%s does not allow optional name '%s'"
                                % (source, name))
    # Enum members can start with a digit, because the generated C
    # code always prefixes it with the enum name
    if enum_member:
        membername = '_' + membername
379 380 381
    # Reserve the entire 'q_' namespace for c_name()
    if not valid_name.match(membername) or \
       c_name(membername, False).startswith('q_'):
E
Eric Blake 已提交
382 383 384
        raise QAPIExprError(expr_info,
                            "%s uses invalid name '%s'" % (source, name))

E
Eric Blake 已提交
385 386

def add_name(name, info, meta, implicit=False):
387 388
    global all_names
    check_name(info, "'%s'" % meta, name)
389 390
    # FIXME should reject names that differ only in '_' vs. '.'
    # vs. '-', because they're liable to clash in generated C.
391 392 393 394
    if name in all_names:
        raise QAPIExprError(info,
                            "%s '%s' is already defined"
                            % (all_names[name], name))
395
    if not implicit and (name.endswith('Kind') or name.endswith('List')):
396
        raise QAPIExprError(info,
397 398
                            "%s '%s' should not end in '%s'"
                            % (meta, name, name[-4:]))
399 400
    all_names[name] = meta

E
Eric Blake 已提交
401

402 403 404 405 406 407
def add_struct(definition, info):
    global struct_types
    name = definition['struct']
    add_name(name, info, 'struct')
    struct_types.append(definition)

E
Eric Blake 已提交
408

409 410 411 412 413 414 415
def find_struct(name):
    global struct_types
    for struct in struct_types:
        if struct['struct'] == name:
            return struct
    return None

E
Eric Blake 已提交
416

417 418 419 420 421 422
def add_union(definition, info):
    global union_types
    name = definition['union']
    add_name(name, info, 'union')
    union_types.append(definition)

E
Eric Blake 已提交
423

424 425 426 427 428 429 430
def find_union(name):
    global union_types
    for union in union_types:
        if union['union'] == name:
            return union
    return None

E
Eric Blake 已提交
431 432

def add_enum(name, info, enum_values=None, implicit=False):
433 434 435 436
    global enum_types
    add_name(name, info, 'enum', implicit)
    enum_types.append({"enum_name": name, "enum_values": enum_values})

E
Eric Blake 已提交
437

438 439 440 441 442 443 444
def find_enum(name):
    global enum_types
    for enum in enum_types:
        if enum['enum_name'] == name:
            return enum
    return None

E
Eric Blake 已提交
445

446
def is_enum(name):
E
Eric Blake 已提交
447 448
    return find_enum(name) is not None

449

E
Eric Blake 已提交
450 451 452
def check_type(expr_info, source, value, allow_array=False,
               allow_dict=False, allow_optional=False,
               allow_metas=[]):
453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470
    global all_names

    if value is None:
        return

    # Check if array type for value is okay
    if isinstance(value, list):
        if not allow_array:
            raise QAPIExprError(expr_info,
                                "%s cannot be an array" % source)
        if len(value) != 1 or not isinstance(value[0], str):
            raise QAPIExprError(expr_info,
                                "%s: array type must contain single type name"
                                % source)
        value = value[0]

    # Check if type name for value is okay
    if isinstance(value, str):
E
Eric Blake 已提交
471
        if value not in all_names:
472 473
            raise QAPIExprError(expr_info,
                                "%s uses unknown type '%s'"
474
                                % (source, value))
475 476 477
        if not all_names[value] in allow_metas:
            raise QAPIExprError(expr_info,
                                "%s cannot use %s type '%s'"
478
                                % (source, all_names[value], value))
479 480 481 482 483
        return

    if not allow_dict:
        raise QAPIExprError(expr_info,
                            "%s should be a type name" % source)
484 485 486 487 488 489

    if not isinstance(value, OrderedDict):
        raise QAPIExprError(expr_info,
                            "%s should be a dictionary or type name" % source)

    # value is a dictionary, check that each member is okay
490
    for (key, arg) in value.items():
E
Eric Blake 已提交
491 492
        check_name(expr_info, "Member of %s" % source, key,
                   allow_optional=allow_optional)
493 494 495 496
        if c_name(key, False).startswith('has_'):
            raise QAPIExprError(expr_info,
                                "Member of %s uses reserved name '%s'"
                                % (source, key))
497 498
        # Todo: allow dictionaries to represent default values of
        # an optional argument.
499
        check_type(expr_info, "Member '%s' of %s" % (key, source), arg,
500
                   allow_array=True,
501
                   allow_metas=['built-in', 'union', 'alternate', 'struct',
502
                                'enum'])
503

E
Eric Blake 已提交
504 505

def check_member_clash(expr_info, base_name, data, source=""):
506 507 508 509 510 511 512 513 514 515 516 517 518
    base = find_struct(base_name)
    assert base
    base_members = base['data']
    for key in data.keys():
        if key.startswith('*'):
            key = key[1:]
        if key in base_members or "*" + key in base_members:
            raise QAPIExprError(expr_info,
                                "Member name '%s'%s clashes with base '%s'"
                                % (key, source, base_name))
    if base.get('base'):
        check_member_clash(expr_info, base['base'], data, source)

E
Eric Blake 已提交
519

520 521
def check_command(expr, expr_info):
    name = expr['command']
522

523
    check_type(expr_info, "'data' for command '%s'" % name,
E
Eric Blake 已提交
524
               expr.get('data'), allow_dict=True, allow_optional=True,
525
               allow_metas=['struct'])
526 527 528
    returns_meta = ['union', 'struct']
    if name in returns_whitelist:
        returns_meta += ['built-in', 'alternate', 'enum']
529
    check_type(expr_info, "'returns' for command '%s'" % name,
530
               expr.get('returns'), allow_array=True,
531
               allow_optional=True, allow_metas=returns_meta)
532

E
Eric Blake 已提交
533

W
Wenchao Xia 已提交
534
def check_event(expr, expr_info):
535 536 537 538 539 540
    global events
    name = expr['event']

    if name.upper() == 'MAX':
        raise QAPIExprError(expr_info, "Event name 'MAX' cannot be created")
    events.append(name)
541
    check_type(expr_info, "'data' for event '%s'" % name,
E
Eric Blake 已提交
542
               expr.get('data'), allow_dict=True, allow_optional=True,
543
               allow_metas=['struct'])
W
Wenchao Xia 已提交
544

E
Eric Blake 已提交
545

546 547 548 549 550
def check_union(expr, expr_info):
    name = expr['union']
    base = expr.get('base')
    discriminator = expr.get('discriminator')
    members = expr['data']
551 552
    values = {'MAX': '(automatic)', 'KIND': '(automatic)',
              'TYPE': '(automatic)'}
553

554 555 556 557
    # Two types of unions, determined by discriminator.

    # With no discriminator it is a simple union.
    if discriminator is None:
558
        enum_define = None
E
Eric Blake 已提交
559
        allow_metas = ['built-in', 'union', 'alternate', 'struct', 'enum']
E
Eric Blake 已提交
560 561
        if base is not None:
            raise QAPIExprError(expr_info,
562
                                "Simple union '%s' must not have a base"
E
Eric Blake 已提交
563
                                % name)
564 565 566

    # Else, it's a flat union.
    else:
E
Eric Blake 已提交
567
        # The object must have a string member 'base'.
568 569 570
        check_type(expr_info, "'base' for union '%s'" % name,
                   base, allow_metas=['struct'])
        if not base:
571
            raise QAPIExprError(expr_info,
572
                                "Flat union '%s' must have a base"
573
                                % name)
E
Eric Blake 已提交
574
        base_fields = find_base_fields(base)
575
        assert base_fields
E
Eric Blake 已提交
576

E
Eric Blake 已提交
577
        # The value of member 'discriminator' must name a non-optional
578
        # member of the base struct.
E
Eric Blake 已提交
579 580
        check_name(expr_info, "Discriminator of flat union '%s'" % name,
                   discriminator)
581 582 583 584
        discriminator_type = base_fields.get(discriminator)
        if not discriminator_type:
            raise QAPIExprError(expr_info,
                                "Discriminator '%s' is not a member of base "
585
                                "struct '%s'"
586 587
                                % (discriminator, base))
        enum_define = find_enum(discriminator_type)
E
Eric Blake 已提交
588
        allow_metas = ['struct']
589 590 591 592 593
        # Do not allow string discriminator
        if not enum_define:
            raise QAPIExprError(expr_info,
                                "Discriminator '%s' must be of enumeration "
                                "type" % discriminator)
594 595 596

    # Check every branch
    for (key, value) in members.items():
E
Eric Blake 已提交
597 598
        check_name(expr_info, "Member of union '%s'" % name, key)

599
        # Each value must name a known type; furthermore, in flat unions,
600
        # branches must be a struct with no overlapping member names
601
        check_type(expr_info, "Member '%s' of union '%s'" % (key, name),
602
                   value, allow_array=not base, allow_metas=allow_metas)
603 604 605 606 607
        if base:
            branch_struct = find_struct(value)
            assert branch_struct
            check_member_clash(expr_info, base, branch_struct['data'],
                               " of branch '%s'" % key)
608

E
Eric Blake 已提交
609
        # If the discriminator names an enum type, then all members
610 611
        # of 'data' must also be members of the enum type, which in turn
        # must not collide with the discriminator name.
E
Eric Blake 已提交
612
        if enum_define:
E
Eric Blake 已提交
613
            if key not in enum_define['enum_values']:
E
Eric Blake 已提交
614 615 616 617
                raise QAPIExprError(expr_info,
                                    "Discriminator value '%s' is not found in "
                                    "enum '%s'" %
                                    (key, enum_define["enum_name"]))
618 619 620 621 622
            if discriminator in enum_define['enum_values']:
                raise QAPIExprError(expr_info,
                                    "Discriminator name '%s' collides with "
                                    "enum value in '%s'" %
                                    (discriminator, enum_define["enum_name"]))
E
Eric Blake 已提交
623 624 625

        # Otherwise, check for conflicts in the generated enum
        else:
626
            c_key = camel_to_upper(key)
E
Eric Blake 已提交
627 628 629 630 631 632
            if c_key in values:
                raise QAPIExprError(expr_info,
                                    "Union '%s' member '%s' clashes with '%s'"
                                    % (name, key, values[c_key]))
            values[c_key] = key

E
Eric Blake 已提交
633

634
def check_alternate(expr, expr_info):
635
    name = expr['alternate']
636
    members = expr['data']
E
Eric Blake 已提交
637
    values = {'MAX': '(automatic)'}
638 639 640 641
    types_seen = {}

    # Check every branch
    for (key, value) in members.items():
E
Eric Blake 已提交
642 643
        check_name(expr_info, "Member of alternate '%s'" % name, key)

644
        # Check for conflicts in the generated enum
645
        c_key = camel_to_upper(key)
646 647
        if c_key in values:
            raise QAPIExprError(expr_info,
648 649
                                "Alternate '%s' member '%s' clashes with '%s'"
                                % (name, key, values[c_key]))
650
        values[c_key] = key
E
Eric Blake 已提交
651

652
        # Ensure alternates have no type conflicts.
653 654 655
        check_type(expr_info, "Member '%s' of alternate '%s'" % (key, name),
                   value,
                   allow_metas=['built-in', 'union', 'struct', 'enum'])
656
        qtype = find_alternate_member_qtype(value)
657
        assert qtype
658 659
        if qtype in types_seen:
            raise QAPIExprError(expr_info,
660
                                "Alternate '%s' member '%s' can't "
661 662 663
                                "be distinguished from member '%s'"
                                % (name, key, types_seen[qtype]))
        types_seen[qtype] = key
664

E
Eric Blake 已提交
665

666 667 668
def check_enum(expr, expr_info):
    name = expr['enum']
    members = expr.get('data')
669
    prefix = expr.get('prefix')
E
Eric Blake 已提交
670
    values = {'MAX': '(automatic)'}
671 672 673 674

    if not isinstance(members, list):
        raise QAPIExprError(expr_info,
                            "Enum '%s' requires an array for 'data'" % name)
675 676 677
    if prefix is not None and not isinstance(prefix, str):
        raise QAPIExprError(expr_info,
                            "Enum '%s' requires a string for 'prefix'" % name)
678
    for member in members:
E
Eric Blake 已提交
679
        check_name(expr_info, "Member of enum '%s'" % name, member,
E
Eric Blake 已提交
680
                   enum_member=True)
681
        key = camel_to_upper(member)
682 683 684 685 686 687
        if key in values:
            raise QAPIExprError(expr_info,
                                "Enum '%s' member '%s' clashes with '%s'"
                                % (name, member, values[key]))
        values[key] = member

E
Eric Blake 已提交
688

689
def check_struct(expr, expr_info):
690
    name = expr['struct']
691 692
    members = expr['data']

693
    check_type(expr_info, "'data' for struct '%s'" % name, members,
E
Eric Blake 已提交
694
               allow_dict=True, allow_optional=True)
695
    check_type(expr_info, "'base' for struct '%s'" % name, expr.get('base'),
696
               allow_metas=['struct'])
697 698
    if expr.get('base'):
        check_member_clash(expr_info, expr['base'], expr['data'])
699

E
Eric Blake 已提交
700

701 702 703 704 705 706 707
def check_keys(expr_elem, meta, required, optional=[]):
    expr = expr_elem['expr']
    info = expr_elem['info']
    name = expr[meta]
    if not isinstance(name, str):
        raise QAPIExprError(info,
                            "'%s' key must have a string value" % meta)
E
Eric Blake 已提交
708
    required = required + [meta]
709
    for (key, value) in expr.items():
E
Eric Blake 已提交
710
        if key not in required and key not in optional:
711 712 713
            raise QAPIExprError(info,
                                "Unknown key '%s' in %s '%s'"
                                % (key, meta, name))
E
Eric Blake 已提交
714
        if (key == 'gen' or key == 'success-response') and value is not False:
715 716 717
            raise QAPIExprError(info,
                                "'%s' of %s '%s' should only use false value"
                                % (key, meta, name))
718
    for key in required:
E
Eric Blake 已提交
719
        if key not in expr:
720 721 722 723
            raise QAPIExprError(info,
                                "Key '%s' is missing from %s '%s'"
                                % (key, meta, name))

E
Eric Blake 已提交
724

725
def check_exprs(exprs):
726 727
    global all_names

728 729 730 731 732 733
    # Learn the types and check for valid expression keys
    for builtin in builtin_types.keys():
        all_names[builtin] = 'built-in'
    for expr_elem in exprs:
        expr = expr_elem['expr']
        info = expr_elem['info']
E
Eric Blake 已提交
734
        if 'enum' in expr:
735
            check_keys(expr_elem, 'enum', ['data'], ['prefix'])
736
            add_enum(expr['enum'], info, expr['data'])
E
Eric Blake 已提交
737
        elif 'union' in expr:
738 739 740
            check_keys(expr_elem, 'union', ['data'],
                       ['base', 'discriminator'])
            add_union(expr, info)
E
Eric Blake 已提交
741
        elif 'alternate' in expr:
742 743
            check_keys(expr_elem, 'alternate', ['data'])
            add_name(expr['alternate'], info, 'alternate')
E
Eric Blake 已提交
744
        elif 'struct' in expr:
745 746
            check_keys(expr_elem, 'struct', ['data'], ['base'])
            add_struct(expr, info)
E
Eric Blake 已提交
747
        elif 'command' in expr:
748 749 750
            check_keys(expr_elem, 'command', [],
                       ['data', 'returns', 'gen', 'success-response'])
            add_name(expr['command'], info, 'command')
E
Eric Blake 已提交
751
        elif 'event' in expr:
752 753 754 755 756
            check_keys(expr_elem, 'event', [], ['data'])
            add_name(expr['event'], info, 'event')
        else:
            raise QAPIExprError(expr_elem['info'],
                                "Expression is missing metatype")
757

758 759 760
    # Try again for hidden UnionKind enum
    for expr_elem in exprs:
        expr = expr_elem['expr']
E
Eric Blake 已提交
761
        if 'union' in expr:
762 763
            if not discriminator_find_enum_define(expr):
                add_enum('%sKind' % expr['union'], expr_elem['info'],
764
                         implicit=True)
E
Eric Blake 已提交
765
        elif 'alternate' in expr:
766 767 768 769 770 771 772
            add_enum('%sKind' % expr['alternate'], expr_elem['info'],
                     implicit=True)

    # Validate that exprs make sense
    for expr_elem in exprs:
        expr = expr_elem['expr']
        info = expr_elem['info']
773

E
Eric Blake 已提交
774
        if 'enum' in expr:
775
            check_enum(expr, info)
E
Eric Blake 已提交
776
        elif 'union' in expr:
777
            check_union(expr, info)
E
Eric Blake 已提交
778
        elif 'alternate' in expr:
779
            check_alternate(expr, info)
E
Eric Blake 已提交
780
        elif 'struct' in expr:
781
            check_struct(expr, info)
E
Eric Blake 已提交
782
        elif 'command' in expr:
783
            check_command(expr, info)
E
Eric Blake 已提交
784
        elif 'event' in expr:
785 786 787 788
            check_event(expr, info)
        else:
            assert False, 'unexpected meta type'

789 790 791 792 793 794 795 796 797 798 799
    return exprs


#
# Schema compiler frontend
#

class QAPISchemaEntity(object):
    def __init__(self, name, info):
        assert isinstance(name, str)
        self.name = name
800 801 802 803 804
        # For explicitly defined entities, info points to the (explicit)
        # definition.  For builtins (and their arrays), info is None.
        # For implicitly defined entities, info points to a place that
        # triggered the implicit definition (there may be more than one
        # such place).
805 806
        self.info = info

807 808 809
    def c_name(self):
        return c_name(self.name)

810 811 812
    def check(self, schema):
        pass

813 814 815
    def is_implicit(self):
        return not self.info

M
Markus Armbruster 已提交
816 817 818 819 820 821 822 823 824 825 826
    def visit(self, visitor):
        pass


class QAPISchemaVisitor(object):
    def visit_begin(self, schema):
        pass

    def visit_end(self):
        pass

827 828 829 830
    def visit_needed(self, entity):
        # Default to visiting everything
        return True

M
Markus Armbruster 已提交
831 832 833 834 835 836 837 838 839 840 841 842
    def visit_builtin_type(self, name, info, json_type):
        pass

    def visit_enum_type(self, name, info, values, prefix):
        pass

    def visit_array_type(self, name, info, element_type):
        pass

    def visit_object_type(self, name, info, base, members, variants):
        pass

843 844 845
    def visit_object_type_flat(self, name, info, members, variants):
        pass

M
Markus Armbruster 已提交
846 847 848 849 850 851 852 853 854 855
    def visit_alternate_type(self, name, info, variants):
        pass

    def visit_command(self, name, info, arg_type, ret_type,
                      gen, success_response):
        pass

    def visit_event(self, name, info, arg_type):
        pass

856 857

class QAPISchemaType(QAPISchemaEntity):
858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875
    def c_type(self, is_param=False):
        return c_name(self.name) + pointer_suffix

    def c_null(self):
        return 'NULL'

    def json_type(self):
        pass

    def alternate_qtype(self):
        json2qtype = {
            'string':  'QTYPE_QSTRING',
            'number':  'QTYPE_QFLOAT',
            'int':     'QTYPE_QINT',
            'boolean': 'QTYPE_QBOOL',
            'object':  'QTYPE_QDICT'
        }
        return json2qtype.get(self.json_type())
876 877 878


class QAPISchemaBuiltinType(QAPISchemaType):
879
    def __init__(self, name, json_type, c_type, c_null):
880
        QAPISchemaType.__init__(self, name, None)
881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900
        assert not c_type or isinstance(c_type, str)
        assert json_type in ('string', 'number', 'int', 'boolean', 'null',
                             'value')
        self._json_type_name = json_type
        self._c_type_name = c_type
        self._c_null_val = c_null

    def c_name(self):
        return self.name

    def c_type(self, is_param=False):
        if is_param and self.name == 'str':
            return 'const ' + self._c_type_name
        return self._c_type_name

    def c_null(self):
        return self._c_null_val

    def json_type(self):
        return self._json_type_name
901

M
Markus Armbruster 已提交
902 903 904
    def visit(self, visitor):
        visitor.visit_builtin_type(self.name, self.info, self.json_type())

905 906 907 908 909 910 911 912 913 914 915 916 917

class QAPISchemaEnumType(QAPISchemaType):
    def __init__(self, name, info, values, prefix):
        QAPISchemaType.__init__(self, name, info)
        for v in values:
            assert isinstance(v, str)
        assert prefix is None or isinstance(prefix, str)
        self.values = values
        self.prefix = prefix

    def check(self, schema):
        assert len(set(self.values)) == len(self.values)

918 919
    def is_implicit(self):
        # See QAPISchema._make_implicit_enum_type()
920
        return self.name.endswith('Kind')
921

922 923 924 925 926 927 928 929 930 931
    def c_type(self, is_param=False):
        return c_name(self.name)

    def c_null(self):
        return c_enum_const(self.name, (self.values + ['MAX'])[0],
                            self.prefix)

    def json_type(self):
        return 'string'

M
Markus Armbruster 已提交
932 933 934 935
    def visit(self, visitor):
        visitor.visit_enum_type(self.name, self.info,
                                self.values, self.prefix)

936 937 938 939 940 941 942 943 944 945 946 947

class QAPISchemaArrayType(QAPISchemaType):
    def __init__(self, name, info, element_type):
        QAPISchemaType.__init__(self, name, info)
        assert isinstance(element_type, str)
        self._element_type_name = element_type
        self.element_type = None

    def check(self, schema):
        self.element_type = schema.lookup_type(self._element_type_name)
        assert self.element_type

948 949 950
    def is_implicit(self):
        return True

951 952 953
    def json_type(self):
        return 'array'

M
Markus Armbruster 已提交
954 955 956
    def visit(self, visitor):
        visitor.visit_array_type(self.name, self.info, self.element_type)

957 958 959 960 961 962 963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985 986

class QAPISchemaObjectType(QAPISchemaType):
    def __init__(self, name, info, base, local_members, variants):
        QAPISchemaType.__init__(self, name, info)
        assert base is None or isinstance(base, str)
        for m in local_members:
            assert isinstance(m, QAPISchemaObjectTypeMember)
        assert (variants is None or
                isinstance(variants, QAPISchemaObjectTypeVariants))
        self._base_name = base
        self.base = None
        self.local_members = local_members
        self.variants = variants
        self.members = None

    def check(self, schema):
        assert self.members is not False        # not running in cycles
        if self.members:
            return
        self.members = False                    # mark as being checked
        if self._base_name:
            self.base = schema.lookup_type(self._base_name)
            assert isinstance(self.base, QAPISchemaObjectType)
            assert not self.base.variants       # not implemented
            self.base.check(schema)
            members = list(self.base.members)
        else:
            members = []
        seen = {}
        for m in members:
987
            assert c_name(m.name) not in seen
988 989 990 991 992 993 994
            seen[m.name] = m
        for m in self.local_members:
            m.check(schema, members, seen)
        if self.variants:
            self.variants.check(schema, members, seen)
        self.members = members

995 996 997 998
    def is_implicit(self):
        # See QAPISchema._make_implicit_object_type()
        return self.name[0] == ':'

999
    def c_name(self):
1000
        assert not self.is_implicit()
1001 1002 1003
        return QAPISchemaType.c_name(self)

    def c_type(self, is_param=False):
1004
        assert not self.is_implicit()
1005 1006 1007 1008 1009
        return QAPISchemaType.c_type(self)

    def json_type(self):
        return 'object'

M
Markus Armbruster 已提交
1010 1011 1012
    def visit(self, visitor):
        visitor.visit_object_type(self.name, self.info,
                                  self.base, self.local_members, self.variants)
1013 1014
        visitor.visit_object_type_flat(self.name, self.info,
                                       self.members, self.variants)
M
Markus Armbruster 已提交
1015

1016 1017 1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031 1032 1033 1034 1035

class QAPISchemaObjectTypeMember(object):
    def __init__(self, name, typ, optional):
        assert isinstance(name, str)
        assert isinstance(typ, str)
        assert isinstance(optional, bool)
        self.name = name
        self._type_name = typ
        self.type = None
        self.optional = optional

    def check(self, schema, all_members, seen):
        assert self.name not in seen
        self.type = schema.lookup_type(self._type_name)
        assert self.type
        all_members.append(self)
        seen[self.name] = self


class QAPISchemaObjectTypeVariants(object):
1036 1037 1038 1039 1040 1041 1042 1043
    def __init__(self, tag_name, tag_member, variants):
        # Flat unions pass tag_name but not tag_member.
        # Simple unions and alternates pass tag_member but not tag_name.
        # After check(), tag_member is always set, and tag_name remains
        # a reliable witness of being used by a flat union.
        assert bool(tag_member) != bool(tag_name)
        assert (isinstance(tag_name, str) or
                isinstance(tag_member, QAPISchemaObjectTypeMember))
1044 1045 1046
        for v in variants:
            assert isinstance(v, QAPISchemaObjectTypeVariant)
        self.tag_name = tag_name
1047
        self.tag_member = tag_member
1048 1049 1050 1051 1052 1053 1054 1055 1056 1057 1058 1059
        self.variants = variants

    def check(self, schema, members, seen):
        if self.tag_name:
            self.tag_member = seen[self.tag_name]
        else:
            self.tag_member.check(schema, members, seen)
        assert isinstance(self.tag_member.type, QAPISchemaEnumType)
        for v in self.variants:
            vseen = dict(seen)
            v.check(schema, self.tag_member.type, vseen)

E
Eric Blake 已提交
1060

1061 1062 1063 1064 1065 1066 1067 1068
class QAPISchemaObjectTypeVariant(QAPISchemaObjectTypeMember):
    def __init__(self, name, typ):
        QAPISchemaObjectTypeMember.__init__(self, name, typ, False)

    def check(self, schema, tag_type, seen):
        QAPISchemaObjectTypeMember.check(self, schema, [], seen)
        assert self.name in tag_type.values

1069 1070 1071
    # This function exists to support ugly simple union special cases
    # TODO get rid of them, and drop the function
    def simple_union_type(self):
1072 1073
        if (self.type.is_implicit() and
                isinstance(self.type, QAPISchemaObjectType)):
1074 1075 1076 1077 1078
            assert len(self.type.members) == 1
            assert not self.type.variants
            return self.type.members[0].type
        return None

1079 1080 1081 1082 1083 1084 1085 1086 1087 1088 1089

class QAPISchemaAlternateType(QAPISchemaType):
    def __init__(self, name, info, variants):
        QAPISchemaType.__init__(self, name, info)
        assert isinstance(variants, QAPISchemaObjectTypeVariants)
        assert not variants.tag_name
        self.variants = variants

    def check(self, schema):
        self.variants.check(schema, [], {})

1090 1091 1092
    def json_type(self):
        return 'value'

M
Markus Armbruster 已提交
1093 1094 1095
    def visit(self, visitor):
        visitor.visit_alternate_type(self.name, self.info, self.variants)

1096 1097 1098 1099 1100 1101 1102 1103 1104 1105 1106 1107 1108 1109 1110 1111 1112 1113 1114 1115 1116 1117

class QAPISchemaCommand(QAPISchemaEntity):
    def __init__(self, name, info, arg_type, ret_type, gen, success_response):
        QAPISchemaEntity.__init__(self, name, info)
        assert not arg_type or isinstance(arg_type, str)
        assert not ret_type or isinstance(ret_type, str)
        self._arg_type_name = arg_type
        self.arg_type = None
        self._ret_type_name = ret_type
        self.ret_type = None
        self.gen = gen
        self.success_response = success_response

    def check(self, schema):
        if self._arg_type_name:
            self.arg_type = schema.lookup_type(self._arg_type_name)
            assert isinstance(self.arg_type, QAPISchemaObjectType)
            assert not self.arg_type.variants   # not implemented
        if self._ret_type_name:
            self.ret_type = schema.lookup_type(self._ret_type_name)
            assert isinstance(self.ret_type, QAPISchemaType)

M
Markus Armbruster 已提交
1118 1119 1120 1121 1122
    def visit(self, visitor):
        visitor.visit_command(self.name, self.info,
                              self.arg_type, self.ret_type,
                              self.gen, self.success_response)

1123 1124 1125 1126 1127 1128 1129 1130 1131 1132 1133 1134 1135 1136

class QAPISchemaEvent(QAPISchemaEntity):
    def __init__(self, name, info, arg_type):
        QAPISchemaEntity.__init__(self, name, info)
        assert not arg_type or isinstance(arg_type, str)
        self._arg_type_name = arg_type
        self.arg_type = None

    def check(self, schema):
        if self._arg_type_name:
            self.arg_type = schema.lookup_type(self._arg_type_name)
            assert isinstance(self.arg_type, QAPISchemaObjectType)
            assert not self.arg_type.variants   # not implemented

M
Markus Armbruster 已提交
1137 1138 1139
    def visit(self, visitor):
        visitor.visit_event(self.name, self.info, self.arg_type)

1140 1141 1142 1143 1144

class QAPISchema(object):
    def __init__(self, fname):
        try:
            self.exprs = check_exprs(QAPISchemaParser(open(fname, "r")).exprs)
1145
            self._entity_dict = {}
1146
            self._predefining = True
1147
            self._def_predefineds()
1148
            self._predefining = False
1149 1150
            self._def_exprs()
            self.check()
1151 1152 1153 1154 1155
        except (QAPISchemaError, QAPIExprError), err:
            print >>sys.stderr, err
            exit(1)

    def _def_entity(self, ent):
1156 1157
        # Only the predefined types are allowed to not have info
        assert ent.info or self._predefining
1158 1159 1160 1161 1162 1163 1164 1165 1166 1167 1168 1169
        assert ent.name not in self._entity_dict
        self._entity_dict[ent.name] = ent

    def lookup_entity(self, name, typ=None):
        ent = self._entity_dict.get(name)
        if typ and not isinstance(ent, typ):
            return None
        return ent

    def lookup_type(self, name):
        return self.lookup_entity(name, QAPISchemaType)

1170 1171 1172
    def _def_builtin_type(self, name, json_type, c_type, c_null):
        self._def_entity(QAPISchemaBuiltinType(name, json_type,
                                               c_type, c_null))
E
Eric Blake 已提交
1173 1174 1175 1176 1177
        # TODO As long as we have QAPI_TYPES_BUILTIN to share multiple
        # qapi-types.h from a single .c, all arrays of builtins must be
        # declared in the first file whether or not they are used.  Nicer
        # would be to use lazy instantiation, while figuring out how to
        # avoid compilation issues with multiple qapi-types.h.
1178
        self._make_array_type(name, None)
1179 1180

    def _def_predefineds(self):
1181 1182 1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 1193
        for t in [('str',    'string',  'char' + pointer_suffix, 'NULL'),
                  ('number', 'number',  'double',   '0'),
                  ('int',    'int',     'int64_t',  '0'),
                  ('int8',   'int',     'int8_t',   '0'),
                  ('int16',  'int',     'int16_t',  '0'),
                  ('int32',  'int',     'int32_t',  '0'),
                  ('int64',  'int',     'int64_t',  '0'),
                  ('uint8',  'int',     'uint8_t',  '0'),
                  ('uint16', 'int',     'uint16_t', '0'),
                  ('uint32', 'int',     'uint32_t', '0'),
                  ('uint64', 'int',     'uint64_t', '0'),
                  ('size',   'int',     'uint64_t', '0'),
                  ('bool',   'boolean', 'bool',     'false'),
1194
                  ('any',    'value',   'QObject' + pointer_suffix, 'NULL')]:
1195
            self._def_builtin_type(*t)
1196 1197 1198
        self.the_empty_object_type = QAPISchemaObjectType(':empty', None, None,
                                                          [], None)
        self._def_entity(self.the_empty_object_type)
1199

1200
    def _make_implicit_enum_type(self, name, info, values):
1201
        name = name + 'Kind'   # Use namespace reserved by add_name()
1202
        self._def_entity(QAPISchemaEnumType(name, info, values, None))
1203 1204
        return name

1205
    def _make_array_type(self, element_type, info):
1206
        name = element_type + 'List'   # Use namespace reserved by add_name()
1207
        if not self.lookup_type(name):
1208
            self._def_entity(QAPISchemaArrayType(name, info, element_type))
1209 1210
        return name

1211
    def _make_implicit_object_type(self, name, info, role, members):
1212 1213 1214 1215
        if not members:
            return None
        name = ':obj-%s-%s' % (name, role)
        if not self.lookup_entity(name, QAPISchemaObjectType):
1216
            self._def_entity(QAPISchemaObjectType(name, info, None,
1217 1218 1219 1220 1221 1222 1223 1224 1225
                                                  members, None))
        return name

    def _def_enum_type(self, expr, info):
        name = expr['enum']
        data = expr['data']
        prefix = expr.get('prefix')
        self._def_entity(QAPISchemaEnumType(name, info, data, prefix))

1226
    def _make_member(self, name, typ, info):
1227 1228 1229 1230 1231 1232
        optional = False
        if name.startswith('*'):
            name = name[1:]
            optional = True
        if isinstance(typ, list):
            assert len(typ) == 1
1233
            typ = self._make_array_type(typ[0], info)
1234 1235
        return QAPISchemaObjectTypeMember(name, typ, optional)

1236 1237
    def _make_members(self, data, info):
        return [self._make_member(key, value, info)
1238 1239 1240 1241 1242 1243 1244
                for (key, value) in data.iteritems()]

    def _def_struct_type(self, expr, info):
        name = expr['struct']
        base = expr.get('base')
        data = expr['data']
        self._def_entity(QAPISchemaObjectType(name, info, base,
1245
                                              self._make_members(data, info),
1246 1247 1248 1249 1250
                                              None))

    def _make_variant(self, case, typ):
        return QAPISchemaObjectTypeVariant(case, typ)

1251
    def _make_simple_variant(self, case, typ, info):
1252 1253
        if isinstance(typ, list):
            assert len(typ) == 1
1254 1255 1256
            typ = self._make_array_type(typ[0], info)
        typ = self._make_implicit_object_type(
            typ, info, 'wrapper', [self._make_member('data', typ, info)])
1257 1258
        return QAPISchemaObjectTypeVariant(case, typ)

1259 1260
    def _make_implicit_tag(self, type_name, info, variants):
        typ = self._make_implicit_enum_type(type_name, info,
1261 1262
                                            [v.name for v in variants])
        return QAPISchemaObjectTypeMember('type', typ, False)
1263 1264 1265 1266 1267 1268

    def _def_union_type(self, expr, info):
        name = expr['union']
        data = expr['data']
        base = expr.get('base')
        tag_name = expr.get('discriminator')
1269
        tag_member = None
1270 1271 1272 1273
        if tag_name:
            variants = [self._make_variant(key, value)
                        for (key, value) in data.iteritems()]
        else:
1274
            variants = [self._make_simple_variant(key, value, info)
1275
                        for (key, value) in data.iteritems()]
1276
            tag_member = self._make_implicit_tag(name, info, variants)
1277 1278
        self._def_entity(
            QAPISchemaObjectType(name, info, base,
1279
                                 self._make_members(OrderedDict(), info),
1280
                                 QAPISchemaObjectTypeVariants(tag_name,
1281
                                                              tag_member,
1282 1283 1284 1285 1286 1287 1288
                                                              variants)))

    def _def_alternate_type(self, expr, info):
        name = expr['alternate']
        data = expr['data']
        variants = [self._make_variant(key, value)
                    for (key, value) in data.iteritems()]
1289
        tag_member = self._make_implicit_tag(name, info, variants)
1290 1291 1292
        self._def_entity(
            QAPISchemaAlternateType(name, info,
                                    QAPISchemaObjectTypeVariants(None,
1293
                                                                 tag_member,
1294 1295 1296 1297 1298 1299 1300 1301 1302
                                                                 variants)))

    def _def_command(self, expr, info):
        name = expr['command']
        data = expr.get('data')
        rets = expr.get('returns')
        gen = expr.get('gen', True)
        success_response = expr.get('success-response', True)
        if isinstance(data, OrderedDict):
1303 1304
            data = self._make_implicit_object_type(
                name, info, 'arg', self._make_members(data, info))
1305 1306
        if isinstance(rets, list):
            assert len(rets) == 1
1307
            rets = self._make_array_type(rets[0], info)
1308 1309 1310 1311 1312 1313 1314
        self._def_entity(QAPISchemaCommand(name, info, data, rets, gen,
                                           success_response))

    def _def_event(self, expr, info):
        name = expr['event']
        data = expr.get('data')
        if isinstance(data, OrderedDict):
1315 1316
            data = self._make_implicit_object_type(
                name, info, 'arg', self._make_members(data, info))
1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 1332 1333 1334 1335 1336 1337 1338 1339 1340
        self._def_entity(QAPISchemaEvent(name, info, data))

    def _def_exprs(self):
        for expr_elem in self.exprs:
            expr = expr_elem['expr']
            info = expr_elem['info']
            if 'enum' in expr:
                self._def_enum_type(expr, info)
            elif 'struct' in expr:
                self._def_struct_type(expr, info)
            elif 'union' in expr:
                self._def_union_type(expr, info)
            elif 'alternate' in expr:
                self._def_alternate_type(expr, info)
            elif 'command' in expr:
                self._def_command(expr, info)
            elif 'event' in expr:
                self._def_event(expr, info)
            else:
                assert False

    def check(self):
        for ent in self._entity_dict.values():
            ent.check(self)
1341

M
Markus Armbruster 已提交
1342
    def visit(self, visitor):
1343 1344 1345 1346
        visitor.visit_begin(self)
        for (name, entity) in sorted(self._entity_dict.items()):
            if visitor.visit_needed(entity):
                entity.visit(visitor)
M
Markus Armbruster 已提交
1347 1348
        visitor.visit_end()

1349

1350 1351 1352 1353
#
# Code generation helpers
#

1354 1355 1356 1357 1358 1359 1360 1361 1362 1363 1364 1365 1366
def camel_case(name):
    new_name = ''
    first = True
    for ch in name:
        if ch in ['_', '-']:
            first = True
        elif first:
            new_name += ch.upper()
            first = False
        else:
            new_name += ch.lower()
    return new_name

E
Eric Blake 已提交
1367

1368 1369 1370 1371 1372 1373 1374 1375 1376 1377 1378 1379 1380 1381
# ENUMName -> ENUM_NAME, EnumName1 -> ENUM_NAME1
# ENUM_NAME -> ENUM_NAME, ENUM_NAME1 -> ENUM_NAME1, ENUM_Name2 -> ENUM_NAME2
# ENUM24_Name -> ENUM24_NAME
def camel_to_upper(value):
    c_fun_str = c_name(value, False)
    if value.isupper():
        return c_fun_str

    new_name = ''
    l = len(c_fun_str)
    for i in range(l):
        c = c_fun_str[i]
        # When c is upper and no "_" appears before, do more checks
        if c.isupper() and (i > 0) and c_fun_str[i - 1] != "_":
E
Eric Blake 已提交
1382 1383 1384
            if i < l - 1 and c_fun_str[i + 1].islower():
                new_name += '_'
            elif c_fun_str[i - 1].isdigit():
1385 1386 1387 1388
                new_name += '_'
        new_name += c
    return new_name.lstrip('_').upper()

E
Eric Blake 已提交
1389

1390 1391 1392
def c_enum_const(type_name, const_name, prefix=None):
    if prefix is not None:
        type_name = prefix
1393 1394
    return camel_to_upper(type_name + '_' + const_name)

1395
c_name_trans = string.maketrans('.-', '__')
1396

E
Eric Blake 已提交
1397

1398 1399 1400 1401 1402 1403 1404 1405 1406
# Map @name to a valid C identifier.
# If @protect, avoid returning certain ticklish identifiers (like
# C keywords) by prepending "q_".
#
# Used for converting 'name' from a 'name':'type' qapi definition
# into a generated struct member, as well as converting type names
# into substrings of a generated C function name.
# '__a.b_c' -> '__a_b_c', 'x-foo' -> 'x_foo'
# protect=True: 'int' -> 'q_int'; protect=False: 'int' -> 'int'
1407
def c_name(name, protect=True):
B
Blue Swirl 已提交
1408 1409
    # ANSI X3J11/88-090, 3.1.1
    c89_words = set(['auto', 'break', 'case', 'char', 'const', 'continue',
E
Eric Blake 已提交
1410 1411 1412 1413 1414
                     'default', 'do', 'double', 'else', 'enum', 'extern',
                     'float', 'for', 'goto', 'if', 'int', 'long', 'register',
                     'return', 'short', 'signed', 'sizeof', 'static',
                     'struct', 'switch', 'typedef', 'union', 'unsigned',
                     'void', 'volatile', 'while'])
B
Blue Swirl 已提交
1415 1416 1417
    # ISO/IEC 9899:1999, 6.4.1
    c99_words = set(['inline', 'restrict', '_Bool', '_Complex', '_Imaginary'])
    # ISO/IEC 9899:2011, 6.4.1
E
Eric Blake 已提交
1418 1419
    c11_words = set(['_Alignas', '_Alignof', '_Atomic', '_Generic',
                     '_Noreturn', '_Static_assert', '_Thread_local'])
B
Blue Swirl 已提交
1420 1421 1422
    # GCC http://gcc.gnu.org/onlinedocs/gcc-4.7.1/gcc/C-Extensions.html
    # excluding _.*
    gcc_words = set(['asm', 'typeof'])
1423 1424 1425 1426 1427 1428 1429 1430 1431 1432
    # C++ ISO/IEC 14882:2003 2.11
    cpp_words = set(['bool', 'catch', 'class', 'const_cast', 'delete',
                     'dynamic_cast', 'explicit', 'false', 'friend', 'mutable',
                     'namespace', 'new', 'operator', 'private', 'protected',
                     'public', 'reinterpret_cast', 'static_cast', 'template',
                     'this', 'throw', 'true', 'try', 'typeid', 'typename',
                     'using', 'virtual', 'wchar_t',
                     # alternative representations
                     'and', 'and_eq', 'bitand', 'bitor', 'compl', 'not',
                     'not_eq', 'or', 'or_eq', 'xor', 'xor_eq'])
1433
    # namespace pollution:
1434
    polluted_words = set(['unix', 'errno'])
E
Eric Blake 已提交
1435 1436
    if protect and (name in c89_words | c99_words | c11_words | gcc_words
                    | cpp_words | polluted_words):
B
Blue Swirl 已提交
1437
        return "q_" + name
1438
    return name.translate(c_name_trans)
1439

1440
eatspace = '\033EATSPACE.'
E
Eric Blake 已提交
1441
pointer_suffix = ' *' + eatspace
1442

E
Eric Blake 已提交
1443

1444 1445
def genindent(count):
    ret = ""
E
Eric Blake 已提交
1446
    for _ in range(count):
1447 1448 1449 1450 1451
        ret += " "
    return ret

indent_level = 0

E
Eric Blake 已提交
1452

1453 1454 1455 1456
def push_indent(indent_amount=4):
    global indent_level
    indent_level += indent_amount

E
Eric Blake 已提交
1457

1458 1459 1460 1461
def pop_indent(indent_amount=4):
    global indent_level
    indent_level -= indent_amount

E
Eric Blake 已提交
1462

1463 1464
# Generate @code with @kwds interpolated.
# Obey indent_level, and strip eatspace.
1465
def cgen(code, **kwds):
1466 1467 1468
    raw = code % kwds
    if indent_level:
        indent = genindent(indent_level)
1469 1470 1471
        # re.subn() lacks flags support before Python 2.7, use re.compile()
        raw = re.subn(re.compile("^.", re.MULTILINE),
                      indent + r'\g<0>', raw)
1472 1473
        raw = raw[0]
    return re.sub(re.escape(eatspace) + ' *', '', raw)
1474

E
Eric Blake 已提交
1475

1476
def mcgen(code, **kwds):
1477 1478 1479
    if code[0] == '\n':
        code = code[1:]
    return cgen(code, **kwds)
1480 1481 1482


def guardname(filename):
M
Markus Armbruster 已提交
1483
    return c_name(filename, protect=False).upper()
1484

E
Eric Blake 已提交
1485

1486 1487 1488 1489 1490 1491 1492 1493 1494
def guardstart(name):
    return mcgen('''

#ifndef %(name)s
#define %(name)s

''',
                 name=guardname(name))

E
Eric Blake 已提交
1495

1496 1497 1498 1499 1500 1501 1502
def guardend(name):
    return mcgen('''

#endif /* %(name)s */

''',
                 name=guardname(name))
1503

E
Eric Blake 已提交
1504

1505
def gen_enum_lookup(name, values, prefix=None):
1506 1507
    ret = mcgen('''

1508
const char *const %(c_name)s_lookup[] = {
1509
''',
1510
                c_name=c_name(name))
1511 1512 1513 1514 1515
    for value in values:
        index = c_enum_const(name, value, prefix)
        ret += mcgen('''
    [%(index)s] = "%(value)s",
''',
1516
                     index=index, value=value)
1517 1518 1519 1520 1521 1522

    max_index = c_enum_const(name, 'MAX', prefix)
    ret += mcgen('''
    [%(max_index)s] = NULL,
};
''',
1523
                 max_index=max_index)
1524 1525
    return ret

E
Eric Blake 已提交
1526

1527 1528 1529
def gen_enum(name, values, prefix=None):
    # append automatically generated _MAX value
    enum_values = values + ['MAX']
1530

1531
    ret = mcgen('''
1532

1533
typedef enum %(c_name)s {
1534
''',
1535
                c_name=c_name(name))
1536 1537 1538

    i = 0
    for value in enum_values:
1539 1540
        ret += mcgen('''
    %(c_enum)s = %(i)d,
1541
''',
1542
                     c_enum=c_enum_const(name, value, prefix),
1543 1544 1545
                     i=i)
        i += 1

1546 1547
    ret += mcgen('''
} %(c_name)s;
1548
''',
1549 1550 1551
                 c_name=c_name(name))

    ret += mcgen('''
1552

1553 1554 1555 1556
extern const char *const %(c_name)s_lookup[];
''',
                 c_name=c_name(name))
    return ret
1557

E
Eric Blake 已提交
1558

1559 1560 1561 1562 1563 1564 1565 1566 1567 1568 1569 1570 1571 1572 1573 1574
def gen_params(arg_type, extra):
    if not arg_type:
        return extra
    assert not arg_type.variants
    ret = ''
    sep = ''
    for memb in arg_type.members:
        ret += sep
        sep = ', '
        if memb.optional:
            ret += 'bool has_%s, ' % c_name(memb.name)
        ret += '%s %s' % (memb.type.c_type(is_param=True), c_name(memb.name))
    if extra:
        ret += sep + extra
    return ret

E
Eric Blake 已提交
1575

1576 1577
def gen_err_check(label='out', skiperr=False):
    if skiperr:
E
Eric Blake 已提交
1578 1579
        return ''
    return mcgen('''
1580
    if (err) {
E
Eric Blake 已提交
1581 1582 1583
        goto %(label)s;
    }
''',
1584
                 label=label)
E
Eric Blake 已提交
1585 1586


1587
def gen_visit_fields(members, prefix='', need_cast=False, skiperr=False):
E
Eric Blake 已提交
1588
    ret = ''
1589
    if skiperr:
E
Eric Blake 已提交
1590
        errparg = 'NULL'
1591 1592
    else:
        errparg = '&err'
E
Eric Blake 已提交
1593 1594 1595 1596 1597 1598 1599 1600

    for memb in members:
        if memb.optional:
            ret += mcgen('''
    visit_optional(v, &%(prefix)shas_%(c_name)s, "%(name)s", %(errp)s);
''',
                         prefix=prefix, c_name=c_name(memb.name),
                         name=memb.name, errp=errparg)
1601
            ret += gen_err_check(skiperr=skiperr)
E
Eric Blake 已提交
1602 1603 1604 1605 1606 1607 1608 1609 1610 1611 1612 1613 1614 1615 1616 1617 1618 1619
            ret += mcgen('''
    if (%(prefix)shas_%(c_name)s) {
''',
                         prefix=prefix, c_name=c_name(memb.name))
            push_indent()

        # Ugly: sometimes we need to cast away const
        if need_cast and memb.type.name == 'str':
            cast = '(char **)'
        else:
            cast = ''

        ret += mcgen('''
    visit_type_%(c_type)s(v, %(cast)s&%(prefix)s%(c_name)s, "%(name)s", %(errp)s);
''',
                     c_type=memb.type.c_name(), prefix=prefix, cast=cast,
                     c_name=c_name(memb.name), name=memb.name,
                     errp=errparg)
1620
        ret += gen_err_check(skiperr=skiperr)
E
Eric Blake 已提交
1621 1622 1623 1624 1625 1626 1627 1628 1629

        if memb.optional:
            pop_indent()
            ret += mcgen('''
    }
''')
    return ret


1630 1631 1632 1633
#
# Common command line parsing
#

E
Eric Blake 已提交
1634 1635

def parse_command_line(extra_options="", extra_long_options=[]):
1636 1637 1638

    try:
        opts, args = getopt.gnu_getopt(sys.argv[1:],
1639
                                       "chp:o:" + extra_options,
1640
                                       ["source", "header", "prefix=",
1641
                                        "output-dir="] + extra_long_options)
1642
    except getopt.GetoptError, err:
1643
        print >>sys.stderr, "%s: %s" % (sys.argv[0], str(err))
1644 1645 1646 1647 1648 1649 1650 1651 1652 1653 1654
        sys.exit(1)

    output_dir = ""
    prefix = ""
    do_c = False
    do_h = False
    extra_opts = []

    for oa in opts:
        o, a = oa
        if o in ("-p", "--prefix"):
1655 1656 1657 1658 1659 1660
            match = re.match('([A-Za-z_.-][A-Za-z0-9_.-]*)?', a)
            if match.end() != len(a):
                print >>sys.stderr, \
                    "%s: 'funny character '%s' in argument of --prefix" \
                    % (sys.argv[0], a[match.end()])
                sys.exit(1)
1661 1662 1663 1664 1665 1666 1667 1668 1669 1670 1671 1672 1673 1674
            prefix = a
        elif o in ("-o", "--output-dir"):
            output_dir = a + "/"
        elif o in ("-c", "--source"):
            do_c = True
        elif o in ("-h", "--header"):
            do_h = True
        else:
            extra_opts.append(oa)

    if not do_c and not do_h:
        do_c = True
        do_h = True

1675 1676
    if len(args) != 1:
        print >>sys.stderr, "%s: need exactly one argument" % sys.argv[0]
1677
        sys.exit(1)
1678
    fname = args[0]
1679

1680
    return (fname, output_dir, do_c, do_h, prefix, extra_opts)
1681

1682 1683 1684 1685
#
# Generate output files with boilerplate
#

E
Eric Blake 已提交
1686

1687 1688
def open_output(output_dir, do_c, do_h, prefix, c_file, h_file,
                c_comment, h_comment):
M
Markus Armbruster 已提交
1689
    guard = guardname(prefix + h_file)
1690 1691 1692
    c_file = output_dir + prefix + c_file
    h_file = output_dir + prefix + h_file

1693 1694 1695 1696 1697 1698
    if output_dir:
        try:
            os.makedirs(output_dir)
        except os.error, e:
            if e.errno != errno.EEXIST:
                raise
1699 1700 1701 1702 1703 1704 1705 1706 1707 1708 1709 1710 1711 1712 1713

    def maybe_open(really, name, opt):
        if really:
            return open(name, opt)
        else:
            import StringIO
            return StringIO.StringIO()

    fdef = maybe_open(do_c, c_file, 'w')
    fdecl = maybe_open(do_h, h_file, 'w')

    fdef.write(mcgen('''
/* AUTOMATICALLY GENERATED, DO NOT MODIFY */
%(comment)s
''',
E
Eric Blake 已提交
1714
                     comment=c_comment))
1715 1716 1717 1718 1719 1720 1721 1722

    fdecl.write(mcgen('''
/* AUTOMATICALLY GENERATED, DO NOT MODIFY */
%(comment)s
#ifndef %(guard)s
#define %(guard)s

''',
E
Eric Blake 已提交
1723
                      comment=h_comment, guard=guard))
1724 1725 1726

    return (fdef, fdecl)

E
Eric Blake 已提交
1727

1728 1729 1730 1731 1732 1733
def close_output(fdef, fdecl):
    fdecl.write('''
#endif
''')
    fdecl.close()
    fdef.close()