Function initServer

src/server.cpp:3912–4130

}

void initServer(void) {
    signal(SIGHUP, SIG_IGN);
    signal(SIGPIPE, SIG_IGN);
    setupSignalHandlers();
    makeThreadKillable();

    zfree(g_pserver->db);   // initServerConfig created a dummy array, free that now
    g_pserver->db = (redisDb**)zmalloc(sizeof(redisDb*)*cserver.dbnum, MALLOC_LOCAL);

    /* Create the Redis databases, and initialize other internal state. */
    if (g_pserver->m_pstorageFactory == nullptr) {
        for (int j = 0; j < cserver.dbnum; j++) {
            g_pserver->db[j] = new (MALLOC_LOCAL) redisDb();
            g_pserver->db[j]->initialize(j);
        }
    } else {
        // Read FLASH metadata and load the appropriate dbid into each databse index, as each DB index can have different dbid mapped due to the swapdb command.
        g_pserver->metadataDb = g_pserver->m_pstorageFactory->createMetadataDb();
        for (int idb = 0; idb < cserver.dbnum; ++idb)
        {
            int dbid = idb;
            std::string dbid_key = "db-" + std::to_string(idb);
            g_pserver->metadataDb->retrieve(dbid_key.c_str(), dbid_key.length(), [&](const char *, size_t, const void *data, size_t){
                dbid = *(int*)data;
            });

            g_pserver->db[idb] = new (MALLOC_LOCAL) redisDb();
            g_pserver->db[idb]->initialize(dbid);
        }
    }

    for (int i = 0; i < MAX_EVENT_LOOPS; ++i)
    {
        g_pserver->rgthreadvar[i].rgdbSnapshot = (const redisDbPersistentDataSnapshot**)zcalloc(sizeof(redisDbPersistentDataSnapshot*)*cserver.dbnum, MALLOC_LOCAL);
        serverAssert(g_pserver->rgthreadvar[i].rgdbSnapshot != nullptr);
    }
    g_pserver->modulethreadvar.rgdbSnapshot = (const redisDbPersistentDataSnapshot**)zcalloc(sizeof(redisDbPersistentDataSnapshot*)*cserver.dbnum, MALLOC_LOCAL);
    serverAssert(g_pserver->modulethreadvar.rgdbSnapshot != nullptr);

    serverAssert(g_pserver->rgthreadvar[0].rgdbSnapshot != nullptr);

    /* Fixup Master Client Database */
    listIter li;
    listNode *ln;
    listRewind(g_pserver->masters, &li);
    while ((ln = listNext(&li)))
    {
        redisMaster *mi = (redisMaster*)listNodeValue(ln);
        serverAssert(mi->master == nullptr);
        if (mi->cached_master != nullptr)
            selectDb(mi->cached_master, 0);
    }

    g_pserver->aof_state = g_pserver->aof_enabled ? AOF_ON : AOF_OFF;
    g_pserver->hz = g_pserver->config_hz;
    cserver.pid = getpid();
    g_pserver->in_fork_child = CHILD_TYPE_NONE;
    cserver.main_thread_id = pthread_self();