+#!/usr/bin/python
+#
+# Copyright (c) 2003 Intel Corporation
+# All rights reserved.
+#
+# Copyright (c) 2004-2006 The Trustees of Princeton University
+# All rights reserved.
+
+import sys, traceback
import string
from Exceptions import *
import BootAPI
+import ModelOptions
-
-SKIP_MODEL_STRING= "/minhw"
-
-
-def Run( vars, log ):
+def Run(vars, log):
"""
- Contact PLC and get the attributes for this node. Also, if the node model
- string ends in SKIP_MODEL_STRING, override the hardware requirements
- configuration value, and skip the checks.
+
+ Contact PLC and get the attributes for this node. Also, parse in
+ options from the node model strong.
Also, update any node network settings at PLC, minus the ip address,
so, upload the mac (if node_id was in conf file), gateway, network,
broadcast, netmask, dns1/2, and the hostname/domainname.
Expect the following keys to be set:
- BOOT_CD_VERSION A tuple of the current bootcd version
SKIP_HARDWARE_REQUIREMENT_CHECK Whether or not we should skip hardware
requirement checks
The following keys are set/updated:
- WAS_NODE_ID_IN_CONF Set to 1 if the node id was in the conf file
- WAS_NODE_KEY_IN_CONF Set to 1 if the node key was in the conf file
- BOOT_STATE The current node boot state
- NODE_MODEL The user specified model of this node
- NETWORK_SETTINGS A dictionary of the values of the network settings
+ WAS_NODE_ID_IN_CONF Set to 1 if the node id was in the conf file
+ WAS_NODE_KEY_IN_CONF Set to 1 if the node key was in the conf file
+ BOOT_STATE The current node boot state
+ NODE_MODEL The user specified model of this node
+ NODE_MODEL_OPTIONS The options extracted from the user specified
+ model of this node
SKIP_HARDWARE_REQUIREMENT_CHECK Whether or not we should skip hardware
- requirement checks
-
+ requirement checks
+ NODE_SESSION The session value returned from BootGetNodeDetails
+ INTERFACES The network interfaces associated with this node
+ INTERFACE_SETTINGS A dictionary of the values of the interface settings
+
Return 1 if able to contact PLC and get node info.
Raise a BootManagerException if anything fails.
"""
- log.write( "\n\nStep: Retrieving details of node from PLC.\n" )
+ log.write("\n\nStep: Retrieving details of node from PLC.\n")
# make sure we have the variables we need
try:
- BOOT_CD_VERSION= vars["BOOT_CD_VERSION"]
- if BOOT_CD_VERSION == "":
- raise ValueError, "BOOT_CD_VERSION"
-
- SKIP_HARDWARE_REQUIREMENT_CHECK= vars["SKIP_HARDWARE_REQUIREMENT_CHECK"]
+ SKIP_HARDWARE_REQUIREMENT_CHECK = vars["SKIP_HARDWARE_REQUIREMENT_CHECK"]
if SKIP_HARDWARE_REQUIREMENT_CHECK == "":
- raise ValueError, "SKIP_HARDWARE_REQUIREMENT_CHECK"
+ raise ValueError("SKIP_HARDWARE_REQUIREMENT_CHECK")
- NETWORK_SETTINGS= vars["NETWORK_SETTINGS"]
- if NETWORK_SETTINGS == "":
- raise ValueError, "NETWORK_SETTINGS"
+ INTERFACE_SETTINGS = vars["INTERFACE_SETTINGS"]
+ if INTERFACE_SETTINGS == "":
+ raise ValueError("INTERFACE_SETTINGS")
- WAS_NODE_ID_IN_CONF= vars["WAS_NODE_ID_IN_CONF"]
+ WAS_NODE_ID_IN_CONF = vars["WAS_NODE_ID_IN_CONF"]
if WAS_NODE_ID_IN_CONF == "":
- raise ValueError, "WAS_NODE_ID_IN_CONF"
+ raise ValueError("WAS_NODE_ID_IN_CONF")
- WAS_NODE_KEY_IN_CONF= vars["WAS_NODE_KEY_IN_CONF"]
+ WAS_NODE_KEY_IN_CONF = vars["WAS_NODE_KEY_IN_CONF"]
if WAS_NODE_KEY_IN_CONF == "":
- raise ValueError, "WAS_NODE_KEY_IN_CONF"
-
- except KeyError, var:
- raise BootManagerException, "Missing variable in vars: %s\n" % var
- except ValueError, var:
- raise BootManagerException, "Variable in vars, shouldn't be: %s\n" % var
-
-
- details= BootAPI.call_api_function( vars, "BootGetNodeDetails", () )
-
- vars['BOOT_STATE']= details['boot_state']
- vars['NODE_MODEL']= string.strip(details['model'])
-
- log.write( "Successfully retrieved node record.\n" )
- log.write( "Current boot state: %s\n" % vars['BOOT_STATE'] )
- log.write( "Node make/model: %s\n" % vars['NODE_MODEL'] )
+ raise ValueError("WAS_NODE_KEY_IN_CONF")
+
+ except KeyError as var:
+ raise BootManagerException("Missing variable in vars: {}\n".format(var))
+ except ValueError as var:
+ raise BootManagerException("Variable in vars, shouldn't be: {}\n".format(var))
+
+ node_details = BootAPI.call_api_function(vars, "GetNodes",
+ (vars['NODE_ID'],
+ ['boot_state', 'nodegroup_ids', 'interface_ids', 'model', 'site_id']))[0]
+
+ vars['BOOT_STATE'] = node_details['boot_state']
+ vars['RUN_LEVEL'] = node_details['boot_state']
+ vars['NODE_MODEL'] = string.strip(node_details['model'])
+ vars['SITE_ID'] = node_details['site_id']
+ log.write("Successfully retrieved node record.\n")
+ log.write("Current boot state: {}\n".format(vars['BOOT_STATE']))
+ log.write("Node make/model: {}\n".format(vars['NODE_MODEL']))
- # if the end of NODE_MODEL string ends in SKIP_MODEL_STRING, skip hardware
- # requirement checks (overrides configuration)
- model= vars['NODE_MODEL']
- len_skip_str= len(SKIP_MODEL_STRING)
- if model[-len_skip_str:] == SKIP_MODEL_STRING:
- vars['SKIP_HARDWARE_REQUIREMENT_CHECK']= 1
- log.write( "node model indicates override to hardware requirements.\n" )
-
+ # parse in the model options from the node_model string
+ model = vars['NODE_MODEL']
+ options = ModelOptions.Get(model)
+ vars['NODE_MODEL_OPTIONS'] = options
+
+ # Check if we should skip hardware requirement check
+ if options & ModelOptions.MINHW:
+ vars['SKIP_HARDWARE_REQUIREMENT_CHECK'] = 1
+ log.write("node model indicates override to hardware requirements.\n")
# this contains all the node networks, for now, we are only concerned
# in the primary network
- node_networks= details['networks']
- got_primary= 0
- for network in node_networks:
+ interfaces = BootAPI.call_api_function(vars, "GetInterfaces", (node_details['interface_ids'],))
+ got_primary = 0
+ for network in interfaces:
if network['is_primary'] == 1:
- got_primary= 1
+ log.write("Primary network as returned from PLC: {}\n".format(network))
+ got_primary = 1
break
if not got_primary:
- raise BootManagerException, "Node did not have a primary network."
-
- log.write( "Primary network as returned from PLC: %s\n" % str(network) )
-
- # if we got this far, the ip on the floppy and the ip in plc match,
- # make the rest of the PLC information match whats on the floppy
- network['method']= NETWORK_SETTINGS['method']
-
- # only nodes that have the node_id specified directly in the configuration
- # file can change their mac address
- if BOOT_CD_VERSION[0] == 3 and WAS_NODE_ID_IN_CONF == 1:
- network['mac']= NETWORK_SETTINGS['mac']
-
- network['gateway']= NETWORK_SETTINGS['gateway']
- network['network']= NETWORK_SETTINGS['network']
- network['broadcast']= NETWORK_SETTINGS['broadcast']
- network['netmask']= NETWORK_SETTINGS['netmask']
- network['dns1']= NETWORK_SETTINGS['dns1']
- network['dns2']= NETWORK_SETTINGS['dns2']
+ raise BootManagerException("Node did not have a primary network.")
+
+ vars['INTERFACES'] = interfaces
- log.write( "Updating network settings at PLC to match floppy " \
- "(except for node ip).\n" )
- update_vals= {}
- update_vals['primary_network']= network
- BootAPI.call_api_function( vars, "BootUpdateNode", (update_vals,) )
+ # call getNodeFlavour and store in VARS['node_flavour']
+ try:
+ node_flavour = BootAPI.call_api_function(vars, "GetNodeFlavour", (vars['NODE_ID'],))
+ except:
+ log.write("GetNodeFlavour failed, not fatal if the node flavour is available in ``configuration''\n")
+ pass
+ flavour_keys = [
+ 'virt',# 'vs' or 'lxc'
+ 'nodefamily',# the basename for downloading nodeimage
+ 'extensions',# extensions to be applied on top of the base nodeimage
+ 'plain'# false if compressed image, true if not
+ ]
+
+ # MyPLC 5.0 workaround
+ # make sure to define 'extensions' even if not yet set
+ if 'extensions' not in vars or vars['extensions']=='':
+ vars['extensions'] = []
+
+ for k in flavour_keys:
+ # Support MyPLC<5.2
+ if k not in vars:
+ try:
+ vars[k] = node_flavour[k]
+ except:
+ exc_type, exc_value, exc_traceback = sys.exc_info()
+ lines = traceback.format_exception(exc_type, exc_value, exc_traceback)
+ for line in lines:
+ log.write(line)
+ raise BootManagerException("Could not call GetNodeFlavour - need PLCAPI-5.2")
+
+ log.write ("NodeFlavour as returned from PLC: {}\n".format(node_flavour))
+
return 1
git://git.onelab.eu / bootmanager.git / blobdiff