We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1e07acc commit 4571c91Copy full SHA for 4571c91
redis/src/cluster_async/mod.rs
@@ -1490,7 +1490,7 @@ where
1490
async fn refresh_slots_inner(inner: Arc<InnerCore<C>>, curr_retry: usize) -> RedisResult<()> {
1491
let read_guard = inner.conn_lock.read().await;
1492
let num_of_nodes = read_guard.len();
1493
- const MAX_REQUESTED_NODES: usize = 50;
+ const MAX_REQUESTED_NODES: usize = 10;
1494
let num_of_nodes_to_query = std::cmp::min(num_of_nodes, MAX_REQUESTED_NODES);
1495
let (new_slots, topology_hash) = calculate_topology_from_random_nodes(
1496
&inner,
0 commit comments