You've already forked node-redis
mirror of
https://github.com/redis/node-redis.git
synced 2025-08-09 00:22:08 +03:00
update comments
This commit is contained in:
@@ -69,7 +69,7 @@ export default class RedisClusterSlots<M extends RedisModules, S extends RedisSc
|
|||||||
}
|
}
|
||||||
|
|
||||||
async #reset(masters: Array<RedisClusterMasterNode>): Promise<void> {
|
async #reset(masters: Array<RedisClusterMasterNode>): Promise<void> {
|
||||||
// Override this.#slots and add not existing clients to this.#clientByKey
|
// Override this.#slots and add not existing clients to this.#nodeByUrl
|
||||||
const promises: Array<Promise<void>> = [],
|
const promises: Array<Promise<void>> = [],
|
||||||
clientsInUse = new Set<string>();
|
clientsInUse = new Set<string>();
|
||||||
for (const master of masters) {
|
for (const master of masters) {
|
||||||
@@ -88,7 +88,7 @@ export default class RedisClusterSlots<M extends RedisModules, S extends RedisSc
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Remove unused clients from this.#clientBykey using clientsInUse
|
// Remove unused clients from this.#nodeByUrl using clientsInUse
|
||||||
for (const [url, { client }] of this.#nodeByUrl.entries()) {
|
for (const [url, { client }] of this.#nodeByUrl.entries()) {
|
||||||
if (clientsInUse.has(url)) continue;
|
if (clientsInUse.has(url)) continue;
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user