def METHOD_NAME(ceph_cluster, get_fs_info=None, **kw):
    try:
        """
        CEPH-11259 - MDS node/service add and removal test, with client
        Pre-requisites :
        1. Create cephfs volume
        Test Case Flow:
        1. Start IOs
        2. remove 1 msd
        3. IO's shouldn't fail
        4. add 1 msd
        5. IO's shouldn't fail
        Cleanup:
        1. Remove all the data in cephfs
        2. Remove all the mounts
        """
        tc = "CEPH-11259"
        log.info("Running cephfs %s test case" % (tc))
        fs_util = FsUtils(ceph_cluster)
        client = ceph_cluster.get_ceph_objects("client")
        mdss = ceph_cluster.get_ceph_objects("mds")
        client1 = client[0]
        mount_dir = "".join(
            secrets.choice(string.ascii_uppercase + string.digits) for i in range(5)
        )
        kernel_mount_dir = f"/mnt/kernel_{mount_dir}"
        fuse_mount_dir = f"/mnt/fuse_{mount_dir}"
        mon_node_ip = fs_util.get_mon_node_ips()
        mon_node_ip = ",".join(mon_node_ip)
        fs_util.kernel_mount(
            [client1], kernel_mount_dir, mon_node_ip, new_client_hostname="admin"
        )
        fs_util.fuse_mount([client1], fuse_mount_dir, new_client_hostname="admin")
        with parallel() as p:
            p.spawn(mds_rm_add, fs_util, mdss, client1)
            p.spawn(
                start_io_time,
                fs_util,
                client1,
                kernel_mount_dir + "/kernel_1",
                timeout=0,
            )
            p.spawn(
                start_io_time,
                fs_util,
                client1,
                fuse_mount_dir + "/fuse_1",
                timeout=0,
            )
        return 0
    except Exception as e:
        log.error(e)
        log.error(traceback.format_exc())
        return 1
    finally:
        client1.exec_command(sudo=True, cmd=f"rm -rf {kernel_mount_dir}/*")
        client1.exec_command(sudo=True, cmd=f"umount {kernel_mount_dir}")
        client1.exec_command(sudo=True, cmd=f"umount {fuse_mount_dir}")
        client1.exec_command(sudo=True, cmd=f"rm -rf {kernel_mount_dir}/")
        client1.exec_command(sudo=True, cmd=f"rm -rf {fuse_mount_dir}/")