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

better logging

Browse Source
This commit is contained in:
Maxksim Fomenkov
2022-09-22 20:06:47 +03:00
parent 0a90c599a1
commit 1c52b649de
2 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -161,7 +161,7 @@ class QuorumRpcReader(
is JsonRpcException -> err is JsonRpcException -> err
else -> JsonRpcException( else -> JsonRpcException(
JsonRpcResponse.NumberId(key.id), JsonRpcResponse.NumberId(key.id),
JsonRpcError(-32603, "Unhandled internal error: ${err.javaClass}") JsonRpcError(-32603, "Unhandled internal error: ${err.javaClass}: ${err.message}")
) )
} }
quorum.record(cleanErr, null, api) quorum.record(cleanErr, null, api)

1
src/main/kotlin/io/emeraldpay/dshackle/upstream/grpc/GrpcHead.kt
View File

@@ -80,6 +80,7 @@ class GrpcHead(
.setTypeValue(chain.id) .setTypeValue(chain.id)
.build() .build()
return client.subscribeHead(chainRef) return client.subscribeHead(chainRef)
.doOnError { log.error("subscribeHead err: ${it.message}", it) }
// simple retry on failure, if eventually failed then it supposed to resubscribe later from outer method // simple retry on failure, if eventually failed then it supposed to resubscribe later from outer method
.retryWhen(Retry.backoff(4, Duration.ofSeconds(1))) .retryWhen(Retry.backoff(4, Duration.ofSeconds(1)))
.onErrorContinue { err, _ -> .onErrorContinue { err, _ ->