Skip to content

Commit 6f6b07c

Browse files
committed
fix: syncLeases redis wrong scaning
1 parent c10de69 commit 6f6b07c

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

redis/redis-checkpoint.go

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -363,12 +363,14 @@ func (checkpointer *RedisCheckpoint) syncLeases(shardStatus map[string]*par.Shar
363363
}
364364

365365
checkpointer.lastLeaseSync = time.Now()
366-
var cursor uint64
367366

368-
iter := checkpointer.svc.Scan(ctx, cursor, checkpointer.shardPrefix+"*", 1).Iterator()
367+
keys, _, err := checkpointer.svc.Scan(ctx, 0, checkpointer.shardPrefix+"*", 0).Result()
369368

370-
for iter.Next(ctx) {
371-
key := iter.Val()
369+
if err != nil {
370+
return fmt.Errorf("syncLeases Scan Error: %s", err)
371+
}
372+
373+
for _, key := range keys {
372374
j, err := checkpointer.svc.Get(ctx, key).Result()
373375

374376
if err != nil { // just logging

0 commit comments

Comments
 (0)