Method pushArray

src/SnapshotPayloadParseState.cpp:244–269

}

void SnapshotPayloadParseState::pushArray(long long size) {
    if (stackParse.empty())
        throw "Bad Protocol: unexpected trailing data";

    if (size == 0) {
        stackParse.back().arraycur++;
        return;
    }
    
    if (stackParse.back().name == ParseStageName::Databases) {
        flushQueuedKeys();
        current_database = stackParse.back().arraycur;
    }

    ParseStage stage;
    stage.name = getNextStage();
    stage.arraylen = size;

    if (stage.name == ParseStageName::Dataset) {
        g_pserver->db[current_database]->expand(stage.arraylen);
    }

    // Note: This affects getNextStage so ensure its after
    stackParse.back().arraycur++;
    stackParse.push_back(stage);
}

void SnapshotPayloadParseState::pushValue(const char *rgch, long long cch) {
    if (stackParse.empty())