From 9d81bbae65897a4872c708cf6dbc6b46ef95b746 Mon Sep 17 00:00:00 2001
From: a10zn8 <a1.cyb3r@gmail.com>
Date: Tue, 21 Mar 2023 13:25:07 +0300
Subject: [PATCH] Less logs in QuorumRpcReader (#179)

---
 .../io/emeraldpay/dshackle/quorum/QuorumRpcReader.kt      | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/main/kotlin/io/emeraldpay/dshackle/quorum/QuorumRpcReader.kt b/src/main/kotlin/io/emeraldpay/dshackle/quorum/QuorumRpcReader.kt
index 1b1e7c9df..02c027165 100644
--- a/src/main/kotlin/io/emeraldpay/dshackle/quorum/QuorumRpcReader.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/quorum/QuorumRpcReader.kt
@@ -98,10 +98,10 @@ class QuorumRpcReader(
     fun execute(key: JsonRpcRequest, retrySpec: reactor.util.retry.Retry): Function<Flux<Upstream>, Mono<CallQuorum>> {
         val quorumReduce = BiFunction<CallQuorum, Tuple4<ByteArray, Optional<ResponseSigner.Signature>, Upstream, Optional<String>>, CallQuorum> { res, a ->
             if (res.record(a.t1, a.t2.orElse(null), a.t3, a.t4.orElse(null))) {
-                log.debug("Quorum is resolved for method ${key.method}")
+                log.trace("Quorum is resolved for method ${key.method}")
                 apiControl.resolve()
             } else {
-                log.debug("Quorum needs more responses for method ${key.method}")
+                log.trace("Quorum needs more responses for method ${key.method}")
                 // quorum needs more responses, so ask api controller to make another
                 apiControl.request(1)
             }
@@ -113,7 +113,7 @@ class QuorumRpcReader(
                     quorum.isFailed() || quorum.isResolved()
                 }
                 .flatMap { api ->
-                    log.debug("Calling upstream ${api.getId()} with method ${key.method}")
+                    log.trace("Calling upstream ${api.getId()} with method ${key.method}")
                     callApi(api, key)
                 }
                 .retryWhen(retrySpec)
@@ -143,7 +143,7 @@ class QuorumRpcReader(
         return SpannedReader(apiReader, tracer, API_READER, spanParams)
             .read(key)
             .flatMap { response ->
-                log.debug("Received response from upstream ${api.getId()} for method ${key.method}")
+                log.trace("Received response from upstream ${api.getId()} for method ${key.method}")
                 response.requireResult()
                     .transform(withSignatureAndUpstream(api, key, response))
             }