Method getStatus

src/Databases/DatabaseReplicated.cpp:246–296

}

void DatabaseReplicated::getStatus(ReplicatedStatus & response, const bool with_zk_fields) const
{
    auto component_guard = Coordination::setCurrentComponent("DatabaseReplicated::getStatus");
    auto zookeeper = getZooKeeper();

    response.is_readonly = is_readonly;
    response.is_session_expired = !zookeeper || zookeeper->expired();
    response.max_log_ptr = 0;

    response.replica_name = replica_name;
    response.replica_path = replica_path;
    response.shard_name = shard_name;
    response.zookeeper_path = zookeeper_path;

    response.total_replicas = 0;

    if (!with_zk_fields || response.is_session_expired)
        return;

    try
    {
        std::vector<std::string> paths;

        paths.push_back(zookeeper_path + "/max_log_ptr");
        paths.push_back(fs::path(replica_path) / "log_ptr");

        auto get_result = zookeeper->tryGet(paths);
        chassert(get_result.size() == paths.size());

        const auto & max_log_pointer_str = get_result[0].data;
        if (get_result[0].error == Coordination::Error::ZNONODE)
            throw zkutil::KeeperException(get_result[0].error);

        response.max_log_ptr = max_log_pointer_str.empty() ? 0 : parse<UInt32>(max_log_pointer_str);

        const auto & log_ptr_str = get_result[1].data;
        if (get_result[1].error == Coordination::Error::ZNONODE)
            throw zkutil::KeeperException(get_result[1].error);

        response.log_ptr = log_ptr_str.empty() ? 0 : parse<UInt32>(log_ptr_str);

        paths.clear();

        const Strings all_replicas = zookeeper->getChildren(fs::path(zookeeper_path) / "replicas");
        response.total_replicas = static_cast<UInt32>(all_replicas.size());
    }
    catch (const Coordination::Exception &)
    {
        response.zookeeper_exception = getCurrentExceptionMessage(false);
    }
}

String DatabaseReplicated::getFullReplicaName() const
{