Commit 944dbb5f authored by Oleksandr Byelkin's avatar Oleksandr Byelkin Committed by Jan Lindström

postmerge rollbacks and fixes

parent d6feda20
...@@ -137,6 +137,8 @@ my $opt_start_dirty; ...@@ -137,6 +137,8 @@ my $opt_start_dirty;
my $opt_start_exit; my $opt_start_exit;
my $start_only; my $start_only;
our @global_suppressions;
END { END {
if ( defined $opt_tmpdir_pid and $opt_tmpdir_pid == $$ ) if ( defined $opt_tmpdir_pid and $opt_tmpdir_pid == $$ )
{ {
...@@ -188,6 +190,8 @@ my @DEFAULT_SUITES= qw( ...@@ -188,6 +190,8 @@ my @DEFAULT_SUITES= qw(
sys_vars- sys_vars-
unit- unit-
vcol- vcol-
wsrep-
galera-
); );
my $opt_suites; my $opt_suites;
...@@ -359,6 +363,7 @@ my $opt_max_test_fail= env_or_val(MTR_MAX_TEST_FAIL => 10); ...@@ -359,6 +363,7 @@ my $opt_max_test_fail= env_or_val(MTR_MAX_TEST_FAIL => 10);
my $opt_core_on_failure= 0; my $opt_core_on_failure= 0;
my $opt_parallel= $ENV{MTR_PARALLEL} || 1; my $opt_parallel= $ENV{MTR_PARALLEL} || 1;
my $opt_port_group_size = $ENV{MTR_PORT_GROUP_SIZE} || 20;
# lock file to stop tests # lock file to stop tests
my $opt_stop_file= $ENV{MTR_STOP_FILE}; my $opt_stop_file= $ENV{MTR_STOP_FILE};
...@@ -1135,6 +1140,7 @@ sub command_line_setup { ...@@ -1135,6 +1140,7 @@ sub command_line_setup {
# Specify ports # Specify ports
'build-thread|mtr-build-thread=i' => \$opt_build_thread, 'build-thread|mtr-build-thread=i' => \$opt_build_thread,
'port-base|mtr-port-base=i' => \$opt_port_base, 'port-base|mtr-port-base=i' => \$opt_port_base,
'port-group-size=s' => \$opt_port_group_size,
# Test case authoring # Test case authoring
'record' => \$opt_record, 'record' => \$opt_record,
...@@ -1830,16 +1836,16 @@ sub set_build_thread_ports($) { ...@@ -1830,16 +1836,16 @@ sub set_build_thread_ports($) {
$ENV{MTR_BUILD_THREAD}= $build_thread; $ENV{MTR_BUILD_THREAD}= $build_thread;
# Calculate baseport # Calculate baseport
$baseport= $build_thread * 20 + 10000; $baseport= $build_thread * $opt_port_group_size + 10000;
if ( $baseport < 5001 or $baseport + 19 >= 32767 ) if ( $baseport < 5001 or $baseport + $opt_port_group_size >= 32767 )
{ {
mtr_error("MTR_BUILD_THREAD number results in a port", mtr_error("MTR_BUILD_THREAD number results in a port",
"outside 5001 - 32767", "outside 5001 - 32767",
"($baseport - $baseport + 19)"); "($baseport - $baseport + $opt_port_group_size)");
} }
mtr_report("Using MTR_BUILD_THREAD $build_thread,", mtr_report("Using MTR_BUILD_THREAD $build_thread,",
"with reserved ports $baseport..".($baseport+19)); "with reserved ports $baseport..".($baseport+($opt_port_group_size-1)));
} }
...@@ -3392,8 +3398,8 @@ sub kill_leftovers ($) { ...@@ -3392,8 +3398,8 @@ sub kill_leftovers ($) {
sub check_ports_free ($) sub check_ports_free ($)
{ {
my $bthread= shift; my $bthread= shift;
my $portbase = $bthread * 10 + 10000; my $portbase = $bthread * $opt_port_group_size + 10000;
for ($portbase..$portbase+9){ for ($portbase..$portbase+($opt_port_group_size-1)){
if (mtr_ping_port($_)){ if (mtr_ping_port($_)){
mtr_report(" - 'localhost:$_' was not free"); mtr_report(" - 'localhost:$_' was not free");
return 0; # One port was not free return 0; # One port was not free
...@@ -4815,6 +4821,7 @@ sub extract_warning_lines ($$) { ...@@ -4815,6 +4821,7 @@ sub extract_warning_lines ($$) {
# Perl code. # Perl code.
my @antipatterns = my @antipatterns =
( (
@global_suppressions,
qr/error .*connecting to master/, qr/error .*connecting to master/,
qr/Plugin 'ndbcluster' will be forced to shutdown/, qr/Plugin 'ndbcluster' will be forced to shutdown/,
qr/InnoDB: Error: in ALTER TABLE `test`.`t[12]`/, qr/InnoDB: Error: in ALTER TABLE `test`.`t[12]`/,
...@@ -6534,6 +6541,8 @@ Options that specify ports ...@@ -6534,6 +6541,8 @@ Options that specify ports
build-thread=# Can be set in environment variable MTR_BUILD_THREAD. build-thread=# Can be set in environment variable MTR_BUILD_THREAD.
Set MTR_BUILD_THREAD="auto" to automatically aquire Set MTR_BUILD_THREAD="auto" to automatically aquire
a build thread id that is unique to current host a build thread id that is unique to current host
port-group-size=N Reserve groups of TCP ports of size N for each MTR thread
Options for test case authoring Options for test case authoring
......
...@@ -18,6 +18,7 @@ ORDER BY VARIABLE_NAME; ...@@ -18,6 +18,7 @@ ORDER BY VARIABLE_NAME;
VARIABLE_NAME VARIABLE_VALUE VARIABLE_NAME VARIABLE_VALUE
WSREP_AUTO_INCREMENT_CONTROL ON WSREP_AUTO_INCREMENT_CONTROL ON
WSREP_CAUSAL_READS ON WSREP_CAUSAL_READS ON
WSREP_CERTIFICATION_RULES strict
WSREP_CERTIFY_NONPK ON WSREP_CERTIFY_NONPK ON
WSREP_CLUSTER_ADDRESS gcomm:// WSREP_CLUSTER_ADDRESS gcomm://
WSREP_CLUSTER_NAME my_wsrep_cluster WSREP_CLUSTER_NAME my_wsrep_cluster
......
...@@ -7768,11 +7768,6 @@ User_var_log_event(const char* buf, uint event_len, ...@@ -7768,11 +7768,6 @@ User_var_log_event(const char* buf, uint event_len,
val_len= uint4korr(buf + UV_VAL_IS_NULL + UV_VAL_TYPE_SIZE + val_len= uint4korr(buf + UV_VAL_IS_NULL + UV_VAL_TYPE_SIZE +
UV_CHARSET_NUMBER_SIZE); UV_CHARSET_NUMBER_SIZE);
if (val + val_len > buf_end)
{
error= true;
goto err;
}
/** /**
We need to check if this is from an old server We need to check if this is from an old server
...@@ -7786,11 +7781,6 @@ User_var_log_event(const char* buf, uint event_len, ...@@ -7786,11 +7781,6 @@ User_var_log_event(const char* buf, uint event_len,
we keep the flags set to UNDEF_F. we keep the flags set to UNDEF_F.
*/ */
uint bytes_read= ((val + val_len) - buf_start); uint bytes_read= ((val + val_len) - buf_start);
if (bytes_read > event_len)
{
error= true;
goto err;
}
if ((data_written - bytes_read) > 0) if ((data_written - bytes_read) > 0)
{ {
flags= (uint) *(buf + UV_VAL_IS_NULL + UV_VAL_TYPE_SIZE + flags= (uint) *(buf + UV_VAL_IS_NULL + UV_VAL_TYPE_SIZE +
......
...@@ -116,6 +116,7 @@ if(NOT MINGW) ...@@ -116,6 +116,7 @@ if(NOT MINGW)
win32/zlib1.rc # If present will override custom build rule below. win32/zlib1.rc # If present will override custom build rule below.
) )
endif() endif()
# parse the full version number from zlib.h and include in ZLIB_FULL_VERSION # parse the full version number from zlib.h and include in ZLIB_FULL_VERSION
file(READ ${CMAKE_CURRENT_SOURCE_DIR}/zlib.h _zlib_h_contents) file(READ ${CMAKE_CURRENT_SOURCE_DIR}/zlib.h _zlib_h_contents)
string(REGEX REPLACE ".*#define[ \t]+ZLIB_VERSION[ \t]+\"([-0-9A-Za-z.]+)\".*" string(REGEX REPLACE ".*#define[ \t]+ZLIB_VERSION[ \t]+\"([-0-9A-Za-z.]+)\".*"
......
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