# IBM(c) 2007 EPL license http://www.eclipse.org/legal/epl-v10.html package xCAT::FSPconn; use strict; use Getopt::Long; use xCAT::PPCcli qw(SUCCESS EXPECT_ERROR RC_ERROR NR_ERROR); use xCAT::Usage; #use Data::Dumper; use xCAT::FSPUtils; use xCAT::PPCconn; use xCAT::MsgUtils qw(verbose_message); ############################################## # Globals ############################################## my %method = ( mkhwconn => \&mkhwconn_parse_args, lshwconn => \&lshwconn_parse_args, rmhwconn => \&rmhwconn_parse_args, ); ########################################################################## # Parse the command line for options and operands ########################################################################## sub parse_args { my $request = shift; my $cmd = $request->{command}; ############################### # Invoke correct parse_args ############################### my $result = $method{$cmd}($request, $request->{arg}); return ($result); } ########################################################################## # Parse arguments for mkhwconn ########################################################################## sub mkhwconn_parse_args { my $request = shift; my $args = shift; my %opt = (); local *usage = sub { my $usage_string = xCAT::Usage->getUsage("mkhwconn"); return ([ $_[0], $usage_string ]); }; ############################################# # Process command-line arguments ############################################# if (!defined($args)) { return (usage("No command specified")); } local @ARGV = ref($args) eq 'ARRAY' ? @$args : (); $Getopt::Long::ignorecase = 0; Getopt::Long::Configure("bundling"); if (!GetOptions(\%opt, qw(V|verbose h|help t s:s T=s p=s P=s port=s ))) { return (usage()); } if (exists $opt{s}) { my $opttmp = xCAT::PPCconn::mkhwconn_parse_args($request, $args); return $opttmp; } return usage() if (exists $opt{h}); if (!exists $opt{t} and !exists $opt{p}) { return (usage('Flag -t or -p must be used.')); } if (exists $opt{t} and exists $opt{p}) { return (usage('Flags -t and -p cannot be used together.')); } if ((exists $opt{P} or grep(/^(-P)$/, @$args)) and !exists $opt{p}) { return (usage('Flags -P can only be used when flag -p is specified.')); } ########################################## # Check if CECs are controlled by a frame ########################################## my $nodes = $request->{node}; my $ppctab = xCAT::Table->new('ppc'); #my $nodetypetab = xCAT::Table->new( 'nodetype'); my $vpdtab = xCAT::Table->new('vpd'); my @bpa_ctrled_nodes = (); my @no_type_nodes = (); my @error_type_nodes = (); my @frame_members = (); ########################################### # mgt=fsp/bpa for PPCconn.pm ########################################## if (exists $opt{p}) { #my $nodetype_hash = $nodetypetab->getNodeAttribs( $opt{p},[qw(nodetype)]); #my $nodetype = $nodetype_hash->{nodetype}; my $nodetype = xCAT::DBobjUtils->getnodetype($opt{p}, "ppc"); if (!defined($nodetype)) { return (usage("Something wrong with the specified HMC (-p Option). The HMC type doesn't exist.")); } if ($nodetype eq 'hmc') { $request->{'hwtype'} = 'hmc'; } } if ($ppctab) { my $hcp_nodetype = undef; my $typehash = xCAT::DBobjUtils->getnodetype($nodes, "ppc"); for my $node (@$nodes) { my $node_parent = undef; my $nodetype = undef; my $node_hcp_nodetype = undef; #my $nodetype_hash = $nodetypetab->getNodeAttribs( $node,[qw(nodetype)]); my $node_parent_hash = $ppctab->getNodeAttribs($node, [qw(parent)]); if (exists $opt{t}) { my $node_hcp_hash = $ppctab->getNodeAttribs($node, [qw(hcp)]); if ($node_hcp_hash->{hcp}) { #my $node_hcp_nodetype_hash = $nodetypetab->getNodeAttribs($node_hcp_hash->{hcp},[qw(nodetype)]); #$node_hcp_nodetype = $node_hcp_nodetype_hash->{nodetype}; $node_hcp_nodetype = xCAT::DBobjUtils->getnodetype($node_hcp_hash->{hcp}, "ppc"); } if (defined $hcp_nodetype) { if ($hcp_nodetype ne $node_hcp_nodetype) { return (usage("Nodetype for all the nodes' hcp must be the same.")); } } else { $hcp_nodetype = $node_hcp_nodetype; if ($hcp_nodetype eq 'hmc') { $request->{'hwtype'} = 'hmc'; } } } #$nodetype = $nodetype_hash->{nodetype}; $nodetype = $$typehash{$node}; $node_parent = $node_parent_hash->{parent}; if (!$nodetype) { push @no_type_nodes, $node; next; } else { unless ($nodetype =~ /^(fsp|bpa|frame|cec|hmc|blade)$/) { push @error_type_nodes, $node; next; } } if (($nodetype eq 'fsp' or $nodetype eq 'cec') and $node_parent and $node_parent ne $node) { push @bpa_ctrled_nodes, $node; } if ($nodetype eq 'bpa') { my $my_frame_bpa_cec = getFrameMembers($node, $vpdtab, $ppctab); push @frame_members, @$my_frame_bpa_cec; } if ($nodetype eq 'frame') { my $my_frame_bpa_cec = xCAT::DBobjUtils::getcecchildren($node); push @frame_members, @$my_frame_bpa_cec if ($my_frame_bpa_cec); push @frame_members, $node; } } } if (scalar(@no_type_nodes)) { my $tmp_nodelist = join ',', @no_type_nodes; return (usage("Attribute nodetype.nodetype cannot be found for node(s) $tmp_nodelist. Please define first and try again.\n")); } if (scalar(@error_type_nodes)) { my $tmp_nodelist = join ',', @error_type_nodes; return (usage("Incorrect nodetype for nodes(s): $tmp_nodelist. Please modify first and try again.\n")); } #if (scalar(@bpa_ctrled_nodes)) #{ # my $tmp_nodelist = join ',', @bpa_ctrled_nodes; # return ( usage("Node(s) $tmp_nodelist is(are) controlled by BPA.")); #} if (scalar(@frame_members)) { my @all_nodes = xCAT::Utils::get_unique_members(@$nodes, @frame_members); $request->{node} = \@all_nodes; } # Set HW type to 'hmc' anyway, so that this command will not going to # PPCfsp.pm # $request->{ 'hwtype'} = 'hmc'; if (!exists $opt{T}) { $opt{T} = "lpar"; #defaut value is lpar. #return( usage('Missing -T option. The value can be lpar or fnm.')); } if ($opt{T} eq "lpar") { $opt{T} = 0; } elsif ($opt{T} eq "fnm") { $opt{T} = 1; } else { return (usage('Wrong value of -T option. The value can be lpar or fnm. The defaut value is lpar.')); } if (!exists $opt{port}) { $opt{port} = "[0|1]"; } elsif ($opt{port} ne "0" and $opt{port} ne "1") { if ($opt{port} eq "0,1") { return ([ 0, "The option --port only be used to specify special port value, please don't specify this value if you want to use all ports." ]); } else { return (usage('Wrong value of --port option. The value can only be 0 or 1.')); } } $ppctab->close(); #$nodetypetab->close(); $vpdtab->close(); if (scalar(@ARGV)) { return (usage("No additional flag is support by this command")); } $request->{method} = 'mkhwconn'; return (\%opt); } #################################################### # Get frame members #################################################### #ppc/vpd nodes cache my @all_ppc_nodes; my @all_vpd_nodes; sub getFrameMembers { my $node = shift; #this a BPA node my $vpdtab = shift; my $ppctab = shift; my @frame_members = (); my @bpa_nodes = (); my $vpdhash = $vpdtab->getNodeAttribs($node, [qw(mtm serial)]); my $mtm = $vpdhash->{mtm}; my $serial = $vpdhash->{serial}; if (scalar(@all_vpd_nodes) == 0) { @all_vpd_nodes = $vpdtab->getAllNodeAttribs([ 'node', 'mtm', 'serial' ]); } for my $vpd_node (@all_vpd_nodes) { if ($vpd_node->{'mtm'} eq $mtm and $vpd_node->{'serial'} eq $serial) { push @frame_members, $vpd_node->{'node'}; push @bpa_nodes, $vpd_node->{'node'}; } } if (scalar(@all_ppc_nodes) == 0) { @all_ppc_nodes = $ppctab->getAllNodeAttribs([ 'node', 'parent' ]); } for my $bpa_node (@bpa_nodes) { for my $ppc_node (@all_ppc_nodes) { if ($ppc_node->{parent} eq $bpa_node) { push @frame_members, $ppc_node->{'node'}; } } } return \@frame_members; } ########################################################################## # Parse arguments for lshwconn --- This function isn't implemented and used. ########################################################################## sub lshwconn_parse_args { my $request = shift; my $args = shift; my %opt = (); local *usage = sub { my $usage_string = xCAT::Usage->getUsage("lshwconn"); return ([ $_[0], $usage_string ]); }; ############################################# # Get options in command line ############################################# local @ARGV = ref($args) eq 'ARRAY' ? @$args : (); $Getopt::Long::ignorecase = 0; Getopt::Long::Configure("bundling"); if (exists $opt{s}) { my $opttmp = xCAT::PPCconn::lshwconn_parse_args($request, $args); return $opttmp; } if (!GetOptions(\%opt, qw(V|verbose h|help T=s s))) { return (usage()); } return usage() if (exists $opt{h}); if (!exists $opt{T}) { $opt{T} = "lpar"; #defaut value is lpar. #return( usage('Missing -T option. The value can be lpar or fnm.')); } if ($opt{T} eq "lpar") { $opt{T} = 0; } elsif ($opt{T} eq "fnm") { $opt{T} = 1; } else { return (usage('Wrong value of -T option. The value can be lpar or fnm. The defaut value is lpar.')); } ############################################# # Process command-line arguments ############################################# if (scalar(@ARGV)) { return (usage("No additional flag is support by this command")); } #my $nodetypetab = xCAT::Table->new('nodetype'); #if (! $nodetypetab) #{ # return( ["Failed to open table 'nodetype'.\n"]); #} my $nodehmtab = xCAT::Table->new('nodehm'); if (!$nodehmtab) { return (["Failed to open table 'nodehm'.\n"]); } my $nodetype; my @no_typenodes = (); my @no_mgt_nodes = (); my @error_type_nodes = (); my $typehash = xCAT::DBobjUtils->getnodetype(\@{ $request->{node} }, "ppc"); for my $node (@{ $request->{node} }) { #my $ent = $nodetypetab->getNodeAttribs( $node, [qw(nodetype)]); my $nodehm = $nodehmtab->getNodeAttribs($node, [qw(mgt)]); if (!$nodehm) { push @no_mgt_nodes, $node; next; } my $ttype = $$typehash{$node}; if (!$ttype) { push @no_typenodes, $node; next; } if ($ttype ne 'fsp' and $ttype ne 'cec' and $ttype ne 'bpa' and $ttype ne 'frame' and $ttype ne 'blade') { push @error_type_nodes, $node; next; } if (!$nodetype) { $nodetype = $ttype; #$ent->{nodetype}; } else { if ($nodetype ne $ttype) #$ent->{nodetype}) { return (["Cannot support multiple node types in this command line.\n"]); } } } if (scalar(@no_typenodes)) { my $tmp_nodelist = join ',', @no_typenodes; return (["Attribute nodetype.nodetype cannot be found for node(s): $tmp_nodelist. Please define first and try again.\n"]); } if (scalar(@no_mgt_nodes)) { my $tmp_nodelist = join ',', @no_mgt_nodes; return (["Failed to get nodehm.mgt value for node(s) $tmp_nodelist. Please define first and try again.\n"]); } if (scalar(@error_type_nodes)) { my $tmp_nodelist = join ',', @error_type_nodes; my $link = (scalar(@error_type_nodes) eq '1') ? 'is' : 'are'; return (["Node type of node(s) $tmp_nodelist $link not supported for this command in FSPAPI.\n"]); } #$nodetypetab->close(); $nodehmtab->close(); $request->{nodetype} = $nodetype; $request->{method} = 'lshwconn'; return (\%opt); } ########################################################################## # Parse arguments for rmhwconn ########################################################################## sub rmhwconn_parse_args { my $request = shift; my $args = shift; my %opt = (); local *usage = sub { my $usage_string = xCAT::Usage->getUsage("rmhwconn"); return ([ $_[0], $usage_string ]); }; ############################################# # Get options in command line ############################################# local @ARGV = ref($args) eq 'ARRAY' ? @$args : (); $Getopt::Long::ignorecase = 0; Getopt::Long::Configure("bundling"); if (!GetOptions(\%opt, qw(V|verbose h|help T=s s))) { return (usage()); } return usage() if (exists $opt{h}); if ($opt{s}) { my $opttmp = xCAT::PPCconn::rmhwconn_parse_args($request, $args); return $opttmp; } if (!exists $opt{T}) { $opt{T} = "lpar"; #defaut value is lpar. #return( usage('Missing -T option. The value can be lpar or fnm.')); } if ($opt{T} eq "lpar") { $opt{T} = 0; } elsif ($opt{T} eq "fnm") { $opt{T} = 1; } else { return (usage('Wrong value of -T option. The value can be lpar or fnm. The default value is lpar.')); } ############################################# # Process command-line arguments ############################################# if (scalar(@ARGV)) { return (usage("No additional flag is support by this command")); } ########################################## # Check if CECs are controlled by a frame ########################################## my $nodes = $request->{node}; my $ppctab = xCAT::Table->new('ppc'); return (["Failed to open table 'ppc'.\n"]) if (!$ppctab); #my $nodetypetab = xCAT::Table->new( 'nodetype'); #return( ["Failed to open table 'nodetype'.\n"]) if ( ! $nodetypetab); my $vpdtab = xCAT::Table->new('vpd'); return (["Failed to open table 'vpd'.\n"]) if (!$vpdtab); my $nodehmtab = xCAT::Table->new('nodehm'); return (["Failed to open table 'nodehm'.\n"]) if (!$nodehmtab); my @bpa_ctrled_nodes = (); my @no_type_nodes = (); my @no_mgt_nodes = (); my @frame_members = (); my $nodetype_hash = xCAT::DBobjUtils->getnodetype($nodes, "ppc"); for my $node (@$nodes) { my $nodehm = $nodehmtab->getNodeAttribs($node, [qw(mgt)]); if (!$nodehm) { push @no_mgt_nodes, $node; next; } my $node_parent = undef; my $nodetype = undef; my $node_parent_hash = $ppctab->getNodeAttribs($node, [qw(parent)]); $nodetype = $$nodetype_hash{$node}; $node_parent = $node_parent_hash->{parent}; if (!$nodetype) { push @no_type_nodes, $node; next; } if (($nodetype eq 'fsp' or $nodetype eq 'cec') and $node_parent and $node_parent ne $node) { push @bpa_ctrled_nodes, $node; } if ($nodetype eq 'bpa') { my $my_frame_bpa_cec = getFrameMembers($node, $vpdtab, $ppctab); push @frame_members, @$my_frame_bpa_cec; } if ($nodetype eq 'frame') { my $my_frame_bpa_cec = xCAT::DBobjUtils::getcecchildren($node); push @frame_members, @$my_frame_bpa_cec; push @frame_members, $node; } } if (scalar(@no_type_nodes)) { my $tmp_nodelist = join ',', @no_type_nodes; return (usage("Attribute nodetype.nodetype cannot be found for node(s) $tmp_nodelist. Please define first and try again.\n")); } if (scalar(@no_mgt_nodes)) { my $tmp_nodelist = join ',', @no_mgt_nodes; return (["Failed to get nodehm.mgt value for node(s) $tmp_nodelist. Please define first and try again.\n"]); } $ppctab->close(); #$nodetypetab->close(); $vpdtab->close(); $nodehmtab->close(); #if (scalar(@bpa_ctrled_nodes)) #{ # my $tmp_nodelist = join ',', @bpa_ctrled_nodes; # return ( usage("Node(s) $tmp_nodelist is(are) controlled by BPA.")); #} if (scalar(@frame_members)) { my @all_nodes = xCAT::Utils::get_unique_members(@$nodes, @frame_members); $request->{node} = \@all_nodes; } $request->{method} = 'rmhwconn'; return (\%opt); } ########################################################################## # Create connection for CECs/BPAs ########################################################################## sub mkhwconn { my $request = shift; my $hash = shift; #my $exp = shift; #my $hwtype = @$exp[2]; my $opt = $request->{opt}; my @value = (); my $Rc = undef; my $tooltype = $opt->{T}; xCAT::MsgUtils->verbose_message($request, "mkhwconn START."); for my $cec_bpa (keys %$hash) { my $node_hash = $hash->{$cec_bpa}; for my $node_name (keys %$node_hash) { my $d = $node_hash->{$node_name}; #my ( undef,undef,$mtms,undef,$type) = @$d; #my ($user, $passwd); #if ( exists $opt->{P}) #{ # ($user, $passwd) = ('HMC', $opt->{P}); #} #else #{ # ($user, $passwd) = xCAT::PPCdb::credentials( $node_name, $type,'HMC'); # if ( !$passwd) # { # push @value, [$node_name, "Cannot get password of userid 'HMC'. Please check table 'passwd' or 'ppcdirect'.",1]; # next; # } #} xCAT::MsgUtils->verbose_message($request, "mkhwconn :add_connection for node:$node_name."); my $res = xCAT::FSPUtils::fsp_api_action($request, $node_name, $d, "add_connection", $tooltype, $opt->{port}); $Rc = @$res[2]; if (@$res[1] ne "") { push @value, [ $node_name, @$res[1], $Rc ]; } } } xCAT::MsgUtils->verbose_message($request, "mkhwconn END."); return \@value; } ########################################################################## # List connection status for CECs/BPAs through FSPAPI ########################################################################## sub lshwconn { my $request = shift; my $hash = shift; my $exp = shift; my $hwtype = @$exp[2]; my $opt = $request->{opt}; my @value = (); my $Rc = undef; my $res = undef; my $tooltype = $opt->{T}; for my $cec_bpa (keys %$hash) { my $node_hash = $hash->{$cec_bpa}; for my $node_name (keys %$node_hash) { my $d = $node_hash->{$node_name}; my $action = "query_connection"; my $res = xCAT::FSPUtils::fsp_api_action($request, $node_name, $d, $action, $tooltype); #print "in lshwconn:\n"; #print Dumper($res); my $Rc = @$res[2]; my $values = @$res[1]; ############################################ # If lssysconn failed, put error into all # nodes' return values ############################################ #if ( $Rc ) # { # push @value, [$node_name, $values, $Rc]; # next; # } my %rec = (); my @data_a = split("\n", $values); foreach my $data (@data_a) { if ($data =~ /state/) { $data =~ /state=([\w\s\,]+), type=([\w-]+), MTMS=([\w-\*\#]+), ([\w=]+), slot=([\w]+), ipadd=([\w.]+), alt_ipadd=([\w.]+)/; #$data =~ /state=([\w\s]+),\(type=([\w-]+)\),\(serial-number=([\w]+)\),\(machinetype-model=([\w-]+)\),sp=([\w]+),\(ip-address=([\w.]+),([\w.]+)\)/ ; print "parsing: $1,$2,$3,$4,$5,$6,$7\n"; my $state = $1; my $type = $2; my $mtms = $3; my $sp = $4; my $slot = $5; my $ipadd = $6; my $alt_ipaddr = $7; if (exists($rec{$slot})) { next; } $rec{$slot} = 1; $data = "$sp,ipadd=$ipadd,alt_ipadd=$alt_ipaddr,state=$state"; } push @value, [ $node_name, $data, $Rc ]; } } } return \@value; } ########################################################################## # Remove connection for CECs/BPAs to Hardware servers ########################################################################## sub rmhwconn { my $request = shift; my $hash = shift; #my $exp = shift; #my $hwtype = @$exp[2]; my $opt = $request->{opt}; my @value = (); my $Rc = undef; my $tooltype = $opt->{T}; for my $cec_bpa (keys %$hash) { my $node_hash = $hash->{$cec_bpa}; for my $node_name (keys %$node_hash) { my $d = $node_hash->{$node_name}; my (undef, undef, undef, undef, $type) = @$d; my $res = xCAT::FSPUtils::fsp_api_action($request, $node_name, $d, "rm_connection", $tooltype); $Rc = @$res[2]; if (@$res[1] ne "") { push @value, [ $node_name, @$res[1], $Rc ]; } } } return \@value; } 1;