redis/node-redis
1
0
Fork 0
mirror of https://github.com/redis/node-redis.git synced 2025-08-06 02:15:48 +03:00
Code Activity

Fix race condition when slots are re-calculated (#2731)

Browse Source
This commit is contained in:
jjsimps
2024-05-16 12:17:32 -05:00
committed by GitHub
parent dbf8f59a47
commit bfa803fa55
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
packages/client/lib/cluster/cluster-slots.ts
View File

@@ -158,13 +158,13 @@ export default class RedisClusterSlots<
} }
async #discover(rootNode?: RedisClusterClientOptions) { async #discover(rootNode?: RedisClusterClientOptions) {
this.#resetSlots();
const addressesInUse = new Set<string>(); const addressesInUse = new Set<string>();
try { try {
const shards = await this.#getShards(rootNode), const shards = await this.#getShards(rootNode),
promises: Array<Promise<unknown>> = [], promises: Array<Promise<unknown>> = [],
eagerConnect = this.#options.minimizeConnections !== true; eagerConnect = this.#options.minimizeConnections !== true;
this.#resetSlots();
for (const { from, to, master, replicas } of shards) { for (const { from, to, master, replicas } of shards) {
const shard: Shard<M, F, S> = { const shard: Shard<M, F, S> = {
master: this.#initiateSlotNode(master, false, eagerConnect, addressesInUse, promises) master: this.#initiateSlotNode(master, false, eagerConnect, addressesInUse, promises)