thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-21 23:21:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

zkutil: modified test [#METR-14296].

Browse Source
This commit is contained in:
Alexey Milovidov 2014-12-14 05:23:19 +03:00
parent bdf7b561a6
commit 52304c68e7
1 changed files with 20 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
libs/libzkutil/src/tests/zkutil_test_async.cpp
View File

@ -6,11 +6,27 @@ try
{
zkutil::ZooKeeper zookeeper{"localhost:2181"};
auto future = zookeeper.asyncGetChildren(argc <= 1 ? "/" : argv[1]);
auto res = future.get();
auto nodes = zookeeper.getChildren("/tmp");
for (const auto & child : res)
std::cerr << child << '\n';
std::vector<std::thread> threads;
for (size_t i = 0; i < 4; ++i)
{
threads.emplace_back([&]
{
while (true)
{
std::vector<zkutil::ZooKeeper::GetFuture> futures;
for (auto & node : nodes)
futures.push_back(zookeeper.asyncGet("/tmp/" + node));
for (auto & future : futures)
std::cerr << (future.get().value.empty() ? ',' : '.');
}
});
}
for (auto & thread : threads)
thread.join();
return 0;
}