CLOUDSTACK-6164: Added few changes for CLOUDSTACK-6164

test/integration/smoke/test_hosts.py

@@ -104,6 +104,8 @@ class TestHosts(cloudstackTestCase):
                                podid=self.pod.id,
                                hypervisor=self.hypervisor
                                )
+                if host == FAILED:
+                    self.fail("Host Creation Failed")
                 self.debug(
                     "Created host (ID: %s) in cluster ID %s" %(
                                                                 host.id,

tools/marvin/marvin/lib/base.py

@@ -22,6 +22,9 @@
 import marvin
 from utils import is_server_ssh_ready, random_gen
 from marvin.cloudstackAPI import *
+from marvin.codes import FAILED, PASS
+from marvin.cloudstackException import GetDetailExceptionInfo
+from marvin.lib.utils import validateList
 # Import System modules
 import time
 import hashlib
@@ -1782,8 +1785,12 @@ class Host:
 
     @classmethod
     def create(cls, apiclient, cluster, services, zoneid=None, podid=None, hypervisor=None):
-        """Create Host in cluster"""
+        """
-
+        1. Creates the host based upon the information provided.
+        2. Verifies the output of the adding host and its state post addition
+           Returns FAILED in case of an issue, else an instance of Host
+        """
+        try:
             cmd = addHost.addHostCmd()
             cmd.hypervisor = hypervisor
             cmd.url = services["url"]
@@ -1806,11 +1813,30 @@ class Host:
             if "password" in services:
                 cmd.password = services["password"]
 
-        # Add host
+            '''
+            Adds a Host,
+            If response is valid and host is up return
+            an instance of Host.
+            If response is invalid, returns FAILED.
+            If host state is not up, verify through listHosts call
+            till host status is up and return accordingly. Max 3 retries
+            '''
             host = apiclient.addHost(cmd)
-
+            ret = validateList(host)
-        if isinstance(host, list):
+            if ret[0] == PASS:
+                if str(host[0].state).lower() == 'up':
                     return Host(host[0].__dict__)
+                retries = 3
+                while retries:
+                    lh_resp = apiclient.listHosts(host[0].id)
+                    ret = validateList(lh_resp)
+                    if (ret[0] == PASS) and (str(ret[1].state).lower() == 'up'):
+                        return Host(host[0].__dict__)
+                    retries += -1
+            return FAILED
+        except Exception, e:
+            print "Exception Occurred Under Host.create : %s" % GetDetailExceptionInfo(e)
+            return FAILED
 
     def delete(self, apiclient):
         """Delete Host"""