Function writeNestedHashToClient

src/t_nhash.cpp:183–227

}

void writeNestedHashToClient(client *c, robj_roptr o) {
    if (o == nullptr) {
        addReply(c, shared.null[c->resp]);
    } else if (o->type == OBJ_STRING) {
        addReplyBulk(c, o);
    } else if (o->type == OBJ_LIST) {
        unsigned char *zl = (unsigned char*)ptrFromObj(o);
        addReplyArrayLen(c, ziplistLen(zl));
        unsigned char *p = ziplistIndex(zl, ZIPLIST_HEAD);
        while (p != nullptr) {
            unsigned char *str;
            unsigned int len;
            long long lval;
            if (ziplistGet(p, &str, &len, &lval)) {
                char rgT[128];
                if (str == nullptr) {
                    len = ll2string(rgT, 128, lval);
                    str = (unsigned char*)rgT;
                }
                addReplyBulkCBuffer(c, (const char*)str, len);
            }
            p = ziplistNext(zl, p);
        }
    } else {
        serverAssert(o->type == OBJ_NESTEDHASH );
        dict *d = (dict*)ptrFromObj(o);

        if (dictSize(d) > 1)
            addReplyArrayLen(c, dictSize(d));
        
        dictIterator *di = dictGetIterator(d);
        dictEntry *de;
        while ((de = dictNext(di))) {
            robj_roptr oT = (robj*)dictGetVal(de);
            addReplyArrayLen(c, 2);
            addReplyBulkCBuffer(c, (sds)dictGetKey(de), sdslen((sds)dictGetKey(de)));
            if (oT->type == OBJ_STRING) {
                addReplyBulk(c, oT);
            } else {
                writeNestedHashToClient(c, oT);
            }
        }
        dictReleaseIterator(di);
    }
}

inline bool FSimpleJsonEscapeCh(char ch) {
    return (ch == '"' || ch == '\\');