fix: broken tx retris for cluster clients after #697

Signed-off-by: Rueian <[email protected]>
redis · Dec 24, 2024 · 443734d · 443734d
1 parent fbdca04
commit 443734d
Show file tree

Hide file tree

Showing 2 changed files with 474 additions and 1 deletion.
diff --git a/cluster.go b/cluster.go
@@ -703,7 +703,7 @@ func (c *clusterClient) doresultfn(
 					continue // the transaction has been added to the retries, go to the next cmd.
 				}
 			}
-			if hasInit && mi < i && i < ei && mi >= 0 && ei < len(commands) && isMulti(commands[mi]) {
+			if hasInit && (mi < i && i < ei && mi >= 0 && isMulti(commands[mi]) || i > ei && ei >= 0 && isMulti(commands[ei])) {
 				continue // the current cmd is in the processed transaction and has been added to the retries.
 			}
 			mu.Lock()