diff --git a/client/operation.go b/client/operation.go index 19a9dfb..5d2452e 100644 --- a/client/operation.go +++ b/client/operation.go @@ -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)) } }