Function main

src/keydb-diagnostic-tool.cpp:843–971

}

int main(int argc, const char **argv) {
    int i;
    
    storage_init(NULL, 0);

    srandom(time(NULL));
    signal(SIGHUP, SIG_IGN);
    signal(SIGPIPE, SIG_IGN);

    initConfigDefaults();

    i = parseOptions(argc,argv);
    argc -= i;
    argv += i;

    config.latency = (long long*)zmalloc(sizeof(long long)*config.requests, MALLOC_LOCAL);

    if (config.max_threads > 0) {
        int err = 0;
        err |= pthread_mutex_init(&(config.requests_issued_mutex), NULL);
        err |= pthread_mutex_init(&(config.requests_finished_mutex), NULL);
        err |= pthread_mutex_init(&(config.liveclients_mutex), NULL);
        err |= pthread_mutex_init(&(config.is_fetching_slots_mutex), NULL);
        err |= pthread_mutex_init(&(config.is_updating_slots_mutex), NULL);
        err |= pthread_mutex_init(&(config.updating_slots_mutex), NULL);
        err |= pthread_mutex_init(&(config.slots_last_update_mutex), NULL);
        if (err != 0)
        {
            perror("Failed to initialize mutex");
            exit(EXIT_FAILURE);
        }
    }

    const char *set_value = "abcdefghijklmnopqrstuvwxyz";
    int self_threads = 0;
    char command[63];

    initBenchmarkThreads();
    redisContext *ctx = getRedisContext(config.hostip, config.hostport, config.hostsocket);
    double server_cpu_time, last_server_cpu_time = getServerCpuTime(ctx);
    struct rusage self_ru;
    double self_cpu_time, last_self_cpu_time = getSelfCpuTime(&self_ru);
    double server_cpu_load, last_server_cpu_load = 0, self_cpu_load, server_cpu_gain;
    std::deque<double> load_gain_history = {};
    double current_gain_avg, peak_gain_avg = 0;

    redisReply *reply = (redisReply*)redisCommand(ctx, "INFO CPU");
    if (reply->type != REDIS_REPLY_STRING) {
        freeReplyObject(reply);
        printf("Error executing INFO command. Exiting.\r\n");
        return 1;
    }
    unsigned int server_threads;
    if (extractPropertyFromInfo(reply->str, "server_threads", server_threads)) {
        printf("Error reading server threads from INFO command. Exiting.\r\n");
        return 1;
    }
    freeReplyObject(reply);