recipe-511433.py 文件源码

def recv(self):
        'Receive one object.'
        self.__recv.acquire()
        try:
            while '\0' not in self.__temp:
                temp = self.__sock.recv(2 ** 12)
                if not temp:
                    if self.__temp:
                        raise IOError
                    else:
                        raise EOFError
                self.__temp += temp
            temp, self.__temp = self.__temp.split('\0', 1)
        finally:
            self.__recv.release()
        return _cPickle.loads(_base255.decode(temp))

################################################################################