From 6d2ce82645da00432f6df23926b29cd7ccf335d4 Mon Sep 17 00:00:00 2001 From: Christopher Homberger Date: Fri, 20 Feb 2026 15:22:00 +0100 Subject: [PATCH] fix not all logs are submitted error check --- internal/pkg/report/reporter.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/internal/pkg/report/reporter.go b/internal/pkg/report/reporter.go index b220b8a..102db85 100644 --- a/internal/pkg/report/reporter.go +++ b/internal/pkg/report/reporter.go @@ -296,10 +296,11 @@ func (r *Reporter) ReportLog(noMore bool) error { r.stateMu.Lock() r.logRows = r.logRows[ack-r.logOffset:] + submitted := r.logOffset + len(rows) r.logOffset = ack r.stateMu.Unlock() - if noMore && ack < r.logOffset+len(rows) { + if noMore && ack < submitted { return fmt.Errorf("not all logs are submitted") }