qapi.py 57.4 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)
E
Eric Blake 已提交
493
        if c_name(key, False) == 'u' or c_name(key, False).startswith('has_'):
494 495 496
            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

class QAPISchemaObjectType(QAPISchemaType):
    def __init__(self, name, info, base, local_members, variants):
960 961 962
        # struct has local_members, optional base, and no variants
        # flat union has base, variants, and no local_members
        # simple union has local_members, variants, and no base
963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989
        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:
990
            assert c_name(m.name) not in seen
991 992
            seen[m.name] = m
        for m in self.local_members:
993 994 995 996
            m.check(schema)
            assert m.name not in seen
            seen[m.name] = m
            members.append(m)
997 998 999 1000
        if self.variants:
            self.variants.check(schema, members, seen)
        self.members = members

1001 1002 1003 1004
    def is_implicit(self):
        # See QAPISchema._make_implicit_object_type()
        return self.name[0] == ':'

1005
    def c_name(self):
1006
        assert not self.is_implicit()
1007 1008 1009
        return QAPISchemaType.c_name(self)

    def c_type(self, is_param=False):
1010
        assert not self.is_implicit()
1011 1012 1013 1014 1015
        return QAPISchemaType.c_type(self)

    def json_type(self):
        return 'object'

M
Markus Armbruster 已提交
1016 1017 1018
    def visit(self, visitor):
        visitor.visit_object_type(self.name, self.info,
                                  self.base, self.local_members, self.variants)
1019 1020
        visitor.visit_object_type_flat(self.name, self.info,
                                       self.members, self.variants)
M
Markus Armbruster 已提交
1021

1022 1023 1024 1025 1026 1027 1028 1029 1030 1031 1032

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

1033
    def check(self, schema):
1034 1035 1036 1037 1038
        self.type = schema.lookup_type(self._type_name)
        assert self.type


class QAPISchemaObjectTypeVariants(object):
1039 1040 1041 1042 1043 1044 1045 1046
    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))
1047 1048 1049
        for v in variants:
            assert isinstance(v, QAPISchemaObjectTypeVariant)
        self.tag_name = tag_name
1050
        self.tag_member = tag_member
1051 1052 1053
        self.variants = variants

    def check(self, schema, members, seen):
1054
        if self.tag_name:    # flat union
1055
            self.tag_member = seen[self.tag_name]
1056 1057
        if seen:
            assert self.tag_member in seen.itervalues()
1058 1059
        assert isinstance(self.tag_member.type, QAPISchemaEnumType)
        for v in self.variants:
1060
            v.check(schema, self.tag_member.type, {})
1061

E
Eric Blake 已提交
1062

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

    def check(self, schema, tag_type, seen):
1068
        QAPISchemaObjectTypeMember.check(self, schema)
1069 1070
        assert self.name in tag_type.values

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

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):
1090
        self.variants.tag_member.check(schema)
1091 1092
        self.variants.check(schema, [], {})

1093 1094 1095
    def json_type(self):
        return 'value'

M
Markus Armbruster 已提交
1096 1097 1098
    def visit(self, visitor):
        visitor.visit_alternate_type(self.name, self.info, self.variants)

1099 1100 1101 1102 1103 1104 1105 1106 1107 1108 1109 1110 1111 1112 1113 1114 1115 1116 1117 1118 1119 1120

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 已提交
1121 1122 1123 1124 1125
    def visit(self, visitor):
        visitor.visit_command(self.name, self.info,
                              self.arg_type, self.ret_type,
                              self.gen, self.success_response)

1126 1127 1128 1129 1130 1131 1132 1133 1134 1135 1136 1137 1138 1139

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 已提交
1140 1141 1142
    def visit(self, visitor):
        visitor.visit_event(self.name, self.info, self.arg_type)

1143 1144 1145 1146 1147

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

    def _def_entity(self, ent):
1159 1160
        # Only the predefined types are allowed to not have info
        assert ent.info or self._predefining
1161 1162 1163 1164 1165 1166 1167 1168 1169 1170 1171 1172
        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)

1173 1174 1175
    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 已提交
1176 1177 1178 1179 1180
        # 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.
1181
        self._make_array_type(name, None)
1182 1183

    def _def_predefineds(self):
1184 1185 1186 1187 1188 1189 1190 1191 1192 1193 1194 1195 1196
        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'),
1197
                  ('any',    'value',   'QObject' + pointer_suffix, 'NULL')]:
1198
            self._def_builtin_type(*t)
1199 1200 1201
        self.the_empty_object_type = QAPISchemaObjectType(':empty', None, None,
                                                          [], None)
        self._def_entity(self.the_empty_object_type)
1202

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

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

1214
    def _make_implicit_object_type(self, name, info, role, members):
1215 1216 1217 1218
        if not members:
            return None
        name = ':obj-%s-%s' % (name, role)
        if not self.lookup_entity(name, QAPISchemaObjectType):
1219
            self._def_entity(QAPISchemaObjectType(name, info, None,
1220 1221 1222 1223 1224 1225 1226 1227 1228
                                                  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))

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

1239 1240
    def _make_members(self, data, info):
        return [self._make_member(key, value, info)
1241 1242 1243 1244 1245 1246 1247
                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,
1248
                                              self._make_members(data, info),
1249 1250 1251 1252 1253
                                              None))

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

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

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

    def _def_union_type(self, expr, info):
        name = expr['union']
        data = expr['data']
        base = expr.get('base')
        tag_name = expr.get('discriminator')
1272
        tag_member = None
1273 1274 1275
        if tag_name:
            variants = [self._make_variant(key, value)
                        for (key, value) in data.iteritems()]
1276
            members = []
1277
        else:
1278
            variants = [self._make_simple_variant(key, value, info)
1279
                        for (key, value) in data.iteritems()]
1280
            tag_member = self._make_implicit_tag(name, info, variants)
1281
            members = [tag_member]
1282
        self._def_entity(
1283
            QAPISchemaObjectType(name, info, base, members,
1284
                                 QAPISchemaObjectTypeVariants(tag_name,
1285
                                                              tag_member,
1286 1287 1288 1289 1290 1291 1292
                                                              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()]
1293
        tag_member = self._make_implicit_tag(name, info, variants)
1294 1295 1296
        self._def_entity(
            QAPISchemaAlternateType(name, info,
                                    QAPISchemaObjectTypeVariants(None,
1297
                                                                 tag_member,
1298 1299 1300 1301 1302 1303 1304 1305 1306
                                                                 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):
1307 1308
            data = self._make_implicit_object_type(
                name, info, 'arg', self._make_members(data, info))
1309 1310
        if isinstance(rets, list):
            assert len(rets) == 1
1311
            rets = self._make_array_type(rets[0], info)
1312 1313 1314 1315 1316 1317 1318
        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):
1319 1320
            data = self._make_implicit_object_type(
                name, info, 'arg', self._make_members(data, info))
1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 1332 1333 1334 1335 1336 1337 1338 1339 1340 1341 1342 1343 1344
        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)
1345

M
Markus Armbruster 已提交
1346
    def visit(self, visitor):
1347 1348 1349 1350
        visitor.visit_begin(self)
        for (name, entity) in sorted(self._entity_dict.items()):
            if visitor.visit_needed(entity):
                entity.visit(visitor)
M
Markus Armbruster 已提交
1351 1352
        visitor.visit_end()

1353

1354 1355 1356 1357
#
# Code generation helpers
#

1358 1359 1360 1361 1362 1363 1364 1365 1366 1367 1368 1369 1370
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 已提交
1371

1372 1373 1374 1375 1376 1377 1378 1379 1380 1381 1382 1383 1384 1385
# 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 已提交
1386 1387 1388
            if i < l - 1 and c_fun_str[i + 1].islower():
                new_name += '_'
            elif c_fun_str[i - 1].isdigit():
1389 1390 1391 1392
                new_name += '_'
        new_name += c
    return new_name.lstrip('_').upper()

E
Eric Blake 已提交
1393

1394 1395 1396
def c_enum_const(type_name, const_name, prefix=None):
    if prefix is not None:
        type_name = prefix
1397 1398
    return camel_to_upper(type_name + '_' + const_name)

1399
c_name_trans = string.maketrans('.-', '__')
1400

E
Eric Blake 已提交
1401

1402 1403 1404 1405 1406 1407 1408 1409 1410
# 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'
1411
def c_name(name, protect=True):
B
Blue Swirl 已提交
1412 1413
    # ANSI X3J11/88-090, 3.1.1
    c89_words = set(['auto', 'break', 'case', 'char', 'const', 'continue',
E
Eric Blake 已提交
1414 1415 1416 1417 1418
                     '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 已提交
1419 1420 1421
    # 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 已提交
1422 1423
    c11_words = set(['_Alignas', '_Alignof', '_Atomic', '_Generic',
                     '_Noreturn', '_Static_assert', '_Thread_local'])
B
Blue Swirl 已提交
1424 1425 1426
    # GCC http://gcc.gnu.org/onlinedocs/gcc-4.7.1/gcc/C-Extensions.html
    # excluding _.*
    gcc_words = set(['asm', 'typeof'])
1427 1428 1429 1430 1431 1432 1433 1434 1435 1436
    # 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'])
1437
    # namespace pollution:
1438
    polluted_words = set(['unix', 'errno'])
E
Eric Blake 已提交
1439 1440
    if protect and (name in c89_words | c99_words | c11_words | gcc_words
                    | cpp_words | polluted_words):
B
Blue Swirl 已提交
1441
        return "q_" + name
1442
    return name.translate(c_name_trans)
1443

1444
eatspace = '\033EATSPACE.'
E
Eric Blake 已提交
1445
pointer_suffix = ' *' + eatspace
1446

E
Eric Blake 已提交
1447

1448 1449
def genindent(count):
    ret = ""
E
Eric Blake 已提交
1450
    for _ in range(count):
1451 1452 1453 1454 1455
        ret += " "
    return ret

indent_level = 0

E
Eric Blake 已提交
1456

1457 1458 1459 1460
def push_indent(indent_amount=4):
    global indent_level
    indent_level += indent_amount

E
Eric Blake 已提交
1461

1462 1463 1464 1465
def pop_indent(indent_amount=4):
    global indent_level
    indent_level -= indent_amount

E
Eric Blake 已提交
1466

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

E
Eric Blake 已提交
1479

1480
def mcgen(code, **kwds):
1481 1482 1483
    if code[0] == '\n':
        code = code[1:]
    return cgen(code, **kwds)
1484 1485 1486


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

E
Eric Blake 已提交
1489

1490 1491 1492 1493 1494 1495 1496 1497 1498
def guardstart(name):
    return mcgen('''

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

''',
                 name=guardname(name))

E
Eric Blake 已提交
1499

1500 1501 1502 1503 1504 1505 1506
def guardend(name):
    return mcgen('''

#endif /* %(name)s */

''',
                 name=guardname(name))
1507

E
Eric Blake 已提交
1508

1509
def gen_enum_lookup(name, values, prefix=None):
1510 1511
    ret = mcgen('''

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

    max_index = c_enum_const(name, 'MAX', prefix)
    ret += mcgen('''
    [%(max_index)s] = NULL,
};
''',
1527
                 max_index=max_index)
1528 1529
    return ret

E
Eric Blake 已提交
1530

1531 1532 1533
def gen_enum(name, values, prefix=None):
    # append automatically generated _MAX value
    enum_values = values + ['MAX']
1534

1535
    ret = mcgen('''
1536

1537
typedef enum %(c_name)s {
1538
''',
1539
                c_name=c_name(name))
1540 1541 1542

    i = 0
    for value in enum_values:
1543 1544
        ret += mcgen('''
    %(c_enum)s = %(i)d,
1545
''',
1546
                     c_enum=c_enum_const(name, value, prefix),
1547 1548 1549
                     i=i)
        i += 1

1550 1551
    ret += mcgen('''
} %(c_name)s;
1552
''',
1553 1554 1555
                 c_name=c_name(name))

    ret += mcgen('''
1556

1557 1558 1559 1560
extern const char *const %(c_name)s_lookup[];
''',
                 c_name=c_name(name))
    return ret
1561

E
Eric Blake 已提交
1562

1563 1564 1565 1566 1567 1568 1569 1570 1571 1572 1573 1574 1575 1576 1577 1578
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 已提交
1579

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


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

    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)
1605
            ret += gen_err_check(skiperr=skiperr)
E
Eric Blake 已提交
1606 1607 1608 1609 1610 1611 1612 1613 1614 1615 1616 1617 1618 1619 1620 1621 1622 1623
            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)
1624
        ret += gen_err_check(skiperr=skiperr)
E
Eric Blake 已提交
1625 1626 1627 1628 1629 1630 1631 1632 1633

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


1634 1635 1636 1637
#
# Common command line parsing
#

E
Eric Blake 已提交
1638 1639

def parse_command_line(extra_options="", extra_long_options=[]):
1640 1641 1642

    try:
        opts, args = getopt.gnu_getopt(sys.argv[1:],
1643
                                       "chp:o:" + extra_options,
1644
                                       ["source", "header", "prefix=",
1645
                                        "output-dir="] + extra_long_options)
1646
    except getopt.GetoptError, err:
1647
        print >>sys.stderr, "%s: %s" % (sys.argv[0], str(err))
1648 1649 1650 1651 1652 1653 1654 1655 1656 1657 1658
        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"):
1659 1660 1661 1662 1663 1664
            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)
1665 1666 1667 1668 1669 1670 1671 1672 1673 1674 1675 1676 1677 1678
            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

1679 1680
    if len(args) != 1:
        print >>sys.stderr, "%s: need exactly one argument" % sys.argv[0]
1681
        sys.exit(1)
1682
    fname = args[0]
1683

1684
    return (fname, output_dir, do_c, do_h, prefix, extra_opts)
1685

1686 1687 1688 1689
#
# Generate output files with boilerplate
#

E
Eric Blake 已提交
1690

1691 1692
def open_output(output_dir, do_c, do_h, prefix, c_file, h_file,
                c_comment, h_comment):
M
Markus Armbruster 已提交
1693
    guard = guardname(prefix + h_file)
1694 1695 1696
    c_file = output_dir + prefix + c_file
    h_file = output_dir + prefix + h_file

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

    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 已提交
1718
                     comment=c_comment))
1719 1720 1721 1722 1723 1724 1725 1726

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

''',
E
Eric Blake 已提交
1727
                      comment=h_comment, guard=guard))
1728 1729 1730

    return (fdef, fdecl)

E
Eric Blake 已提交
1731

1732 1733 1734 1735 1736 1737
def close_output(fdef, fdecl):
    fdecl.write('''
#endif
''')
    fdecl.close()
    fdef.close()