Merge "Marks mysql slave read-only"

This commit is contained in:
Jenkins 2014-09-11 09:50:52 +00:00 committed by Gerrit Code Review
commit 43801e85da
2 changed files with 18 additions and 0 deletions

View File

@ -39,6 +39,7 @@ SLAVE_CONFIG = """
[mysqld]
log_bin = /var/lib/mysql/mysql-bin.log
relay_log = /var/lib/mysql/mysql-relay-bin.log
read_only = true
"""
REPL_BACKUP_NAMESPACE = 'trove.guestagent.strategies.backup.mysql_impl'

View File

@ -116,6 +116,13 @@ class VerifySlave(object):
poll_until(slave_is_running())
@test(depends_on=[test_correctly_started_replication])
def test_slave_is_read_only(self):
cmd = "mysql -BNq -e \\\'select @@read_only\\\'"
server = create_server_connection(slave_instance.id)
stdout, stderr = server.execute(cmd)
assert_equal(stdout, "1\n")
@test(depends_on=[test_slave_is_read_only])
def test_create_db_on_master(self):
databases = [{'name': slave_instance.replicated_db}]
instance_info.dbaas.databases.create(instance_info.id, databases)
@ -174,6 +181,16 @@ class DetachReplica(object):
poll_until(slave_is_running(False))
@test(depends_on=[test_detach_replica])
def test_slave_is_not_read_only(self):
if CONFIG.fake_mode:
raise SkipTest("Test not_read_only not supported in fake mode")
cmd = "mysql -BNq -e \\\'select @@read_only\\\'"
server = create_server_connection(slave_instance.id)
stdout, stderr = server.execute(cmd)
assert_equal(stdout, "0\n")
@test(groups=[GROUP],
depends_on=[WaitForCreateSlaveToFinish],