# IBM(c) 2012 EPL license http://www.eclipse.org/legal/epl-v10.html #------------------------------------------------------- =head1 xCAT plugin to support Profiled nodes management =cut #------------------------------------------------------- package xCAT_plugin::profilednodes; use strict; use warnings; use Getopt::Long qw(:config no_ignore_case); use Data::Dumper; require xCAT::Table; require xCAT::DBobjUtils; require xCAT::Utils; require xCAT::TableUtils; require xCAT::NetworkUtils; require xCAT::MsgUtils; require xCAT::ProfiledNodeUtils; # Globals. # These 2 global variables are for storing the parse result of hostinfo file. # These 2 global varialbes are set in lib xCAT::DBobjUtils->readFileInput. #%::FILEATTRS; #@::fileobjnames; # All database records. my %allhostnames; my %allbmcips; my %allmacs; my %allips; my %allinstallips; my %allnicips; my %allracks; my %allchassis; # The array of all chassis which is special CMM my %allcmmchassis; # Define parameters for xcat requests. my $request; my $callback; my $request_command; my $command; my $args; # Put arguments in a hash. my %args_dict; #------------------------------------------------------- =head3 handled_commands Return list of commands handled by this plugin =cut #------------------------------------------------------- sub handled_commands { return { nodeimport => 'profilednodes', nodepurge => 'profilednodes', nodechprofile => 'profilednodes', noderefresh => 'profilednodes', nodediscoverstart => 'profilednodes', nodediscoverstop => 'profilednodes', nodediscoverls => 'profilednodes', nodediscoverstatus => 'profilednodes', nodeaddunmged => 'profilednodes', nodechmac => 'profilednodes', findme => 'profilednodes', }; } #------------------------------------------------------- =head3 process_request Process the command. This is the main call. =cut #------------------------------------------------------- sub process_request { $request = shift; $callback = shift; #$::CALLBACK = $callback; $request_command = shift; $command = $request->{command}->[0]; $args = $request->{arg}; # There is no need to acquire lock for command nodediscoverstatus and nodediscoverls. if ($command eq "nodediscoverstatus"){ nodediscoverstatus(); return; } elsif ($command eq "nodediscoverls"){ nodediscoverls(); return; } my $lock = xCAT::Utils->acquire_lock("nodemgmt", 1); if (! $lock){ setrsp_errormsg("Cannot acquire lock, another process is already running."); return; } # These commands should make sure no discover is running. if (grep{ $_ eq $command} ("nodeimport", "nodepurge", "nodechprofile", "nodeaddunmged", "nodechmac")){ my $discover_running = xCAT::ProfiledNodeUtils->is_discover_started(); if ($discover_running){ setrsp_errormsg("Cannot run the $command command, the node discovery process is already running."); xCAT::Utils->release_lock($lock, 1); return; } } if ($command eq "nodeimport"){ nodeimport(); } elsif ($command eq "nodepurge"){ nodepurge(); } elsif ($command eq "nodechprofile"){ nodechprofile(); } elsif ($command eq "noderefresh"){ noderefresh(); } elsif ($command eq "nodediscoverstart"){ nodediscoverstart(); } elsif ($command eq "nodediscoverstop"){ nodediscoverstop(); } elsif ($command eq "findme"){ findme(); } elsif ($command eq "nodeaddunmged"){ nodeaddunmged(); } elsif ($command eq "nodechmac"){ nodechmac(); } xCAT::Utils->release_lock($lock, 1); } #------------------------------------------------------- =head3 parse_args Description : Parse arguments. We placed arguments into a directory %args_dict Arguments : args - args of xCAT requests. Returns : undef - parse succeed. A string - parse arguments failed, the return value is error message. =cut #----------------------------------------------------- sub parse_args{ foreach my $arg (@ARGV){ my @argarray = split(/=/,$arg); my $arglen = @argarray; if ($arglen > 2){ return "Illegal argument $arg specified."; } # translate the profile names into real group names in db. if($argarray[0] eq "networkprofile"){ $args_dict{$argarray[0]} = "__NetworkProfile_".$argarray[1]; } elsif ($argarray[0] eq "imageprofile"){ $args_dict{$argarray[0]} = "__ImageProfile_".$argarray[1]; } elsif ($argarray[0] eq "hardwareprofile"){ $args_dict{$argarray[0]} = "__HardwareProfile_".$argarray[1]; } else{ $args_dict{$argarray[0]} = $argarray[1]; } } return undef; } sub validate_args{ my $helpmsg = shift; my $enabledparamsref = shift; my $mandatoryparamsref = shift; my $help; my $ver; @ARGV = (); if($args) { @ARGV = @$args; } GetOptions( 'h|help' => \$help, 'V|verbose' => \$::VERBOSE, 'v|version' => \$ver, ); if($help){ setrsp_infostr($helpmsg); return 0; } if($ver){ my $version = xCAT::Utils->Version(); my $versionmsg = "$command : $version"; setrsp_infostr($versionmsg); return 0; } my $parseret = parse_args(); if ($parseret){ setrsp_errormsg($parseret); return 0; } # Make sure the specified parameters are valid ones. my @enabledparams = (); if($enabledparamsref){ @enabledparams = @$enabledparamsref; } foreach my $argname (keys %args_dict){ if (! grep{ $_ eq $argname} @enabledparams){ setrsp_errormsg("Illegal attribute $argname specified."); return 0; } } # Mandatory arguments. my @mandatoryparams = (); if ($mandatoryparamsref){ @mandatoryparams = @$mandatoryparamsref; } foreach (@mandatoryparams){ if(! exists($args_dict{$_})){ setrsp_errormsg("You must specify the $_ option."); return 0; } } return 1; } #------------------------------------------------------- =head3 nodeimport Description : Create profiled nodes by importing hostinfo file. This sub maps to request "nodeimport", we need to call this command from CLI like following steps: # ln -s /opt/xcat/bin/xcatclientnnr /opt/xcat/bin/nodeimport # nodeimport file=/root/hostinfo.file networkprofile=network_cn imageprofile=rhel63_cn hardwareprofile=ipmi groups=group1,group2 The hostinfo file should be written like: (MAC address is mandatory attribute) # Auto generate hostname for this node entry. __hostname__: mac=11:11:11:11:11:11 # Specified hostname node. node01: mac=22:22:22:22:22:22 After this call finished, the compute node's info will be updated automatically in /etc/hosts, dns config, dhcp config, TFTP config... =cut #------------------------------------------------------- sub nodeimport{ # Parse arges. xCAT::MsgUtils->message('S', "Import profiled nodes through hostinfo file."); my $helpmsg = "nodeimport: create profiled nodes by importing hostinfo file. Usage: \tnodeimport file= networkprofile= imageprofile= hostnameformat= [hardwareprofile=] [groups=] \tnodeimport [-h|--help] \tnodeimport {-v|--version}"; my @enabledparams = ('file', 'groups', 'networkprofile', 'hardwareprofile', 'imageprofile', 'hostnameformat'); my @mandatoryparams = ('file','networkprofile', 'imageprofile', 'hostnameformat'); my $ret = validate_args($helpmsg, \@enabledparams, \@mandatoryparams); if (! $ret){ return; } if(! (-e $args_dict{'file'})){ setrsp_errormsg("Node information file does not exist."); return; } # validate hostnameformat: my $nameformattype = xCAT::ProfiledNodeUtils->get_hostname_format_type($args_dict{'hostnameformat'}); if ($nameformattype eq "unknown"){ setrsp_errormsg("Invalid node name format: $args_dict{'hostnameformat'}"); return; } # Validate if profile consistent my $imageprofile = $args_dict{'imageprofile'}; my $networkprofile = $args_dict{'networkprofile'}; my $hardwareprofile = $args_dict{'hardwareprofile'}; my ($returncode, $errmsg) = xCAT::ProfiledNodeUtils->check_profile_consistent($imageprofile, $networkprofile, $hardwareprofile); if (not $returncode) { setrsp_errormsg($errmsg); return; } # Get database records: all hostnames, all ips, all racks... xCAT::MsgUtils->message('S', "Getting database records."); my $recordsref = xCAT::ProfiledNodeUtils->get_allnode_singleattrib_hash('nodelist', 'node'); %allhostnames = %$recordsref; $recordsref = xCAT::ProfiledNodeUtils->get_allnode_singleattrib_hash('ipmi', 'bmc'); %allbmcips = %$recordsref; $recordsref = xCAT::ProfiledNodeUtils->get_allnode_singleattrib_hash('mac', 'mac'); %allmacs = %$recordsref; # Get all FSP ip address $recordsref = xCAT::ProfiledNodeUtils->get_allnode_singleattrib_hash('ppc', 'hcp'); my %allfspips = %$recordsref; # MAC records looks like: "01:02:03:04:05:0E!node5│01:02:03:05:0F!node6-eth1". We want to get the real mac addres. foreach (keys %allmacs){ my @hostentries = split(/\|/, $_); foreach my $hostandmac ( @hostentries){ my ($macstr, $machostname) = split("!", $hostandmac); $allmacs{$macstr} = 0; } } $recordsref = xCAT::ProfiledNodeUtils->get_allnode_singleattrib_hash('hosts', 'ip'); %allinstallips = %$recordsref; $recordsref = xCAT::NetworkUtils->get_all_nicips(1); %allips = %$recordsref; # Merge all BMC IPs and install IPs into allips. %allips = (%allips, %allbmcips, %allinstallips, %allfspips); #TODO: can not use getallnode to get rack infos. $recordsref = xCAT::ProfiledNodeUtils->get_all_rack(1); %allracks = %$recordsref; $recordsref = xCAT::ProfiledNodeUtils->get_all_chassis(1); %allchassis = %$recordsref; $recordsref = xCAT::ProfiledNodeUtils->get_all_chassis(1,'cmm'); %allcmmchassis = %$recordsref; # Generate temporary hostnames for hosts entries in hostfile. xCAT::MsgUtils->message('S', "Generate temporary hostnames."); my ($retcode_read, $retstr_read) = read_and_generate_hostnames($args_dict{'file'}); if ($retcode_read != 0){ setrsp_progress("Failed to validate node information file."); setrsp_errormsg($retstr_read); return; } # Parse and validate the hostinfo string. The real hostnames will be generated here. xCAT::MsgUtils->message('S', "Parsing hostinfo string and validate it."); my ($hostinfo_dict_ref, $invalid_records_ref) = parse_hosts_string($retstr_read); my %hostinfo_dict = %$hostinfo_dict_ref; my @invalid_records = @$invalid_records_ref; if (@invalid_records){ setrsp_progress("Failed to validate node information file."); setrsp_invalidrecords(\@invalid_records); return; } unless (%hostinfo_dict){ setrsp_progress("Failed to validate node information file."); setrsp_errormsg("Cannot find node records in node information file."); return; } # Create the real hostinfo string in stanza file format. xCAT::MsgUtils->message('S', "Generating new hostinfo string."); my ($retcode_gen, $retstr_gen) = gen_new_hostinfo_string(\%hostinfo_dict); unless ($retcode_gen){ setrsp_progress("Failed to validate node information file."); setrsp_errormsg($retstr_gen); return; } # call mkdef to create hosts and then call nodemgmt for node management plugins. setrsp_progress("Importing nodes..."); setrsp_progress("Creating nodes..."); my $warnstr = ""; my $retref = xCAT::Utils->runxcmd({command=>["mkdef"], stdin=>[$retstr_gen], arg=>['-z']}, $request_command, 0, 2); my $retstrref = parse_runxcmd_ret($retref); # runxcmd failed. if ($::RUNCMD_RC != 0){ $warnstr = "Warning: failed to import some nodes."; setrsp_progress($warnstr); if ($retstrref->[1]) { $warnstr .= "Details: $retstrref->[1]"; } } my @nodelist = keys %hostinfo_dict; setrsp_progress("Configuring nodes..."); $retref = xCAT::Utils->runxcmd({command=>["kitnodeadd"], node=>\@nodelist}, $request_command, 0, 2); $retstrref = parse_runxcmd_ret($retref); if ($::RUNCMD_RC != 0){ $warnstr .= "Warning: failed to run command kitnodeadd."; if ($retstrref->[1]) { $warnstr .= "Details: $retstrref->[1]"; } } setrsp_progress("Imported nodes."); #TODO: get the real nodelist here. setrsp_success(\@nodelist, $warnstr); } #------------------------------------------------------- =head3 nodepurge Description : Remove nodes. After nodes removed, their info in /etc/hosts, dhcp, dns... will be removed automatically. Arguments : N/A =cut #------------------------------------------------------- sub nodepurge{ my $nodes = $request->{node}; xCAT::MsgUtils->message('S', "Purging nodes."); # For remove nodes, we should call 'nodemgmt' in front of 'noderm' setrsp_progress("Configuring nodes..."); my $helpmsg = "nodepurge: Removes nodes from database and system configuration. Usage: \tnodepurge \tnodepurge [-h|--help] \tnodepurge {-v|--version}"; my $ret = validate_args($helpmsg); if (! $ret){ return; } my $warnstr = ""; my $retref = xCAT::Utils->runxcmd({command=>["kitnoderemove"], node=>$nodes}, $request_command, 0, 2); my $retstrref = parse_runxcmd_ret($retref); # runxcmd failed. if ($::RUNCMD_RC != 0){ setrsp_progress("Warning: failed to call kitnoderemove command."); $warnstr .= "Warning: failed to call kitnoderemove command."; if ($retstrref->[1]) { $warnstr .= "Details: $retstrref->[1]"; } } setrsp_progress("Removing nodes..."); $retref = xCAT::Utils->runxcmd({command=>["noderm"], node=>$nodes}, $request_command, 0, 2); $retstrref = parse_runxcmd_ret($retref); if ($::RUNCMD_RC != 0){ setrsp_progress("Warning: Cannot remove all nodes. The noderm command failed to remove some of the nodes."); $warnstr .= "Warning: Cannot remove all nodes. The noderm command failed to remove some of the nodes."; if ($retstrref->[1]) { $warnstr .= "Details: $retstrref->[1]"; } } setrsp_progress("Removed all nodes."); setrsp_success($nodes, $warnstr); } #------------------------------------------------------- =head3 noderefresh Description : Re-Call kit plugins for node management Arguments : N/A =cut #------------------------------------------------------ sub noderefresh { my $nodes = $request->{node}; my $helpmsg = "noderefresh: Calls kit plugins for the nodes in the profile. Usage: \tnoderefresh \tnoderefresh [-h|--help] \tnoderefresh {-v|--version}"; my $ret = validate_args($helpmsg); if (! $ret){ return; } my $retref = xCAT::Utils->runxcmd({command=>["kitnoderefresh"], node=>$nodes}, $request_command, 0, 2); my $retstrref = parse_runxcmd_ret($retref); # runxcmd failed. if ($::RUNCMD_RC != 0){ setrsp_progress("Warning: Failed to call kit commands."); } setrsp_success($nodes); } #------------------------------------------------------- =head3 nodechprofile Description : Update node profiles: imageprofile, networkprofile and hardwareprofile. Arguments : N/A =cut #------------------------------------------------------- sub nodechprofile{ my $nodes = $request->{node}; xCAT::MsgUtils->message('S', "Update nodes' profile settings."); my $helpmsg = "nodechprofile: Update node profiles for profiled nodes. Usage: \tnodechprofile [networkprofile=] [imageprofile=] [hardwareprofile=] \tnodechprofile [-h|--help] \tnodechprofile {-v|--version}"; my @enabledparams = ('networkprofile', 'hardwareprofile', 'imageprofile'); my $ret = validate_args($helpmsg, \@enabledparams); if (! $ret){ return; } my %updated_groups; # Get current templates for all nodes. setrsp_progress("Getting all node groups from the database..."); my %groupdict; my $nodelstab = xCAT::Table->new('nodelist'); my $nodeshashref = $nodelstab->getNodesAttribs($nodes, ['groups']); my %nodeshash = %$nodeshashref; my %updatenodeshash; foreach (keys %nodeshash){ my @groups; my $attrshashref = $nodeshash{$_}[0]; my %attrshash = %$attrshashref; # Update node's status to defined $updatenodeshash{$_}{'status'} = 'defined'; # Update node's groups (profiles) info. if ($attrshash{'groups'}){ @groups = split(/,/, $attrshash{'groups'}); my $groupsref = []; # Replace the old template name with new specified ones in args_dict if(exists $args_dict{'networkprofile'}){ $groupsref = replace_item_in_array(\@groups, "NetworkProfile", $args_dict{'networkprofile'}); } if(exists $args_dict{'hardwareprofile'}){ $groupsref = replace_item_in_array(\@groups, "HardwareProfile", $args_dict{'hardwareprofile'}); } if(exists $args_dict{'imageprofile'}){ $groupsref = replace_item_in_array(\@groups, "ImageProfile", $args_dict{'imageprofile'}); } $updatenodeshash{$_}{'groups'} = join (',', @$groupsref); } } #update DataBase. setrsp_progress("Updating database records..."); my $nodetab = xCAT::Table->new('nodelist',-create=>1); $nodetab->setNodesAttribs(\%updatenodeshash); $nodetab->close(); # call plugins setrsp_progress("Configuring nodes..."); my $retref = xCAT::Utils->runxcmd({command=>["kitnodeupdate"], node=>$nodes}, $request_command, 0, 2); my $retstrref = parse_runxcmd_ret($retref); if ($::RUNCMD_RC != 0){ setrsp_progress("Warning: failed to call kit commands."); } setrsp_progress("Updated the image/network/hardware profiles used by nodes."); setrsp_success($nodes); } #------------------------------------------------------- =head3 nodeaddunmged Description : Create a node with hostname and ip address specified. This node will belong to group "__Unmanaged". Host file /etc/hosts will be updated automatically. Arguments : N/A =cut #------------------------------------------------------- sub nodeaddunmged { xCAT::MsgUtils->message("Adding a unmanaged node."); my $helpmsg = "nodeaddunmged: Creates an unmanaged node specifying the node name and IP address Usage: \tnodeaddunmged hostname ip= \tnodeaddunmged [-h|--help] \tnodeaddunmged {-v|--version}"; my @enabledparams = ('hostname', 'ip'); my $ret = validate_args($helpmsg, \@enabledparams, \@enabledparams); if (! $ret){ return; } # validate the IP address my $recordsref = xCAT::ProfiledNodeUtils->get_allnode_singleattrib_hash('ipmi', 'bmc'); %allbmcips = %$recordsref; $recordsref = xCAT::ProfiledNodeUtils->get_allnode_singleattrib_hash('hosts', 'ip'); %allinstallips = %$recordsref; $recordsref = xCAT::NetworkUtils->get_all_nicips(1); %allips = %$recordsref; %allips = (%allips, %allbmcips, %allinstallips); if (exists $allips{$args_dict{'ip'}}){ setrsp_errormsg("The specified IP address $args_dict{'ip'} already exists in the IP address database. You must use a different IP address."); return; }elsif((xCAT::NetworkUtils->validate_ip($args_dict{'ip'}))[0]->[0] ){ setrsp_errormsg("The specified IP address $args_dict{'ip'} is invalid. You must use a valid IP address."); return; }elsif(xCAT::NetworkUtils->isReservedIP($args_dict{'ip'})){ setrsp_errormsg("The specified IP address $args_dict{'ip'} is invalid. You must use a valid IP address."); return; } # validate hostname. $recordsref = xCAT::ProfiledNodeUtils->get_allnode_singleattrib_hash('nodelist', 'node'); %allhostnames = %$recordsref; if (exists $allhostnames{$args_dict{'hostname'}}){ setrsp_errormsg("The specified node name $args_dict{'hostname'} already exists. You must use a different node name."); return; } if (! xCAT::NetworkUtils->isValidFQDN($args_dict{'hostname'})){ setrsp_errormsg("The specified node name $args_dict{'hostname'} is invalid. You must use a valid node name."); return; } my %updatenodeshash = (); $updatenodeshash{$args_dict{'hostname'}}{'ip'} = $args_dict{'ip'}; my $hoststab = xCAT::Table->new('hosts',-create=>1); $hoststab->setNodesAttribs(\%updatenodeshash); $hoststab->close(); %updatenodeshash = (); $updatenodeshash{$args_dict{'hostname'}}{'groups'} = "__Unmanaged"; my $nodetab = xCAT::Table->new('nodelist',-create=>1); $nodetab->setNodesAttribs(\%updatenodeshash); $nodetab->close(); my $retref = xCAT::Utils->runxcmd({command=>["makehosts"], node=>[$args_dict{"hostname"}]}, $request_command, 0, 2); my $retstrref = parse_runxcmd_ret($retref); if ($::RUNCMD_RC != 0){ setrsp_progress("Warning: failed to update /etc/hosts for unmanaged node."); } setrsp_infostr("Created unmanaged node."); } #------------------------------------------------------- =head3 nodechmac Description : Change node's provisioning NIC's MAC address. And then call kits plugins for nodes. Arguments : N/A =cut #------------------------------------------------------- sub nodechmac { xCAT::MsgUtils->message("Replacing node's mac address."); my $helpmsg = "nodechmac: updates the MAC address for a provisioning network interface. Usage: \tnodechmac mac= \tnodechmac [-h|--help] \tnodechmac {-v|--version}"; my @enabledparams = ('mac'); my $ret = validate_args($helpmsg, \@enabledparams, \@enabledparams); if (! $ret){ return; } my $nodelist = $request->{node}; my $hostname = $nodelist->[0]; # Validate MAC address my $recordsref = xCAT::ProfiledNodeUtils->get_allnode_singleattrib_hash('mac', 'mac'); %allmacs = %$recordsref; foreach (keys %allmacs){ my @hostentries = split(/\|/, $_); foreach my $hostandmac ( @hostentries){ my ($macstr, $machostname) = split("!", $hostandmac); $allmacs{$macstr} = 0; } } if (exists $allmacs{$args_dict{"mac"}}){ setrsp_errormsg("The specified MAC address $args_dict{'mac'} already exists. You must use a different MAC address."); return; } elsif(! xCAT::NetworkUtils->isValidMAC($args_dict{'mac'})){ setrsp_errormsg("The specified MAC address $args_dict{'mac'} is invalid. You must use a valid MAC address."); return; } # Update database records. setrsp_progress("Updating database..."); my $mactab = xCAT::Table->new('mac',-create=>1); $mactab->setNodeAttribs($hostname, {mac=>$args_dict{'mac'}}); $mactab->close(); # Call Plugins. setrsp_progress("Configuring nodes..."); my $retref = xCAT::Utils->runxcmd({command=>["kitnodeupdate"], node=>[$hostname]}, $request_command, 0, 2); my $retstrref = parse_runxcmd_ret($retref); if ($::RUNCMD_RC != 0){ setrsp_progress("Warning: failed to call kit commands."); } setrsp_progress("Updated MAC address."); } #------------------------------------------------------- =head3 nodediscoverstart Description : Start profiled nodes discovery. If already started, return a failure. User should specify networkprofile, hardwareprofile, imageprofile, hostnameformat, rack, chassis, height and u so that node's IP address will be generated automatcially according to networkprofile, node's hardware settings will be set according to hardware profile, node's os settings will be set according to image profile, node's hostname will be set according to hostnameformat and rank. And other node's attribs will also be set according to rack, chassis, height and u. Arguments : N/A =cut #------------------------------------------------------- sub nodediscoverstart{ xCAT::MsgUtils->message("Profiled nodes discovery started."); my $helpmsg = "nodediscoverstart: Start profiled nodes discovery. Usage: \tnodediscoverstart networkprofile= imageprofile= hostnameformat= [hardwareprofile=] [groups=] [rack=] [chassis=] [height=] [unit=] [rank=rank] \tnodediscoverstart [-h|--help] \tnodediscoverstart {-v|--version} "; my @enabledparams = ('networkprofile', 'hardwareprofile', 'imageprofile', 'hostnameformat', 'rank', 'rack', 'chassis', 'height', 'unit', 'groups'); my @mandatoryparams = ('networkprofile', 'imageprofile', 'hostnameformat'); my $ret = validate_args($helpmsg, \@enabledparams, \@mandatoryparams); if (! $ret){ return; } # validate hostnameformat: my $nameformattype = xCAT::ProfiledNodeUtils->get_hostname_format_type($args_dict{'hostnameformat'}); if ($nameformattype eq "unknown"){ setrsp_errormsg("Invalid node name format: $args_dict{'hostnameformat'}"); return; } my $recordsref = xCAT::ProfiledNodeUtils->get_all_rack(1); %allracks = %$recordsref; $recordsref = xCAT::ProfiledNodeUtils->get_all_chassis(1); %allchassis = %$recordsref; # check rack if (exists $args_dict{'rack'}){ if (! exists $allracks{$args_dict{'rack'}}){ setrsp_errormsg("Specified rack $args_dict{'rack'} is not defined"); return; } # rack must be specified with chassis or unit + height. if (exists $args_dict{'chassis'}){ setrsp_errormsg("Specified chassis cannot be used with rack."); return; } else{ # We set default value for height and u if rack specified if(! exists $args_dict{'height'}){$args_dict{'height'} = 1} if(! exists $args_dict{'unit'}){$args_dict{'unit'} = 1} } } # chassis jdugement. if (exists $args_dict{'chassis'}){ if (! exists $allchassis{$args_dict{'chassis'}}){ setrsp_errormsg("Specified chassis $args_dict{'chassis'} is not defined."); return; } if (exists $args_dict{'unit'} or exists $args_dict{'height'}){ setrsp_errormsg("Specified chassis cannot be used with unit or height."); return; } } # height and u must be valid numbers. if (exists $args_dict{'unit'}){ # unit must be specified together with rack. if (! exists $args_dict{'rack'}){ setrsp_errormsg("Specified unit must also include specified rack"); return; } # Not a valid number. if (!($args_dict{'unit'} =~ /^\d+$/)){ setrsp_errormsg("Specified unit $args_dict{'u'} is invalid"); return; } } if (exists $args_dict{'height'}){ # unit must be specified together with rack. if (! exists $args_dict{'rack'}){ setrsp_errormsg("Specified height must include specified rack."); return; } # Not a valid number. if (!($args_dict{'height'} =~ /^\d+$/)){ setrsp_errormsg("Specified height $args_dict{'height'} is invalid."); return; } } # Read DB to confirm the discover is not started yet. my $discover_running = xCAT::ProfiledNodeUtils->is_discover_started(); if ($discover_running){ setrsp_errormsg("Profiled nodes discovery already started."); return; } # Make sure provisioning network has a dynamic range. my $provnet = xCAT::ProfiledNodeUtils->get_netprofile_provisionnet($args_dict{networkprofile}); if (! $provnet){ setrsp_errormsg("Provisioning network not defined for network profile."); return; } my $networkstab = xCAT::Table->new("networks"); my $netentry = ($networkstab->getAllAttribsWhere("netname = '$provnet'", 'ALL'))[0]; if (! $netentry->{'dynamicrange'}){ setrsp_errormsg("Dynamic IP address range not defined for provisioning network."); return; } # save discover args into table site. my $valuestr = ""; foreach (keys %args_dict){ if($args_dict{$_}){ $valuestr .= "$_:$args_dict{$_},"; } } my $sitetab = xCAT::Table->new('site',-create=>1); $sitetab->setAttribs({"key" => "__PCMDiscover"}, {"value" => "$valuestr"}); $sitetab->close(); setrsp_infostr("Profiled node's discover started"); } #------------------------------------------------------- =head3 nodediscoverstop Description : Stop profiled nodes auto discover. This action will remove the dababase flags. Arguments : N/A =cut #------------------------------------------------------ sub nodediscoverstop{ my $helpmsg = "nodediscoverstop: stops node auto-discovery. Usage: \tnodediscoverstop \tnodediscoverstop [-h|--help] \tnodediscoverstop {-v|--version}"; my $ret = validate_args($helpmsg); if (! $ret){ return; } # Read DB to confirm the discover is started. xCAT::MsgUtils->message("Stopping profiled node's discover."); my $discover_running = xCAT::ProfiledNodeUtils->is_discover_started(); if (! $discover_running){ setrsp_errormsg("Node discovery for all nodes using profiles is not started."); return; } # remove site table records: discover flag. my $sitetab=xCAT::Table->new("site"); my %keyhash; $keyhash{'key'} = "__PCMDiscover"; $sitetab->delEntries(\%keyhash); $sitetab->commit(); # Update node's attributes, remove from gruop "__PCMDiscover". # we'll call rmdef so that node's groupinfo in table nodelist will be updated automatically. my @nodes = xCAT::NodeRange::noderange('__PCMDiscover'); if (@nodes){ # There are some nodes discvoered. my $retref = xCAT::Utils->runxcmd({command=>["rmdef"], arg=>["-t", "group", "-o", "__PCMDiscover"]}, $request_command, 0, 2); } setrsp_infostr("Node discovery for all nodes using profiles stopped."); } #------------------------------------------------------- =head3 nodediscoverstatus Description : Detect whether Profiled nodes discovery is running or not. Arguments : N/A =cut #------------------------------------------------------- sub nodediscoverstatus{ my $helpmsg = "nodediscoverstatus: detects if node discovery is running. Usage: \tnodediscoverstatus \tnodediscoverstatus [-h|--help] \tnodediscoverstatus {-v|--version}"; my $ret = validate_args($helpmsg); if (! $ret){ return; } my $discover_running = xCAT::ProfiledNodeUtils->is_discover_started(); if($discover_running){ setrsp_progress("Node discovery for all nodes using profiles is running"); }else{ setrsp_progress("Node discovery for all nodes using profiles is not started"); } } #------------------------------------------------------- =head3 nodediscoverls Description : List all discovered profiled nodes. Arguments : N/A =cut #------------------------------------------------------- sub nodediscoverls{ my $helpmsg = "nodediscoverls: lists all discovered nodes using profiles. Usage: \tnodediscoverls \tnodediscoverls [-h|--help] \tnodediscoverls {-v|--version}"; my $ret = validate_args($helpmsg); if (! $ret){ return; } # Read DB to confirm the discover is started. my $discover_running = xCAT::ProfiledNodeUtils->is_discover_started(); if (! $discover_running){ setrsp_errormsg("Node discovery process is not running."); return; } my @nodes = xCAT::NodeRange::noderange('__PCMDiscover'); my $mactab = xCAT::Table->new("mac"); my $macsref = $mactab->getNodesAttribs(\@nodes, ['mac']); my $nodelisttab = xCAT::Table->new("nodelist"); my $statusref = $nodelisttab->getNodesAttribs(\@nodes, ['status']); my $rspentry; my $i = 0; foreach (@nodes){ if (! $_){ next; } $rspentry->{node}->[$i]->{"name"} = $_; # Only get the MAC address of provisioning NIC. my @hostentries = split(/\|/, $macsref->{$_}->[0]->{"mac"}); foreach my $hostandmac ( @hostentries){ if (! $hostandmac){ next; } if(index($hostandmac, "!") == -1){ $rspentry->{node}->[$i]->{"mac"} = $hostandmac; last; } } if ($statusref->{$_}->[0]){ $rspentry->{node}->[$i]->{"status"} = $statusref->{$_}->[0]->{status}; } else{ $rspentry->{node}->[$i]->{"status"} = "defined"; } $i++; } $callback->($rspentry); } #------------------------------------------------------- =head3 findme Description : The default interface for node discovery. We must implement this method so that profiled nodes's findme request can be answered while profiled nodes discovery is running. Arguments : N/A =cut #------------------------------------------------------- sub findme{ xCAT::MsgUtils->message('S', "Profield nodes discover: Start.\n"); # Read DB to confirm the discover is started. my @sitevalues = xCAT::TableUtils->get_site_attribute("__PCMDiscover"); if (! $sitevalues[0]){ setrsp_errormsg("Profiled nodes discovery not started yet."); return; } # We store node profiles in site table, key is "__PCMDiscover" my @profilerecords = split(',', $sitevalues[0]); foreach (@profilerecords){ if ($_){ my ($profilename, $profilevalue) = split(':', $_); if ($profilename and $profilevalue){ $args_dict{$profilename} = $profilevalue; } } } # Get database records: all hostnames, all ips, all racks... # To improve performance, we should initalize a daemon later?? xCAT::MsgUtils->message('S', "Getting database records.\n"); my $recordsref = xCAT::ProfiledNodeUtils->get_allnode_singleattrib_hash('nodelist', 'node'); %allhostnames = %$recordsref; $recordsref = xCAT::ProfiledNodeUtils->get_allnode_singleattrib_hash('ipmi', 'bmc'); %allbmcips = %$recordsref; $recordsref = xCAT::ProfiledNodeUtils->get_allnode_singleattrib_hash('mac', 'mac'); %allmacs = %$recordsref; foreach (keys %allmacs){ my @hostentries = split(/\|/, $_); foreach my $hostandmac ( @hostentries){ my ($macstr, $machostname) = split("!", $hostandmac); $allmacs{$macstr} = 0; } } $recordsref = xCAT::ProfiledNodeUtils->get_allnode_singleattrib_hash('hosts', 'ip'); %allinstallips = %$recordsref; $recordsref = xCAT::NetworkUtils->get_all_nicips(1); %allips = %$recordsref; # Merge all BMC IPs and install IPs into allips. %allips = (%allips, %allbmcips, %allinstallips); $recordsref = xCAT::ProfiledNodeUtils->get_all_rack(1); %allracks = %$recordsref; $recordsref = xCAT::ProfiledNodeUtils->get_all_chassis(1); %allchassis = %$recordsref; # Get discovered client IP and MAC my $ip = $request->{'_xcat_clientip'}; xCAT::MsgUtils->message('S', "Profield nodes discover: _xcat_clientip is $ip.\n"); my $mac = ''; my $arptable = `/sbin/arp -n`; my @arpents = split /\n/,$arptable; foreach (@arpents) { if (m/^($ip)\s+\S+\s+(\S+)\s/) { $mac=$2; last; } } if (! $mac){ setrsp_errormsg("Profiled nodes discover: Can not get mac address of this node."); return; } xCAT::MsgUtils->message('S', "Profiled nodes discover: mac is $mac.\n"); if ( exists $allmacs{$mac}){ setrsp_errormsg("Discovered MAC $mac already exists in database."); return; } # Assign TMPHOSTS9999 as a temporary hostname, in parse_hsots_string, # it will detect this and arrange a real hostname for it. my $raw_hostinfo_str = "TMPHOSTS9999:\n mac=$mac\n"; # Append rack, chassis, unit, height into host info string. foreach my $key ('rack', 'chassis', 'unit', 'height'){ if(exists($args_dict{$key})){ $raw_hostinfo_str .= " $key=$args_dict{$key}\n"; } } if (exists $args_dict{'unit'} and exists $args_dict{'height'}){ # increase start unit automatically. $args_dict{'unit'} = $args_dict{'unit'} + $args_dict{'height'}; # save discover args into table site. my $valuestr = ""; foreach (keys %args_dict){ if($args_dict{$_}){ $valuestr .= "$_:$args_dict{$_},"; } } my $sitetab = xCAT::Table->new('site',-create=>1); $sitetab->setAttribs({"key" => "__PCMDiscover"}, {"value" => "$valuestr"}); $sitetab->close(); } my ($hostinfo_dict_ref, $invalid_records_ref) = parse_hosts_string($raw_hostinfo_str); my %hostinfo_dict = %$hostinfo_dict_ref; # Create the real hostinfo string in stanza file format. xCAT::MsgUtils->message('S', "Profiled nodes discover: Generating new hostinfo string.\n"); my ($retcode_gen, $retstr_gen) = gen_new_hostinfo_string($hostinfo_dict_ref); unless ($retcode_gen){ setrsp_errormsg($retstr_gen); return; } # call mkdef to create hosts and then call nodemgmt for node management plugins. xCAT::MsgUtils->message('S', "Call mkdef to create nodes.\n"); my $retref = xCAT::Utils->runxcmd({command=>["mkdef"], stdin=>[$retstr_gen], arg=>['-z']}, $request_command, 0, 2); my $retstrref = parse_runxcmd_ret($retref); # runxcmd failed. if ($::RUNCMD_RC != 0){ setrsp_errormsg($retstr_gen); return; } my @nodelist = keys %hostinfo_dict; # call discover to notify client. xCAT::MsgUtils->message('S', "Call discovered request.\n"); $request->{"command"} = ["discovered"]; $request->{"node"} = \@nodelist; $retref = xCAT::Utils->runxcmd($request, $request_command, 0, 2); $retstrref = parse_runxcmd_ret($retref); xCAT::MsgUtils->message('S', "Call nodemgmt plugins.\n"); $retref = xCAT::Utils->runxcmd({command=>["kitnodeadd"], node=>\@nodelist}, $request_command, 0, 2); $retstrref = parse_runxcmd_ret($retref); # Set discovered flag. my $nodegroupstr = $hostinfo_dict{$nodelist[0]}{"groups"}; my $nodelstab = xCAT::Table->new('nodelist',-create=>1); $nodelstab->setNodeAttribs($nodelist[0],{groups=>$nodegroupstr.",__PCMDiscover"}); $nodelstab->close(); } #------------------------------------------------------- =head3 replace_item_in_array Description : Replace an item in a list with new value. This item should match specified pattern. Arguments : arrayref - the list. pattern - the pattern which the old item must match. newitem - the updated value. =cut #------------------------------------------------------- sub replace_item_in_array{ my $arrayref = shift; my $pattern = shift; my $newitem = shift; my @newarray; foreach (@$arrayref){ if ($_ =~ /__$pattern/){ next; } push (@newarray, $_); } push(@newarray, $newitem); return \@newarray; } #------------------------------------------------------- =head3 gen_new_hostinfo_string Description : Generate a stanza file format string used for 'mkdef' to create nodes. Arguments : hostinfo_dict_ref - The reference of hostinfo dict. Returns : (returnvalue, returnmsg) returnvalue - 0, stands for generate new hostinfo string failed. 1, stands for generate new hostinfo string OK. returnnmsg - error messages if generate failed. - the new hostinfo string if generate OK. =cut #------------------------------------------------------- sub gen_new_hostinfo_string{ my $hostinfo_dict_ref = shift; my %hostinfo_dict = %$hostinfo_dict_ref; # Get free ips list for all networks in network profile. my @allknownips = keys %allips; my $netprofileattrsref = xCAT::ProfiledNodeUtils->get_nodes_nic_attrs([$args_dict{'networkprofile'}])->{$args_dict{'networkprofile'}}; my %netprofileattr = %$netprofileattrsref; my %freeipshash; foreach (keys %netprofileattr){ my $netname = $netprofileattr{$_}{'network'}; if($netname and (! exists $freeipshash{$netname})) { $freeipshash{$netname} = xCAT::ProfiledNodeUtils->get_allocable_staticips_innet($netname, \@allknownips); } } # Get networkprofile's installip my $noderestab = xCAT::Table->new('noderes'); my $networkprofile = $args_dict{'networkprofile'}; my $nodereshashref = $noderestab->getNodeAttribs($networkprofile, ['installnic']); my %nodereshash = %$nodereshashref; my $installnic = $nodereshash{'installnic'}; # Get node's provisioning method my $provmethod = xCAT::ProfiledNodeUtils->get_imageprofile_prov_method($args_dict{'imageprofile'}); # compose the stanza string for hostinfo file. my $hostsinfostr = ""; foreach my $item (keys %hostinfo_dict){ # Generate IPs for all interfaces. my %ipshash; foreach (keys %netprofileattr){ my $netname = $netprofileattr{$_}{'network'}; my $freeipsref; if ($netname){ $freeipsref = $freeipshash{$netname}; } my $nextip = shift @$freeipsref; if (!$nextip){ return 0, "There are no more IP addresses available in the static network range of network $netname for interface $_"; }else{ $ipshash{$_} = $nextip; $allips{$nextip} = 0; } } my $nicips = ""; foreach(keys %ipshash){ $nicips = "$_:$ipshash{$_},$nicips"; } $hostinfo_dict{$item}{"nicips"} = $nicips; # Generate IP address if no IP specified. if (! exists $hostinfo_dict{$item}{"ip"}) { if (exists $ipshash{$installnic}){ $hostinfo_dict{$item}{"ip"} = $ipshash{$installnic}; }else{ return 0, "There are no more IP addresses available in the static network range for interface $installnic"; } } $hostinfo_dict{$item}{"objtype"} = "node"; $hostinfo_dict{$item}{"groups"} = "__Managed"; if (exists $args_dict{'networkprofile'}){$hostinfo_dict{$item}{"groups"} .= ",".$args_dict{'networkprofile'}} if (exists $args_dict{'imageprofile'}){$hostinfo_dict{$item}{"groups"} .= ",".$args_dict{'imageprofile'}} if (exists $args_dict{'hardwareprofile'}){$hostinfo_dict{$item}{"groups"} .= ",".$args_dict{'hardwareprofile'}} if (exists $args_dict{'groups'}){$hostinfo_dict{$item}{"groups"} .= ",".$args_dict{'groups'}} $hostinfo_dict{$item}{"chain"} = 'osimage='.$provmethod; if (exists $netprofileattr{"bmc"}){ # Update BMC records. $hostinfo_dict{$item}{"mgt"} = "ipmi"; $hostinfo_dict{$item}{"chain"} = 'runcmd=bmcsetup,osimage='.$provmethod; if (exists $ipshash{"bmc"}){ $hostinfo_dict{$item}{"bmc"} = $ipshash{"bmc"}; } else{ return 0, "There are no more IP addresses available in the static network range for the BMC network."; } } elsif (exists $netprofileattr{"fsp"}){ # Update FSP records $hostinfo_dict{$item}{"mgt"} = "fsp"; $hostinfo_dict{$item}{"mpa"}= $hostinfo_dict{$item}{"chassis"}; if (exists $ipshash{"fsp"}){ $hostinfo_dict{$item}{"hcp"} = $ipshash{"fsp"}; } else{ return 0, "No sufficient IP addresses for FSP"; } } # Generate the hostinfo string. $hostsinfostr = "$hostsinfostr$item:\n"; my $itemdictref = $hostinfo_dict{$item}; my %itemdict = %$itemdictref; foreach (keys %itemdict){ $hostsinfostr = "$hostsinfostr $_=\"$itemdict{$_}\"\n"; } } return 1, $hostsinfostr; } #------------------------------------------------------- =head3 read_and_generate_hostnames Description : Read hostinfo file and generate temporary hostnames for no-hostname specified ones. Arguments : hostfile - the location of hostinfo file. Returns : (returnvalue, returnmsg) returnvalue - 0, stands for a failed return 1, stands for a success return returnnmsg - error messages for failed return. - the contents of the hostinfo string. =cut #------------------------------------------------------- sub read_and_generate_hostnames{ my $hostfile = shift; # Get 10000 temprary hostnames. my $freehostnamesref = xCAT::ProfiledNodeUtils->gen_numric_hostnames("TMPHOSTS","", 4); # Auto generate hostnames for "__hostname__" entries. open(HOSTFILE, $hostfile); my $filecontent = join("", ); # Convert windows txt file into unix format. $filecontent =~ s/\cM\cJ/\n/g; while ((index $filecontent, "__hostname__:") >= 0){ my $nexthost = shift @$freehostnamesref; # no more valid hostnames to assign. if (! $nexthost){ return 1, "Failed to generate a node name. There are no more valid node names available."; } # This hostname already specified in hostinfo file. if ((index $filecontent, "$nexthost:") >= 0){ next; } # This hostname should not in database. if (exists $allhostnames{$nexthost}){ next; } $filecontent =~ s/__hostname__/$nexthost/; } close(HOSTFILE); return 0, $filecontent; } #------------------------------------------------------- =head3 parse_hosts_string Description : Parse the hostinfo string and validate it. Arguments : filecontent - The content of hostinfo file. Returns : (hostinfo_dict, invalid_records) hostinfo_dict - Reference of hostinfo dict. Key are hostnames and values is an attributes dict. invalid_records - Reference of invalid records list. =cut #------------------------------------------------------- sub parse_hosts_string{ my $filecontent = shift; my %hostinfo_dict; my @invalid_records; my $nameformat = $args_dict{'hostnameformat'}; my $nameformattype = xCAT::ProfiledNodeUtils->get_hostname_format_type($nameformat); my %freehostnames; # Parse hostinfo file string. xCAT::DBobjUtils->readFileInput($filecontent); # Record duplicated items. # We should go through list @::fileobjnames first as %::FILEATTRS is just a hash, # it not tells whether there are some duplicated hostnames in the hostinfo string. my %hostnamedict; foreach my $hostname (@::fileobjnames){ if (exists $hostnamedict{$hostname}){ push @invalid_records, [$hostname, "Duplicated hostname defined"]; } else{ $hostnamedict{$hostname} = 0; } } # Verify each node entry. my $rank = 0; if (exists($args_dict{'rank'})){ $rank = $args_dict{'rank'}; } my $provnet = xCAT::ProfiledNodeUtils->get_netprofile_provisionnet($args_dict{networkprofile}); my @allknownips = keys %allips; my $freeprovipsref = xCAT::ProfiledNodeUtils->get_allocable_staticips_innet($provnet); foreach my $attr (keys %::FILEATTRS){ my $errmsg = validate_node_entry($attr, $::FILEATTRS{$attr}); # Check whether specified IP is in our prov network, static range. if ($::FILEATTRS{$attr}->{'ip'}){ unless (grep{ $_ eq $::FILEATTRS{$attr}->{'ip'}} @$freeprovipsref){ $errmsg .= "Specified IP address $::FILEATTRS{$attr}->{'ip'} not in static range of provision network $provnet"; } } if ($errmsg) { if ($attr =~ /^TMPHOSTS/){ push @invalid_records, ["__hostname__", $errmsg]; } else{ push @invalid_records, [$attr, $errmsg]; } next; } # We need generate hostnames for this entry. if ($attr =~ /^TMPHOSTS/) { # rack + numric hostname format, we must specify rack in node's definition. my $numricformat; # Need convert hostname format into numric format first. if ($nameformattype eq "rack"){ if (! exists $::FILEATTRS{$attr}{"rack"}){ push @invalid_records, ["__hostname__", "Rack information is not specified. You must enter the required rack information."]; next; } $numricformat = xCAT::ProfiledNodeUtils->rackformat_to_numricformat($nameformat, $::FILEATTRS{$attr}{"rack"}); if(! $numricformat){ push @invalid_records, ["__hostname__", "The rack number of rack $::FILEATTRS{$attr}{'rack'} does not match hostname format $nameformat"]; } } else{ # pure numric hostname format $numricformat = $nameformat; } # Generate hostnames based on numric hostname format. my $hostnamelistref; if (! exists $freehostnames{$numricformat}){ $hostnamelistref = xCAT::ProfiledNodeUtils->genhosts_with_numric_tmpl($numricformat, $rank, 10000); $rank = $rank + 10000; if (! @$hostnamelistref){ push @invalid_records, ["__hostname__", "Can not generate sufficient hostnames from hostname format."]; last; }else{ $freehostnames{$numricformat} = $hostnamelistref; } } $hostnamelistref = $freehostnames{$numricformat}; my $nexthostname = shift @$hostnamelistref; while ( (! $nexthostname) || exists $allhostnames{$nexthostname}){ if (! @$hostnamelistref){ $hostnamelistref = xCAT::ProfiledNodeUtils->genhosts_with_numric_tmpl($numricformat, $rank, 10000); $rank = $rank + 10000; if(! @$hostnamelistref){ push @invalid_records, ["__hostname__", "Can not generate sufficient hostnames from hostname format."]; last; } } $nexthostname = shift @$hostnamelistref; } $hostinfo_dict{$nexthostname} = $::FILEATTRS{$attr}; } else{ $hostinfo_dict{$attr} = $::FILEATTRS{$attr}; } } return (\%hostinfo_dict, \@invalid_records); } #------------------------------------------------------- =head3 validate_node_entry Description : Validate a node info hash. Arguments : node_name - node hostname. node_entry_ref - Reference of the node info hash. Returns : errormsg - undef: stands for no errror. - valid string: stands for the error message of validation. =cut #------------------------------------------------------- sub validate_node_entry{ my $node_name = shift; my $node_entry_ref = shift; my %node_entry = %$node_entry_ref; my $errmsg = ""; # duplicate hostname found in hostinfo file. if (exists $allhostnames{$node_name}) { $errmsg .= "Node name $node_name already exists. You must use a new node name.\n"; } # Must specify either MAC or switch + port. if (exists $node_entry{"mac"} || exists $node_entry{"switch"} && exists $node_entry{"port"}){ } else{ $errmsg .= "MAC address, switch and port is not specified. You must specify the MAC address or switch and port.\n"; } if (! xCAT::NetworkUtils->isValidHostname($node_name)){ $errmsg .= "Node name: $node_name is invalid. You must use a valid node name.\n"; } # validate if node use FSP network my $is_fsp = xCAT::ProfiledNodeUtils->is_fsp_node($args_dict{'networkprofile'}); # validate each single value. foreach (keys %node_entry){ if ($_ eq "mac"){ if (exists $allmacs{$node_entry{$_}}){ $errmsg .= "MAC address $node_entry{$_} already exists in the database or in the nodeinfo file. You must use a new MAC address.\n"; }elsif(! xCAT::NetworkUtils->isValidMAC($node_entry{$_})){ $errmsg .= "MAC address $node_entry{$_} is invalid. You must use a valid MAC address.\n"; }else{ $allmacs{$node_entry{$_}} = 0; } }elsif ($_ eq "ip"){ if (exists $allips{$node_entry{$_}}){ $errmsg .= "IP address $node_entry{$_} already exists in the database or in the nodeinfo file.\n"; }elsif((xCAT::NetworkUtils->validate_ip($node_entry{$_}))[0]->[0] ){ $errmsg .= "IP address $node_entry{$_} is invalid. You must use a valid IP address.\n"; }elsif(xCAT::NetworkUtils->isReservedIP($node_entry{$_})){ $errmsg .= "IP address $node_entry{$_} is invalid. You must use a valid IP address.\n"; }else { #push the IP into allips list. $allips{$node_entry{$_}} = 0; } }elsif ($_ eq "switch"){ #TODO: xCAT switch discovery enhance: verify whether switch exists. }elsif ($_ eq "port"){ }elsif ($_ eq "rack"){ if (! exists $allracks{$node_entry{$_}}){ $errmsg .= "Specified rack $node_entry{$_} is not defined\n"; } # rack must be specified with chassis or unit + height. if (exists $node_entry{"chassis"}){ $errmsg .= "Specified rack cannot be used with chassis.\n"; } elsif (exists $node_entry{"height"} and exists $node_entry{"unit"}){ } else { $errmsg .= "Specified rack must also specify the chassis or the height and unit.\n"; } }elsif ($_ eq "chassis"){ if (! exists $allchassis{$node_entry{$_}}){ $errmsg .= "Specified chassis $node_entry{$_} is not defined\n"; } # Chassis must not be specified with unit and height. if (exists $node_entry{"height"} or exists $node_entry{"unit"}){ $errmsg .= "Specified chassis cannot be used with height or unit.\n"; } # Check if this chassis is CMM. If it is, must specify slotid if (exists $allcmmchassis{$node_entry{$_}}){ if (not exists $node_entry{"slotid"}){ $errmsg .= "Specified CMM Chassis must be used with sloid"; } }else { # If the specific chassis is not CMM chassis, but network is fsp if ($is_fsp) { $errmsg .= "Specified FSP network must be used with CMM chassis." } } }elsif ($_ eq "unit"){ if (! exists $node_entry{"rack"}){ $errmsg .= "Specified unit must be used with rack.\n"; } # Not a valid number. if (!($node_entry{$_} =~ /^\d+$/)){ $errmsg .= "Specified unit $node_entry{$_} is invalid\n"; } }elsif ($_ eq "height"){ if (! exists $node_entry{"rack"}){ $errmsg .= "Height must be used with rack\n"; } # Not a valid number. if (!($node_entry{$_} =~ /^\d+$/)){ $errmsg .= "Specified height $node_entry{$_} is invalid\n"; } }elsif ($_ eq "slotid"){ if (not exists $node_entry{"chassis"}){ $errmsg .= "Specified slotid must be used with chassis"; } # Not a valid number. if (!($node_entry{$_} =~ /^[1-9]\d*$/)){ $errmsg .= "Specified slotid $node_entry{$_} is invalid"; } }else{ $errmsg .= "Invalid attribute $_ specified\n"; } } # push hostinfo into global dicts. $allhostnames{$node_name} = 0; return $errmsg; } #------------------------------------------------------- =head3 setrsp_invalidrecords Description : Set response for processing invalid host records. Arguments : recordsref - Refrence of invalid nodes list. =cut #------------------------------------------------------- sub setrsp_invalidrecords { my $recordsref = shift; my $rsp; # The total number of invalid records. $rsp->{error} = "Errors found in nodeinfo file"; $rsp->{errorcode} = 2; $rsp->{invalid_records_num} = scalar @$recordsref; # We write details of invalid records into a file. my ($fh, $filename) = xCAT::ProfiledNodeUtils->get_output_filename(); foreach (@$recordsref){ my @erroritem = @$_; print $fh "nodename $erroritem[0], error:\n$erroritem[1]\n"; } close $fh; #make it readable for http. system("chmod +r $filename"); # Tells the URL of the details file. xCAT::MsgUtils->message('S', "Detailed response info placed in file: $filename\n"); $rsp->{details} = $filename; $callback->($rsp); } #------------------------------------------------------- =head3 setrsp_errormsg Description : Set response for error messages. Arguments : errormsg - Error messages. =cut #------------------------------------------------------- sub setrsp_errormsg { my $errormsg = shift; my $rsp; xCAT::MsgUtils->message('S', "$errormsg\n"); $rsp->{error} = $errormsg; $rsp->{errorcode} = 1; $callback->($rsp); } #------------------------------------------------------- =head3 setrsp_infostr Description : Set response for a info string. Arguments : infostr - The info string.. =cut #------------------------------------------------------- sub setrsp_infostr { my $infostr = shift; my $rsp; xCAT::MsgUtils->message('S', "$infostr\n"); $rsp->{data} = $infostr; $callback->($rsp); } #------------------------------------------------------- =head3 setrsp_progress Description : Set response for running progress Arguments : progress: the progress string. =cut #------------------------------------------------------- sub setrsp_progress { my $progress = shift; my $rsp; xCAT::MsgUtils->message('S', "$progress"); $rsp->{info} = $progress; $callback->($rsp); } #------------------------------------------------------- =head3 setrsp_success Description : Set response for successfully processed nodes. Arguments : recordsref - Refrence of nodes list. =cut #------------------------------------------------------- sub setrsp_success { my $recordsref = shift; my $warnstr = shift; my $rsp; # The total number of success nodes. $rsp->{success_nodes_num} = scalar @$recordsref; my ($fh, $filename) = xCAT::ProfiledNodeUtils->get_output_filename(); foreach (@$recordsref){ print $fh "success: $_\n"; } if ($warnstr){ print $fh "There are some warnings:\n$warnstr\n"; } close $fh; #make it readable for http. system("chmod +r $filename"); # Tells the URL of the details file. xCAT::MsgUtils->message('S', "Detailed response info placed in file: $filename\n"); $rsp->{details} = $filename; $callback->($rsp); } #----------------------------------------------------- =head3 parse_runxcmd_ret Description : Get return of runxcmd and convert it into strings. Arguments : The return reference of runxcmd Return: : [$outstr, $errstr], A reference of list, placing standard output and standard error message. =cut #----------------------------------------------------- sub parse_runxcmd_ret { my $retref = shift; my $msglistref; my $outstr = ""; my $errstr = ""; if ($retref){ if($retref->{data}){ $msglistref = $retref->{data}; $outstr = Dumper(@$msglistref); xCAT::MsgUtils->message('S',"Command standard output: $outstr"); } if($retref->{error}){ $msglistref = $retref->{error}; $errstr = Dumper(@$msglistref); xCAT::MsgUtils->message('S',"Command error output: $errstr"); } } return [$outstr, $errstr]; } 1;