update

Thearas · Thearas · commit 0034d76191ab · 2024-11-15T16:59:47.000+08:00
Change-Id: I0892c785642cdc8708feacb72508b1cc030df031
diff --git a/src/db.go b/src/db.go
@@ -482,13 +482,16 @@ func getDBAuditLogs(
 			logScan.onMatch(vals, true)
 		}
 
+		// prepare limit/offset for next retry
+		limit -= i
+		offset += i
+
 		_ = r.Close()
-		if err = r.Err(); err == nil {
+		if err != nil {
+			continue
+		} else if err = r.Err(); err == nil {
 			break
 		}
-
-		// increase offset for next retry
-		offset += i
 	}
 
 	return

Original file line number	Diff line number	Diff line change
`@@ -482,13 +482,16 @@ func getDBAuditLogs(`
`482`	`482`	`logScan.onMatch(vals, true)`
`483`	`483`	`}`
`484`	`484`
	`485`	`+ // prepare limit/offset for next retry`
	`486`	`+ limit -= i`
	`487`	`+ offset += i`
	`488`	`+`
`485`	`489`	`_ = r.Close()`
`486`		`- if err = r.Err(); err == nil {`
	`490`	`+ if err != nil {`
	`491`	`+ continue`
	`492`	`+ } else if err = r.Err(); err == nil {`
`487`	`493`	`break`
`488`	`494`	`}`
`489`		`-`
`490`		`- // increase offset for next retry`
`491`		`- offset += i`
`492`	`495`	`}`
`493`	`496`
`494`	`497`	`return`