From 3c065a67d2701cee02c2f0c1d1e331a77a1f0763 Mon Sep 17 00:00:00 2001 From: ligi Date: Thu, 20 Jan 2022 14:04:46 +0100 Subject: [PATCH] WIP: allow totalDifficulty to be the same --- .../kotlin/io/emeraldpay/dshackle/upstream/AbstractHead.kt | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/AbstractHead.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/AbstractHead.kt index 9f85e7f63..900e6645f 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/AbstractHead.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/AbstractHead.kt @@ -46,7 +46,7 @@ abstract class AbstractHead : Head { it.hash }.filter { block -> val curr = head.get() - curr == null || curr.difficulty < block.difficulty + curr == null || curr.difficulty <= block.difficulty } .doFinally { // close internal stream if upstream is finished, otherwise it gets stuck, @@ -59,7 +59,7 @@ abstract class AbstractHead : Head { .subscribe { block -> notifyBeforeBlock() val prev = head.getAndUpdate { curr -> - if (curr == null || curr.difficulty < block.difficulty) { + if (curr == null || curr.difficulty <= block.difficulty) { block } else { curr