Skip to content

Commit 25eccdb

Browse files
committed
don't hit disconnected servers when crawling endpoints
1 parent de30e25 commit 25eccdb

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

tests/NRedisStack.Tests/AbstractNRedisStackTest.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ protected IDatabase GetCleanDatabase(string endpointId = EndpointsFixture.Env.St
5252
{
5353
var server = redis.GetServer(endPoint);
5454

55-
if (server.IsReplica) continue;
55+
if (server.IsReplica || !server.IsConnected) continue;
5656

5757
server.Execute("FLUSHALL");
5858
}

tests/NRedisStack.Tests/Search/SearchTests.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1514,7 +1514,7 @@ private int DatabaseSize(IDatabase db, out int replicaCount)
15141514
var count = 0L;
15151515
foreach (var server in db.Multiplexer.GetServers())
15161516
{
1517-
if (server.IsReplica)
1517+
if (server.IsReplica || !server.IsConnected)
15181518
{
15191519
replicaCount++;
15201520
}
@@ -1532,7 +1532,7 @@ private async Task<int> DatabaseSizeAsync(IDatabase db)
15321532
var count = 0L;
15331533
foreach (var server in db.Multiplexer.GetServers())
15341534
{
1535-
if (!server.IsReplica)
1535+
if (!server.IsReplica && server.IsConnected)
15361536
{
15371537
count += await server.DatabaseSizeAsync();
15381538
}

0 commit comments

Comments
 (0)