Function removeRecursive

programs/keeper-bench/Runner.cpp:1496–1518

}

void removeRecursive(Coordination::ZooKeeper & zookeeper, const std::string & path, bool allow_native)
{
    if (allow_native && zookeeper.isFeatureEnabled(DB::KeeperFeatureFlag::REMOVE_RECURSIVE))
    {
        auto promise = std::make_shared<std::promise<Coordination::Error>>();
        auto future = promise->get_future();
        zookeeper.removeRecursive(path, /*remove_nodes_limit=*/ 100000000,
            [promise](const Coordination::RemoveRecursiveResponse & response)
            {
                promise->set_value(response.error);
            });
        auto error = future.get();
        if (error == Coordination::Error::ZNONODE)
            return;
        if (error != Coordination::Error::ZOK)
            throw zkutil::KeeperException(error, "Failed to recursively remove {}", path);
        return;
    }

    Coordination::Requests batch;
    removeRecursiveManual(zookeeper, path, batch);
    flushMulti(zookeeper, batch);
}

}