Method asyncCommand

src/server.cpp:5148–5180

}

bool client::asyncCommand(std::function<void(const redisDbPersistentDataSnapshot *, const std::vector<robj_sharedptr> &)> &&mainFn, 
                            std::function<void(const redisDbPersistentDataSnapshot *)> &&postFn) 
{
    serverAssert(FCorrectThread(this));
    if (serverTL->in_eval)
        return false;   // we cannot block clients in EVAL
    const redisDbPersistentDataSnapshot *snapshot = nullptr;
    if (!(this->flags & (CLIENT_MULTI | CLIENT_BLOCKED)))
        snapshot = this->db->createSnapshot(this->mvccCheckpoint, false /* fOptional */);
    if (snapshot == nullptr) {
        return false;
    }
    aeEventLoop *el = serverTL->el;
    blockClient(this, BLOCKED_ASYNC);
    g_pserver->asyncworkqueue->AddWorkFunction([el, this, mainFn, postFn, snapshot] {
        std::vector<robj_sharedptr> args = clientArgs(this);
        aePostFunction(el, [this, mainFn, postFn, snapshot, args] {
            aeReleaseLock();
            std::unique_lock<decltype(this->lock)> lock(this->lock);
            AeLocker locker;
            locker.arm(this);
            unblockClient(this);
            mainFn(snapshot, args);
            locker.disarm();
            lock.unlock();
            if (postFn)
                postFn(snapshot);
            this->db->endSnapshotAsync(snapshot);
            aeAcquireLock();
        });
    });
    return true;
}

/* ====================== Error lookup and execution ===================== */