infra
/
cpu_ctrl
1
0
Fork 0
Code Releases Activity

메모리 사용 줄임

This commit is contained in:
Sangbum Kim 2017-09-26 07:59:13 +09:00
parent 6b4fc97216
commit a2d7f5e720
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
consumer/influx_stat.go
View File

@ -86,18 +86,17 @@ func (m *influxMetric) StartLogging() {
panic(err) panic(err)
} }
ticker := time.Tick(time.Second) ticker := time.Tick(time.Second)
metricData := make([]data, m.processorCount) pastMetricData, newMetricData := make([]data, m.processorCount), make([]data, m.processorCount)
for { for {
select { select {
case <-ticker: case <-ticker:
sendData := make([]data, m.processorCount) copy(pastMetricData, newMetricData)
copy(sendData, metricData) go m.sendPoint(influxDbConn, batchPoint, pastMetricData)
m.sendPoint(influxDbConn, batchPoint, sendData)
case changedSpeed := <-m.fanSpeedConsumer: case changedSpeed := <-m.fanSpeedConsumer:
metricData[changedSpeed.Id].FanSpeed = changedSpeed.FanSpeed newMetricData[changedSpeed.Id].FanSpeed = changedSpeed.FanSpeed
case changedTempeture := <-m.tempetureConsumer: case changedTempeture := <-m.tempetureConsumer:
metricData[changedTempeture.Id].Tempeture = changedTempeture.Tempeture newMetricData[changedTempeture.Id].Tempeture = changedTempeture.Tempeture
case <-m.handler.Done(): case <-m.handler.Done():
return return
} }