mainscnt/mains-frequency-counter-stm32
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

sink adjusted

Browse Source
This commit is contained in:
Wolfgang Hottgenroth 2021-02-15 12:33:47 +01:00
parent e39d562a4d
commit 0f873713a5
Signed by: wn
GPG Key ID: 6C1E5E531E0D5D7F
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
sink/sink20169.c
View File

@ -275,10 +275,11 @@ int forwardMinuteBuffer(t_forwarderHandle *handle, t_minuteBuffer *buf) {
const char *location = device->location; const char *location = device->location;
for (uint8_t j = 0; j < SECONDS_PER_MINUTE; j++) { for (uint8_t j = 0; j < SECONDS_PER_MINUTE; j++) {
logmsg(LOG_DEBUG, "Time: %lu, Frequency: %u", buf->s.events[j].timestamp, buf->s.events[j].frequency); uint64_t timestamp = buf->s.timestamp + j;
logmsg(LOG_DEBUG, "Time: %lu, Frequency: %u", timestamp, buf->s.frequency[j]);
int frequency_before_point = buf->s.events[j].frequency / 1000; int frequency_before_point = buf->s.frequency[j] / 1000;
int frequency_behind_point = buf->s.events[j].frequency - (frequency_before_point * 1000); int frequency_behind_point = buf->s.frequency[j] - (frequency_before_point * 1000);
char payload[256]; char payload[256];
int res = snprintf(payload, sizeof(payload), int res = snprintf(payload, sizeof(payload),
@ -291,7 +292,7 @@ int forwardMinuteBuffer(t_forwarderHandle *handle, t_minuteBuffer *buf) {
"", "",
handle->influxMeasurement, location, buf->s.deviceId, handle->influxMeasurement, location, buf->s.deviceId,
frequency_before_point, frequency_behind_point, frequency_before_point, frequency_behind_point,
buf->s.events[j].timestamp); timestamp);
if (res > sizeof(payload)) { if (res > sizeof(payload)) {
logmsg(LOG_ERR, "payload buffer to small"); logmsg(LOG_ERR, "payload buffer to small");
return -1; return -1;