From: Rishabh Dave Date: Fri, 19 Jul 2019 04:35:18 +0000 (+0530) Subject: test_sessionmap: use sudo_write_file() from teuthology.misc X-Git-Tag: v15.1.0~2157^2 X-Git-Url: http://git.apps.os.sepia.ceph.com/?a=commitdiff_plain;h=4b776240705ebe8bdd0d43cd6244491e435a509c;p=ceph-ci.git test_sessionmap: use sudo_write_file() from teuthology.misc Instead of defining a method to write files within the testsuite, use sudo_write_file() from teuthology.misc. Signed-off-by: Rishabh Dave --- diff --git a/qa/tasks/cephfs/test_sessionmap.py b/qa/tasks/cephfs/test_sessionmap.py index 71d1334a442..5108d5d6ac8 100644 --- a/qa/tasks/cephfs/test_sessionmap.py +++ b/qa/tasks/cephfs/test_sessionmap.py @@ -6,6 +6,7 @@ import logging from tasks.cephfs.fuse_mount import FuseMount from teuthology.exceptions import CommandFailedError from tasks.cephfs.cephfs_test_case import CephFSTestCase +from teuthology.misc import sudo_write_file log = logging.getLogger(__name__) @@ -148,27 +149,6 @@ class TestSessionMap(CephFSTestCase): self.assertEqual(table_json['0']['result'], 0) self.assertEqual(len(table_json['0']['data']['Sessions']), 0) - def _sudo_write_file(self, remote, path, data): - """ - Write data to a remote file as super user - - :param remote: Remote site. - :param path: Path on the remote being written to. - :param data: Data to be written. - - Both perms and owner are passed directly to chmod. - """ - remote.run( - args=[ - 'sudo', - 'python', - '-c', - 'import shutil, sys; shutil.copyfileobj(sys.stdin, file(sys.argv[1], "wb"))', - path, - ], - stdin=data, - ) - def _configure_auth(self, mount, id_name, mds_caps, osd_caps=None, mon_caps=None): """ Set up auth credentials for a client mount, and write out the keyring @@ -188,7 +168,7 @@ class TestSessionMap(CephFSTestCase): "mon", mon_caps ) mount.client_id = id_name - self._sudo_write_file(mount.client_remote, mount.get_keyring_path(), out) + sudo_write_file(mount.client_remote, mount.get_keyring_path(), out) self.set_conf("client.{name}".format(name=id_name), "keyring", mount.get_keyring_path()) def test_session_reject(self):