From 1d947aeb9dedb5ca93eead9e21474bcef0189158 Mon Sep 17 00:00:00 2001 From: Igor Artamonov Date: Sat, 16 May 2020 17:08:40 -0400 Subject: [PATCH] problem: unnecessary logging --- .../kotlin/io/emeraldpay/dshackle/rpc/TrackBitcoinAddress.kt | 2 -- src/main/kotlin/io/emeraldpay/dshackle/upstream/FilteredApis.kt | 1 - .../io/emeraldpay/dshackle/upstream/bitcoin/BitcoinRpcHead.kt | 1 - .../io/emeraldpay/dshackle/upstream/rpcclient/JsonRpcParser.kt | 1 - 4 files changed, 5 deletions(-) diff --git a/src/main/kotlin/io/emeraldpay/dshackle/rpc/TrackBitcoinAddress.kt b/src/main/kotlin/io/emeraldpay/dshackle/rpc/TrackBitcoinAddress.kt index dededb4b..58896632 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/rpc/TrackBitcoinAddress.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/rpc/TrackBitcoinAddress.kt @@ -118,8 +118,6 @@ class TrackBitcoinAddress( override fun subscribe(request: BlockchainOuterClass.BalanceRequest): Flux { val chain = Chain.byId(request.asset.chainValue) - println("up: ${multistreamHolder.getUpstream(chain)}") - println("up cast: ${multistreamHolder.getUpstream(chain)?.cast(BitcoinMultistream::class.java)}") val upstream = multistreamHolder.getUpstream(chain)?.cast(BitcoinMultistream::class.java) ?: return Flux.error(SilentException.UnsupportedBlockchain(request.asset.chainValue)) val addresses = allAddresses(request) ?: return Flux.error(SilentException("Unsupported address")) diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/FilteredApis.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/FilteredApis.kt index 01e1e36a..93845663 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/FilteredApis.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/FilteredApis.kt @@ -97,7 +97,6 @@ class FilteredApis( } override fun request(tries: Int) { - println("requested ${tries}") //TODO check the buffer size before submitting repeat(tries) { control.onNext(true) diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/bitcoin/BitcoinRpcHead.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/bitcoin/BitcoinRpcHead.kt index 3bed608b..bf7830df 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/bitcoin/BitcoinRpcHead.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/bitcoin/BitcoinRpcHead.kt @@ -68,7 +68,6 @@ class BitcoinRpcHead( .timeout(Defaults.timeout, Mono.error(Exception("Block data is not received"))) } .onErrorContinue { err, _ -> - err.printStackTrace() log.debug("RPC error ${err.message}") } refreshSubscription = super.follow(base) diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/rpcclient/JsonRpcParser.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/rpcclient/JsonRpcParser.kt index d7401a1d..6d043ac7 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/rpcclient/JsonRpcParser.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/rpcclient/JsonRpcParser.kt @@ -33,7 +33,6 @@ class JsonRpcParser() { val parser: JsonParser = jsonFactory.createParser(json) parser.nextToken() if (parser.currentToken != JsonToken.START_OBJECT) { - println("token ${parser.currentToken}") return JsonRpcResponse(null, JsonRpcResponse.ResponseError(RpcResponseError.CODE_UPSTREAM_INVALID_RESPONSE, "Invalid JSON")) } var nullResponse: JsonRpcResponse? = null