hcq/MaxScale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch '2.3' into 2.4

Browse Source
This commit is contained in:
Markus Mäkelä
2020-07-14 10:25:40 +03:00
parent 45589c533c fcb78108be
commit 12dca480ee
1 changed files with 1 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
maxscale-system-test/mxs548_short_session_change_user.cpp
View File

@ -18,23 +18,6 @@
std::atomic<bool> keep_running {true}; std::atomic<bool> keep_running {true};
void query_thread_master(TestConnections& test)
{
auto conn = test.repl->get_connection(0);
std::vector<char> sql;
sql.reserve(1000000);
create_insert_string(&sql[0], 5000, 2);
test.expect(conn.connect(), "Connection should work: %s", conn.error());
while (keep_running && test.ok())
{
test.expect(conn.query(sql.data()), "Query failed: %s", conn.error());
std::this_thread::sleep_for(std::chrono::milliseconds(10));
}
}
void query_thread(TestConnections& test) void query_thread(TestConnections& test)
{ {
while (keep_running && test.ok()) while (keep_running && test.ok())
@ -79,12 +62,7 @@ int main(int argc, char** argv)
std::vector<std::thread> threads; std::vector<std::thread> threads;
test.stop_timeout(); test.stop_timeout();
for (int i = 0; i < 3; i++) for (int i = 0; i < 5; i++)
{
threads.emplace_back(query_thread_master, std::ref(test));
}
for (int i = 0; i < 40; i++)
{ {
threads.emplace_back(query_thread, std::ref(test)); threads.emplace_back(query_thread, std::ref(test));
} }