connection.py 文件源码

def getMessage(self):
        if len(self.__readBuffer) < 4:
            return None
        l = struct.unpack('i', self.__readBuffer[:4])[0]
        if len(self.__readBuffer) - 4 < l:
            return None
        data = self.__readBuffer[4:4 + l]
        try:
            message = cPickle.loads(zlib.decompress(data))
        except (zlib.error, cPickle.UnpicklingError):
            self.__disconnected = True
            return None
        self.__readBuffer = self.__readBuffer[4 + l:]
        return message