timeout=30
)
except RuntimeError:
- log.warn("Timeout waiting for daemons {0}, while we have {1}".format(
+ log.warning("Timeout waiting for daemons {0}, while we have {1}".format(
daemon_ids, get_daemon_names()
))
raise
if info:
return info['addr']
else:
- log.warn(json.dumps(list(self.get_all()), indent=2)) # dump for debugging
+ log.warning(json.dumps(list(self.get_all()), indent=2)) # dump for debugging
raise RuntimeError("MDS id '{0}' not found in map".format(name))
class CephCluster(object):
# failures) and ensure the mount is not left half-up.
# Otherwise we might leave a zombie mount point that causes
# anyone traversing cephtest/ to get hung up on.
- log.warn("Trying to clean up after failed mount")
+ log.warning("Trying to clean up after failed mount")
self.umount_wait(force=True)
raise
if ("endpoint is not connected" in error
or "Software caused connection abort" in error):
# This happens is fuse is killed without unmount
- log.warn("Found stale moutn point at {0}".format(self.mountpoint))
+ log.warning("Found stale moutn point at {0}".format(self.mountpoint))
return True
else:
# This happens if the mount directory doesn't exist
p = self.run_shell(["df", "-B1", "."])
lines = p.stdout.getvalue().strip().split("\n")
fs, total, used, avail = lines[1].split()[:4]
- log.warn(lines)
+ log.warning(lines)
return {
"total": int(total),
# Configs for this test should bring this setting down in order to
# run reasonably quickly
if osd_mon_report_interval > 10:
- log.warn("This test may run rather slowly unless you decrease"
+ log.warning("This test may run rather slowly unless you decrease"
"osd_mon_report_interval (5 is a good setting)!")
self.mount_a.run_python(template.format(
try:
mount.umount()
except (CommandFailedError, MaxWhileTries):
- log.warn("Ordinary umount failed, forcing...")
+ log.warning("Ordinary umount failed, forcing...")
forced = True
mount.umount_wait(force=True)
for remote in ctx.cluster.remotes.keys():
log.debug('checking console status of %s' % remote.shortname)
if not remote.console.check_status():
- log.warn('Failed to get console status for %s',
+ log.warning('Failed to get console status for %s',
remote.shortname)
# check that all osd remotes have a valid console
check_status=False
)
if p.exitstatus != 0:
- log.warn("ls conns failed with {0}, assuming none".format(p.exitstatus))
+ log.warning("ls conns failed with {0}, assuming none".format(p.exitstatus))
return []
ls_str = six.ensure_str(p.stdout.getvalue().strip())
for line in lines:
if 'ceph-fuse' in line or 'ceph-mds' in line:
pid = int(line.split()[0])
- log.warn("Killing stray process {0}".format(line))
+ log.warning("Killing stray process {0}".format(line))
os.kill(pid, signal.SIGKILL)
# Fire up the Ceph cluster if the user requested it
mount = LocalFuseMount(ctx, test_dir, client_id)
mounts.append(mount)
if mount.is_mounted():
- log.warn("unmounting {0}".format(mount.mountpoint))
+ log.warning("unmounting {0}".format(mount.mountpoint))
mount.umount_wait()
else:
if os.path.exists(mount.mountpoint):
if hasattr(fn, 'is_for_teuthology') and getattr(fn, 'is_for_teuthology') is True:
drop_test = True
- log.warn("Dropping test because long running: ".format(method.id()))
+ log.warning("Dropping test because long running: ".format(method.id()))
if getattr(fn, "needs_trimming", False) is True:
drop_test = (os.getuid() != 0)
- log.warn("Dropping test because client trim unavailable: ".format(method.id()))
+ log.warning("Dropping test because client trim unavailable: ".format(method.id()))
if drop_test:
# Don't drop the test if it was explicitly requested in arguments