diff options
Diffstat (limited to 'mysql-test/suite/rpl')
| -rw-r--r-- | mysql-test/suite/rpl/r/rpl_dump_request_retry_warning.result | 22 | ||||
| -rw-r--r-- | mysql-test/suite/rpl/t/rpl_dump_request_retry_warning.test | 34 |
2 files changed, 56 insertions, 0 deletions
diff --git a/mysql-test/suite/rpl/r/rpl_dump_request_retry_warning.result b/mysql-test/suite/rpl/r/rpl_dump_request_retry_warning.result index 3a80d5b5f31..71a8605c26c 100644 --- a/mysql-test/suite/rpl/r/rpl_dump_request_retry_warning.result +++ b/mysql-test/suite/rpl/r/rpl_dump_request_retry_warning.result @@ -19,4 +19,26 @@ a 1 connection master; DROP TABLE t1; +connection slave; +include/stop_slave.inc +connection master; +CREATE TABLE t1(a int); +INSERT INTO t1 VALUES(1); +connection slave; +SET @saved_dbug = @@GLOBAL.debug_dbug; +SET @@global.debug_dbug= 'd,simulate_error_on_packet_read'; +START SLAVE; +SET DEBUG_SYNC= 'now WAIT_FOR parked'; +SET @@GLOBAL.debug_dbug = @saved_dbug; +SET DEBUG_SYNC= 'now SIGNAL continue'; +SET DEBUG_SYNC= 'RESET'; +include/wait_for_slave_io_to_start.inc +include/wait_for_slave_sql_to_start.inc +connection master; +include/sync_slave_sql_with_master.inc +SELECT * FROM t1; +a +1 +connection master; +DROP TABLE t1; include/rpl_end.inc diff --git a/mysql-test/suite/rpl/t/rpl_dump_request_retry_warning.test b/mysql-test/suite/rpl/t/rpl_dump_request_retry_warning.test index d750d44ae71..9537a9016ad 100644 --- a/mysql-test/suite/rpl/t/rpl_dump_request_retry_warning.test +++ b/mysql-test/suite/rpl/t/rpl_dump_request_retry_warning.test @@ -14,6 +14,9 @@ # dump request command execution. # 2 - Start the slave. Observe that slave is able to reconnect post # temporary network write error. +# 3 - Simulate packet read error during dump request command execution. +# 4 - Start the slave. Observe that slave is able to reconnect post +# temporary network read error. # # ==== References ==== # @@ -57,4 +60,35 @@ SELECT * FROM t1; connection master; DROP TABLE t1; +connection slave; +--source include/stop_slave.inc + +connection master; +# Do an insert on master +CREATE TABLE t1(a int); +INSERT INTO t1 VALUES(1); + +# Add a debug point and start the slave so that dump request fails. +connection slave; +SET @saved_dbug = @@GLOBAL.debug_dbug; +SET @@global.debug_dbug= 'd,simulate_error_on_packet_read'; + +START SLAVE; +SET DEBUG_SYNC= 'now WAIT_FOR parked'; +SET @@GLOBAL.debug_dbug = @saved_dbug; +SET DEBUG_SYNC= 'now SIGNAL continue'; +SET DEBUG_SYNC= 'RESET'; + +--source include/wait_for_slave_io_to_start.inc +--source include/wait_for_slave_sql_to_start.inc + +# Sync the slave and verify that slave has caught up with the master. +connection master; +--source include/sync_slave_sql_with_master.inc +SELECT * FROM t1; + +# Cleanup +connection master; +DROP TABLE t1; + --source include/rpl_end.inc |