aboutsummaryrefslogtreecommitdiffstats
path: root/modules/queue
diff options
context:
space:
mode:
authorLunny Xiao <xiaolunwen@gmail.com>2020-03-16 16:59:21 +0800
committerGitHub <noreply@github.com>2020-03-16 16:59:21 +0800
commitcf7ece6245429f4caae874a35747d0d7345c1015 (patch)
tree74e842834faba9d4b4a6de325004da2c7cfaf4b2 /modules/queue
parent28b934b3ae5d332a66271076a783c1f960b8944f (diff)
downloadgitea-cf7ece6245429f4caae874a35747d0d7345c1015.tar.gz
gitea-cf7ece6245429f4caae874a35747d0d7345c1015.zip
Fix queue log param (#10733)
Diffstat (limited to 'modules/queue')
-rw-r--r--modules/queue/queue_wrapped.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/modules/queue/queue_wrapped.go b/modules/queue/queue_wrapped.go
index ef90d18608..32c01546de 100644
--- a/modules/queue/queue_wrapped.go
+++ b/modules/queue/queue_wrapped.go
@@ -56,7 +56,7 @@ func (q *delayedStarter) setInternal(atShutdown func(context.Context, func()), h
for q.internal == nil {
select {
case <-ctx.Done():
- return fmt.Errorf("Timedout creating queue %v with cfg %s in %s", q.underlying, q.cfg, q.name)
+ return fmt.Errorf("Timedout creating queue %v with cfg %#v in %s", q.underlying, q.cfg, q.name)
default:
queue, err := NewQueue(q.underlying, handle, q.cfg, exemplar)
if err == nil {
@@ -64,11 +64,11 @@ func (q *delayedStarter) setInternal(atShutdown func(context.Context, func()), h
break
}
if err.Error() != "resource temporarily unavailable" {
- log.Warn("[Attempt: %d] Failed to create queue: %v for %s cfg: %s error: %v", i, q.underlying, q.name, q.cfg, err)
+ log.Warn("[Attempt: %d] Failed to create queue: %v for %s cfg: %#v error: %v", i, q.underlying, q.name, q.cfg, err)
}
i++
if q.maxAttempts > 0 && i > q.maxAttempts {
- return fmt.Errorf("Unable to create queue %v for %s with cfg %s by max attempts: error: %v", q.underlying, q.name, q.cfg, err)
+ return fmt.Errorf("Unable to create queue %v for %s with cfg %#v by max attempts: error: %v", q.underlying, q.name, q.cfg, err)
}
sleepTime := 100 * time.Millisecond
if q.timeout > 0 && q.maxAttempts > 0 {