Skip to content

Commit 639a3a2

Browse files
committed
Merge branch 'i1462' of github.com:ergoplatform/ergo into i1462
2 parents a879d98 + ad57f9a commit 639a3a2

File tree

3 files changed

+5
-20
lines changed

3 files changed

+5
-20
lines changed

src/main/scala/org/ergoplatform/network/ErgoDeliveryTracker.scala

Lines changed: 0 additions & 18 deletions
This file was deleted.

src/main/scala/org/ergoplatform/network/ErgoNodeViewSynchronizer.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ import scorex.core.transaction.Transaction
2323
import scorex.core.utils.NetworkTimeProvider
2424
import scorex.core.validation.MalformedModifierError
2525
import scorex.util.ModifierId
26-
26+
import scorex.core.network.DeliveryTracker
2727
import scala.collection.mutable
2828
import scala.concurrent.ExecutionContext
2929
import scala.concurrent.duration._
@@ -42,7 +42,7 @@ class ErgoNodeViewSynchronizer(networkControllerRef: ActorRef,
4242
settings.scorexSettings.network, timeProvider, Constants.modifierSerializers) {
4343

4444
override protected val deliveryTracker =
45-
new ErgoDeliveryTracker(context.system, deliveryTimeout, maxDeliveryChecks, self, timeProvider)
45+
new DeliveryTracker(context.system, deliveryTimeout, maxDeliveryChecks, self)
4646

4747
private val networkSettings: NetworkSettings = settings.scorexSettings.network
4848

src/main/scala/scorex/core/network/DeliveryTracker.scala

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,9 @@ class DeliveryTracker(system: ActorSystem,
5050
// when our node received a modifier we put it to `received`
5151
protected val received: mutable.Map[ModifierId, ConnectedPeer] = mutable.Map()
5252

53+
/** how many Requested modifiers DeliveryTracker holds */
54+
def requestedSize: Int = requested.size
55+
5356
/**
5457
* @return status of modifier `id`.
5558
* Since this class do not keep statuses for modifiers that are already in NodeViewHolder,

0 commit comments

Comments
 (0)