Commit 26c1eb85 authored by Michael Ott's avatar Michael Ott
Browse files

Use new SensorDataStore::insertBatch() function to improve CollectAgent ingress rate

parent 76aaf386
......@@ -201,11 +201,14 @@ int mqttCallback(SimpleMQTTMessage *msg)
}
cout << endl;
#endif
std::list<DCDB::SensorDataStoreReading> readings;
for (uint64_t i = 0; i < len / sizeof(mqttPayload); i++) {
mySensorDataStore->insert(&sid, payload[i].timestamp, payload[i].value);
DCDB::SensorDataStoreReading r(sid, payload[i].timestamp, payload[i].value);
readings.push_back(r);
mySensorCache.storeSensor(sid, payload[i].timestamp, payload[i].value);
}
mySensorDataStore->insertBatch(readings);
//mySensorCache.dump();
}
#if 1
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment