75 lines
2.2 KiB
C++
75 lines
2.2 KiB
C++
/**
|
|
* @file slave_failover.cpp Check how Maxscale works in case of one slave failure, only one slave is configured
|
|
*
|
|
* - Connect to RWSplit
|
|
* - find which backend slave is used for connection
|
|
* - blocm mariadb on the slave with firewall
|
|
* - wait 60 seconds
|
|
* - check which slave is used for connection now, expecting any other slave
|
|
* - check warning in the error log about broken slave
|
|
* - unblock mariadb backend (restore slave firewall settings)
|
|
* - check if Maxscale still alive
|
|
*/
|
|
|
|
|
|
#include "testconnections.h"
|
|
|
|
int main(int argc, char *argv[])
|
|
{
|
|
TestConnections * Test = new TestConnections(argc, argv);
|
|
Test->set_timeout(20);
|
|
int res = 0;
|
|
|
|
unsigned int current_slave;
|
|
unsigned int old_slave;
|
|
|
|
printf("Connecting to RWSplit %s\n", Test->maxscale_IP);
|
|
if (Test->connect_rwsplit() != 0)
|
|
{
|
|
Test->add_result(1, "Error connection to RWSplit! Exiting\n");
|
|
}
|
|
else
|
|
{
|
|
|
|
Test->tprintf("Checking current slave\n");
|
|
old_slave = Test->find_connected_slave( &res);
|
|
|
|
Test->add_result(res, "no current slave\n");
|
|
|
|
Test->tprintf("Setup firewall to block mysql on old slave (oldslave is node %d)\n", old_slave);
|
|
if ((old_slave < 0) || (old_slave >= Test->repl->N))
|
|
{
|
|
Test->add_result(1, "Active slave is not found\n");
|
|
}
|
|
else
|
|
{
|
|
Test->repl->block_node(old_slave);
|
|
|
|
Test->tprintf("Sleeping 60 seconds to let MaxScale to find new slave\n");
|
|
Test->stop_timeout();
|
|
sleep(60);
|
|
Test->set_timeout(20);
|
|
|
|
current_slave = Test->find_connected_slave(&res);
|
|
if ((current_slave == old_slave) || (current_slave < 0))
|
|
{
|
|
Test->add_result(1, "No failover happened\n");
|
|
}
|
|
|
|
Test->tprintf("Setup firewall back to allow mysql\n");
|
|
Test->repl->unblock_node(old_slave);
|
|
|
|
Test->close_rwsplit();
|
|
|
|
Test->check_maxscale_alive();
|
|
Test->set_timeout(20);
|
|
}
|
|
Test->set_timeout(200);
|
|
Test->repl->start_replication();
|
|
}
|
|
|
|
int rval = Test->global_result;
|
|
delete Test;
|
|
return rval;
|
|
}
|