2
0
mirror of https://github.com/xcat2/xcat-core.git synced 2025-06-19 04:40:21 +00:00

Merge pull request #2017 from xuweibj/i2013

fix issue 2013, get nodes array to set status
This commit is contained in:
Weihua Hu
2016-10-24 16:24:02 +08:00
committed by GitHub

View File

@ -908,23 +908,26 @@ sub handle_cluster_msg {
}
}
} elsif ($log_ref->{msg} =~ /(.+)\s+status:\s+(.+)\s+statustime:/) {
my $node = $1;
my $nodes = $1;
my $status = $2;
my $record = "Node status is changed to $status";
my @split_node = split(" ", $nodes);
if (exists $node_state_ref->{$node}) {
probe_utils->send_msg("stdout", "d", "[$node] $record") if ($monitor);
push(@{ $node_state_ref->{$node}{log} }, $log_ref->{msg}) if ($debug);
foreach my $node (@split_node) {
if (exists $node_state_ref->{$node}) {
probe_utils->send_msg("stdout", "d", "[$node] $record") if ($monitor);
push(@{ $node_state_ref->{$node}{log} }, $log_ref->{msg}) if ($debug);
if ($status eq "installing") {
set_node_state($node_state_ref, $node, $::STATE_INSTALLING);
} elsif ($status eq "powering-on") {
set_node_state($node_state_ref, $node, $::STATE_POWERINGON);
} elsif ($status eq "booting") {
set_node_state($node_state_ref, $node, $::STATE_BOOTING);
} elsif ($status eq "failed") {
$node_state_ref->{$node}{done} = 1;
}
if ($status eq "installing") {
set_node_state($node_state_ref, $node, $::STATE_INSTALLING);
} elsif ($status eq "powering-on") {
set_node_state($node_state_ref, $node, $::STATE_POWERINGON);
} elsif ($status eq "booting") {
set_node_state($node_state_ref, $node, $::STATE_BOOTING);
} elsif ($status eq "failed") {
$node_state_ref->{$node}{done} = 1;
}
}
}
}
}