Skip to content
Snippets Groups Projects
Commit fcf824b4 authored by sguazt's avatar sguazt
Browse files

OpenStack: use InstanceStatus instead of strings in node status map

parent 38955e53
No related branches found
No related tags found
No related merge requests found
...@@ -24,24 +24,24 @@ class OpenStackInstance(Instance): ...@@ -24,24 +24,24 @@ class OpenStackInstance(Instance):
""" """
_NODE_STATUS_MAP = { _NODE_STATUS_MAP = {
'BUILD': 'pending', 'BUILD': InstanceStatus.PENDING,
'REBUILD': 'pending', 'REBUILD': InstanceStatus.PENDING,
'ACTIVE': 'running', 'ACTIVE': InstanceStatus.RUNNING,
'SUSPENDED': 'suspended', 'SUSPENDED': InstanceStatus.SUSPENDED,
'SHUTOFF': 'stopped', 'SHUTOFF': InstanceStatus.STOPPED,
'DELETED': 'terminated', 'DELETED': InstanceStatus.TERMINATED,
'QUEUE_RESIZE': 'pending', 'QUEUE_RESIZE': InstanceStatus.PENDING,
'PREP_RESIZE': 'pending', 'PREP_RESIZE': InstanceStatus.PENDING,
'VERIFY_RESIZE': 'running', 'VERIFY_RESIZE': InstanceStatus.RUNNING,
'PASSWORD': 'pending', 'PASSWORD': InstanceStatus.PENDING,
'RESCUE': 'pending', 'RESCUE': InstanceStatus.PENDING,
'REBOOT': 'rebooting', 'REBOOT': InstanceStatus.REBOOTING,
'HARD_REBOOT': 'rebooting', 'HARD_REBOOT': InstanceStatus.REBOOTING,
'SHARE_IP': 'pending', 'SHARE_IP': InstanceStatus.PENDING,
'SHARE_IP_NO_CONFIG': 'pending', 'SHARE_IP_NO_CONFIG': InstanceStatus.PENDING,
'DELETE_IP': 'pending', 'DELETE_IP': InstanceStatus.PENDING,
'ERROR': 'error', 'ERROR': InstanceStatus.ERROR,
'UNKNOWN': 'unknown' 'UNKNOWN': InstanceStatus.UNKNOWN
} }
def __init__(self, os_conn, os_instance): def __init__(self, os_conn, os_instance):
...@@ -88,9 +88,11 @@ class OpenStackInstance(Instance): ...@@ -88,9 +88,11 @@ class OpenStackInstance(Instance):
def start(self): def start(self):
self._os_conn.compute.start_server(self._os_inst) self._os_conn.compute.start_server(self._os_inst)
#TODO: call "self._os_conn.compute.wait_for_server(self._os_inst, status='ACTIVE', wait = timeout)" to perform a synchronous version of this method (note, if timeout is None you should invoke this method without the "wait" parameter, catching the "ResourceTimeout" exception and, in case such an exception is thrown, calling again the "wait_for_server()" method)
def stop(self): def stop(self):
self._os_conn.compute.stop_server(self._os_inst) self._os_conn.compute.stop_server(self._os_inst)
#TODO: call "self._os_conn.compute.wait_for_server(self._os_inst, status='ACTIVE', wait = timeout)" to perform a synchronous version of this method (note, if timeout is None you should invoke this method without the "wait" parameter, catching the "ResourceTimeout" exception and, in case such an exception is thrown, calling again the "wait_for_server()" method)
class OpenStack(MetaManager): class OpenStack(MetaManager):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment