void ProducerTable::set()

in common/producertable.cpp [85:109]


void ProducerTable::set(const string &key, const vector<FieldValueTuple> &values, const string &op, const string &prefix)
{
    if (m_dumpFile.is_open())
    {
        if (!m_firstItem)
            m_dumpFile << "," << endl;
        else
            m_firstItem = false;

        json j;
        string json_key = getKeyName(key);
        j[json_key] = json::object();
        for (const auto &it : values)
            j[json_key][fvField(it)] = fvValue(it);
        j["OP"] = op;
        m_dumpFile << j.dump(4);
    }

    enqueueDbChange(key, JSon::buildJson(values), "S" + op, prefix);
    // Only buffer "set", "bulkset" or "create" operations
    if (!m_buffered || (op != "create" && op != "set" && op != "bulkset" ))
    {
        m_pipe->flush();
    }
}