def run(self, args, check_status=True, wait=True,
stdout=None, stderr=None, cwd=None, stdin=None,
- logger=None, label=None, env=None):
+ logger=None, label=None, env=None, timeout=None):
# We don't need no stinkin' sudo
args = [a for a in args if a != "sudo"]
proc = self.controller.run([os.path.join(BIN_PREFIX, "ceph")] + list(args), **kwargs)
return proc.exitstatus
- def admin_socket(self, daemon_type, daemon_id, command, check_status=True):
+ def admin_socket(self, daemon_type, daemon_id, command, check_status=True, timeout=None):
return self.controller.run(
- args=[os.path.join(BIN_PREFIX, "ceph"), "daemon", "{0}.{1}".format(daemon_type, daemon_id)] + command, check_status=check_status
+ args=[os.path.join(BIN_PREFIX, "ceph"), "daemon", "{0}.{1}".format(daemon_type, daemon_id)] + command,
+ check_status=check_status,
+ timeout=timeout
)