diff --git a/tools/pika_keys_analysis/pika.go b/tools/pika_keys_analysis/pika.go index 47a7cf5eaf..72003a53bc 100644 --- a/tools/pika_keys_analysis/pika.go +++ b/tools/pika_keys_analysis/pika.go @@ -101,6 +101,8 @@ func SolveSingleClient(client *redis.Client, ctx context.Context, wg *sync.WaitG } } }(cursor) + cursor += int64(ScanSize) + start = true keys, _, err := client.Scan(ctx, uint64(cursor), "*", 1).Result() if err != nil { _ = fmt.Errorf("scan error: %s", err) @@ -111,8 +113,6 @@ func SolveSingleClient(client *redis.Client, ctx context.Context, wg *sync.WaitG break } } - cursor += int64(ScanSize) - start = true } fmt.Printf("Current client %s done, waiting for task to finish\n", client) wgClient.Wait()