File tree Expand file tree Collapse file tree 1 file changed +15
-0
lines changed
src/main/scala/io/iohk/ethereum/blockchain/sync Expand file tree Collapse file tree 1 file changed +15
-0
lines changed Original file line number Diff line number Diff line change @@ -396,6 +396,8 @@ class SyncStateSchedulerActor(
396
396
(newState, newStats)
397
397
}
398
398
399
+ reportStats(syncInitiator, newStats1, newState1)
400
+
399
401
context.become(
400
402
syncing(
401
403
newState1,
@@ -461,6 +463,19 @@ object SyncStateSchedulerActor {
461
463
case object SyncKey
462
464
case object Sync
463
465
466
+ private def reportStats (
467
+ to : ActorRef ,
468
+ currentStats : ProcessingStatistics ,
469
+ currentState : SyncStateScheduler .SchedulerState
470
+ ): Unit = {
471
+ to ! StateSyncStats (
472
+ currentStats.saved + currentState.memBatch.size,
473
+ currentState.numberOfPendingRequests
474
+ )
475
+ }
476
+
477
+ case class StateSyncStats (saved : Long , missing : Long )
478
+
464
479
case class ProcessingResult (result : Either [ProcessingError , ProcessingSuccess ])
465
480
466
481
def props (
You can’t perform that action at this time.
0 commit comments