메트릭 로그 정리
This commit is contained in:
@ -236,6 +236,7 @@ func (hc *houstonClient) launch(meta *procmeta) error {
|
||||
metricValues := make(map[string]metricValueAccessor)
|
||||
|
||||
defer func() {
|
||||
logger.Println("stdReader is terminated :", meta.name)
|
||||
if meta.isState(protos.ProcessState_Running) {
|
||||
hc.operationChan <- &protos.OperationQueryResponse{
|
||||
Operation: string(shared.Exception),
|
||||
@ -249,6 +250,7 @@ func (hc *houstonClient) launch(meta *procmeta) error {
|
||||
for {
|
||||
buff, err := reader.ReadBytes('\n')
|
||||
if err != nil {
|
||||
logger.Println("ReadBytes at stdReader return err :", err, meta.name)
|
||||
break
|
||||
}
|
||||
|
||||
@ -260,10 +262,8 @@ func (hc *houstonClient) launch(meta *procmeta) error {
|
||||
}
|
||||
|
||||
if readingMetric {
|
||||
logger.Println("readingMetric is on :", string(buff))
|
||||
if metricBuffer[len(metricBuffer)-2] == metric.METRIC_TAIL_INLINE {
|
||||
readingMetric = false
|
||||
logger.Println("readingMetric is off :", string(buff))
|
||||
|
||||
metricBuffer = metricBuffer[:len(metricBuffer)-2]
|
||||
if metricBuffer[0] == '{' {
|
||||
@ -289,6 +289,8 @@ func (hc *houstonClient) launch(meta *procmeta) error {
|
||||
|
||||
if accessor, ok := metricValues[string(keybytes)]; ok {
|
||||
accessor.set(val)
|
||||
} else {
|
||||
logger.Println("metric set but unregistered :", string(keybytes))
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user