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();
}
}