Function parseClientCommandBuffer

src/networking.cpp:2572–2620

}

void parseClientCommandBuffer(client *c) {
    if (!FClientReady(c))
        return;
    
    while(c->qb_pos < sdslen(c->querybuf)) {    
        /* Determine request type when unknown. */
        if (!c->reqtype) {
            if (c->querybuf[c->qb_pos] == '*') {
                c->reqtype = PROTO_REQ_MULTIBULK;
            } else {
                c->reqtype = PROTO_REQ_INLINE;
            }
        }

        size_t cqueriesStart = c->vecqueuedcmd.size();
        if (c->reqtype == PROTO_REQ_INLINE) {
            if (processInlineBuffer(c) != C_OK) break;
        } else if (c->reqtype == PROTO_REQ_MULTIBULK) {
            if (processMultibulkBuffer(c) != C_OK) break;
        } else {
            serverPanic("Unknown request type");
        }
        if (!c->vecqueuedcmd.empty() && (c->vecqueuedcmd.back().argc <= 0 || c->vecqueuedcmd.back().argv == nullptr)) {
            c->vecqueuedcmd.pop_back();
        } else if (!c->vecqueuedcmd.empty()) {
            if (c->flags & CLIENT_MASTER) c->vecqueuedcmd.back().reploff = c->read_reploff - sdslen(c->querybuf) + c->qb_pos;
            serverAssert(c->vecqueuedcmd.back().reploff >= 0);
        }

        /* Prefetch outside the lock for better perf */
        if (g_pserver->prefetch_enabled && (cserver.cthreads > 1 || g_pserver->m_pstorageFactory) && cqueriesStart < c->vecqueuedcmd.size() &&
            (g_pserver->m_pstorageFactory || aeLockContested(cserver.cthreads/2) || cserver.cthreads == 1) && !GlobalLocksAcquired()) {
            auto &query = c->vecqueuedcmd.back();
            if (query.argc > 0 && query.argc == query.argcMax) {
                c->db->prefetchKeysAsync(c, query);
            }
        }
        c->reqtype = 0;
        c->multibulklen = 0;
        c->bulklen = -1;
        c->reqtype = 0;
    }

    /* Trim to pos */
    if (c->qb_pos) {
        sdsrange(c->querybuf,c->qb_pos,-1);
        c->qb_pos = 0;
    }
}

bool FAsyncCommand(parsed_command &cmd)
{