# 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; ############################################## # 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 @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}); 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; 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}); } 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 = xCAT::DBobjUtils->getnodetype($node); $node_parent = $node_parent_hash->{parent}; if ( !$nodetype ) { push @no_type_nodes, $node; next; } else { unless ( $nodetype =~ /^(fsp|bpa|frame|cec|hmc)$/) { return ( usage("Node type is incorrect. \n")); } } 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")); } #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"; } if( $opt{port} ne "0" and $opt{port} ne "1") { return( usage('Wrong value of --port option. The value can be 0 or 1, and the default value is 0.')); } $ppctab->close(); #$nodetypetab->close(); $vpdtab->close(); $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; for my $node ( @{$request->{node}}) { #my $ent = $nodetypetab->getNodeAttribs( $node, [qw(nodetype)]); my $nodehm = $nodehmtab->getNodeAttribs( $node, [qw(mgt)]); #if ( ! $ent) #{ # return( ["Failed to get node type for node $node.\n"]); #} my $ttype = xCAT::DBobjUtils->getnodetype($node); if ( ! $ttype) { return( ["Failed to get nodehm.mgt value for node $node.\n"]); } if ( $ttype ne 'fsp' and $ttype ne 'cec' and $ttype ne 'bpa' and $ttype ne 'frame') { return( ["Node type $ttype is not supported for this command in FSPAPI\n"]); } if ( ! $nodetype) { $nodetype = $ttype; #$ent->{nodetype}; } else { if ( $nodetype ne $ttype) #$ent->{nodetype}) { return( ["Cannot support multiple node types in this command line.\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 @frame_members = (); for my $node ( @$nodes) { my $nodehm = $nodehmtab->getNodeAttribs( $node, [qw(mgt)]); if ( ! $nodehm) { return( ["Failed to get nodehm.mgt value for node $node.\n"]); } my $node_parent = undef; my $nodetype = undef; #my $nodetype_hash = $nodetypetab->getNodeAttribs( $node,[qw(nodetype)]); my $node_parent_hash = $ppctab->getNodeAttribs( $node,[qw(parent)]); #$nodetype = $nodetype_hash->{nodetype}; $nodetype = xCAT::DBobjUtils->getnodetype($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")); } $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}; 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; # } #} my $res = xCAT::FSPUtils::fsp_api_action( $node_name, $d, "add_connection", $tooltype, $opt->{port} ); $Rc = @$res[2]; if( @$res[1] ne "") { push @value, [$node_name, @$res[1], $Rc]; } } } 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 ($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 @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; $data = "$ipadd: $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( $node_name, $d, "rm_connection", $tooltype ); $Rc = @$res[2]; if( @$res[1] ne "") { push @value, [$node_name, @$res[1], $Rc]; } } } return \@value; } 1;