From: carey.xu <carey.xuhan@huawei.com>
Date: Wed, 3 Feb 2016 01:54:03 +0000 (+0800)
Subject: bugfix: increase retry time when get cluster state
X-Git-Tag: colorado.1.0~199
X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=commitdiff_plain;h=refs%2Fchanges%2F93%2F9093%2F4;p=compass4nfv.git

bugfix: increase retry time when get cluster state

JIRA: COMPASS-301

Change-Id: I10dad32f1f1f7429d0081851042db7dbe204c71e
Signed-off-by: carey.xu <carey.xuhan@huawei.com>
---

diff --git a/deploy/client.py b/deploy/client.py
index 174356e0..0d51ce20 100644
--- a/deploy/client.py
+++ b/deploy/client.py
@@ -834,6 +834,21 @@ class CompassClient(object):
             )
             raise RuntimeError("redeploy cluster failed")
 
+    def get_cluster_state(self, cluster_id):
+        for _ in range(10):
+            try:
+                status, cluster_state = self.client.get_cluster_state(cluster_id)
+                if self.is_ok(status):
+                    break
+            except:
+                status = 500
+                cluster_state = ""
+
+            LOG.error("can not get cluster %s's state, try again" % cluster_id)
+            time.sleep(6)
+
+        return status, cluster_state
+
     def get_installing_progress(self, cluster_id):
         def _get_installing_progress():
             """get intalling progress."""
@@ -843,16 +858,9 @@ class CompassClient(object):
 
             current_time = time.time
             while current_time() < deployment_timeout:
-                status, cluster_state = self.client.get_cluster_state(cluster_id)
+                status, cluster_state = self.get_cluster_state(cluster_id)
                 if not self.is_ok(status):
-                    LOG.error("can not get cluster state")
-
-                    # maybe a transient error?
-                    time.sleep(5)
-                    status, cluster_state = self.client.get_cluster_state(cluster_id)
-                    if not self.is_ok(status):
-                        # OK, there's something wrong
-                        raise RuntimeError("can not get cluster state")
+                    raise RuntimeError("can not get cluster state")
 
                 if cluster_state['state'] in ['UNINITIALIZED', 'INITIALIZED']:
                     if current_time() >= action_timeout: