Commit 6516d59d authored by Leigh B. Stoller's avatar Leigh B. Stoller
Browse files

Quickie change to see if retry will work on a failed plab node!

parent 5bef91ea
...@@ -3556,13 +3556,13 @@ sub LoadCurrent() ...@@ -3556,13 +3556,13 @@ sub LoadCurrent()
my $query_result = my $query_result =
DBQueryFatal("select r.vname,r.node_id,n.phys_nodeid, ". DBQueryFatal("select r.vname,r.node_id,n.phys_nodeid, ".
" nt.isvirtnode,nt.isremotenode ". " nt.isvirtnode,nt.isremotenode,nt.isplabdslice ".
" from reserved as r ". " from reserved as r ".
"left join nodes as n on n.node_id=r.node_id ". "left join nodes as n on n.node_id=r.node_id ".
"left join node_types as nt on nt.type=n.type ". "left join node_types as nt on nt.type=n.type ".
"where r.pid='$pid' and r.eid='$eid'"); "where r.pid='$pid' and r.eid='$eid'");
while (($vname,$reserved,$physnode,$isvirt,$isremote) = while (($vname,$reserved,$physnode,$isvirt,$isremote,$isplab) =
$query_result->fetchrow_array) { $query_result->fetchrow_array) {
# #
...@@ -3570,7 +3570,7 @@ sub LoadCurrent() ...@@ -3570,7 +3570,7 @@ sub LoadCurrent()
# #
fatal(1, "*** $0:\n". fatal(1, "*** $0:\n".
" Cannot update widearea nodes yet!") " Cannot update widearea nodes yet!")
if ($isremote); if ($isremote && !$isplab);
LoadPhysNode($reserved); LoadPhysNode($reserved);
......
...@@ -66,11 +66,13 @@ my $osselect = "$TB/bin/os_select"; ...@@ -66,11 +66,13 @@ my $osselect = "$TB/bin/os_select";
my $dbg = 0; my $dbg = 0;
my $failed = 0; my $failed = 0;
my $failedvnodes= 0; my $failedvnodes= 0;
my $failedplab = 0;
my %nodes = (); my %nodes = ();
my %vnodes = (); my %vnodes = ();
my %vnodephosts = (); my %vnodephosts = ();
my %vnode2pnode = (); my %vnode2pnode = ();
my %pnodevcount = (); my %pnodevcount = ();
my %plabvnodes = ();
my %osids = (); my %osids = ();
my %canfail = (); my %canfail = ();
my $db_result; my $db_result;
...@@ -170,6 +172,7 @@ while (my %row = $db_result->fetchhash()) { ...@@ -170,6 +172,7 @@ while (my %row = $db_result->fetchhash()) {
# #
if ($virtnode) { if ($virtnode) {
$vnodes{$node} = ($jailnode || $plabnode); $vnodes{$node} = ($jailnode || $plabnode);
$plabvnodes{$node} = $plabnode;
if (! $jailnode && ! $plabnode) { if (! $jailnode && ! $plabnode) {
next; next;
} }
...@@ -681,7 +684,7 @@ elsif (@vnodelist) { ...@@ -681,7 +684,7 @@ elsif (@vnodelist) {
my $node = shift(@vnodelist); my $node = shift(@vnodelist);
my $pnode = $vnode2pnode{$node}; my $pnode = $vnode2pnode{$node};
my $wstart = $waitstart{$node}; my $wstart = $waitstart{$node};
my $maxwait = 90 + (300 * $pnodevcount{$pnode}); my $maxwait = 90 + (100 * $pnodevcount{$pnode});
if (!TBNodeStateWait($node, TBDB_NODESTATE_ISUP, $wstart, $maxwait)) { if (!TBNodeStateWait($node, TBDB_NODESTATE_ISUP, $wstart, $maxwait)) {
print "$node is alive and well\n"; print "$node is alive and well\n";
...@@ -719,8 +722,13 @@ elsif (@vnodelist) { ...@@ -719,8 +722,13 @@ elsif (@vnodelist) {
print "*** Continuing with experiment setup anyway ...\n"; print "*** Continuing with experiment setup anyway ...\n";
next; next;
} }
if ($plabvnodes{$node}) {
$failedplab++;
}
else {
$failedvnodes++; $failedvnodes++;
} }
}
TBDebugTimeStamp("Virtual node waiting finished"); TBDebugTimeStamp("Virtual node waiting finished");
} }
...@@ -729,6 +737,8 @@ print "*** There were $failed failed nodes\n" ...@@ -729,6 +737,8 @@ print "*** There were $failed failed nodes\n"
if ($failed); if ($failed);
print "*** There were $failedvnodes failed virtual nodes\n" print "*** There were $failedvnodes failed virtual nodes\n"
if ($failedvnodes); if ($failedvnodes);
print "*** There were $failedplab failed plab nodes\n"
if ($failedplab);
TBDebugTimeStamp("os_setup finished"); TBDebugTimeStamp("os_setup finished");
...@@ -736,7 +746,7 @@ TBDebugTimeStamp("os_setup finished"); ...@@ -736,7 +746,7 @@ TBDebugTimeStamp("os_setup finished");
exit(-1) exit(-1)
if ($failedvnodes); if ($failedvnodes);
exit(1) exit(1)
if ($failed); if ($failed || $failedplab);
exit 0; exit 0;
# #
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment