From ee3c28a7d72e2bcbb0d0c2b925c4b55084606b25 Mon Sep 17 00:00:00 2001 From: Ulric Qin Date: Sat, 23 Jul 2022 20:37:47 +0800 Subject: [PATCH] collect metrics immediately after start-up --- agent/metrics_agent.go | 2 +- agent/metrics_reader.go | 8 ++++---- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/agent/metrics_agent.go b/agent/metrics_agent.go index 6cdf28f..41ea8d0 100644 --- a/agent/metrics_agent.go +++ b/agent/metrics_agent.go @@ -58,7 +58,7 @@ func (a *Agent) startMetricsAgent() error { continue } - a.StartReader(name, input) + a.StartInputReader(name, input) log.Println("I! input:", name, "started") } diff --git a/agent/metrics_reader.go b/agent/metrics_reader.go index c1b39c4..044f835 100644 --- a/agent/metrics_reader.go +++ b/agent/metrics_reader.go @@ -24,7 +24,7 @@ type InputReader struct { quitChan chan struct{} } -func (a *Agent) StartReader(name string, in inputs.Input) { +func (a *Agent) StartInputReader(name string, in inputs.Input) { reader := NewInputReader(name, in) go reader.startInput() a.InputReaders[name] = reader @@ -55,7 +55,6 @@ func (r *InputReader) startInput() { close(r.quitChan) return default: - time.Sleep(interval) var start time.Time if config.Config.DebugMode { start = time.Now() @@ -65,9 +64,10 @@ func (r *InputReader) startInput() { r.gatherOnce() if config.Config.DebugMode { - ms := time.Since(start).Milliseconds() - log.Println("D!", r.inputName, ": after gather once,", "duration:", ms, "ms") + log.Println("D!", r.inputName, ": after gather once,", "duration:", time.Since(start)) } + + time.Sleep(interval) } } }