fcb78108be
Removed the inserts from the test. They don't make any functional difference and it only slows the whole system down. Also reduced the number of threads doing the change user command. This should reduce the CPU usage of the test.
101 lines
3.3 KiB
C++
101 lines
3.3 KiB
C++
/**
|
|
* @file mxs548_short_session_change_user.cpp MXS-548 regression case ("Maxscale crash")
|
|
* - configure 2 backend servers (one Master, one Slave)
|
|
* - create 'user' with password 'pass2'
|
|
* - create load on Master (3 threads are inserting data into 't1' in the loop)
|
|
* - in 40 parallel threads open connection, execute change_user to 'user', execute change_user to default
|
|
* user, close connection
|
|
* - repeat test first only for RWSplit and second for all maxscales->routers[0]
|
|
* - check logs for lack of "Unable to write to backend 'server2' due to authentication failure" errors
|
|
* - check for lack of crashes in the log
|
|
*/
|
|
|
|
|
|
#include "testconnections.h"
|
|
#include "sql_t1.h"
|
|
|
|
#include <atomic>
|
|
|
|
std::atomic<bool> keep_running {true};
|
|
|
|
void query_thread(TestConnections& test)
|
|
{
|
|
while (keep_running && test.ok())
|
|
{
|
|
std::vector<Connection> conns;
|
|
conns.emplace_back(test.maxscales->rwsplit());
|
|
conns.emplace_back(test.maxscales->readconn_master());
|
|
conns.emplace_back(test.maxscales->readconn_slave());
|
|
|
|
for (auto& conn : conns)
|
|
{
|
|
if (conn.connect())
|
|
{
|
|
test.expect(conn.change_user("user", "pass2"), "Change user to user:pass2 should work");
|
|
test.expect(conn.reset_connection(), "Change user back should work");
|
|
}
|
|
|
|
std::this_thread::sleep_for(std::chrono::milliseconds(10));
|
|
}
|
|
}
|
|
}
|
|
|
|
int main(int argc, char** argv)
|
|
{
|
|
TestConnections test(argc, argv);
|
|
test.set_timeout(20);
|
|
|
|
test.repl->connect();
|
|
test.maxscales->connect_maxscale(0);
|
|
create_t1(test.maxscales->conn_rwsplit[0]);
|
|
test.repl->execute_query_all_nodes("set global max_connections = 2000;");
|
|
test.repl->sync_slaves();
|
|
|
|
test.tprintf("Creating user 'user' ");
|
|
test.try_query(test.maxscales->conn_rwsplit[0], "DROP USER IF EXISTS user@'%%'");
|
|
test.try_query(test.maxscales->conn_rwsplit[0], "CREATE USER user@'%%' IDENTIFIED BY 'pass2'");
|
|
test.try_query(test.maxscales->conn_rwsplit[0], "GRANT SELECT ON test.* TO user@'%%'");
|
|
test.try_query(test.maxscales->conn_rwsplit[0], "DROP TABLE IF EXISTS test.t1");
|
|
test.try_query(test.maxscales->conn_rwsplit[0], "CREATE TABLE test.t1 (x1 int, fl int)");
|
|
test.repl->sync_slaves();
|
|
|
|
std::vector<std::thread> threads;
|
|
test.stop_timeout();
|
|
|
|
for (int i = 0; i < 5; i++)
|
|
{
|
|
threads.emplace_back(query_thread, std::ref(test));
|
|
}
|
|
|
|
const int RUN_TIME = 10;
|
|
test.tprintf("Threads are running %d seconds ", RUN_TIME);
|
|
|
|
sleep(RUN_TIME);
|
|
keep_running = false;
|
|
|
|
test.set_timeout(120);
|
|
test.tprintf("Waiting for all threads to exit");
|
|
|
|
for (auto& a : threads)
|
|
{
|
|
a.join();
|
|
}
|
|
|
|
test.tprintf("Flushing backend hosts");
|
|
test.set_timeout(60);
|
|
test.repl->flush_hosts();
|
|
|
|
test.tprintf("Dropping tables and users");
|
|
test.set_timeout(60);
|
|
test.try_query(test.maxscales->conn_rwsplit[0], "DROP TABLE test.t1;");
|
|
test.try_query(test.maxscales->conn_rwsplit[0], "DROP USER user@'%%'");
|
|
test.maxscales->close_maxscale_connections(0);
|
|
|
|
test.set_timeout(160);
|
|
test.check_maxscale_alive(0);
|
|
test.log_excludes(0, "due to authentication failure");
|
|
test.log_excludes(0, "due to handshake failure");
|
|
|
|
return test.global_result;
|
|
}
|