diff --git a/kvmagent/kvmagent/plugins/ha_plugin.py b/kvmagent/kvmagent/plugins/ha_plugin.py index a8cbea4cae..8480c13972 100755 --- a/kvmagent/kvmagent/plugins/ha_plugin.py +++ b/kvmagent/kvmagent/plugins/ha_plugin.py @@ -117,7 +117,12 @@ def setup_ceph_self_fencer(self, req): self.run_ceph_fencer = True def ceph_in_error_stat(): - healthStatus = shell.call('ceph health') + healthStatus = shell.ShellCmd('timeout %s ceph health' % cmd.storageCheckerTimeout) + healthStatus(False) + + if healthStatus.return_code != 0: + return True + return healthStatus.startswith('HEALTH_ERR') def heartbeat_file_exists():