diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/DirectEthereumApi.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/DirectEthereumApi.kt index fe0151ad..b5304472 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/DirectEthereumApi.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/DirectEthereumApi.kt @@ -42,7 +42,7 @@ open class DirectEthereumApi( } return result .doOnError { t -> - log.warn("Upstream error: ${t.message} for ${method}") + log.warn("Upstream error: [${t.message}] for ${method}") } .map { val resp = ResponseJson() diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/grpc/EthereumGrpcTransport.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/grpc/EthereumGrpcTransport.kt index 584eee0e..ac1735e6 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/grpc/EthereumGrpcTransport.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/grpc/EthereumGrpcTransport.kt @@ -124,7 +124,7 @@ class EthereumGrpcTransport( .map(asStatus) .doFinally { mapping.values.forEach { bi -> - bi.onError(RpcException(-32603, "RPC response not received")) + bi.onError(RpcException(-32603, "RPC response not received for ${bi.call.method}")) } } .timeout(Duration.ofSeconds(15))