From 6416c27230bbb3124d4dca793146b9b050ab9315 Mon Sep 17 00:00:00 2001 From: mountain Date: Sat, 25 Nov 2023 21:06:52 +0900 Subject: [PATCH] =?UTF-8?q?=EB=A9=94=ED=8A=B8=EB=A6=AD=20=EB=A1=9C?= =?UTF-8?q?=EA=B7=B8=20=EC=A0=95=EB=A6=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- client/operation.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) 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)) } }