PacketFramingStream.py 文件源码

def writeFrame(self):
        if self._endChecked:
            raise Exception("Cannot write frame data. Already present")

        self._stream.seek(self._prefixStart+4)
        check = zlib.adler32(self.MAGIC)
        sizeBytes = struct.pack("!I",self._dataSize)
        check = zlib.adler32(sizeBytes, check)
        self._stream.write(sizeBytes)
        self._stream.write(struct.pack("!I",check))

        self._stream.seek(self._prefixStart + self.PREFIX_SIZE + self._dataSize)

        check = zlib.adler32(sizeBytes)
        check = zlib.adler32(self.REV_MAGIC, check)
        self._stream.write(struct.pack("!I", check))
        self._stream.write(sizeBytes)
        self._stream.write(self.REV_MAGIC)

        self._endChecked = True