diff options
author | Lunny Xiao <xiaolunwen@gmail.com> | 2020-03-16 16:59:21 +0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-03-16 16:59:21 +0800 |
commit | cf7ece6245429f4caae874a35747d0d7345c1015 (patch) | |
tree | 74e842834faba9d4b4a6de325004da2c7cfaf4b2 /modules/queue | |
parent | 28b934b3ae5d332a66271076a783c1f960b8944f (diff) | |
download | gitea-cf7ece6245429f4caae874a35747d0d7345c1015.tar.gz gitea-cf7ece6245429f4caae874a35747d0d7345c1015.zip |
Fix queue log param (#10733)
Diffstat (limited to 'modules/queue')
-rw-r--r-- | modules/queue/queue_wrapped.go | 6 |
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 { |