diff --git a/libs/libzkutil/src/tests/zkutil_test_commands.cpp b/libs/libzkutil/src/tests/zkutil_test_commands.cpp index f6029118a77..f4f3a48dbaa 100644 --- a/libs/libzkutil/src/tests/zkutil_test_commands.cpp +++ b/libs/libzkutil/src/tests/zkutil_test_commands.cpp @@ -3,9 +3,6 @@ #include 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");