message.py 文件源码

def __init__(self, version, flags, unused, command, error_code, key, body=None, body_size=None):
        self.version = version
        self.flags = flags
        self.unused = unused
        self.command = command
        self.error_code = error_code

        # body is not specified, this is a stream header
        if body == None:
            # the body size is already specified, don't override it
            self.body_size = body_size if body_size != None else -1
            self.body_checksum = 1 # equivalent to zlib.adler32("")
        else:
            # the body size is already specified, don't override it
            self.body_size = body_size if body_size != None else len(body)
            self.body_checksum = zlib.adler32(body)

        self.key = key
        self.body = body