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

log quorum errors at debug level

Browse Source
This commit is contained in:
a10zn8
2023-08-02 10:24:08 +03:00
parent d10b3fb4b0
commit 4173ac6ee8
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -167,7 +167,7 @@ class QuorumRpcReader(
private fun <T> withErrorResume(api: Upstream, key: JsonRpcRequest): Function<Mono<T>, Mono<T>> { private fun <T> withErrorResume(api: Upstream, key: JsonRpcRequest): Function<Mono<T>, Mono<T>> {
return Function { src -> return Function { src ->
src.onErrorResume { err -> 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 // when the call failed with an error we want to notify the quorum because
// it may use the error message or other details // it may use the error message or other details
// //
@@ -191,10 +191,10 @@ class QuorumRpcReader(
if (q.isFailed()) { if (q.isFailed()) {
val resolvedBy = resolvedBy()?.getId() val resolvedBy = resolvedBy()?.getId()
val err = handleError(q.getError(), key.id, resolvedBy) 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) Mono.error(err)
} else { } 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) noResponse(key.method, q)
} }
} }