diff --git a/swift/obj/replicator.py b/swift/obj/replicator.py index 116cf4f67f..46cf37a020 100644 --- a/swift/obj/replicator.py +++ b/swift/obj/replicator.py @@ -572,6 +572,10 @@ class ObjectReplicator(Daemon): self.run_pool = GreenPool(size=self.concurrency) jobs = self.collect_jobs() for job in jobs: + dev_path = join(self.devices_dir, job['device']) + if self.mount_check and not os.path.ismount(dev_path): + self.logger.warn(_('%s is not mounted'), job['device']) + continue if not self.check_ring(): self.logger.info(_("Ring change detected. Aborting " "current replication pass."))