projects / ceph.git / blame
| Commit | Line | Data |
|---|---|---|
| 7c673cae FG |
1 | |
| 2 | from unittest import case | |
| 3 | from tasks.cephfs.cephfs_test_case import CephFSTestCase | |
| 4 | from tasks.cephfs.fuse_mount import FuseMount | |
| 5 | ||
| 6 | ||
| 7 | class TestConfigCommands(CephFSTestCase): | |
| 8 | """ | |
| 9 | Test that daemons and clients respond to the otherwise rarely-used | |
| 10 | runtime config modification operations. | |
| 11 | """ | |
| 12 | ||
| 13 | CLIENTS_REQUIRED = 1 | |
| 14 | MDSS_REQUIRED = 1 | |
| 15 | ||
| 16 | def test_client_config(self): | |
| 17 | """ | |
| 18 | That I can successfully issue asok "config set" commands | |
| 19 | ||
| 20 | :return: | |
| 21 | """ | |
| 22 | ||
| 23 | if not isinstance(self.mount_a, FuseMount): | |
| 24 | raise case.SkipTest("Test only applies to FUSE clients") | |
| 25 | ||
| 26 | test_key = "client_cache_size" | |
| 27 | test_val = "123" | |
| 28 | self.mount_a.admin_socket(['config', 'set', test_key, test_val]) | |
| 29 | out = self.mount_a.admin_socket(['config', 'get', test_key]) | |
| 30 | self.assertEqual(out[test_key], test_val) | |
| 31 | ||
| 32 | self.mount_a.write_n_mb("file.bin", 1); | |
| 33 | ||
| 34 | # Implicitly asserting that things don't have lockdep error in shutdown | |
| 35 | self.mount_a.umount_wait(require_clean=True) | |
| 36 | self.fs.mds_stop() | |
| 37 | ||
| 38 | def test_mds_config_asok(self): | |
| 39 | test_key = "mds_max_purge_ops" | |
| 40 | test_val = "123" | |
| 41 | self.fs.mds_asok(['config', 'set', test_key, test_val]) | |
| 42 | out = self.fs.mds_asok(['config', 'get', test_key]) | |
| 43 | self.assertEqual(out[test_key], test_val) | |
| 44 | ||
| 45 | # Implicitly asserting that things don't have lockdep error in shutdown | |
| 46 | self.mount_a.umount_wait(require_clean=True) | |
| 47 | self.fs.mds_stop() | |
| 48 | ||
| 49 | def test_mds_config_tell(self): | |
| 50 | test_key = "mds_max_purge_ops" | |
| 51 | test_val = "123" | |
| 52 | ||
| 53 | mds_id = self.fs.get_lone_mds_id() | |
| 54 | self.fs.mon_manager.raw_cluster_cmd("tell", "mds.{0}".format(mds_id), "injectargs", | |
| 55 | "--{0}={1}".format(test_key, test_val)) | |
| 56 | ||
| 57 | # Read it back with asok because there is no `tell` equivalent | |
| 58 | out = self.fs.mds_asok(['config', 'get', test_key]) | |
| 59 | self.assertEqual(out[test_key], test_val) | |
| 60 | ||
| 61 | # Implicitly asserting that things don't have lockdep error in shutdown | |
| 62 | self.mount_a.umount_wait(require_clean=True) | |
| 63 | self.fs.mds_stop() |