percona/percona-toolkit
1
0
Fork 0
mirror of https://github.com/percona/percona-toolkit.git synced 2025-09-11 21:51:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

Make sure t/pt-slave-delay/auto_restart.t doesn't break replication on 12347 after restarting 12346; silence some noise from t/lib/MasterSlave.t when it restarts instances (mysqld will print warnings about thread_stack on mysql5.0)

Browse Source
This commit is contained in:
baron
2012-06-05 10:58:59 -04:00
parent 95f7e53feb
commit 4906b52d3b
2 changed files with 26 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
t/lib/MasterSlave.t
View File

@@ -230,13 +230,13 @@ my %port_for = (
); );
foreach my $port ( values %port_for ) { foreach my $port ( values %port_for ) {
if ( -d "/tmp/$port" ) { if ( -d "/tmp/$port" ) {
diag(`$trunk/sandbox/stop-sandbox $port >/dev/null`); diag(`$trunk/sandbox/stop-sandbox $port >/dev/null 2>&1`);
} }
} }
diag(`$trunk/sandbox/start-sandbox master 2900 >/dev/null`); diag(`$trunk/sandbox/start-sandbox master 2900 >/dev/null 2>&1`);
diag(`$trunk/sandbox/start-sandbox slave 2903 2900 >/dev/null`); diag(`$trunk/sandbox/start-sandbox slave 2903 2900 >/dev/null 2>&1`);
diag(`$trunk/sandbox/start-sandbox slave 2901 2900 >/dev/null`); diag(`$trunk/sandbox/start-sandbox slave 2901 2900 >/dev/null 2>&1`);
diag(`$trunk/sandbox/start-sandbox slave 2902 2901 >/dev/null`); diag(`$trunk/sandbox/start-sandbox slave 2902 2901 >/dev/null 2>&1`);
# I discovered something weird while updating this test. Above, you see that # I discovered something weird while updating this test. Above, you see that
# slave2 is started first, then the others. Before, slave2 was started last, # slave2 is started first, then the others. Before, slave2 was started last,
@@ -607,14 +607,14 @@ SKIP: {
$master_dbh->disconnect(); $master_dbh->disconnect();
$slave_dbh->disconnect(); $slave_dbh->disconnect();
diag(`/tmp/12346/stop >/dev/null`); diag(`/tmp/12346/stop >/dev/null 2>&1`);
diag(`/tmp/12345/stop >/dev/null`); diag(`/tmp/12345/stop >/dev/null 2>&1`);
diag(`cp /tmp/12346/my.sandbox.cnf /tmp/12346/orig.cnf`); diag(`cp /tmp/12346/my.sandbox.cnf /tmp/12346/orig.cnf`);
diag(`cp /tmp/12345/my.sandbox.cnf /tmp/12345/orig.cnf`); diag(`cp /tmp/12345/my.sandbox.cnf /tmp/12345/orig.cnf`);
diag(`echo "replicate-ignore-db=foo" >> /tmp/12346/my.sandbox.cnf`); diag(`echo "replicate-ignore-db=foo" >> /tmp/12346/my.sandbox.cnf`);
diag(`echo "binlog-ignore-db=bar" >> /tmp/12345/my.sandbox.cnf`); diag(`echo "binlog-ignore-db=bar" >> /tmp/12345/my.sandbox.cnf`);
diag(`/tmp/12345/start >/dev/null`); diag(`/tmp/12345/start >/dev/null 2>&1`);
diag(`/tmp/12346/start >/dev/null`); diag(`/tmp/12346/start >/dev/null 2>&1`);
$master_dbh = $sb->get_dbh_for('master'); $master_dbh = $sb->get_dbh_for('master');
$slave_dbh = $sb->get_dbh_for('slave1'); $slave_dbh = $sb->get_dbh_for('slave1');
@@ -635,12 +635,12 @@ SKIP: {
"Slave replication filter" "Slave replication filter"
); );
diag(`/tmp/12346/stop >/dev/null`); diag(`/tmp/12346/stop >/dev/null 2>&1`);
diag(`/tmp/12345/stop >/dev/null`); diag(`/tmp/12345/stop >/dev/null 2>&1`);
diag(`mv /tmp/12346/orig.cnf /tmp/12346/my.sandbox.cnf`); diag(`mv /tmp/12346/orig.cnf /tmp/12346/my.sandbox.cnf`);
diag(`mv /tmp/12345/orig.cnf /tmp/12345/my.sandbox.cnf`); diag(`mv /tmp/12345/orig.cnf /tmp/12345/my.sandbox.cnf`);
diag(`/tmp/12345/start >/dev/null`); diag(`/tmp/12345/start >/dev/null 2>&1`);
diag(`/tmp/12346/start >/dev/null`); diag(`/tmp/12346/start >/dev/null 2>&1`);
}; };
is( is(
@@ -702,9 +702,9 @@ is(
# ############################################################################# # #############################################################################
# Done. # Done.
# ############################################################################# # #############################################################################
diag(`$trunk/sandbox/stop-sandbox 2903 2902 2901 2900 >/dev/null`); diag(`$trunk/sandbox/stop-sandbox 2903 2902 2901 2900 >/dev/null 2>&1`);
diag(`/tmp/12346/use -e "set global read_only=1"`); diag(`/tmp/12346/use -e "set global read_only=1"`);
diag(`/tmp/12347/use -e "set global read_only=1"`); diag(`/tmp/12347/use -e "set global read_only=1"`);
diag(`$trunk/sandbox/test-env reset`); diag(`$trunk/sandbox/test-env reset >/dev/null 2>&1`);
ok($sb->ok(), "Sandbox servers") or BAIL_OUT(__FILE__ . " broke the sandbox"); ok($sb->ok(), "Sandbox servers") or BAIL_OUT(__FILE__ . " broke the sandbox");
exit; exit;

14
t/pt-slave-delay/auto_restart.t
View File

@@ -20,7 +20,8 @@ require "$trunk/bin/pt-slave-delay";
my $dp = DSNParser->new(opts => $dsn_opts); my $dp = DSNParser->new(opts => $dsn_opts);
my $sb = Sandbox->new(basedir => '/tmp', DSNParser => $dp); my $sb = Sandbox->new(basedir => '/tmp', DSNParser => $dp);
my $dbh = $sb->get_dbh_for('slave1'); my $master_dbh = $sb->get_dbh_for('master');
my $dbh = $sb->get_dbh_for('slave1');
if ( !$dbh ) { if ( !$dbh ) {
plan skip_all => 'Cannot connect to MySQL slave.'; plan skip_all => 'Cannot connect to MySQL slave.';
@@ -62,7 +63,10 @@ else {
diag(`/tmp/12346/stop >/dev/null`); diag(`/tmp/12346/stop >/dev/null`);
sleep 1; sleep 1;
diag(`/tmp/12346/start >/dev/null`); diag(`/tmp/12346/start >/dev/null`);
diag(`/tmp/12346/use -e "set global read_only=1"`); # Ensure we don't break the sandbox -- instance 12347 will be disconnected
# when its master gets rebooted
diag("Restarting slave on instance 12347 after restarting instance 12346");
diag(`/tmp/12347/use -e "stop slave; start slave"`);
exit; exit;
} }
# Reap the child. # Reap the child.
@@ -87,7 +91,10 @@ else {
foreach my $c ( @cxn ) { foreach my $c ( @cxn ) {
# The parent's connection: # The parent's connection:
# {command => 'Sleep',db => 'mysql',host => 'localhost',id => '5',info => undef,state => '',time => '1',user => 'msandbox'} # {command => 'Sleep',db => 'mysql',host => 'localhost',id => '5',info => undef,state => '',time => '1',user => 'msandbox'}
if ( ($c->{db} || '') eq 'mysql' && ($c->{user} || '') eq 'msandbox' ) { if ( ($c->{db} || '') eq 'mysql' && ($c->{user} || '') eq 'msandbox'
&& ($c->{command} || '') ne 'Binlog Dump' # Don't kill the slave threads from 12347 or others!
) {
diag("Killing connection on slave1: $c->{id} ($c->{command})");
$c_dbh->do("KILL $c->{id}"); $c_dbh->do("KILL $c->{id}");
} }
} }
@@ -99,5 +106,6 @@ waitpid ($pid, 0);
# ############################################################################# # #############################################################################
# Done. # Done.
# ############################################################################# # #############################################################################
$sb->wipe_clean($master_dbh);
ok($sb->ok(), "Sandbox servers") or BAIL_OUT(__FILE__ . " broke the sandbox"); ok($sb->ok(), "Sandbox servers") or BAIL_OUT(__FILE__ . " broke the sandbox");
exit; exit;