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