Source code for freezer_dr.evacuators.drivers.default.standard

# (c) Copyright 2014,2015 Hewlett-Packard Development Company, L.P.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
from freezer_dr.common.utils import get_os_client
from freezer_dr.evacuators.common.driver import EvacuatorBaseDriver
from oslo_config import cfg
from oslo_log import log
import time

CONF = cfg.CONF
LOG = log.getLogger(__name__)


[docs]class StandardEvacuator(EvacuatorBaseDriver): def __init__(self, nodes, evacuator_conf, fencer): super(StandardEvacuator, self).__init__(nodes, evacuator_conf, fencer) # initialize the OS client! self.client = get_os_client() self.wait = evacuator_conf.get('wait') self.retires = evacuator_conf.get('retries', 1) if self.retires <= 0: self.retires = 1 def _disable_node(self, node): if not self.is_node_disabled(node): return self.disable_node(node) else: True
[docs] def evacuate(self, enable_fencing=True): # try to disable node # @todo needs more error handling like if the status didn't update or # we are unable to disable the node ??? failed_nodes = [] # maintain nodes that are going to fail at any state succeeded_nodes = [] for node in self.nodes: status = False for i in range(0, self.retires): status = self._disable_node(node) # if True ( node disabled ) break the loop if status: break else: status = False node['status'] = status # make sure the disable request was successful if not self.get_node_status(node): # if the node failed at any step no reason to move it to # the next step failed_nodes.append(node) self.nodes.remove(node) # else: succeeded_nodes.append(node) nodes = succeeded_nodes if enable_fencing: nodes = self.fencer.fence(nodes=nodes) """ @todo this code needs to be commented for the time being till we fix nova bug found in state, which always go up afer enable or disable. We will use get_node_details for the time being from the main script to get nodes details before evacuating ... succeeded_nodes = [] for node in nodes: node['instances'] = self.driver.get_node_instances(node) succeeded_nodes.append(node) nodes = succeeded_nodes """ # Start evacuation calls ... evacuated_nodes = [] for i in range(0, self.retires): try: time.sleep(self.wait) nodes = self.evacuate_nodes(nodes) if not nodes: break evacuated_nodes = nodes except Exception as e: LOG.error(e) return evacuated_nodes, failed_nodes
[docs] def get_node_instances(self, node): return self.client.get_hypervisor_instances(node)
[docs] def disable_node(self, node): return self.client.disable_node(node)
[docs] def get_node_status(self, node): return self.client.get_node_status(node)
[docs] def is_node_disabled(self, node): return self.client.get_node_status(node)
[docs] def evacuate_nodes(self, nodes): return self.client.evacuate( nodes, shared_storage=self.evacuator_conf['shared_storage'])
[docs] def get_info(self): """ To be implemented. Get Driver Information :return: Dict contains driver information """ raise NotImplementedError