Function setDeferredAggregateLen

src/networking.cpp:771–802

Populate the length object and try gluing it to the next chunk. */

/* Populate the length object and try gluing it to the next chunk. */
void setDeferredAggregateLen(client *c, void *node, long length, char prefix) {
    serverAssert(length >= 0);

    if (FCorrectThread(c)) {
        /* Abort when *node is NULL: when the client should not accept writes
         * we return NULL in addReplyDeferredLen() */
        if (node == NULL) return;
        char lenstr[128];
        size_t lenstr_len = snprintf(lenstr, sizeof(lenstr), "%c%ld\r\n", prefix, length);
        setDeferredReply(c, node, lenstr, lenstr_len);
    } else {
        char lenstr[128];
        int lenstr_len = snprintf(lenstr, sizeof(lenstr), "%c%ld\r\n", prefix, length);

        size_t idxSplice = (size_t)node;
        serverAssert(idxSplice <= c->replyAsync->used);
        if (c->replyAsync->size < (c->replyAsync->used + lenstr_len))
        {
            int newsize = std::max(c->replyAsync->used + lenstr_len, c->replyAsync->size*2);
            clientReplyBlock *replyNew = (clientReplyBlock*)zmalloc(sizeof(clientReplyBlock) + newsize);
            replyNew->size = zmalloc_usable_size(replyNew) - sizeof(clientReplyBlock);
            replyNew->used = c->replyAsync->used;
            memcpy(replyNew->buf(), c->replyAsync->buf(), c->replyAsync->used);
            zfree(c->replyAsync);
            c->replyAsync = replyNew;
        }
        
        memmove(c->replyAsync->buf() + idxSplice + lenstr_len, c->replyAsync->buf() + idxSplice, c->replyAsync->used - idxSplice);
        memcpy(c->replyAsync->buf() + idxSplice, lenstr, lenstr_len);
        c->replyAsync->used += lenstr_len;
    }
}

void setDeferredArrayLen(client *c, void *node, long length) {
    setDeferredAggregateLen(c,node,length,'*');