MyFavMirrors/minio
1
0
Fork 0
mirror of https://github.com/minio/minio.git synced 2025-11-09 05:34:56 -05:00
Code Issues Packages Projects Releases Wiki Activity

fix: increment counter when entry be skipped (#17237)

Browse Source
This commit is contained in:
jiuker
2023-05-19 23:36:52 +08:00
committed by GitHub
parent e94e6adf91
commit 41fa8fa2d2
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
internal/logger/target/http/http.go
View File

@@ -380,6 +380,8 @@ func (h *Target) Send(ctx context.Context, entry interface{}) error {
default: default:
// Drop messages until we are online. // Drop messages until we are online.
if !h.IsOnline(ctx) { if !h.IsOnline(ctx) {
atomic.AddInt64(&h.totalMessages, 1)
atomic.AddInt64(&h.failedMessages, 1)
return errors.New("log buffer full and remote offline") return errors.New("log buffer full and remote offline")
} }
nWorkers := atomic.LoadInt64(&h.workers) nWorkers := atomic.LoadInt64(&h.workers)