@@ -1888,24 +1888,25 @@ TEST_F(Sess, pool_ttl)
1888
1888
1889
1889
#endif
1890
1890
1891
- {
1891
+ // Temporary disabled, bug#30532629
1892
1892
1893
+ #if 0
1894
+ {
1893
1895
std::cout << "Not threaded" << std::endl;
1894
1896
1895
1897
settings.set(ClientOption::POOL_QUEUE_TIMEOUT, std::chrono::seconds(100),
1896
- ClientOption::POOL_MAX_IDLE_TIME, std::chrono::seconds (10 ));
1898
+ ClientOption::POOL_MAX_IDLE_TIME, std::chrono::seconds(10));
1897
1899
1898
1900
mysqlx::Client client(settings);
1899
1901
1900
1902
1901
- auto get_sessions = [&client, &max_connections] ()
1903
+ auto get_sessions = [&client, &max_connections]()
1902
1904
{
1903
1905
std::list<mysqlx::Session> sessions;
1904
- for (int i = 0 ; i < max_connections; ++i)
1906
+ for (int i = 0; i < max_connections; ++i)
1905
1907
{
1906
1908
sessions.emplace_back(client);
1907
1909
EXPECT_EQ(1, sessions.back().sql("select 1").execute()
1908
- .fetchOne ()[0 ].get <int >());
1909
1910
}
1910
1911
};
1911
1912
@@ -1917,15 +1918,13 @@ TEST_F(Sess, pool_ttl)
1917
1918
1918
1919
int this_thread_id = sql("SELECT CONNECTION_ID()").fetchOne()[0].get<int>();
1919
1920
1920
- std::list<Row> rows =sql (" show processlist" ).fetchAll ();
1921
+ std::list<Row> rows = sql("show processlist").fetchAll();
1921
1922
1922
1923
for (auto row : rows)
1923
1924
{
1924
1925
auto val = row.get(7);
1925
1926
int thread_id = row.get(0).get<int>();
1926
1927
if (val.isNull() ||
1927
- val.get <string>() != string (" PLUGIN" ) ||
1928
- thread_id == this_thread_id)
1929
1928
continue;
1930
1929
1931
1930
proccess_ids.push_back(thread_id);
@@ -1954,6 +1953,9 @@ TEST_F(Sess, pool_ttl)
1954
1953
client.getSession().sql("set global mysqlx_wait_timeout=28800").execute();
1955
1954
}
1956
1955
1956
+ #endif // 0
1957
+
1958
+
1957
1959
{
1958
1960
settings.set (ClientOption::POOL_MAX_SIZE, 1 );
1959
1961
0 commit comments