Method write_background

qa/tasks/cephfs/mount.py:1225–1263

Open a file for writing, complete as soon as you can :param basename: :return:

(self, basename="background_file", loop=False)

        ])

    def write_background(self, basename="background_file", loop=False):
        """
        Open a file for writing, complete as soon as you can
        :param basename:
        :return:
        """
        assert(self.is_mounted())

        path = os.path.join(self.hostfs_mntpt, basename)

        pyscript = dedent("""
            import fcntl
            import os
            import sys
            import time

            fcntl.fcntl(sys.stdin, fcntl.F_SETFL, fcntl.fcntl(sys.stdin, fcntl.F_GETFL) | os.O_NONBLOCK)

            fd = os.open("{path}", os.O_RDWR | os.O_CREAT, 0o644)
            try:
                while True:
                    print("write_background: writing", file=sys.stderr)
                    os.write(fd, b'content')
                    if not {loop}:
                        break
                    try:
                        if os.read(0, 4096) == b"":
                            break
                    except BlockingIOError:
                        pass
                    time.sleep(2)
            except IOError as e:
                pass
            os.close(fd)
            """).format(path=path, loop=str(loop))

        rproc = self._run_python(pyscript)
        self.background_procs.append(rproc)
        return rproc

    def write_n_mb(self, filename, n_mb, seek=0, wait=True):
        """