From f8edcf576207d8e9aa516d09eab9733a7846886a Mon Sep 17 00:00:00 2001 From: Igor Artamonov Date: Thu, 22 Aug 2019 15:21:10 -0400 Subject: [PATCH] problem: calls gRPC upstream even if it's unavailable --- src/main/kotlin/io/emeraldpay/dshackle/upstream/GrpcUpstream.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/GrpcUpstream.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/GrpcUpstream.kt index 71df82a6..b8859f60 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/GrpcUpstream.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/GrpcUpstream.kt @@ -147,7 +147,7 @@ open class GrpcUpstream( } override fun isAvailable(matcher: Selector.Matcher): Boolean { - return headBlock.get() != null && nodes.get().getNodes().any { + return getStatus() == UpstreamAvailability.OK && headBlock.get() != null && nodes.get().getNodes().any { it.quorum > 0 && matcher.matches(it.labels) } }