로거 이름 변경

체널 종료위치 변경

consumer/influx_stat.go

@@ -9,7 +9,7 @@ import (
 )
 
 var (
-	influxLogger = logger.NewLogger("consumer")
+	influxLogger = logger.NewLogger("influx")
 )
 
 type influxMetric struct {

main.go

@@ -120,9 +120,6 @@ func main() {
 		tempetureChannel = make(chan processor.TempetureInfo)
 		fanspeedChannel  = make(chan processor.FanspeedInfo)
 	)
-	defer close(tempetureChannel)
-	defer close(fanspeedChannel)
-
 	processors = make([]processor.Processor, 0, processorCount)
 	for i := 0; i < processorCount; i++ {
 		if info, err := processor.NewProcessorInfo(handler, i, sampleDuration,
@@ -141,10 +138,15 @@ func main() {
 	fanController := consumer.NewFanControl(processorCount, sampleDuration, handler)
 	metricLogger := consumer.NewInfluxMetric("", processorCount, handler)
 
+
 	handler.IncreaseWait()
 	go FanoutTempeture(tempetureChannel, handler, metricLogger.TempetureConsumer())
+	defer close(tempetureChannel)
+
 	handler.IncreaseWait()
 	go FanoutSpeed(fanspeedChannel, handler, fanController.Consumer(), metricLogger.FanSpeedConsumer())
+	defer close(fanspeedChannel)
+
 	handler.IncreaseWait()
 	go fanController.StartControl()
 	handler.IncreaseWait()