qapi.py 59.0 KB
Newer Older
1 2 3 4
#
# QAPI helper library
#
# Copyright IBM, Corp. 2011
5
# Copyright (c) 2013-2016 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',
E
Eric Blake 已提交
36
    'any':      None,           # any QType possible, actually
37
    'QType':    'QTYPE_QSTRING',
K
Kevin Wolf 已提交
38 39
}

40 41 42 43
# Whitelist of commands allowed to return a non-dictionary
returns_whitelist = [
    # From QMP:
    'human-monitor-command',
44
    'qom-get',
45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61
    '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',
]

62 63 64 65 66 67 68 69 70
# Whitelist of entities allowed to violate case conventions
case_whitelist = [
    # From QMP:
    'ACPISlotType',         # DIMM, visible through query-acpi-ospm-status
    'CpuInfoMIPS',          # PC, visible through query-cpu
    'CpuInfoTricore',       # PC, visible through query-cpu
    'QapiErrorClass',       # all members, visible through errors
    'UuidInfo',             # UUID, visible through query-uuid
    'X86CPURegister32',     # all members, visible indirectly through qom-get
71
    'q_obj_CpuInfo-base',   # CPU, visible through query-cpu
72 73
]

74 75 76 77 78 79
enum_types = []
struct_types = []
union_types = []
events = []
all_names = {}

80 81 82 83
#
# Parsing the schema into expressions
#

E
Eric Blake 已提交
84

85 86 87 88 89 90 91 92
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 已提交
93

94 95
class QAPISchemaError(Exception):
    def __init__(self, schema, msg):
96
        Exception.__init__(self)
97
        self.fname = schema.fname
98
        self.msg = msg
99 100 101 102
        self.col = 1
        self.line = schema.line
        for ch in schema.src[schema.line_pos:schema.pos]:
            if ch == '\t':
103 104 105
                self.col = (self.col + 7) % 8 + 1
            else:
                self.col += 1
106
        self.info = schema.incl_info
107 108

    def __str__(self):
109
        return error_path(self.info) + \
110
            "%s:%d:%d: %s" % (self.fname, self.line, self.col, self.msg)
111

E
Eric Blake 已提交
112

113 114
class QAPIExprError(Exception):
    def __init__(self, expr_info, msg):
115
        Exception.__init__(self)
116
        assert expr_info
117
        self.info = expr_info
118 119 120
        self.msg = msg

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

E
Eric Blake 已提交
124

125
class QAPISchemaParser(object):
126

E
Eric Blake 已提交
127
    def __init__(self, fp, previously_included=[], incl_info=None):
128
        abs_fname = os.path.abspath(fp.name)
129
        fname = fp.name
130 131 132
        self.fname = fname
        previously_included.append(abs_fname)
        self.incl_info = incl_info
133 134 135 136
        self.src = fp.read()
        if self.src == '' or self.src[-1] != '\n':
            self.src += '\n'
        self.cursor = 0
137 138
        self.line = 1
        self.line_pos = 0
139 140 141
        self.exprs = []
        self.accept()

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

    def accept(self):
        while True:
            self.tok = self.src[self.cursor]
182
            self.pos = self.cursor
183 184 185
            self.cursor += 1
            self.val = None

186
            if self.tok == '#':
187
                self.cursor = self.src.find('\n', self.cursor)
188
            elif self.tok in "{}:,[]":
189 190 191 192 193 194 195 196
                return
            elif self.tok == "'":
                string = ''
                esc = False
                while True:
                    ch = self.src[self.cursor]
                    self.cursor += 1
                    if ch == '\n':
197 198
                        raise QAPISchemaError(self,
                                              'Missing terminating "\'"')
199
                    if esc:
200 201 202 203 204 205 206 207 208 209 210 211
                        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 已提交
212
                            for _ in range(0, 4):
213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233
                                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 已提交
234
                                                  "Unknown escape \\%s" % ch)
235 236 237 238 239 240 241 242
                        esc = False
                    elif ch == "\\":
                        esc = True
                    elif ch == "'":
                        self.val = string
                        return
                    else:
                        string += ch
243 244 245 246 247 248 249 250 251 252 253 254
            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
255 256 257 258
            elif self.tok == '\n':
                if self.cursor == len(self.src):
                    self.tok = None
                    return
259 260
                self.line += 1
                self.line_pos = self.cursor
261 262
            elif not self.tok.isspace():
                raise QAPISchemaError(self, 'Stray "%s"' % self.tok)
263 264 265

    def get_members(self):
        expr = OrderedDict()
266 267 268 269 270 271
        if self.tok == '}':
            self.accept()
            return expr
        if self.tok != "'":
            raise QAPISchemaError(self, 'Expected string or "}"')
        while True:
272 273
            key = self.val
            self.accept()
274 275 276
            if self.tok != ':':
                raise QAPISchemaError(self, 'Expected ":"')
            self.accept()
277 278
            if key in expr:
                raise QAPISchemaError(self, 'Duplicate key "%s"' % key)
279
            expr[key] = self.get_expr(True)
280
            if self.tok == '}':
281
                self.accept()
282 283 284 285 286 287
                return expr
            if self.tok != ',':
                raise QAPISchemaError(self, 'Expected "," or "}"')
            self.accept()
            if self.tok != "'":
                raise QAPISchemaError(self, 'Expected string')
288 289 290

    def get_values(self):
        expr = []
291 292 293
        if self.tok == ']':
            self.accept()
            return expr
E
Eric Blake 已提交
294
        if self.tok not in "{['tfn":
295 296
            raise QAPISchemaError(self, 'Expected "{", "[", "]", string, '
                                  'boolean or "null"')
297
        while True:
298
            expr.append(self.get_expr(True))
299
            if self.tok == ']':
300
                self.accept()
301 302 303 304
                return expr
            if self.tok != ',':
                raise QAPISchemaError(self, 'Expected "," or "]"')
            self.accept()
305

306 307 308
    def get_expr(self, nested):
        if self.tok != '{' and not nested:
            raise QAPISchemaError(self, 'Expected "{"')
309 310 311 312 313 314
        if self.tok == '{':
            self.accept()
            expr = self.get_members()
        elif self.tok == '[':
            self.accept()
            expr = self.get_values()
315
        elif self.tok in "'tfn":
316 317
            expr = self.val
            self.accept()
318 319
        else:
            raise QAPISchemaError(self, 'Expected "{", "[" or string')
320
        return expr
K
Kevin Wolf 已提交
321

322 323
#
# Semantic analysis of schema expressions
324 325
# TODO fold into QAPISchema
# TODO catching name collisions in generated code would be nice
326 327
#

E
Eric Blake 已提交
328

329
def find_base_members(base):
330 331
    if isinstance(base, dict):
        return base
332 333 334 335 336
    base_struct_define = find_struct(base)
    if not base_struct_define:
        return None
    return base_struct_define['data']

E
Eric Blake 已提交
337

338 339
# Return the qtype of an alternate branch, or None on error.
def find_alternate_member_qtype(qapi_type):
E
Eric Blake 已提交
340
    if qapi_type in builtin_types:
E
Eric Blake 已提交
341 342 343 344 345
        return builtin_types[qapi_type]
    elif find_struct(qapi_type):
        return "QTYPE_QDICT"
    elif find_enum(qapi_type):
        return "QTYPE_QSTRING"
346 347
    elif find_union(qapi_type):
        return "QTYPE_QDICT"
E
Eric Blake 已提交
348 349
    return None

E
Eric Blake 已提交
350

351 352 353 354 355 356 357 358 359
# 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

360 361
    base_members = find_base_members(base)
    if not base_members:
362 363
        return None

364
    discriminator_type = base_members.get(discriminator)
365 366 367 368 369
    if not discriminator_type:
        return None

    return find_enum(discriminator_type)

E
Eric Blake 已提交
370

371 372 373 374 375
# Names must be letters, numbers, -, and _.  They must start with letter,
# except for downstream extensions which must start with __RFQDN_.
# Dots are only valid in the downstream extension prefix.
valid_name = re.compile('^(__[a-zA-Z0-9.-]+_)?'
                        '[a-zA-Z][a-zA-Z0-9_-]*$')
E
Eric Blake 已提交
376 377 378 379


def check_name(expr_info, source, name, allow_optional=False,
               enum_member=False):
E
Eric Blake 已提交
380 381 382 383 384 385 386 387 388 389 390 391 392 393
    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
394 395
    if enum_member and membername[0].isdigit():
        membername = 'D' + membername
396 397
    # Reserve the entire 'q_' namespace for c_name(), and for 'q_empty'
    # and 'q_obj_*' implicit type names.
398 399
    if not valid_name.match(membername) or \
       c_name(membername, False).startswith('q_'):
E
Eric Blake 已提交
400 401 402
        raise QAPIExprError(expr_info,
                            "%s uses invalid name '%s'" % (source, name))

E
Eric Blake 已提交
403 404

def add_name(name, info, meta, implicit=False):
405 406
    global all_names
    check_name(info, "'%s'" % meta, name)
407 408
    # FIXME should reject names that differ only in '_' vs. '.'
    # vs. '-', because they're liable to clash in generated C.
409 410 411 412
    if name in all_names:
        raise QAPIExprError(info,
                            "%s '%s' is already defined"
                            % (all_names[name], name))
413
    if not implicit and (name.endswith('Kind') or name.endswith('List')):
414
        raise QAPIExprError(info,
415 416
                            "%s '%s' should not end in '%s'"
                            % (meta, name, name[-4:]))
417 418
    all_names[name] = meta

E
Eric Blake 已提交
419

420 421 422 423 424 425
def add_struct(definition, info):
    global struct_types
    name = definition['struct']
    add_name(name, info, 'struct')
    struct_types.append(definition)

E
Eric Blake 已提交
426

427 428 429 430 431 432 433
def find_struct(name):
    global struct_types
    for struct in struct_types:
        if struct['struct'] == name:
            return struct
    return None

E
Eric Blake 已提交
434

435 436 437 438 439 440
def add_union(definition, info):
    global union_types
    name = definition['union']
    add_name(name, info, 'union')
    union_types.append(definition)

E
Eric Blake 已提交
441

442 443 444 445 446 447 448
def find_union(name):
    global union_types
    for union in union_types:
        if union['union'] == name:
            return union
    return None

E
Eric Blake 已提交
449 450

def add_enum(name, info, enum_values=None, implicit=False):
451 452 453 454
    global enum_types
    add_name(name, info, 'enum', implicit)
    enum_types.append({"enum_name": name, "enum_values": enum_values})

E
Eric Blake 已提交
455

456 457 458 459 460 461 462
def find_enum(name):
    global enum_types
    for enum in enum_types:
        if enum['enum_name'] == name:
            return enum
    return None

E
Eric Blake 已提交
463

464
def is_enum(name):
E
Eric Blake 已提交
465 466
    return find_enum(name) is not None

467

E
Eric Blake 已提交
468 469 470
def check_type(expr_info, source, value, allow_array=False,
               allow_dict=False, allow_optional=False,
               allow_metas=[]):
471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488
    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 已提交
489
        if value not in all_names:
490 491
            raise QAPIExprError(expr_info,
                                "%s uses unknown type '%s'"
492
                                % (source, value))
493 494 495
        if not all_names[value] in allow_metas:
            raise QAPIExprError(expr_info,
                                "%s cannot use %s type '%s'"
496
                                % (source, all_names[value], value))
497 498 499 500 501
        return

    if not allow_dict:
        raise QAPIExprError(expr_info,
                            "%s should be a type name" % source)
502 503 504 505 506 507

    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
508
    for (key, arg) in value.items():
E
Eric Blake 已提交
509 510
        check_name(expr_info, "Member of %s" % source, key,
                   allow_optional=allow_optional)
E
Eric Blake 已提交
511
        if c_name(key, False) == 'u' or c_name(key, False).startswith('has_'):
512 513 514
            raise QAPIExprError(expr_info,
                                "Member of %s uses reserved name '%s'"
                                % (source, key))
515 516
        # Todo: allow dictionaries to represent default values of
        # an optional argument.
517
        check_type(expr_info, "Member '%s' of %s" % (key, source), arg,
518
                   allow_array=True,
519
                   allow_metas=['built-in', 'union', 'alternate', 'struct',
520
                                'enum'])
521

E
Eric Blake 已提交
522

523 524
def check_command(expr, expr_info):
    name = expr['command']
525

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

E
Eric Blake 已提交
536

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

    events.append(name)
542
    check_type(expr_info, "'data' for event '%s'" % name,
E
Eric Blake 已提交
543
               expr.get('data'), allow_dict=True, allow_optional=True,
544
               allow_metas=['struct'])
W
Wenchao Xia 已提交
545

E
Eric Blake 已提交
546

547 548 549 550 551 552
def check_union(expr, expr_info):
    name = expr['union']
    base = expr.get('base')
    discriminator = expr.get('discriminator')
    members = expr['data']

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

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

    # Else, it's a flat union.
    else:
566
        # The object must have a string or dictionary 'base'.
567
        check_type(expr_info, "'base' for union '%s'" % name,
568 569
                   base, allow_dict=True, allow_optional=True,
                   allow_metas=['struct'])
570
        if not base:
571
            raise QAPIExprError(expr_info,
572
                                "Flat union '%s' must have a base"
573
                                % name)
574 575
        base_members = find_base_members(base)
        assert base_members
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
        discriminator_type = base_members.get(discriminator)
582 583 584
        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 597 598
    # Check every branch; don't allow an empty union
    if len(members) == 0:
        raise QAPIExprError(expr_info,
                            "Union '%s' cannot have empty 'data'" % name)
599
    for (key, value) in members.items():
E
Eric Blake 已提交
600 601
        check_name(expr_info, "Member of union '%s'" % name, key)

602
        # Each value must name a known type
603
        check_type(expr_info, "Member '%s' of union '%s'" % (key, name),
604
                   value, allow_array=not base, allow_metas=allow_metas)
605

E
Eric Blake 已提交
606
        # If the discriminator names an enum type, then all members
607
        # of 'data' must also be members of the enum type.
E
Eric Blake 已提交
608
        if enum_define:
E
Eric Blake 已提交
609
            if key not in enum_define['enum_values']:
E
Eric Blake 已提交
610 611 612 613 614
                raise QAPIExprError(expr_info,
                                    "Discriminator value '%s' is not found in "
                                    "enum '%s'" %
                                    (key, enum_define["enum_name"]))

615 616 617 618 619 620 621 622
    # If discriminator is user-defined, ensure all values are covered
    if enum_define:
        for value in enum_define['enum_values']:
            if value not in members.keys():
                raise QAPIExprError(expr_info,
                                    "Union '%s' data missing '%s' branch"
                                    % (name, value))

E
Eric Blake 已提交
623

624
def check_alternate(expr, expr_info):
625
    name = expr['alternate']
626 627 628
    members = expr['data']
    types_seen = {}

629 630 631 632 633
    # Check every branch; require at least two branches
    if len(members) < 2:
        raise QAPIExprError(expr_info,
                            "Alternate '%s' should have at least two branches "
                            "in 'data'" % name)
634
    for (key, value) in members.items():
E
Eric Blake 已提交
635 636
        check_name(expr_info, "Member of alternate '%s'" % name, key)

637
        # Ensure alternates have no type conflicts.
638 639 640
        check_type(expr_info, "Member '%s' of alternate '%s'" % (key, name),
                   value,
                   allow_metas=['built-in', 'union', 'struct', 'enum'])
641
        qtype = find_alternate_member_qtype(value)
642 643 644 645
        if not qtype:
            raise QAPIExprError(expr_info,
                                "Alternate '%s' member '%s' cannot use "
                                "type '%s'" % (name, key, value))
646 647
        if qtype in types_seen:
            raise QAPIExprError(expr_info,
648
                                "Alternate '%s' member '%s' can't "
649 650 651
                                "be distinguished from member '%s'"
                                % (name, key, types_seen[qtype]))
        types_seen[qtype] = key
652

E
Eric Blake 已提交
653

654 655 656
def check_enum(expr, expr_info):
    name = expr['enum']
    members = expr.get('data')
657
    prefix = expr.get('prefix')
658 659 660 661

    if not isinstance(members, list):
        raise QAPIExprError(expr_info,
                            "Enum '%s' requires an array for 'data'" % name)
662 663 664
    if prefix is not None and not isinstance(prefix, str):
        raise QAPIExprError(expr_info,
                            "Enum '%s' requires a string for 'prefix'" % name)
665
    for member in members:
E
Eric Blake 已提交
666
        check_name(expr_info, "Member of enum '%s'" % name, member,
E
Eric Blake 已提交
667
                   enum_member=True)
668

E
Eric Blake 已提交
669

670
def check_struct(expr, expr_info):
671
    name = expr['struct']
672 673
    members = expr['data']

674
    check_type(expr_info, "'data' for struct '%s'" % name, members,
E
Eric Blake 已提交
675
               allow_dict=True, allow_optional=True)
676
    check_type(expr_info, "'base' for struct '%s'" % name, expr.get('base'),
677 678
               allow_metas=['struct'])

E
Eric Blake 已提交
679

680 681 682 683 684 685 686
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 已提交
687
    required = required + [meta]
688
    for (key, value) in expr.items():
E
Eric Blake 已提交
689
        if key not in required and key not in optional:
690 691 692
            raise QAPIExprError(info,
                                "Unknown key '%s' in %s '%s'"
                                % (key, meta, name))
E
Eric Blake 已提交
693
        if (key == 'gen' or key == 'success-response') and value is not False:
694 695 696
            raise QAPIExprError(info,
                                "'%s' of %s '%s' should only use false value"
                                % (key, meta, name))
697
    for key in required:
E
Eric Blake 已提交
698
        if key not in expr:
699 700 701 702
            raise QAPIExprError(info,
                                "Key '%s' is missing from %s '%s'"
                                % (key, meta, name))

E
Eric Blake 已提交
703

704
def check_exprs(exprs):
705 706
    global all_names

707 708 709 710 711 712
    # 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 已提交
713
        if 'enum' in expr:
714
            check_keys(expr_elem, 'enum', ['data'], ['prefix'])
715
            add_enum(expr['enum'], info, expr['data'])
E
Eric Blake 已提交
716
        elif 'union' in expr:
717 718 719
            check_keys(expr_elem, 'union', ['data'],
                       ['base', 'discriminator'])
            add_union(expr, info)
E
Eric Blake 已提交
720
        elif 'alternate' in expr:
721 722
            check_keys(expr_elem, 'alternate', ['data'])
            add_name(expr['alternate'], info, 'alternate')
E
Eric Blake 已提交
723
        elif 'struct' in expr:
724 725
            check_keys(expr_elem, 'struct', ['data'], ['base'])
            add_struct(expr, info)
E
Eric Blake 已提交
726
        elif 'command' in expr:
727 728 729
            check_keys(expr_elem, 'command', [],
                       ['data', 'returns', 'gen', 'success-response'])
            add_name(expr['command'], info, 'command')
E
Eric Blake 已提交
730
        elif 'event' in expr:
731 732 733 734 735
            check_keys(expr_elem, 'event', [], ['data'])
            add_name(expr['event'], info, 'event')
        else:
            raise QAPIExprError(expr_elem['info'],
                                "Expression is missing metatype")
736

737 738 739
    # Try again for hidden UnionKind enum
    for expr_elem in exprs:
        expr = expr_elem['expr']
E
Eric Blake 已提交
740
        if 'union' in expr:
741 742
            if not discriminator_find_enum_define(expr):
                add_enum('%sKind' % expr['union'], expr_elem['info'],
743
                         implicit=True)
E
Eric Blake 已提交
744
        elif 'alternate' in expr:
745 746 747 748 749 750 751
            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']
752

E
Eric Blake 已提交
753
        if 'enum' in expr:
754
            check_enum(expr, info)
E
Eric Blake 已提交
755
        elif 'union' in expr:
756
            check_union(expr, info)
E
Eric Blake 已提交
757
        elif 'alternate' in expr:
758
            check_alternate(expr, info)
E
Eric Blake 已提交
759
        elif 'struct' in expr:
760
            check_struct(expr, info)
E
Eric Blake 已提交
761
        elif 'command' in expr:
762
            check_command(expr, info)
E
Eric Blake 已提交
763
        elif 'event' in expr:
764 765 766 767
            check_event(expr, info)
        else:
            assert False, 'unexpected meta type'

768 769 770 771 772 773 774 775 776 777 778
    return exprs


#
# Schema compiler frontend
#

class QAPISchemaEntity(object):
    def __init__(self, name, info):
        assert isinstance(name, str)
        self.name = name
779 780 781 782 783
        # 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).
784 785
        self.info = info

786 787 788
    def c_name(self):
        return c_name(self.name)

789 790 791
    def check(self, schema):
        pass

792 793 794
    def is_implicit(self):
        return not self.info

M
Markus Armbruster 已提交
795 796 797 798 799 800 801 802 803 804 805
    def visit(self, visitor):
        pass


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

    def visit_end(self):
        pass

806 807 808 809
    def visit_needed(self, entity):
        # Default to visiting everything
        return True

M
Markus Armbruster 已提交
810 811 812 813 814 815 816 817 818 819 820 821
    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

822 823 824
    def visit_object_type_flat(self, name, info, members, variants):
        pass

M
Markus Armbruster 已提交
825 826 827 828 829 830 831 832 833 834
    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

835 836

class QAPISchemaType(QAPISchemaEntity):
E
Eric Blake 已提交
837 838 839 840 841 842 843 844 845 846 847 848
    # Return the C type for common use.
    # For the types we commonly box, this is a pointer type.
    def c_type(self):
        pass

    # Return the C type to be used in a parameter list.
    def c_param_type(self):
        return self.c_type()

    # Return the C type to be used where we suppress boxing.
    def c_unboxed_type(self):
        return self.c_type()
849 850 851 852 853 854 855 856 857 858 859 860 861

    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())
862 863 864


class QAPISchemaBuiltinType(QAPISchemaType):
E
Eric Blake 已提交
865
    def __init__(self, name, json_type, c_type):
866
        QAPISchemaType.__init__(self, name, None)
867 868 869 870 871 872 873 874 875
        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

    def c_name(self):
        return self.name

E
Eric Blake 已提交
876 877 878 879 880
    def c_type(self):
        return self._c_type_name

    def c_param_type(self):
        if self.name == 'str':
881 882 883 884 885
            return 'const ' + self._c_type_name
        return self._c_type_name

    def json_type(self):
        return self._json_type_name
886

M
Markus Armbruster 已提交
887 888 889
    def visit(self, visitor):
        visitor.visit_builtin_type(self.name, self.info, self.json_type())

890 891 892 893 894

class QAPISchemaEnumType(QAPISchemaType):
    def __init__(self, name, info, values, prefix):
        QAPISchemaType.__init__(self, name, info)
        for v in values:
895 896
            assert isinstance(v, QAPISchemaMember)
            v.set_owner(name)
897 898 899 900 901
        assert prefix is None or isinstance(prefix, str)
        self.values = values
        self.prefix = prefix

    def check(self, schema):
902 903 904
        seen = {}
        for v in self.values:
            v.check_clash(self.info, seen)
905

906 907
    def is_implicit(self):
        # See QAPISchema._make_implicit_enum_type()
908
        return self.name.endswith('Kind')
909

E
Eric Blake 已提交
910
    def c_type(self):
911 912
        return c_name(self.name)

913 914 915
    def member_names(self):
        return [v.name for v in self.values]

916 917 918
    def json_type(self):
        return 'string'

M
Markus Armbruster 已提交
919 920
    def visit(self, visitor):
        visitor.visit_enum_type(self.name, self.info,
921
                                self.member_names(), self.prefix)
M
Markus Armbruster 已提交
922

923 924 925 926 927 928 929 930 931 932 933 934

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

935 936 937
    def is_implicit(self):
        return True

E
Eric Blake 已提交
938 939 940
    def c_type(self):
        return c_name(self.name) + pointer_suffix

941 942 943
    def json_type(self):
        return 'array'

M
Markus Armbruster 已提交
944 945 946
    def visit(self, visitor):
        visitor.visit_array_type(self.name, self.info, self.element_type)

947 948 949

class QAPISchemaObjectType(QAPISchemaType):
    def __init__(self, name, info, base, local_members, variants):
950 951 952
        # 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
953 954 955 956
        QAPISchemaType.__init__(self, name, info)
        assert base is None or isinstance(base, str)
        for m in local_members:
            assert isinstance(m, QAPISchemaObjectTypeMember)
957 958 959 960
            m.set_owner(name)
        if variants is not None:
            assert isinstance(variants, QAPISchemaObjectTypeVariants)
            variants.set_owner(name)
961 962 963 964 965 966 967
        self._base_name = base
        self.base = None
        self.local_members = local_members
        self.variants = variants
        self.members = None

    def check(self, schema):
E
Eric Blake 已提交
968 969 970
        if self.members is False:               # check for cycles
            raise QAPIExprError(self.info,
                                "Object %s contains itself" % self.name)
971 972 973
        if self.members:
            return
        self.members = False                    # mark as being checked
974
        seen = OrderedDict()
975 976 977 978
        if self._base_name:
            self.base = schema.lookup_type(self._base_name)
            assert isinstance(self.base, QAPISchemaObjectType)
            self.base.check(schema)
979
            self.base.check_clash(schema, self.info, seen)
980
        for m in self.local_members:
981
            m.check(schema)
982
            m.check_clash(self.info, seen)
983
        self.members = seen.values()
984
        if self.variants:
985
            self.variants.check(schema, seen)
986
            assert self.variants.tag_member in self.members
987
            self.variants.check_clash(schema, self.info, seen)
988

989
    # Check that the members of this type do not cause duplicate JSON members,
990 991 992
    # and update seen to track the members seen so far. Report any errors
    # on behalf of info, which is not necessarily self.info
    def check_clash(self, schema, info, seen):
993 994
        assert not self.variants       # not implemented
        for m in self.members:
995
            m.check_clash(info, seen)
996

997
    def is_implicit(self):
998 999 1000
        # See QAPISchema._make_implicit_object_type(), as well as
        # _def_predefineds()
        return self.name.startswith('q_')
1001

1002 1003 1004
    def c_name(self):
        return QAPISchemaType.c_name(self)

E
Eric Blake 已提交
1005
    def c_type(self):
1006
        assert not self.is_implicit()
1007
        return c_name(self.name) + pointer_suffix
1008

E
Eric Blake 已提交
1009 1010 1011
    def c_unboxed_type(self):
        return c_name(self.name)

1012 1013 1014
    def json_type(self):
        return 'object'

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

1021

1022
class QAPISchemaMember(object):
1023 1024
    role = 'member'

1025
    def __init__(self, name):
1026 1027
        assert isinstance(name, str)
        self.name = name
1028 1029 1030 1031 1032
        self.owner = None

    def set_owner(self, name):
        assert not self.owner
        self.owner = name
1033

1034 1035
    def check_clash(self, info, seen):
        cname = c_name(self.name)
1036 1037 1038
        if cname.lower() != cname and self.owner not in case_whitelist:
            raise QAPIExprError(info,
                                "%s should not use uppercase" % self.describe())
1039 1040 1041 1042 1043
        if cname in seen:
            raise QAPIExprError(info,
                                "%s collides with %s"
                                % (self.describe(), seen[cname].describe()))
        seen[cname] = self
1044

1045 1046
    def _pretty_owner(self):
        owner = self.owner
1047
        if owner.startswith('q_obj_'):
1048 1049
            # See QAPISchema._make_implicit_object_type() - reverse the
            # mapping there to create a nice human-readable description
1050
            owner = owner[6:]
1051 1052
            if owner.endswith('-arg'):
                return '(parameter of %s)' % owner[:-4]
1053 1054
            elif owner.endswith('-base'):
                return '(base of %s)' % owner[:-5]
1055 1056 1057 1058
            else:
                assert owner.endswith('-wrapper')
                # Unreachable and not implemented
                assert False
1059 1060 1061
        if owner.endswith('Kind'):
            # See QAPISchema._make_implicit_enum_type()
            return '(branch of %s)' % owner[:-4]
1062 1063 1064 1065 1066
        return '(%s of %s)' % (self.role, owner)

    def describe(self):
        return "'%s' %s" % (self.name, self._pretty_owner())

1067

1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080 1081 1082
class QAPISchemaObjectTypeMember(QAPISchemaMember):
    def __init__(self, name, typ, optional):
        QAPISchemaMember.__init__(self, name)
        assert isinstance(typ, str)
        assert isinstance(optional, bool)
        self._type_name = typ
        self.type = None
        self.optional = optional

    def check(self, schema):
        assert self.owner
        self.type = schema.lookup_type(self._type_name)
        assert self.type


1083
class QAPISchemaObjectTypeVariants(object):
1084 1085 1086 1087 1088 1089 1090 1091
    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))
1092
        assert len(variants) > 0
1093 1094 1095
        for v in variants:
            assert isinstance(v, QAPISchemaObjectTypeVariant)
        self.tag_name = tag_name
1096
        self.tag_member = tag_member
1097 1098
        self.variants = variants

1099 1100 1101 1102
    def set_owner(self, name):
        for v in self.variants:
            v.set_owner(name)

1103
    def check(self, schema, seen):
1104
        if not self.tag_member:    # flat union
1105 1106
            self.tag_member = seen[c_name(self.tag_name)]
            assert self.tag_name == self.tag_member.name
1107 1108
        assert isinstance(self.tag_member.type, QAPISchemaEnumType)
        for v in self.variants:
1109
            v.check(schema)
1110 1111 1112
            # Union names must match enum values; alternate names are
            # checked separately. Use 'seen' to tell the two apart.
            if seen:
1113
                assert v.name in self.tag_member.type.member_names()
1114
                assert isinstance(v.type, QAPISchemaObjectType)
1115 1116
                v.type.check(schema)

1117
    def check_clash(self, schema, info, seen):
1118 1119 1120 1121
        for v in self.variants:
            # Reset seen map for each variant, since qapi names from one
            # branch do not affect another branch
            assert isinstance(v.type, QAPISchemaObjectType)
1122
            v.type.check_clash(schema, info, dict(seen))
1123

E
Eric Blake 已提交
1124

1125
class QAPISchemaObjectTypeVariant(QAPISchemaObjectTypeMember):
1126 1127
    role = 'branch'

1128 1129 1130 1131 1132 1133 1134 1135 1136
    def __init__(self, name, typ):
        QAPISchemaObjectTypeMember.__init__(self, name, typ, False)


class QAPISchemaAlternateType(QAPISchemaType):
    def __init__(self, name, info, variants):
        QAPISchemaType.__init__(self, name, info)
        assert isinstance(variants, QAPISchemaObjectTypeVariants)
        assert not variants.tag_name
1137 1138
        variants.set_owner(name)
        variants.tag_member.set_owner(self.name)
1139 1140 1141
        self.variants = variants

    def check(self, schema):
1142
        self.variants.tag_member.check(schema)
1143 1144
        # Not calling self.variants.check_clash(), because there's nothing
        # to clash with
1145
        self.variants.check(schema, {})
1146 1147 1148 1149 1150
        # Alternate branch names have no relation to the tag enum values;
        # so we have to check for potential name collisions ourselves.
        seen = {}
        for v in self.variants.variants:
            v.check_clash(self.info, seen)
1151

E
Eric Blake 已提交
1152 1153 1154
    def c_type(self):
        return c_name(self.name) + pointer_suffix

1155 1156 1157
    def json_type(self):
        return 'value'

M
Markus Armbruster 已提交
1158 1159 1160
    def visit(self, visitor):
        visitor.visit_alternate_type(self.name, self.info, self.variants)

1161 1162 1163 1164 1165 1166 1167 1168 1169 1170 1171 1172 1173 1174 1175 1176 1177 1178 1179 1180 1181 1182

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 已提交
1183 1184 1185 1186 1187
    def visit(self, visitor):
        visitor.visit_command(self.name, self.info,
                              self.arg_type, self.ret_type,
                              self.gen, self.success_response)

1188 1189 1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201

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

1205 1206 1207 1208 1209

class QAPISchema(object):
    def __init__(self, fname):
        try:
            self.exprs = check_exprs(QAPISchemaParser(open(fname, "r")).exprs)
1210
            self._entity_dict = {}
1211
            self._predefining = True
1212
            self._def_predefineds()
1213
            self._predefining = False
1214 1215
            self._def_exprs()
            self.check()
1216
        except (QAPISchemaError, QAPIExprError) as err:
1217 1218 1219 1220
            print >>sys.stderr, err
            exit(1)

    def _def_entity(self, ent):
1221 1222
        # Only the predefined types are allowed to not have info
        assert ent.info or self._predefining
1223 1224 1225 1226 1227 1228 1229 1230 1231 1232 1233 1234
        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)

E
Eric Blake 已提交
1235 1236
    def _def_builtin_type(self, name, json_type, c_type):
        self._def_entity(QAPISchemaBuiltinType(name, json_type, c_type))
E
Eric Blake 已提交
1237 1238 1239 1240 1241
        # 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.
1242
        self._make_array_type(name, None)
1243 1244

    def _def_predefineds(self):
E
Eric Blake 已提交
1245 1246 1247 1248 1249 1250 1251 1252 1253 1254 1255 1256 1257 1258
        for t in [('str',    'string',  'char' + pointer_suffix),
                  ('number', 'number',  'double'),
                  ('int',    'int',     'int64_t'),
                  ('int8',   'int',     'int8_t'),
                  ('int16',  'int',     'int16_t'),
                  ('int32',  'int',     'int32_t'),
                  ('int64',  'int',     'int64_t'),
                  ('uint8',  'int',     'uint8_t'),
                  ('uint16', 'int',     'uint16_t'),
                  ('uint32', 'int',     'uint32_t'),
                  ('uint64', 'int',     'uint64_t'),
                  ('size',   'int',     'uint64_t'),
                  ('bool',   'boolean', 'bool'),
                  ('any',    'value',   'QObject' + pointer_suffix)]:
1259
            self._def_builtin_type(*t)
1260 1261
        self.the_empty_object_type = QAPISchemaObjectType('q_empty', None,
                                                          None, [], None)
1262
        self._def_entity(self.the_empty_object_type)
1263 1264 1265 1266
        qtype_values = self._make_enum_members(['none', 'qnull', 'qint',
                                                'qstring', 'qdict', 'qlist',
                                                'qfloat', 'qbool'])
        self._def_entity(QAPISchemaEnumType('QType', None, qtype_values,
1267
                                            'QTYPE'))
1268

1269 1270 1271
    def _make_enum_members(self, values):
        return [QAPISchemaMember(v) for v in values]

1272
    def _make_implicit_enum_type(self, name, info, values):
1273
        # See also QAPISchemaObjectTypeMember._pretty_owner()
1274
        name = name + 'Kind'   # Use namespace reserved by add_name()
1275 1276
        self._def_entity(QAPISchemaEnumType(
            name, info, self._make_enum_members(values), None))
1277 1278
        return name

1279
    def _make_array_type(self, element_type, info):
1280
        name = element_type + 'List'   # Use namespace reserved by add_name()
1281
        if not self.lookup_type(name):
1282
            self._def_entity(QAPISchemaArrayType(name, info, element_type))
1283 1284
        return name

1285
    def _make_implicit_object_type(self, name, info, role, members):
1286 1287
        if not members:
            return None
1288
        # See also QAPISchemaObjectTypeMember._pretty_owner()
1289
        name = 'q_obj_%s-%s' % (name, role)
1290
        if not self.lookup_entity(name, QAPISchemaObjectType):
1291
            self._def_entity(QAPISchemaObjectType(name, info, None,
1292 1293 1294 1295 1296 1297 1298
                                                  members, None))
        return name

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

1302
    def _make_member(self, name, typ, info):
1303 1304 1305 1306 1307 1308
        optional = False
        if name.startswith('*'):
            name = name[1:]
            optional = True
        if isinstance(typ, list):
            assert len(typ) == 1
1309
            typ = self._make_array_type(typ[0], info)
1310 1311
        return QAPISchemaObjectTypeMember(name, typ, optional)

1312 1313
    def _make_members(self, data, info):
        return [self._make_member(key, value, info)
1314 1315 1316 1317 1318 1319 1320
                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,
1321
                                              self._make_members(data, info),
1322 1323 1324 1325 1326
                                              None))

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

1327
    def _make_simple_variant(self, case, typ, info):
1328 1329
        if isinstance(typ, list):
            assert len(typ) == 1
1330 1331 1332
            typ = self._make_array_type(typ[0], info)
        typ = self._make_implicit_object_type(
            typ, info, 'wrapper', [self._make_member('data', typ, info)])
1333 1334 1335 1336 1337 1338 1339
        return QAPISchemaObjectTypeVariant(case, typ)

    def _def_union_type(self, expr, info):
        name = expr['union']
        data = expr['data']
        base = expr.get('base')
        tag_name = expr.get('discriminator')
1340
        tag_member = None
1341 1342 1343
        if isinstance(base, dict):
            base = (self._make_implicit_object_type(
                    name, info, 'base', self._make_members(base, info)))
1344 1345 1346
        if tag_name:
            variants = [self._make_variant(key, value)
                        for (key, value) in data.iteritems()]
1347
            members = []
1348
        else:
1349
            variants = [self._make_simple_variant(key, value, info)
1350
                        for (key, value) in data.iteritems()]
E
Eric Blake 已提交
1351 1352 1353
            typ = self._make_implicit_enum_type(name, info,
                                                [v.name for v in variants])
            tag_member = QAPISchemaObjectTypeMember('type', typ, False)
1354
            members = [tag_member]
1355
        self._def_entity(
1356
            QAPISchemaObjectType(name, info, base, members,
1357
                                 QAPISchemaObjectTypeVariants(tag_name,
1358
                                                              tag_member,
1359 1360 1361 1362 1363 1364 1365
                                                              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()]
1366
        tag_member = QAPISchemaObjectTypeMember('type', 'QType', False)
1367 1368 1369
        self._def_entity(
            QAPISchemaAlternateType(name, info,
                                    QAPISchemaObjectTypeVariants(None,
1370
                                                                 tag_member,
1371 1372 1373 1374 1375 1376 1377 1378 1379
                                                                 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):
1380 1381
            data = self._make_implicit_object_type(
                name, info, 'arg', self._make_members(data, info))
1382 1383
        if isinstance(rets, list):
            assert len(rets) == 1
1384
            rets = self._make_array_type(rets[0], info)
1385 1386 1387 1388 1389 1390 1391
        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):
1392 1393
            data = self._make_implicit_object_type(
                name, info, 'arg', self._make_members(data, info))
1394 1395 1396 1397 1398 1399 1400 1401 1402 1403 1404 1405 1406 1407 1408 1409 1410 1411 1412 1413 1414 1415 1416 1417
        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)
1418

M
Markus Armbruster 已提交
1419
    def visit(self, visitor):
1420 1421 1422 1423
        visitor.visit_begin(self)
        for (name, entity) in sorted(self._entity_dict.items()):
            if visitor.visit_needed(entity):
                entity.visit(visitor)
M
Markus Armbruster 已提交
1424 1425
        visitor.visit_end()

1426

1427 1428 1429 1430
#
# Code generation helpers
#

1431 1432 1433 1434 1435 1436 1437 1438 1439 1440 1441 1442 1443
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 已提交
1444

1445 1446 1447 1448 1449 1450 1451 1452 1453 1454 1455 1456 1457 1458
# 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 已提交
1459 1460 1461
            if i < l - 1 and c_fun_str[i + 1].islower():
                new_name += '_'
            elif c_fun_str[i - 1].isdigit():
1462 1463 1464 1465
                new_name += '_'
        new_name += c
    return new_name.lstrip('_').upper()

E
Eric Blake 已提交
1466

1467 1468 1469
def c_enum_const(type_name, const_name, prefix=None):
    if prefix is not None:
        type_name = prefix
1470
    return camel_to_upper(type_name) + '_' + c_name(const_name, False).upper()
1471

1472
c_name_trans = string.maketrans('.-', '__')
1473

E
Eric Blake 已提交
1474

1475 1476 1477 1478 1479 1480 1481 1482 1483
# 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'
1484
def c_name(name, protect=True):
B
Blue Swirl 已提交
1485 1486
    # ANSI X3J11/88-090, 3.1.1
    c89_words = set(['auto', 'break', 'case', 'char', 'const', 'continue',
E
Eric Blake 已提交
1487 1488 1489 1490 1491
                     '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 已提交
1492 1493 1494
    # 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 已提交
1495 1496
    c11_words = set(['_Alignas', '_Alignof', '_Atomic', '_Generic',
                     '_Noreturn', '_Static_assert', '_Thread_local'])
B
Blue Swirl 已提交
1497 1498 1499
    # GCC http://gcc.gnu.org/onlinedocs/gcc-4.7.1/gcc/C-Extensions.html
    # excluding _.*
    gcc_words = set(['asm', 'typeof'])
1500 1501 1502 1503 1504 1505 1506 1507 1508 1509
    # 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'])
1510
    # namespace pollution:
1511
    polluted_words = set(['unix', 'errno', 'mips', 'sparc'])
E
Eric Blake 已提交
1512
    name = name.translate(c_name_trans)
E
Eric Blake 已提交
1513 1514
    if protect and (name in c89_words | c99_words | c11_words | gcc_words
                    | cpp_words | polluted_words):
B
Blue Swirl 已提交
1515
        return "q_" + name
E
Eric Blake 已提交
1516
    return name
1517

1518
eatspace = '\033EATSPACE.'
E
Eric Blake 已提交
1519
pointer_suffix = ' *' + eatspace
1520

E
Eric Blake 已提交
1521

1522 1523
def genindent(count):
    ret = ""
E
Eric Blake 已提交
1524
    for _ in range(count):
1525 1526 1527 1528 1529
        ret += " "
    return ret

indent_level = 0

E
Eric Blake 已提交
1530

1531 1532 1533 1534
def push_indent(indent_amount=4):
    global indent_level
    indent_level += indent_amount

E
Eric Blake 已提交
1535

1536 1537 1538 1539
def pop_indent(indent_amount=4):
    global indent_level
    indent_level -= indent_amount

E
Eric Blake 已提交
1540

1541 1542
# Generate @code with @kwds interpolated.
# Obey indent_level, and strip eatspace.
1543
def cgen(code, **kwds):
1544 1545 1546
    raw = code % kwds
    if indent_level:
        indent = genindent(indent_level)
1547 1548 1549
        # re.subn() lacks flags support before Python 2.7, use re.compile()
        raw = re.subn(re.compile("^.", re.MULTILINE),
                      indent + r'\g<0>', raw)
1550 1551
        raw = raw[0]
    return re.sub(re.escape(eatspace) + ' *', '', raw)
1552

E
Eric Blake 已提交
1553

1554
def mcgen(code, **kwds):
1555 1556 1557
    if code[0] == '\n':
        code = code[1:]
    return cgen(code, **kwds)
1558 1559 1560


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

E
Eric Blake 已提交
1563

1564 1565 1566 1567 1568 1569 1570 1571 1572
def guardstart(name):
    return mcgen('''

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

''',
                 name=guardname(name))

E
Eric Blake 已提交
1573

1574 1575 1576 1577 1578 1579 1580
def guardend(name):
    return mcgen('''

#endif /* %(name)s */

''',
                 name=guardname(name))
1581

E
Eric Blake 已提交
1582

1583
def gen_enum_lookup(name, values, prefix=None):
1584 1585
    ret = mcgen('''

1586
const char *const %(c_name)s_lookup[] = {
1587
''',
1588
                c_name=c_name(name))
1589 1590 1591 1592 1593
    for value in values:
        index = c_enum_const(name, value, prefix)
        ret += mcgen('''
    [%(index)s] = "%(value)s",
''',
1594
                     index=index, value=value)
1595

1596
    max_index = c_enum_const(name, '_MAX', prefix)
1597 1598 1599 1600
    ret += mcgen('''
    [%(max_index)s] = NULL,
};
''',
1601
                 max_index=max_index)
1602 1603
    return ret

E
Eric Blake 已提交
1604

1605 1606
def gen_enum(name, values, prefix=None):
    # append automatically generated _MAX value
1607
    enum_values = values + ['_MAX']
1608

1609
    ret = mcgen('''
1610

1611
typedef enum %(c_name)s {
1612
''',
1613
                c_name=c_name(name))
1614 1615 1616

    i = 0
    for value in enum_values:
1617 1618
        ret += mcgen('''
    %(c_enum)s = %(i)d,
1619
''',
1620
                     c_enum=c_enum_const(name, value, prefix),
1621 1622 1623
                     i=i)
        i += 1

1624 1625
    ret += mcgen('''
} %(c_name)s;
1626
''',
1627 1628 1629
                 c_name=c_name(name))

    ret += mcgen('''
1630

1631 1632 1633 1634
extern const char *const %(c_name)s_lookup[];
''',
                 c_name=c_name(name))
    return ret
1635

E
Eric Blake 已提交
1636

1637 1638 1639 1640 1641 1642 1643 1644 1645 1646 1647
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)
E
Eric Blake 已提交
1648
        ret += '%s %s' % (memb.type.c_param_type(), c_name(memb.name))
1649 1650 1651 1652
    if extra:
        ret += sep + extra
    return ret

E
Eric Blake 已提交
1653

1654
def gen_err_check():
E
Eric Blake 已提交
1655
    return mcgen('''
1656
    if (err) {
1657
        goto out;
E
Eric Blake 已提交
1658 1659 1660 1661
    }
''')


1662 1663 1664 1665
#
# Common command line parsing
#

E
Eric Blake 已提交
1666 1667

def parse_command_line(extra_options="", extra_long_options=[]):
1668 1669 1670

    try:
        opts, args = getopt.gnu_getopt(sys.argv[1:],
1671
                                       "chp:o:" + extra_options,
1672
                                       ["source", "header", "prefix=",
1673
                                        "output-dir="] + extra_long_options)
1674
    except getopt.GetoptError as err:
1675
        print >>sys.stderr, "%s: %s" % (sys.argv[0], str(err))
1676 1677 1678 1679 1680 1681 1682 1683 1684 1685 1686
        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"):
1687 1688 1689 1690 1691 1692
            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)
1693 1694 1695 1696 1697 1698 1699 1700 1701 1702 1703 1704 1705 1706
            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

1707 1708
    if len(args) != 1:
        print >>sys.stderr, "%s: need exactly one argument" % sys.argv[0]
1709
        sys.exit(1)
1710
    fname = args[0]
1711

1712
    return (fname, output_dir, do_c, do_h, prefix, extra_opts)
1713

1714 1715 1716 1717
#
# Generate output files with boilerplate
#

E
Eric Blake 已提交
1718

1719 1720
def open_output(output_dir, do_c, do_h, prefix, c_file, h_file,
                c_comment, h_comment):
M
Markus Armbruster 已提交
1721
    guard = guardname(prefix + h_file)
1722 1723 1724
    c_file = output_dir + prefix + c_file
    h_file = output_dir + prefix + h_file

1725 1726 1727
    if output_dir:
        try:
            os.makedirs(output_dir)
1728
        except os.error as e:
1729 1730
            if e.errno != errno.EEXIST:
                raise
1731 1732 1733 1734 1735 1736 1737 1738 1739 1740 1741 1742 1743 1744 1745

    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 已提交
1746
                     comment=c_comment))
1747 1748 1749 1750 1751 1752 1753 1754

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

''',
E
Eric Blake 已提交
1755
                      comment=h_comment, guard=guard))
1756 1757 1758

    return (fdef, fdecl)

E
Eric Blake 已提交
1759

1760 1761 1762 1763 1764 1765
def close_output(fdef, fdecl):
    fdecl.write('''
#endif
''')
    fdecl.close()
    fdef.close()