infra
/
cpu_ctrl
1
0
Fork 0
Code Releases Activity

테스트 코드 돌려놓기

This commit is contained in:
Sangbum Kim 2018-07-10 01:56:24 +09:00
parent 84a1cc5a63
commit 69ab132133
1 changed files with 64 additions and 62 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

126
bootstrap.go
View File

@ -14,6 +14,7 @@ import (
"amuz.es/src/infra/cpu_ctrl/producer"
"amuz.es/src/infra/cpu_ctrl/consumer"
"go.uber.org/zap"
"errors"
)
func finalCloser() {
@ -122,77 +123,78 @@ func initProcessor(handler *handler.Handler) func() {
}
}
//FanoutSpeed := func(sender <-chan producer.FanspeedInfo, receivers ...chan<- producer.FanspeedInfo) {
// defer func() {
// for _, receiver := range receivers {
// close(receiver)
// }
// if err := recover(); err != nil {
// handler.NotifyError(err.(error))
// }
// }()
// for speed := range sender {
// for _, receiver := range receivers {
// select {
// case receiver <- speed:
// default:
// logger.Warn("Some Fanspeed consumer blocked!")
// }
// }
// }
//}
//
//FanoutTempeture := func(sender <-chan producer.TempetureInfo, receivers ...chan<- producer.TempetureInfo) {
// defer func() {
//
// for _, receiver := range receivers {
// close(receiver)
// }
// if err := recover(); err != nil {
// handler.NotifyError(err.(error))
// }
// }()
// for tempeture := range sender {
// for _, receiver := range receivers {
// select {
// case receiver <- tempeture:
// default:
// logger.Warn("Some Tempeture consumer blocked!")
// }
// }
// }
//}
//
//processorCount := producer.GetProcessorCount()
//if processorCount == 0 {
// panic(errors.New("cpu not found!"))
//}
FanoutSpeed := func(sender <-chan producer.FanspeedInfo, receivers ...chan<- producer.FanspeedInfo) {
defer func() {
for _, receiver := range receivers {
close(receiver)
}
if err := recover(); err != nil {
handler.NotifyError(err.(error))
}
}()
for speed := range sender {
for _, receiver := range receivers {
select {
case receiver <- speed:
default:
logger.Warn("Some Fanspeed consumer blocked!")
}
}
}
}
FanoutTempeture := func(sender <-chan producer.TempetureInfo, receivers ...chan<- producer.TempetureInfo) {
defer func() {
for _, receiver := range receivers {
close(receiver)
}
if err := recover(); err != nil {
handler.NotifyError(err.(error))
}
}()
for tempeture := range sender {
for _, receiver := range receivers {
select {
case receiver <- tempeture:
default:
logger.Warn("Some Tempeture consumer blocked!")
}
}
}
}
processorCount := producer.GetProcessorCount()
if processorCount == 0 {
panic(errors.New("cpu not found!"))
}
osMetricInfoChan := producer.NewOsMetric(
handler,
*SampleInterval,
)
//tempetureInfoChan, fanspeedChan := producer.AggregateProcessorChannel(
// handler,
// *SampleInterval, processorCount,
// *P, *I, *D,
// *SetPoint,
//)
simpleLogger := consumer.NewSampleOSLogger(*SampleInterval, handler)
//fanController := consumer.NewFanControl(processorCount, *SampleInterval, handler)
//metricLogger := consumer.NewInfluxMetric((*InfluxHost).String(), processorCount, handler)
tempetureInfoChan, fanspeedChan := producer.AggregateProcessorChannel(
handler,
*SampleInterval, processorCount,
*P, *I, *D,
*SetPoint,
)
//simpleLogger := consumer.NewSampleOSLogger(*SampleInterval, handler)
fanController := consumer.NewFanControl(processorCount, *SampleInterval, handler)
metricLogger := consumer.NewInfluxMetric((*InfluxHost).String(), processorCount, handler)
//handler.IncreaseWait()
//go simpleLogger.StartControl()
handler.IncreaseWait()
go simpleLogger.StartControl()
//handler.IncreaseWait()
//go fanController.StartControl()
//handler.IncreaseWait()
//go metricLogger.StartLogging()
go fanController.StartControl()
handler.IncreaseWait()
go metricLogger.StartLogging()
go FanoutOsMetricInfo(osMetricInfoChan, simpleLogger.Consumer())
//go FanoutOsMetricInfo(osMetricInfoChan, simpleLogger.Consumer())
//go FanoutOsMetricInfo(osMetricInfoChan, simpleLogger.Consumer(), metricLogger.OsMetricConsumer())
//go FanoutTempeture(tempetureInfoChan, metricLogger.TempetureConsumer())
//go FanoutSpeed(fanspeedChan, fanController.Consumer(), metricLogger.FanSpeedConsumer())
go FanoutOsMetricInfo(osMetricInfoChan, metricLogger.OsMetricConsumer())
go FanoutTempeture(tempetureInfoChan, metricLogger.TempetureConsumer())
go FanoutSpeed(fanspeedChan, fanController.Consumer(), metricLogger.FanSpeedConsumer())
return func() {}
}