mirror of
https://github.com/xcat2/xcat-core.git
synced 2025-05-29 17:23:08 +00:00
Add code to support rinv and rsetboot for openbmc
This commit is contained in:
XuWei
parent
cf06123a0a
commit
e5b3e4786e
@ -24,6 +24,7 @@ use xCAT::Usage;
|
||||
use xCAT::SvrUtils;
|
||||
use File::Basename;
|
||||
use Data::Dumper;
|
||||
use Getopt::Long;
|
||||
use JSON;
|
||||
|
||||
$::OPENBMC_DEVEL = $ENV{'OPENBMC_DEVEL'};
|
||||
@ -117,11 +118,50 @@ my %status_info = (
|
||||
|
||||
RINV_REQUEST => {
|
||||
method => "GET",
|
||||
init_url => "$openbmc_url/inventory/enumerate",
|
||||
init_url => "$openbmc_project_url/inventory/enumerate",
|
||||
},
|
||||
RINV_RESPONSE => {
|
||||
process => \&rinv_response,
|
||||
},
|
||||
RSETBOOT_HD_REQUEST => {
|
||||
method => "PUT",
|
||||
init_url => "",
|
||||
data => "",
|
||||
},
|
||||
RSETBOOT_HD_RESPONSE => {
|
||||
process => \&rsetboot_response,
|
||||
},
|
||||
RSETBOOT_NET_REQUEST => {
|
||||
method => "PUT",
|
||||
init_url => "",
|
||||
data => "",
|
||||
},
|
||||
RSETBOOT_NET_RESPONSE => {
|
||||
process => \&rsetboot_response,
|
||||
},
|
||||
RSETBOOT_CD_REQUEST => {
|
||||
method => "PUT",
|
||||
init_url => "",
|
||||
data => "",
|
||||
},
|
||||
RSETBOOT_CD_RESPONSE => {
|
||||
process => \&rsetboot_response,
|
||||
},
|
||||
RSETBOOT_DEF_REQUEST => {
|
||||
method => "PUT",
|
||||
init_url => "",
|
||||
data => "",
|
||||
},
|
||||
RSETBOOT_DEF_RESPONSE => {
|
||||
process => \&rsetboot_response,
|
||||
},
|
||||
RSETBOOT_STATUS_REQUEST => {
|
||||
method => "GET",
|
||||
init_url => "",
|
||||
},
|
||||
RSETBOOT_STATUS_RESPONSE => {
|
||||
process => \&rsetboot_response,
|
||||
},
|
||||
);
|
||||
|
||||
|
||||
@ -289,7 +329,7 @@ sub parse_args {
|
||||
my $extrargs = shift;
|
||||
my $check = undef;
|
||||
|
||||
if (scalar(@ARGV) > 1) {
|
||||
if (scalar(@ARGV) > 1 and $command ne "rsetboot") {
|
||||
return ([ 1, "Only one option is supported at the same time" ]);
|
||||
}
|
||||
|
||||
@ -312,12 +352,23 @@ sub parse_args {
|
||||
#
|
||||
$check = unsupported($callback); if (ref($check) eq "ARRAY") { return $check; }
|
||||
|
||||
|
||||
unless ($subcommand =~ /^cpu$|^dimm$|^bios$|^all$/) {
|
||||
$subcommand = "all" if (!defined($ARGV[0]));
|
||||
unless ($subcommand =~ /^cpu$|^dimm$|^bios$|^model$|^serial$|^all$/) {
|
||||
return ([ 1, "Unsupported command: $command $subcommand" ]);
|
||||
}
|
||||
} elsif ($command eq "getopenbmccons") {
|
||||
#command for openbmc rcons
|
||||
} elsif ($command eq "rsetboot") {
|
||||
if (!defined($extrargs)) {
|
||||
return ([ 1, "No option specified for $command" ]);
|
||||
}
|
||||
#
|
||||
# disable function until fully tested
|
||||
#
|
||||
$check = unsupported($callback); if (ref($check) eq "ARRAY") { return $check; }
|
||||
unless ($subcommand =~ /^net$|^hd$|^cd$|^def$|^default$|^stat$/) {
|
||||
return ([ 1, "Unsupported command: $command $subcommand" ]);
|
||||
}
|
||||
} else {
|
||||
return ([ 1, "Command is not supported." ]);
|
||||
}
|
||||
@ -336,11 +387,12 @@ sub parse_args {
|
||||
#-------------------------------------------------------
|
||||
sub parse_command_status {
|
||||
my $command = shift;
|
||||
my $subcommand;
|
||||
|
||||
$next_status{LOGIN_REQUEST} = "LOGIN_RESPONSE";
|
||||
|
||||
if ($command eq "rpower") {
|
||||
my $subcommand = $ARGV[0];
|
||||
$subcommand = $ARGV[0];
|
||||
|
||||
if ($subcommand eq "on") {
|
||||
$next_status{LOGIN_RESPONSE} = "RPOWER_ON_REQUEST";
|
||||
@ -365,15 +417,54 @@ sub parse_command_status {
|
||||
}
|
||||
|
||||
if ($command eq "rinv") {
|
||||
my $subcommand = $ARGV[0];
|
||||
if (defined($ARGV[0])) {
|
||||
$subcommand = $ARGV[0];
|
||||
} else {
|
||||
$subcommand = "all";
|
||||
}
|
||||
|
||||
if ($subcommand eq "cpu" or $subcommand eq "dimm" or $subcommand eq "bios" or $subcommand eq "all") {
|
||||
if ($subcommand eq "cpu" or $subcommand eq "dimm" or $subcommand eq "bios" or $subcommand eq "model" or $subcommand eq "serial" or $subcommand eq "all") {
|
||||
$next_status{LOGIN_RESPONSE} = "RINV_REQUEST";
|
||||
$next_status{RINV_REQUEST} = "RINV_RESPONSE";
|
||||
$status_info{RINV_RESPONSE}{argv} = "$subcommand";
|
||||
}
|
||||
}
|
||||
|
||||
if ($command eq "rsetboot") {
|
||||
my $persistent = 0;
|
||||
my $uefi = 0;
|
||||
unless (GetOptions(
|
||||
"p" => \$persistent,
|
||||
)) {
|
||||
xCAT::SvrUtils::sendmsg([ 1, "Error parsing arguments" ], $callback);
|
||||
exit 1;
|
||||
}
|
||||
|
||||
$subcommand = $ARGV[0];
|
||||
if ($subcommand eq "hd") {
|
||||
$next_status{LOGIN_RESPONSE} = "RSETBOOT_HD_REQUEST";
|
||||
$next_status{RSETBOOT_HD_REQUEST} = "RSETBOOT_HD_RESPONSE";
|
||||
# modify $status_info{RSETBOOT_SET_REQUEST}{data} if $persistent or $uefi
|
||||
} elsif ($subcommand eq "net") {
|
||||
$next_status{LOGIN_RESPONSE} = "RSETBOOT_NET_REQUEST";
|
||||
$next_status{RSETBOOT_NET_REQUEST} = "RSETBOOT_NET_RESPONSE";
|
||||
# modify $status_info{RSETBOOT_SET_REQUEST}{data} if $persistent or $uefi
|
||||
} elsif ($subcommand eq "cd"){
|
||||
$next_status{LOGIN_RESPONSE} = "RSETBOOT_CD_REQUEST";
|
||||
$next_status{RSETBOOT_CD_REQUEST} = "RSETBOOT_CD_RESPONSE";
|
||||
# modify $status_info{RSETBOOT_SET_REQUEST}{data} if $persistent or $uefi
|
||||
} elsif ($subcommand eq "default" or $subcommand eq "def") {
|
||||
$next_status{LOGIN_RESPONSE} = "RSETBOOT_DEF_REQUEST";
|
||||
$next_status{RSETBOOT_DEF_REQUEST} = "RSETBOOT_DEF_RESPONSE";
|
||||
# modify $status_info{RSETBOOT_SET_REQUEST}{data} if $persistent or $uefi
|
||||
} elsif ($subcommand eq "stat") {
|
||||
$next_status{LOGIN_RESPONSE} = "RSETBOOT_STATUS_REQUEST";
|
||||
$next_status{RSETBOOT_STATUS_REQUEST} = "RSETBOOT_STATUS_RESPONSE";
|
||||
}
|
||||
xCAT::SvrUtils::sendmsg("Command $command is not available now!", $callback);
|
||||
exit;
|
||||
}
|
||||
|
||||
print Dumper(\%next_status) . "\n";
|
||||
}
|
||||
|
||||
@ -598,7 +689,11 @@ sub rpower_response {
|
||||
}
|
||||
|
||||
if ($node_info{$node}{cur_status} eq "RPOWER_STATUS_RESPONSE") {
|
||||
xCAT::SvrUtils::sendmsg($response_info->{'data'}->{CurrentHostState}, $callback, $node);
|
||||
if ($response_info->{'data'}->{CurrentHostState} =~ /Off$/) {
|
||||
xCAT::SvrUtils::sendmsg("off", $callback, $node);
|
||||
} else {
|
||||
xCAT::SvrUtils::sendmsg("on", $callback, $node);
|
||||
}
|
||||
}
|
||||
|
||||
if ($next_status{ $node_info{$node}{cur_status} }) {
|
||||
@ -642,14 +737,31 @@ sub rinv_response {
|
||||
my $content_info;
|
||||
|
||||
foreach my $key_url (keys %{$response_info->{data}}) {
|
||||
if ($grep_string eq "all" or $key_url =~ /\/$grep_string/) {
|
||||
my %content = %{ ${ $response_info->{data} }{$key_url} };
|
||||
|
||||
if ($grep_string eq "model") {
|
||||
if ($key_url =~ /\/motherboard$/) {
|
||||
my $model = "Model : " . $content{Model};
|
||||
my $partnumber = "PartNumber : " . "$content{PartNumber}";
|
||||
xCAT::SvrUtils::sendmsg("$model", $callback, $node);
|
||||
xCAT::SvrUtils::sendmsg("$partnumber", $callback, $node);
|
||||
next;
|
||||
}
|
||||
} elsif ($grep_string eq "serial") {
|
||||
if ($key_url =~ /\/motherboard$/) {
|
||||
my $prettyname = "PrettyName : " . $content{PrettyName};
|
||||
my $serialnumber = "SerialNumber : " . "$content{SerialNumber}";
|
||||
xCAT::SvrUtils::sendmsg("$prettyname", $callback, $node);
|
||||
xCAT::SvrUtils::sendmsg("$serialnumber", $callback, $node);
|
||||
next;
|
||||
}
|
||||
} elsif ($grep_string eq "all" or $key_url =~ /\/$grep_string/) {
|
||||
if ($key_url =~ /\/(cpu\d*)\/(\w+)/) {
|
||||
$src = "$1 $2";
|
||||
} else {
|
||||
$src = basename $key_url;
|
||||
}
|
||||
|
||||
my %content = %{ ${ $response_info->{data} }{$key_url} };
|
||||
foreach my $key (keys %content) {
|
||||
$content_info = uc ($src) . " " . $key . " : " . $content{$key};
|
||||
xCAT::SvrUtils::sendmsg("$content_info", $callback, $node);
|
||||
@ -695,6 +807,60 @@ sub getopenbmccons {
|
||||
return $rsp;
|
||||
}
|
||||
|
||||
#-------------------------------------------------------
|
||||
|
||||
=head3 rsetboot_response
|
||||
|
||||
Deal with response of rsetboot command
|
||||
Input:
|
||||
$node: nodename of current response
|
||||
$response: Async return response
|
||||
|
||||
=cut
|
||||
|
||||
#-------------------------------------------------------
|
||||
sub rsetboot_response {
|
||||
my $node = shift;
|
||||
my $response = shift;
|
||||
|
||||
my $response_info = decode_json $response->content;
|
||||
|
||||
if ($node_info{$node}{cur_status} eq "RSETBOOT_HD_RESPONSE") {
|
||||
if ($response_info->{'message'} eq "200 OK") {
|
||||
xCAT::SvrUtils::sendmsg("HD", $callback, $node);
|
||||
}
|
||||
}
|
||||
|
||||
if ($node_info{$node}{cur_status} eq "RSETBOOT_NET_RESPONSE") {
|
||||
if ($response_info->{'message'} eq "200 OK") {
|
||||
xCAT::SvrUtils::sendmsg("NET", $callback, $node);
|
||||
}
|
||||
}
|
||||
|
||||
if ($node_info{$node}{cur_status} eq "RSETBOOT_CD_RESPONSE") {
|
||||
if ($response_info->{'message'} eq "200 OK") {
|
||||
xCAT::SvrUtils::sendmsg("CD", $callback, $node);
|
||||
}
|
||||
}
|
||||
|
||||
if ($node_info{$node}{cur_status} eq "RSETBOOT_DEF_RESPONSE") {
|
||||
if ($response_info->{'message'} eq "200 OK") {
|
||||
xCAT::SvrUtils::sendmsg("DEF", $callback, $node);
|
||||
}
|
||||
}
|
||||
|
||||
if ($node_info{$node}{cur_status} eq "RSETBOOT_STATUS_RESPONSE") {
|
||||
# wait for more information
|
||||
}
|
||||
|
||||
if ($next_status{ $node_info{$node}{cur_status} }) {
|
||||
$node_info{$node}{cur_status} = $next_status{ $node_info{$node}{cur_status} };
|
||||
gen_send_request($node);
|
||||
} else {
|
||||
$wait_node_num--;
|
||||
}
|
||||
|
||||
return;
|
||||
}
|
||||
|
||||
1;
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user