connection.py 文件源码

def read(self, size):
        try:
            tmp = self.socket.recv(size)
            if not tmp:
                raise ConnectionClosed()
            return tmp
        except socket.error, e:
            if e.errno == errno.EAGAIN:
                raise ConnectionAgain(str(e))
            if e.errno == errno.EBADF:
                raise ConnectionClosed(str(e))
            if e.errno == errno.ECONNRESET:
                raise ConnectionClosed(str(e))
            raise