done = mgr_map['available']
if done:
log.info("Available after assign ports (new active {0}/{1})".format(
- mgr_map['active_name'] , mgr_map['active_gid']))
+ mgr_map['active_name'], mgr_map['active_gid']))
return done
cls.wait_until_true(is_available, timeout=30)
"create-self-signed-cert")
def test_standby(self):
- original_active = self.mgr_cluster.get_active_id()
-
+ original_active_id = self.mgr_cluster.get_active_id()
original_uri = self._get_uri("dashboard")
- log.info("Originally running at {0}".format(original_uri))
+ log.info("Originally running manager '{}' at {}".format(
+ original_active_id, original_uri))
- self.mgr_cluster.mgr_fail(original_active)
+ # Force a failover and wait until the previously active manager
+ # is listed as standby.
+ self.mgr_cluster.mgr_fail(original_active_id)
+ self.wait_until_true(
+ lambda: original_active_id in self.mgr_cluster.get_standby_ids(),
+ timeout=30)
+ failed_active_id = self.mgr_cluster.get_active_id()
failed_over_uri = self._get_uri("dashboard")
- log.info("After failover running at {0}".format(failed_over_uri))
+ log.info("After failover running manager '{}' at {}".format(
+ failed_active_id, failed_over_uri))
self.assertNotEqual(original_uri, failed_over_uri)
</head>
<body>
No active ceph-mgr instance is currently running
- the dashboard. A failover may be in progress.
+ the dashboard. A failover may be in progress.
Retrying in {delay} seconds...
</body>
</html>