From f932a31b657001ff5d80b4234dacece9e1ea772a Mon Sep 17 00:00:00 2001 From: Paul Rogers Date: Thu, 18 Apr 2024 16:12:56 -0400 Subject: [PATCH] Add setReader() function --- clients/pkg/promtail/targets/file/filetarget.go | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/clients/pkg/promtail/targets/file/filetarget.go b/clients/pkg/promtail/targets/file/filetarget.go index eca4883003c1..0ade51902b49 100644 --- a/clients/pkg/promtail/targets/file/filetarget.go +++ b/clients/pkg/promtail/targets/file/filetarget.go @@ -405,9 +405,7 @@ func (t *FileTarget) startTailing(ps []string) { } reader = tailer } - t.readersMutex.Lock() - t.readers[p] = reader - t.readersMutex.Unlock() + t.setReader(p, reader) } } @@ -452,6 +450,12 @@ func (t *FileTarget) getReader(val string) (Reader, bool) { return reader, ok } +func (t *FileTarget) setReader(val string, reader Reader) { + t.readersMutex.Lock() + defer t.readersMutex.Unlock() + t.readers[val] = reader +} + func (t *FileTarget) getWatch(val string) (struct{}, bool) { t.watchesMutex.Lock() defer t.watchesMutex.Unlock()