jeans/Tasmota
jeans/Tasmota
1
0
Fork 0
mirror of https://github.com/arendst/Tasmota.git synced 2025-07-25 19:56:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

Limit number of possible influxdb publish situations

Browse Source 
Limit number of possible influxdb publish situations (#15257)
This commit is contained in:
Theo Arends 2022-04-06 09:45:17 +02:00
parent 500a01db39
commit 721bb4143b
2 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
tasmota/xdrv_02_9_mqtt.ino
View File

@ -791,6 +791,9 @@ void MqttPublishPrefixTopicRulesProcess_P(uint32_t prefix, const char* subtopic)
void MqttPublishTeleSensor(void) { void MqttPublishTeleSensor(void) {
// Publish tele/<device>/SENSOR default ResponseData string with optional retained // Publish tele/<device>/SENSOR default ResponseData string with optional retained
// then process rules // then process rules
#ifdef USE_INFLUXDB
InfluxDbProcess(1); // Use a copy of ResponseData
#endif
MqttPublishPrefixTopicRulesProcess_P(TELE, PSTR(D_RSLT_SENSOR), Settings->flag.mqtt_sensor_retain); // CMND_SENSORRETAIN MqttPublishPrefixTopicRulesProcess_P(TELE, PSTR(D_RSLT_SENSOR), Settings->flag.mqtt_sensor_retain); // CMND_SENSORRETAIN
} }

8
tasmota/xdrv_interface.ino
View File

@ -1093,14 +1093,8 @@ bool XdrvRulesProcess(bool teleperiod, const char* event) {
} }
bool XdrvRulesProcess(bool teleperiod) { bool XdrvRulesProcess(bool teleperiod) {
#ifdef USE_INFLUXDB
if (!teleperiod) { // Only process ad-hoc data here
InfluxDbProcess(1); // Use a copy
}
#endif
bool result = XdrvRulesProcess(teleperiod, ResponseData()); bool result = XdrvRulesProcess(teleperiod, ResponseData());
ResponseClear(); // Free heap space ResponseClear(); // Free heap space
return result; return result;
} }