diff options
| author | zeripath <art27@cantab.net> | 2022-01-29 20:52:37 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-01-29 20:52:37 +0000 |
| commit | be77ede9542650185a1a52fff487c3969f07a78e (patch) | |
| tree | 0a7a38e12d7b5a7fd477b56489217304c2ec1267 /modules/queue | |
| parent | e19b9653ea138c2ba9a5325e6fcbc696a0e758a3 (diff) | |
| download | gitea-be77ede9542650185a1a52fff487c3969f07a78e.tar.gz gitea-be77ede9542650185a1a52fff487c3969f07a78e.zip | |
Change some logging levels (#18421)
* Change some logging levels
* PlainTextWithBytes - 4xx/5xx this should just be TRACE
* notFoundInternal - the "error" here is too noisy and should be DEBUG
* WorkerPool - Worker pool scaling messages are normal and should be DEBUG
Signed-off-by: Andrew Thornton <art27@cantab.net>
Co-authored-by: wxiaoguang <wxiaoguang@gmail.com>
Diffstat (limited to 'modules/queue')
| -rw-r--r-- | modules/queue/workerpool.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/modules/queue/workerpool.go b/modules/queue/workerpool.go index 3eeebaa1a0..fd56f782d4 100644 --- a/modules/queue/workerpool.go +++ b/modules/queue/workerpool.go @@ -118,7 +118,7 @@ func (p *WorkerPool) zeroBoost() { boost = p.maxNumberOfWorkers - p.numberOfWorkers } if mq != nil { - log.Warn("WorkerPool: %d (for %s) has zero workers - adding %d temporary workers for %s", p.qid, mq.Name, boost, p.boostTimeout) + log.Debug("WorkerPool: %d (for %s) has zero workers - adding %d temporary workers for %s", p.qid, mq.Name, boost, p.boostTimeout) start := time.Now() pid := mq.RegisterWorkers(boost, start, true, start.Add(p.boostTimeout), cancel, false) @@ -126,7 +126,7 @@ func (p *WorkerPool) zeroBoost() { mq.RemoveWorkers(pid) } } else { - log.Warn("WorkerPool: %d has zero workers - adding %d temporary workers for %s", p.qid, p.boostWorkers, p.boostTimeout) + log.Debug("WorkerPool: %d has zero workers - adding %d temporary workers for %s", p.qid, p.boostWorkers, p.boostTimeout) } p.lock.Unlock() p.addWorkers(ctx, cancel, boost) @@ -163,7 +163,7 @@ func (p *WorkerPool) pushBoost(data Data) { boost = p.maxNumberOfWorkers - p.numberOfWorkers } if mq != nil { - log.Warn("WorkerPool: %d (for %s) Channel blocked for %v - adding %d temporary workers for %s, block timeout now %v", p.qid, mq.Name, ourTimeout, boost, p.boostTimeout, p.blockTimeout) + log.Debug("WorkerPool: %d (for %s) Channel blocked for %v - adding %d temporary workers for %s, block timeout now %v", p.qid, mq.Name, ourTimeout, boost, p.boostTimeout, p.blockTimeout) start := time.Now() pid := mq.RegisterWorkers(boost, start, true, start.Add(p.boostTimeout), boostCtxCancel, false) @@ -173,7 +173,7 @@ func (p *WorkerPool) pushBoost(data Data) { boostCtxCancel() }() } else { - log.Warn("WorkerPool: %d Channel blocked for %v - adding %d temporary workers for %s, block timeout now %v", p.qid, ourTimeout, p.boostWorkers, p.boostTimeout, p.blockTimeout) + log.Debug("WorkerPool: %d Channel blocked for %v - adding %d temporary workers for %s, block timeout now %v", p.qid, ourTimeout, p.boostWorkers, p.boostTimeout, p.blockTimeout) } go func() { <-time.After(p.boostTimeout) |