From a62d37bafa4b7194b90b86e37ca166b59e33ed61 Mon Sep 17 00:00:00 2001 From: Sangbum Kim Date: Tue, 12 Sep 2017 21:39:08 +0900 Subject: [PATCH] =?UTF-8?q?=EC=98=A4=ED=83=80=20=EC=88=98=EC=A0=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- consumer/influx_stat.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/consumer/influx_stat.go b/consumer/influx_stat.go index 0e08dba..5b33c85 100644 --- a/consumer/influx_stat.go +++ b/consumer/influx_stat.go @@ -91,13 +91,13 @@ func (m *influxMetric) StartLogging() { case <-ticker: break checker case changedSpeed := <-m.fanSpeedConsumer: - if point, err := m.getFanspeedPoint(changedSpeed); err != nil { + if point, err := m.getFanspeedPoint(changedSpeed); err == nil { pointList = append(pointList, point) } else { influxLogger.Debugf("id %d speed err %s", changedSpeed.Id, err) } case changedTempeture := <-m.tempetureConsumer: - if point, err := m.getTempeturePoint(changedTempeture); err != nil { + if point, err := m.getTempeturePoint(changedTempeture); err == nil { pointList = append(pointList, point) } else { influxLogger.Debugf("id %d tempeture err %s", changedTempeture.Id, err)