(self)
| 31 | self.remote = get_remote_for_role(self.ctx, self.client) |
| 32 | |
| 33 | def begin(self): |
| 34 | super(CephFSMirror, self).begin() |
| 35 | testdir = misc.get_testdir(self.ctx) |
| 36 | |
| 37 | args = [ |
| 38 | 'adjust-ulimits', |
| 39 | 'ceph-coverage', |
| 40 | '{tdir}/archive/coverage'.format(tdir=testdir), |
| 41 | 'daemon-helper', |
| 42 | 'term', |
| 43 | ] |
| 44 | |
| 45 | if 'valgrind' in self.config: |
| 46 | args = get_valgrind_args( |
| 47 | testdir, 'cephfs-mirror-{id}'.format(id=self.client), |
| 48 | args, self.config.get('valgrind')) |
| 49 | |
| 50 | args.extend([ |
| 51 | 'cephfs-mirror', |
| 52 | '--cluster', |
| 53 | self.cluster_name, |
| 54 | '--id', |
| 55 | self.client_id, |
| 56 | ]) |
| 57 | if 'run_in_foreground' in self.config: |
| 58 | args.extend(['--foreground']) |
| 59 | |
| 60 | self.ctx.daemons.add_daemon( |
| 61 | self.remote, 'cephfs-mirror', self.client, |
| 62 | args=args, |
| 63 | logger=self.log.getChild(self.client), |
| 64 | stdin=run.PIPE, |
| 65 | wait=False, |
| 66 | ) |
| 67 | |
| 68 | def end(self): |
| 69 | mirror_daemon = self.ctx.daemons.get_daemon('cephfs-mirror', self.client) |
nothing calls this directly
no test coverage detected