(self, ctx=None, cluster_name=None)
| 810 | # the same name. |
| 811 | class LocalCephManager(CephManager): |
| 812 | def __init__(self, ctx=None, cluster_name=None): |
| 813 | self.ctx = ctx |
| 814 | self.cluster = cluster_name |
| 815 | |
| 816 | # Deliberately skip parent init, only inheriting from it to get |
| 817 | # util methods like osd_dump that sit on top of raw_cluster_cmd |
| 818 | self.controller = LocalRemote() |
| 819 | |
| 820 | # A minority of CephManager fns actually bother locking for when |
| 821 | # certain teuthology tests want to run tasks in parallel |
| 822 | self.lock = threading.RLock() |
| 823 | |
| 824 | self.log = lambda x: log.debug(x) |
| 825 | |
| 826 | # Don't bother constructing a map of pools: it should be empty |
| 827 | # at test cluster start, and in any case it would be out of date |
| 828 | # in no time. The attribute needs to exist for some of the CephManager |
| 829 | # methods to work though. |
| 830 | self.pools = {} |
| 831 | |
| 832 | # NOTE: These variables are being overriden here so that parent class |
| 833 | # can pick it up. |
| 834 | self.cephadm = False |
| 835 | self.rook = False |
| 836 | self.testdir = None |
| 837 | self.RADOS_CMD = [RADOS_CMD] |
| 838 | |
| 839 | self.save_conf_epoch() |
| 840 | |
| 841 | def get_ceph_cmd(self, **kwargs): |
| 842 | return [CEPH_CMD] |
nothing calls this directly
no test coverage detected