Commit 704ef98d authored by Marko Mäkelä's avatar Marko Mäkelä

Merge 10.2 into 10.3

parents 49680497 bcc26dce
...@@ -3975,32 +3975,32 @@ sub run_testcase ($$) { ...@@ -3975,32 +3975,32 @@ sub run_testcase ($$) {
} }
my $test= $tinfo->{suite}->start_test($tinfo); my $test= $tinfo->{suite}->start_test($tinfo);
# Set to a list of processes we have to keep waiting (expectedly died servers) # Set only when we have to keep waiting after expectedly died server
my %keep_waiting_proc = (); my $keep_waiting_proc = 0;
my $print_timeout= start_timer($print_freq * 60); my $print_timeout= start_timer($print_freq * 60);
while (1) while (1)
{ {
my $proc; my $proc;
if (scalar(keys(%keep_waiting_proc)) > 0) if ($keep_waiting_proc)
{ {
# Any other process exited? # Any other process exited?
$proc = My::SafeProcess->check_any(); $proc = My::SafeProcess->check_any();
if ($proc) if ($proc)
{ {
mtr_verbose ("Found exited process $proc"); mtr_verbose ("Found exited process $proc");
$keep_waiting_proc{$proc} = 1;
} }
else else
{ {
$proc = $keep_waiting_proc;
# Also check if timer has expired, if so cancel waiting # Also check if timer has expired, if so cancel waiting
if ( has_expired($test_timeout) ) if ( has_expired($test_timeout) )
{ {
%keep_waiting_proc = (); $keep_waiting_proc = 0;
} }
} }
} }
if (scalar(keys(%keep_waiting_proc)) == 0) if (! $keep_waiting_proc)
{ {
if($test_timeout > $print_timeout) if($test_timeout > $print_timeout)
{ {
...@@ -4017,148 +4017,137 @@ sub run_testcase ($$) { ...@@ -4017,148 +4017,137 @@ sub run_testcase ($$) {
else else
{ {
$proc= My::SafeProcess->wait_any_timeout($test_timeout); $proc= My::SafeProcess->wait_any_timeout($test_timeout);
$keep_waiting_proc{$proc} = 1;
} }
} }
if (scalar(keys(%keep_waiting_proc)) == 0) # Will be restored if we need to keep waiting
$keep_waiting_proc = 0;
unless ( defined $proc )
{ {
mtr_error("wait_any failed"); mtr_error("wait_any failed");
} }
mtr_verbose("Got " . join(",", keys(%keep_waiting_proc))); mtr_verbose("Got $proc");
mark_time_used('test'); mark_time_used('test');
my $expected_exit = 1; # ----------------------------------------------------
foreach $proc (keys(%keep_waiting_proc)) { # Was it the test program that exited
# ---------------------------------------------------- # ----------------------------------------------------
# Was it the test program that exited if ($proc eq $test)
# ---------------------------------------------------- {
if ($proc eq $test) my $res= $test->exit_status();
{
my $res= $test->exit_status();
if (($res == 0 or $res == 62) and $opt_warnings and check_warnings($tinfo) ) if (($res == 0 or $res == 62) and $opt_warnings and check_warnings($tinfo) )
{ {
# If test case suceeded, but it has produced unexpected # If test case suceeded, but it has produced unexpected
# warnings, continue with $res == 1; # warnings, continue with $res == 1;
# but if the test was skipped, it should remain skipped # but if the test was skipped, it should remain skipped
$res= 1 if $res == 0; $res= 1 if $res == 0;
resfile_output($tinfo->{'warnings'}) if $opt_resfile; resfile_output($tinfo->{'warnings'}) if $opt_resfile;
} }
if ( $res == 0 ) if ( $res == 0 )
{ {
my $check_res; my $check_res;
if ( $opt_check_testcases and if ( $opt_check_testcases and
$check_res= check_testcase($tinfo, "after")) $check_res= check_testcase($tinfo, "after"))
{ {
if ($check_res == 1) { if ($check_res == 1) {
# Test case had sideeffects, not fatal error, just continue # Test case had sideeffects, not fatal error, just continue
if ($opt_warnings) { if ($opt_warnings) {
# Checking error logs for warnings, so need to stop server # Checking error logs for warnings, so need to stop server
# gracefully so that memory leaks etc. can be properly detected. # gracefully so that memory leaks etc. can be properly detected.
stop_servers(reverse all_servers()); stop_servers(reverse all_servers());
check_warnings_post_shutdown($server_socket); check_warnings_post_shutdown($server_socket);
# Even if we got warnings here, we should not fail this # Even if we got warnings here, we should not fail this
# particular test, as the warnings may be caused by an earlier # particular test, as the warnings may be caused by an earlier
# test. # test.
} else { } else {
# Not checking warnings, so can do a hard shutdown. # Not checking warnings, so can do a hard shutdown.
stop_all_servers($opt_shutdown_timeout); stop_all_servers($opt_shutdown_timeout);
}
mtr_report("Resuming tests...\n");
resfile_output($tinfo->{'check'}) if $opt_resfile;
}
else {
# Test case check failed fatally, probably a server crashed
report_failure_and_restart($tinfo);
return 1;
} }
} mtr_report("Resuming tests...\n");
mtr_report_test_passed($tinfo); resfile_output($tinfo->{'check'}) if $opt_resfile;
} }
elsif ( $res == 62 ) else {
{ # Test case check failed fatally, probably a server crashed
# Testcase itself tell us to skip this one report_failure_and_restart($tinfo);
$tinfo->{skip_detected_by_test}= 1; return 1;
# Try to get reason from test log file }
find_testcase_skipped_reason($tinfo); }
mtr_report_test_skipped($tinfo); mtr_report_test_passed($tinfo);
# Restart if skipped due to missing perl, it may have had side effects
if ( $tinfo->{'comment'} =~ /^perl not found/ )
{
stop_all_servers($opt_shutdown_timeout);
}
}
elsif ( $res == 65 )
{
# Testprogram killed by signal
$tinfo->{comment}=
"testprogram crashed(returned code $res)";
report_failure_and_restart($tinfo);
}
elsif ( $res == 1 )
{
# Check if the test tool requests that
# an analyze script should be run
my $analyze= find_analyze_request();
if ($analyze){
run_on_all($tinfo, "analyze-$analyze");
}
# Wait a bit and see if a server died, if so report that instead
mtr_milli_sleep(100);
my $srvproc= My::SafeProcess::check_any();
if ($srvproc && grep($srvproc eq $_, started(all_servers()))) {
$proc= $srvproc;
goto SRVDIED;
}
# Test case failure reported by mysqltest
report_failure_and_restart($tinfo);
}
else
{
# mysqltest failed, probably crashed
$tinfo->{comment}=
"mysqltest failed with unexpected return code $res\n";
report_failure_and_restart($tinfo);
}
# Save info from this testcase run to mysqltest.log
if( -f $path_current_testlog)
{
if ($opt_resfile && $res && $res != 62) {
resfile_output_file($path_current_testlog);
}
mtr_appendfile_to_file($path_current_testlog, $path_testlog);
unlink($path_current_testlog);
}
return ($res == 62) ? 0 : $res;
} }
elsif ( $res == 62 )
# ---------------------------------------------------- {
# Check if it was an expected crash # Testcase itself tell us to skip this one
# ---------------------------------------------------- $tinfo->{skip_detected_by_test}= 1;
my $check_crash = check_expected_crash_and_restart($proc); # Try to get reason from test log file
if ($check_crash == 0) # unexpected exit/crash of $proc find_testcase_skipped_reason($tinfo);
mtr_report_test_skipped($tinfo);
# Restart if skipped due to missing perl, it may have had side effects
if ( $tinfo->{'comment'} =~ /^perl not found/ )
{
stop_all_servers($opt_shutdown_timeout);
}
}
elsif ( $res == 65 )
{
# Testprogram killed by signal
$tinfo->{comment}=
"testprogram crashed(returned code $res)";
report_failure_and_restart($tinfo);
}
elsif ( $res == 1 )
{ {
$expected_exit = 0; # Check if the test tool requests that
last; # an analyze script should be run
my $analyze= find_analyze_request();
if ($analyze){
run_on_all($tinfo, "analyze-$analyze");
}
# Wait a bit and see if a server died, if so report that instead
mtr_milli_sleep(100);
my $srvproc= My::SafeProcess::check_any();
if ($srvproc && grep($srvproc eq $_, started(all_servers()))) {
$proc= $srvproc;
goto SRVDIED;
}
# Test case failure reported by mysqltest
report_failure_and_restart($tinfo);
} }
elsif ($check_crash == 1) # $proc was started again by check_expected_crash_and_restart() else
{ {
delete $keep_waiting_proc{$proc}; # mysqltest failed, probably crashed
$tinfo->{comment}=
"mysqltest failed with unexpected return code $res\n";
report_failure_and_restart($tinfo);
} }
elsif ($check_crash == 2) # we must keep waiting
# Save info from this testcase run to mysqltest.log
if( -f $path_current_testlog)
{ {
# do nothing if ($opt_resfile && $res && $res != 62) {
resfile_output_file($path_current_testlog);
}
mtr_appendfile_to_file($path_current_testlog, $path_testlog);
unlink($path_current_testlog);
} }
return ($res == 62) ? 0 : $res;
} }
if ($expected_exit) { # ----------------------------------------------------
# Check if it was an expected crash
# ----------------------------------------------------
my $check_crash = check_expected_crash_and_restart($proc);
if ($check_crash)
{
# Keep waiting if it returned 2, if 1 don't wait or stop waiting.
$keep_waiting_proc = 0 if $check_crash == 1;
$keep_waiting_proc = $proc if $check_crash == 2;
next; next;
} }
......
Markdown is supported
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