thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-25 17:12:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixed zkutil_test_commands, updated .gitignore. [#METR-10202]

Browse Source
This commit is contained in:
Michael Kolupaev 2014-06-30 15:48:11 +04:00
parent 2c8c1c4abe
commit 4d22313fb2
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
libs/libzkutil/src/tests/zkutil_test_commands.cpp
View File

@ -3,9 +3,6 @@
#include <unistd.h>
using namespace zkutil;
/** Проверяет, правда ли, что вызовы при просроченной сессии блокируются навсегда.
* Разорвать сессию можно, например, так: `./nozk.sh && sleep 6s && ./yeszk.sh`
*/
void watcher(zhandle_t *zh, int type, int state, const char *path,void *watcherCtx)
{
@ -20,15 +17,14 @@ int main()
std::cout << "create path" << std::endl;
zk.create("/test", "old", zkutil::CreateMode::Persistent);
zkutil::Stat stat;
zkutil::WatchFuture watch;
zkutil::EventPtr watch = new Poco::Event;
std::cout << "get path" << std::endl;
zk.get("/test", &stat, &watch);
zk.get("/test", &stat, watch);
std::cout << "set path" << std::endl;
zk.set("/test", "new");
watch.wait();
WatchEventInfo event_info = watch.get();
std::cout << "watch happened for path: " << event_info.path << " " << event_info.event << std::endl;
watch->wait();
std::cout << "watch happened" << std::endl;
std::cout << "remove path" << std::endl;
zk.remove("/test");