Function handle_info_response

src/modules/keydb_modstatsd/modmain.cpp:391–434

}

void handle_info_response(struct RedisModuleCtx *ctx, const char *szReply, size_t len, const char *command) {
    
    #define SAFETY_CHECK_POINTER(_p) ((_p) < (szReply + len))

    // Parse the INFO reply string line by line
    const char *pchLineStart = szReply;

    while (SAFETY_CHECK_POINTER(pchLineStart) && *pchLineStart != '\0') {
        // Loop Each Line
        const char *pchColon = pchLineStart;
        while (SAFETY_CHECK_POINTER(pchColon) && *pchColon != ':' && *pchColon != '\r') {
            ++pchColon;
        }
        if (!SAFETY_CHECK_POINTER(pchColon)) {
            RedisModule_Log(ctx, REDISMODULE_LOGLEVEL_WARNING, "Unexpected line termination when parsing response from %s command: \"%s\"", command, pchLineStart);
            break; // BUG
        }
        const char *pchLineEnd = pchColon;
        while (SAFETY_CHECK_POINTER(pchLineEnd) && *pchLineEnd != '\n')
            ++pchLineEnd;
        
        std::string strCheck(pchLineStart, pchColon - pchLineStart);
        if (strCheck.find("errorstat_") != std::string::npos) {
            std::string remainder(pchColon + 1, pchLineEnd - (pchColon + 1));
            handleErrorStatItem(ctx, strCheck, remainder);
        } else if (std::regex_match(strCheck, g_replica_or_db_info_regex)) {
            std::string remainder(pchColon + 1, pchLineEnd - (pchColon + 1));
            handleReplicaOrDbInfoItem(ctx, strCheck, remainder);
        } else {
            auto itr = g_mapInfoFields.find(strCheck);
            if (itr != g_mapInfoFields.end()) {
                // This is an info field we care about
                if (itr->second.szAlternate != nullptr)
                    strCheck = itr->second.szAlternate;
                handleStatItem(ctx, strCheck, itr->second, pchColon+1);
            }
        }

        RedisModule_Log(ctx, REDISMODULE_LOGLEVEL_DEBUG, "INFO response line: \"%s\"", std::string(pchLineStart, pchLineEnd - pchLineStart).c_str());
        pchLineStart = pchLineEnd + 1;    // start of next line, if we're over the loop will catch it
    }

    #undef SAFETY_CHECK_POINTER
}

void handle_cluster_nodes_response(struct RedisModuleCtx *ctx, const char *szReply, size_t len) {
    #define SAFETY_CHECK_POINTER(_p) ((_p) < (szReply + len))