Function main

utils/zookeeper-cli/zookeeper-cli.cpp:58–223

int main(int argc, char ** argv)
{
    try
    {
        if (argc != 2)
        {
            std::cerr << "usage: " << argv[0] << " hosts" << std::endl;
            return 2;
        }

        Poco::AutoPtr<Poco::ConsoleChannel> channel = new Poco::ConsoleChannel(std::cerr);
        Poco::Logger::root().setChannel(channel);
        Poco::Logger::root().setLevel("trace");

        zkutil::ZooKeeper zk(argv[1]);
        LineReader lr({}, false, {"\\"}, {});

        do
        {
            const auto & line = lr.readLine(":3 ", ":3 ");
            if (line.empty())
                break;

            try
            {
                std::stringstream ss(line);     // STYLE_CHECK_ALLOW_STD_STRING_STREAM

                std::string cmd;
                ss >> cmd;

                if (cmd == "q" || cmd == "quit" || cmd == "exit" || cmd == ":q")
                    break;

                std::string path;
                ss >> path;
                if (cmd == "ls")
                {
                    std::string w;
                    ss >> w;
                    bool watch = w == "w";
                    zkutil::EventPtr event = watch ? std::make_shared<Poco::Event>() : nullptr;
                    std::vector<std::string> v = zk.getChildren(path, nullptr, event);
                    for (const auto & child : v)
                        std::cout << child << std::endl;
                    if (watch)
                        waitForWatch(event);
                }
                else if (cmd == "create")
                {
                    DB::ReadBufferFromString in(line);

                    std::string path_ignored;
                    std::string data;
                    std::string mode;

                    DB::assertString("create", in);
                    DB::skipWhitespaceIfAny(in);
                    readMaybeQuoted(path_ignored, in);