infra
/
cpu_ctrl
1
0
Fork 0
Code Releases Activity

오타 수정

This commit is contained in:
Sangbum Kim 2017-09-12 21:39:08 +09:00
parent 8191d0922c
commit a62d37bafa
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
consumer/influx_stat.go
View File

@ -91,13 +91,13 @@ func (m *influxMetric) StartLogging() {
case <-ticker: case <-ticker:
break checker break checker
case changedSpeed := <-m.fanSpeedConsumer: case changedSpeed := <-m.fanSpeedConsumer:
if point, err := m.getFanspeedPoint(changedSpeed); err != nil { if point, err := m.getFanspeedPoint(changedSpeed); err == nil {
pointList = append(pointList, point) pointList = append(pointList, point)
} else { } else {
influxLogger.Debugf("id %d speed err %s", changedSpeed.Id, err) influxLogger.Debugf("id %d speed err %s", changedSpeed.Id, err)
} }
case changedTempeture := <-m.tempetureConsumer: case changedTempeture := <-m.tempetureConsumer:
if point, err := m.getTempeturePoint(changedTempeture); err != nil { if point, err := m.getTempeturePoint(changedTempeture); err == nil {
pointList = append(pointList, point) pointList = append(pointList, point)
} else { } else {
influxLogger.Debugf("id %d tempeture err %s", changedTempeture.Id, err) influxLogger.Debugf("id %d tempeture err %s", changedTempeture.Id, err)