connection.py 文件源码

def write(self, obj):
        try:
            size = self.socket.send(obj)
            if size == 0:
                raise ConnectionClosed()
            return size
        except socket.error, e:
            if e.errno == errno.EAGAIN:
                raise ConnectionAgain(str(e))
            if e.errno == errno.EPIPE:
                raise ConnectionClosed(str(e))
            if e.errno == errno.ECONNRESET:
                raise ConnectionClosed(str(e))
            raise