StakeSquid/dshackle
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Less logs in QuorumRpcReader (#179)

Browse Source
This commit is contained in:
a10zn8
2023-03-21 13:25:07 +03:00
committed by GitHub
parent a3a89ab920
commit 9d81bbae65
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/kotlin/io/emeraldpay/dshackle/quorum/QuorumRpcReader.kt
View File

@@ -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))
}