From 4173ac6ee8718aadf23000a2a41414dbd6218db8 Mon Sep 17 00:00:00 2001 From: a10zn8 Date: Wed, 2 Aug 2023 10:24:08 +0300 Subject: [PATCH] log quorum errors at debug level --- .../kotlin/io/emeraldpay/dshackle/quorum/QuorumRpcReader.kt | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/kotlin/io/emeraldpay/dshackle/quorum/QuorumRpcReader.kt b/src/main/kotlin/io/emeraldpay/dshackle/quorum/QuorumRpcReader.kt index 9b295f8f..1f6fe5aa 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/quorum/QuorumRpcReader.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/quorum/QuorumRpcReader.kt @@ -167,7 +167,7 @@ class QuorumRpcReader( private fun withErrorResume(api: Upstream, key: JsonRpcRequest): Function, Mono> { return Function { src -> src.onErrorResume { err -> - log.error("Error during call upstream ${api.getId()} with method ${key.method}", err) + log.debug("Error during call upstream ${api.getId()} with method ${key.method}", err) // when the call failed with an error we want to notify the quorum because // it may use the error message or other details // @@ -191,10 +191,10 @@ class QuorumRpcReader( if (q.isFailed()) { val resolvedBy = resolvedBy()?.getId() val err = handleError(q.getError(), key.id, resolvedBy) - log.warn("Quorum is failed. Method ${key.method}, message ${err.message}") + log.debug("Quorum is failed. Method ${key.method}, message ${err.message}") Mono.error(err) } else { - log.warn("Did not get any result from upstream. Method [${key.method}] using [$q]") + log.debug("Did not get any result from upstream. Method [${key.method}] using [$q]") noResponse(key.method, q) } }