Method endWork

src/rdb.cpp:2866–2895

    size_t ckeys() { return ckeysLoaded; }

    size_t endWork() {
        if (!fLaunched) {
            return ckeysLoaded;
        }
        if (!vecbatch.empty()) {
            queueJobs.enqueue_bulk(vecbatch.data(), vecbatch.size());
            vecbatch.clear();
        }
        std::atomic_thread_fence(std::memory_order_seq_cst);    // The queue must have transferred to the consumer before we call fExit
        serverAssert(fLaunched);
        fExit = true;
        if (g_pserver->m_pstorageFactory) {
            // If we have a storage provider it can take some time to complete and we want to process events in the meantime
            while (!workerThreadDone) {
                usleep(10);
                pauseExecution();
                ProcessWhileBlocked();
                resumeExecution();
            }
        }
        m_thread.join();
        while (cstorageWritesInFlight.load(std::memory_order_seq_cst)) {
            usleep(10);
            ProcessWhileBlocked();
        }
        fLaunched = false;
        fExit = false;
        serverAssert(queueJobs.size_approx() == 0);
        return ckeysLoaded;
    }

    void processJob(rdbInsertJob &job) {
        redisObjectStack keyobj;