arif/xcat-core
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
fef814d4d4
xcat-core/perl-xCAT/xCAT/FSPconn.pm
jjhua d55a7c6d5a performance enhancement for getIPaddress() in FSPxx.pm 
git-svn-id: https://svn.code.sf.net/p/xcat/code/xcat-core/trunk@12389 8638fb3e-16cb-4fca-ae20-7b5d299a9bcd
2012-04-28 09:26:49 +00:00

712 lines
22 KiB
Perl
Raw Blame History

# 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 @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) == '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};
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($request, $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 ($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;
Reference in New Issue View Git Blame Copy Permalink