c04d6748d3
The slave backend would be closed twice if it would both respond with a different result and be closed due to a hangup before the master responded. Added a test case that reproduced the problem.
70 lines
1.7 KiB
C++
70 lines
1.7 KiB
C++
/**
|
|
* Double-close on bad session command result
|
|
*/
|
|
|
|
#include "testconnections.h"
|
|
|
|
void run_test(TestConnections& test)
|
|
{
|
|
Connection conn = test.maxscales->rwsplit();
|
|
conn.connect();
|
|
|
|
for (int i = 0; i <= 300 && test.global_result == 0; i++)
|
|
{
|
|
if (conn.query("SET @a = 1")
|
|
&& conn.query("USE test")
|
|
&& conn.query("SET SQL_MODE=''")
|
|
&& conn.query("USE test")
|
|
&& conn.query("SELECT @@last_insert_id")
|
|
&& conn.query("SELECT 1")
|
|
&& conn.query("USE test")
|
|
&& conn.query("SELECT 1")
|
|
&& conn.query("SET @a = 123")
|
|
&& conn.query("BEGIN")
|
|
&& conn.query("SELECT @a")
|
|
&& conn.query("COMMIT")
|
|
&& conn.query("SET @a = 321")
|
|
&& conn.query("SELECT @a")
|
|
&& conn.query("SET @a = 456")
|
|
&& conn.query("START TRANSACTION READ ONLY")
|
|
&& conn.query("SELECT @a")
|
|
&& conn.query("COMMIT")
|
|
&& conn.query("PREPARE ps FROM 'SELECT 1'")
|
|
&& conn.query("EXECUTE ps")
|
|
&& conn.query("DEALLOCATE PREPARE ps"))
|
|
{
|
|
conn.reset_connection();
|
|
}
|
|
else
|
|
{
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
int main(int argc, char* argv[])
|
|
{
|
|
TestConnections test(argc, argv);
|
|
|
|
std::vector<std::thread> threads;
|
|
|
|
for (int i = 0; i < 5; i++)
|
|
{
|
|
threads.emplace_back(run_test, std::ref(test));
|
|
}
|
|
|
|
for (int i = 0; i < 5; i++)
|
|
{
|
|
test.repl->stop_node(1 + i % 3);
|
|
test.repl->start_node(1 + i % 3);
|
|
sleep(1);
|
|
}
|
|
|
|
for (auto& a : threads)
|
|
{
|
|
a.join();
|
|
}
|
|
|
|
return test.global_result;
|
|
}
|