Commit 22830296 authored by Bjorn Munch's avatar Bjorn Munch

merge from 5.5-mtr

parents 0bb4f5fb e0678e2c
...@@ -177,8 +177,6 @@ sub collect_test_cases ($$$$) { ...@@ -177,8 +177,6 @@ sub collect_test_cases ($$$$) {
if ( $opt_reorder && !$quick_collect) if ( $opt_reorder && !$quick_collect)
{ {
# Reorder the test cases in an order that will make them faster to run # Reorder the test cases in an order that will make them faster to run
my %sort_criteria;
# Make a mapping of test name to a string that represents how that test # Make a mapping of test name to a string that represents how that test
# should be sorted among the other tests. Put the most important criterion # should be sorted among the other tests. Put the most important criterion
# first, then a sub-criterion, then sub-sub-criterion, etc. # first, then a sub-criterion, then sub-sub-criterion, etc.
...@@ -190,24 +188,31 @@ sub collect_test_cases ($$$$) { ...@@ -190,24 +188,31 @@ sub collect_test_cases ($$$$) {
# Append the criteria for sorting, in order of importance. # Append the criteria for sorting, in order of importance.
# #
push(@criteria, "ndb=" . ($tinfo->{'ndb_test'} ? "A" : "B")); push(@criteria, "ndb=" . ($tinfo->{'ndb_test'} ? "A" : "B"));
push(@criteria, $tinfo->{template_path});
# Group test with equal options together. # Group test with equal options together.
# Ending with "~" makes empty sort later than filled # Ending with "~" makes empty sort later than filled
my $opts= $tinfo->{'master_opt'} ? $tinfo->{'master_opt'} : []; my $opts= $tinfo->{'master_opt'} ? $tinfo->{'master_opt'} : [];
push(@criteria, join("!", sort @{$opts}) . "~"); push(@criteria, join("!", sort @{$opts}) . "~");
# Add slave opts if any
if ($tinfo->{'slave_opt'})
{
push(@criteria, join("!", sort @{$tinfo->{'slave_opt'}}));
}
# This sorts tests with force-restart *before* identical tests
push(@criteria, $tinfo->{force_restart} ? "force-restart" : "no-restart");
$sort_criteria{$tinfo->{name}} = join(" ", @criteria); $tinfo->{criteria}= join(" ", @criteria);
} }
@$cases = sort { @$cases = sort {$a->{criteria} cmp $b->{criteria}; } @$cases;
$sort_criteria{$a->{'name'}} . $a->{'name'} cmp
$sort_criteria{$b->{'name'}} . $b->{'name'}; } @$cases;
# For debugging the sort-order # For debugging the sort-order
# foreach my $tinfo (@$cases) # foreach my $tinfo (@$cases)
# { # {
# print("$sort_criteria{$tinfo->{'name'}} -> \t$tinfo->{'name'}\n"); # my $tname= $tinfo->{name} . ' ' . $tinfo->{combination};
# my $crit= $tinfo->{criteria};
# print("$tname\n\t$crit\n");
# } # }
} }
if (defined $print_testcases){ if (defined $print_testcases){
......
...@@ -704,22 +704,40 @@ sub run_test_server ($$$) { ...@@ -704,22 +704,40 @@ sub run_test_server ($$$) {
next; next;
} }
# Prefer same configuration, or just use next if --noreorder
if (!$opt_reorder or (defined $result and
$result->{template_path} eq $t->{template_path}))
{
#mtr_report("Test uses same config => good match");
# Test uses same config => good match
$next= splice(@$tests, $i, 1);
last;
}
# Second best choice is the first that does not fulfill # Second best choice is the first that does not fulfill
# any of the above conditions # any of the above conditions
if (!defined $second_best){ if (!defined $second_best){
#mtr_report("Setting second_best to $i"); #mtr_report("Setting second_best to $i");
$second_best= $i; $second_best= $i;
} }
# Smart allocation of next test within this thread.
if ($opt_reorder and $opt_parallel > 1 and defined $result)
{
my $wid= $result->{worker};
# Reserved for other thread, try next
next if (defined $t->{reserved} and $t->{reserved} != $wid);
if (! defined $t->{reserved})
{
# Force-restart not relevant when comparing *next* test
$t->{criteria} =~ s/force-restart$/no-restart/;
my $criteria= $t->{criteria};
# Reserve similar tests for this worker, but not too many
my $maxres= (@$tests - $i) / $opt_parallel + 1;
for (my $j= $i+1; $j <= $i + $maxres; $j++)
{
my $tt= $tests->[$j];
last unless defined $tt;
last if $tt->{criteria} ne $criteria;
$tt->{reserved}= $wid;
}
}
}
# At this point we have found next suitable test
$next= splice(@$tests, $i, 1);
last;
} }
# Use second best choice if no other test has been found # Use second best choice if no other test has been found
...@@ -728,10 +746,12 @@ sub run_test_server ($$$) { ...@@ -728,10 +746,12 @@ sub run_test_server ($$$) {
mtr_error("Internal error, second best too large($second_best)") mtr_error("Internal error, second best too large($second_best)")
if $second_best > $#$tests; if $second_best > $#$tests;
$next= splice(@$tests, $second_best, 1); $next= splice(@$tests, $second_best, 1);
delete $next->{reserved};
} }
if ($next) { if ($next) {
#$next->print_test(); # We don't need this any more
delete $next->{criteria};
$next->write_test($sock, 'TESTCASE'); $next->write_test($sock, 'TESTCASE');
$running{$next->key()}= $next; $running{$next->key()}= $next;
$num_ndb_tests++ if ($next->{ndb_test}); $num_ndb_tests++ if ($next->{ndb_test});
...@@ -816,6 +836,11 @@ sub run_worker ($) { ...@@ -816,6 +836,11 @@ sub run_worker ($) {
delete($test->{'comment'}); delete($test->{'comment'});
delete($test->{'logfile'}); delete($test->{'logfile'});
# A sanity check. Should this happen often we need to look at it.
if (defined $test->{reserved} && $test->{reserved} != $thread_num) {
my $tres= $test->{reserved};
mtr_warning("Test reserved for w$tres picked up by w$thread_num");
}
$test->{worker} = $thread_num if $opt_parallel > 1; $test->{worker} = $thread_num if $opt_parallel > 1;
run_testcase($test); run_testcase($test);
...@@ -894,7 +919,7 @@ sub command_line_setup { ...@@ -894,7 +919,7 @@ sub command_line_setup {
'ssl|with-openssl' => \$opt_ssl, 'ssl|with-openssl' => \$opt_ssl,
'skip-ssl' => \$opt_skip_ssl, 'skip-ssl' => \$opt_skip_ssl,
'compress' => \$opt_compress, 'compress' => \$opt_compress,
'vs-config' => \$opt_vs_config, 'vs-config=s' => \$opt_vs_config,
# Max number of parallel threads to use # Max number of parallel threads to use
'parallel=s' => \$opt_parallel, 'parallel=s' => \$opt_parallel,
...@@ -4741,17 +4766,6 @@ sub server_need_restart { ...@@ -4741,17 +4766,6 @@ sub server_need_restart {
} }
} }
# Temporary re-enable the "always restart slave" hack
# this should be removed asap, but will require that each rpl
# testcase cleanup better after itself - ie. stop and reset
# replication
# Use the "#!use-slave-opt" marker to detect that this is a "slave"
# server
if ( $server->option("#!use-slave-opt") ){
mtr_verbose_restart($server, "Always restart slave(s)");
return 1;
}
my $is_mysqld= grep ($server eq $_, mysqlds()); my $is_mysqld= grep ($server eq $_, mysqlds());
if ($is_mysqld) if ($is_mysqld)
{ {
......
--max_binlog_size=4096 --default-storage-engine=MyISAM --max_binlog_size=4096 --default-storage-engine=MyISAM
--force-restart
--binlog-do-db=b42829 --binlog-do-db=b42829
--force-restart
...@@ -13,3 +13,4 @@ n ...@@ -13,3 +13,4 @@ n
24 24
drop table t1; drop table t1;
delete from mysql.user where user="replicate"; delete from mysql.user where user="replicate";
call mtr.force_restart();
...@@ -142,3 +142,4 @@ HEX(word) ...@@ -142,3 +142,4 @@ HEX(word)
SELECT * FROM tmptbl504451f4258$1; SELECT * FROM tmptbl504451f4258$1;
ERROR 42S02: Table 'test.tmptbl504451f4258$1' doesn't exist ERROR 42S02: Table 'test.tmptbl504451f4258$1' doesn't exist
DROP TABLE t5; DROP TABLE t5;
call mtr.force_restart();
...@@ -33,3 +33,4 @@ Slave_IO_Running = No (should be No) ...@@ -33,3 +33,4 @@ Slave_IO_Running = No (should be No)
DROP TABLE t1; DROP TABLE t1;
[on master] [on master]
DROP TABLE t1; DROP TABLE t1;
call mtr.force_restart();
...@@ -31,4 +31,6 @@ drop table t1; ...@@ -31,4 +31,6 @@ drop table t1;
delete from mysql.user where user="replicate"; delete from mysql.user where user="replicate";
sync_slave_with_master; sync_slave_with_master;
call mtr.force_restart();
# End of 4.1 tests # End of 4.1 tests
--replicate-same-server-id --relay-log=slave-relay-bin --replicate-same-server-id --relay-log=slave-relay-bin
--force-restart
...@@ -174,3 +174,5 @@ SELECT * FROM tmptbl504451f4258$1; ...@@ -174,3 +174,5 @@ SELECT * FROM tmptbl504451f4258$1;
connection master; connection master;
DROP TABLE t5; DROP TABLE t5;
sync_slave_with_master; sync_slave_with_master;
call mtr.force_restart();
rm -f $MYSQLTEST_VARDIR/std_data_master_link
ln -s $MYSQLTEST_VARDIR/std_data $MYSQLTEST_VARDIR/std_data_master_link ln -s $MYSQLTEST_VARDIR/std_data $MYSQLTEST_VARDIR/std_data_master_link
rm -f $MYSQLTEST_VARDIR/std_data_slave_link
ln -s $MYSQLTEST_VARDIR/std_data $MYSQLTEST_VARDIR/std_data_slave_link ln -s $MYSQLTEST_VARDIR/std_data $MYSQLTEST_VARDIR/std_data_slave_link
$SEMISYNC_PLUGIN_OPT $SEMISYNC_PLUGIN_OPT
--force-restart
...@@ -68,3 +68,4 @@ DROP TABLE t1; ...@@ -68,3 +68,4 @@ DROP TABLE t1;
--echo [on master] --echo [on master]
connection master; connection master;
DROP TABLE t1; DROP TABLE t1;
call mtr.force_restart();
...@@ -150,3 +150,4 @@ source include/diff_tables.inc; ...@@ -150,3 +150,4 @@ source include/diff_tables.inc;
--echo =====Clean up=======; --echo =====Clean up=======;
connection master; connection master;
drop table t1; drop table t1;
--remove_file $MYSQLD_SLAVE_DATADIR/master.backup
--loose-debug="+d,all_errors_are_temporary_errors" --slave-transaction-retries=2 --loose-debug="+d,all_errors_are_temporary_errors" --slave-transaction-retries=2
--force-restart
--key_buffer_size=2M --small.key_buffer_size=256K --small.key_buffer_size=128K --key_buffer_size=2M --small.key_buffer_size=256K --small.key_buffer_size=128K
--force-restart
--max-binlog-size=4096 --max-binlog-size=4096
--force-restart
...@@ -1062,7 +1062,7 @@ SELECT ( SELECT a UNION SELECT a ) INTO OUTFILE 'union.out.file3' FROM t1; ...@@ -1062,7 +1062,7 @@ SELECT ( SELECT a UNION SELECT a ) INTO OUTFILE 'union.out.file3' FROM t1;
SELECT ( SELECT a UNION SELECT a ) INTO DUMPFILE 'union.out.file4' FROM t1; SELECT ( SELECT a UNION SELECT a ) INTO DUMPFILE 'union.out.file4' FROM t1;
DROP TABLE t1; DROP TABLE t1;
remove_files_wildcard $MYSQLTEST_VARDIR/mysqld.1/data/test union.out.fil*;
--echo # --echo #
--echo # Bug #49734: Crash on EXPLAIN EXTENDED UNION ... ORDER BY --echo # Bug #49734: Crash on EXPLAIN EXTENDED UNION ... ORDER BY
......
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