qa/cephfs: enhance write_brachground()

Signed-off-by: Venky Shankar <vshankar@redhat.com>

diff --git a/qa/tasks/cephfs/mount.py b/qa/tasks/cephfs/mount.py
index 35d7c630dff2ae80337d7aeaba135dfad11a37fd..0863d282cf487b93f2d1c72c74d70a0d8851962d 100644 (file)
--- a/qa/tasks/cephfs/mount.py
+++ b/qa/tasks/cephfs/mount.py
@@ -1190,10 +1190,12 @@ class CephFSMountBase(object):
             'python3', '-c', pyscript
         ])
 
-    def write_background(self, basename="background_file", loop=False):
+    def write_background(self, basename="background_file", loop=False, sleep_interval=2):
         """
         Open a file for writing, complete as soon as you can
-        :param basename:
+        :param basename: filename to create/write
+        :param loop: write till stdin is closed
+        :param sleep_interval: delay between write operations
         :return:
         """
         assert(self.is_mounted())
@@ -1220,11 +1222,11 @@ class CephFSMountBase(object):
                             break
                     except BlockingIOError:
                         pass
-                    time.sleep(2)
+                    time.sleep(sleep_interval)
             except IOError as e:
                 pass
             os.close(fd)
-            """).format(path=path, loop=str(loop))
+            """).format(path=path, loop=str(loop), delay=sleep_interval)
 
         rproc = self._run_python(pyscript)
         self.background_procs.append(rproc)