Skip to content

Commit dfe7f6a

Browse files
KonradStaniecKonradStaniec
committed
[ETCM-197] Move all fast sync components to separate package
1 parent 057f84c commit dfe7f6a

24 files changed

+62
-51
lines changed

‎src/it/scala/io/iohk/ethereum/sync/util/FastSyncItSpecUtils.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,8 +3,9 @@ package io.iohk.ethereum.sync.util
33
import akka.util.ByteString
44
import cats.effect.Resource
55
import io.iohk.ethereum.Mocks.MockValidatorsAlwaysSucceed
6-
import io.iohk.ethereum.blockchain.sync.{FastSync, SyncProtocol}
7-
import io.iohk.ethereum.blockchain.sync.FastSync.SyncState
6+
import io.iohk.ethereum.blockchain.sync.SyncProtocol
7+
import io.iohk.ethereum.blockchain.sync.fast.FastSync
8+
import io.iohk.ethereum.blockchain.sync.fast.FastSync.SyncState
89
import io.iohk.ethereum.crypto.kec256
910
import io.iohk.ethereum.domain.Address
1011
import io.iohk.ethereum.mpt.{HashNode, MptNode, MptTraversals}

‎src/main/scala/io/iohk/ethereum/blockchain/sync/SyncController.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package io.iohk.ethereum.blockchain.sync
22

33
import akka.actor.{Actor, ActorLogging, ActorRef, PoisonPill, Props, Scheduler}
4+
import io.iohk.ethereum.blockchain.sync.fast.FastSync
45
import io.iohk.ethereum.blockchain.sync.regular.RegularSync
56
import io.iohk.ethereum.consensus.blocks.CheckpointBlockGenerator
67
import io.iohk.ethereum.consensus.validators.Validators

‎src/main/scala/io/iohk/ethereum/blockchain/sync/DownloaderState.scala renamed to ‎src/main/scala/io/iohk/ethereum/blockchain/sync/fast/DownloaderState.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,18 +1,18 @@
1-
package io.iohk.ethereum.blockchain.sync
1+
package io.iohk.ethereum.blockchain.sync.fast
22

33
import akka.util.ByteString
44
import cats.data.NonEmptyList
5-
import io.iohk.ethereum.blockchain.sync.SyncStateScheduler.SyncResponse
6-
import io.iohk.ethereum.blockchain.sync.SyncStateSchedulerActor.{
5+
import io.iohk.ethereum.blockchain.sync.fast.SyncStateScheduler.SyncResponse
6+
import io.iohk.ethereum.blockchain.sync.fast.SyncStateSchedulerActor.{
77
NoUsefulDataInResponse,
88
PeerRequest,
99
ResponseProcessingResult,
1010
UnrequestedResponse,
1111
UsefulData
1212
}
1313
import io.iohk.ethereum.crypto.kec256
14-
import io.iohk.ethereum.network.{Peer, PeerId}
1514
import io.iohk.ethereum.network.p2p.messages.PV63.NodeData
15+
import io.iohk.ethereum.network.{Peer, PeerId}
1616

1717
import scala.annotation.tailrec
1818

‎src/main/scala/io/iohk/ethereum/blockchain/sync/FastSync.scala renamed to ‎src/main/scala/io/iohk/ethereum/blockchain/sync/fast/FastSync.scala

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,16 @@
1-
package io.iohk.ethereum.blockchain.sync
1+
package io.iohk.ethereum.blockchain.sync.fast
22

33
import java.time.Instant
4+
45
import akka.actor._
56
import akka.util.ByteString
67
import cats.data.NonEmptyList
7-
import io.iohk.ethereum.blockchain.sync.FastSyncReceiptsValidator.ReceiptsValidationResult
88
import io.iohk.ethereum.blockchain.sync.PeerRequestHandler.ResponseReceived
9-
import io.iohk.ethereum.blockchain.sync.SyncBlocksValidator.BlockBodyValidationResult
109
import io.iohk.ethereum.blockchain.sync.SyncProtocol.Status.Progress
11-
import io.iohk.ethereum.blockchain.sync.SyncStateSchedulerActor.{
10+
import io.iohk.ethereum.blockchain.sync._
11+
import io.iohk.ethereum.blockchain.sync.fast.FastSyncReceiptsValidator.ReceiptsValidationResult
12+
import io.iohk.ethereum.blockchain.sync.fast.SyncBlocksValidator.BlockBodyValidationResult
13+
import io.iohk.ethereum.blockchain.sync.fast.SyncStateSchedulerActor.{
1214
RestartRequested,
1315
StartSyncingTo,
1416
StateSyncFinished,
@@ -25,6 +27,7 @@ import io.iohk.ethereum.network.p2p.messages.PV63._
2527
import io.iohk.ethereum.utils.ByteStringUtils
2628
import io.iohk.ethereum.utils.Config.SyncConfig
2729
import org.bouncycastle.util.encoders.Hex
30+
2831
import scala.annotation.tailrec
2932
import scala.concurrent.ExecutionContext.Implicits.global
3033
import scala.concurrent.duration._

‎src/main/scala/io/iohk/ethereum/blockchain/sync/FastSyncMetrics.scala renamed to ‎src/main/scala/io/iohk/ethereum/blockchain/sync/fast/FastSyncMetrics.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,10 @@
1-
package io.iohk.ethereum.blockchain.sync
1+
package io.iohk.ethereum.blockchain.sync.fast
22

33
import java.util.concurrent.atomic.AtomicLong
44

5-
import io.iohk.ethereum.blockchain.sync.FastSync.SyncState
6-
import io.iohk.ethereum.metrics.MetricsContainer
75
import com.google.common.util.concurrent.AtomicDouble
6+
import io.iohk.ethereum.blockchain.sync.fast.FastSync.SyncState
7+
import io.iohk.ethereum.metrics.MetricsContainer
88

99
object FastSyncMetrics extends MetricsContainer {
1010

‎src/main/scala/io/iohk/ethereum/blockchain/sync/FastSyncReceiptsValidator.scala renamed to ‎src/main/scala/io/iohk/ethereum/blockchain/sync/fast/FastSyncReceiptsValidator.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
1-
package io.iohk.ethereum.blockchain.sync
1+
package io.iohk.ethereum.blockchain.sync.fast
22

33
import akka.util.ByteString
44
import io.iohk.ethereum.consensus.validators.Validators
5-
import io.iohk.ethereum.domain.{Blockchain, Receipt}
65
import io.iohk.ethereum.consensus.validators.std.StdBlockValidator.BlockError
6+
import io.iohk.ethereum.domain.{Blockchain, Receipt}
77

88
trait FastSyncReceiptsValidator {
99

‎src/main/scala/io/iohk/ethereum/blockchain/sync/FastSyncStateStorageActor.scala renamed to ‎src/main/scala/io/iohk/ethereum/blockchain/sync/fast/FastSyncStateStorageActor.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
1-
package io.iohk.ethereum.blockchain.sync
1+
package io.iohk.ethereum.blockchain.sync.fast
22

33
import akka.actor.{Actor, ActorLogging}
44
import akka.pattern.pipe
5-
import io.iohk.ethereum.blockchain.sync.FastSync.SyncState
6-
import io.iohk.ethereum.blockchain.sync.FastSyncStateStorageActor.GetStorage
5+
import io.iohk.ethereum.blockchain.sync.fast.FastSync.SyncState
6+
import io.iohk.ethereum.blockchain.sync.fast.FastSyncStateStorageActor.GetStorage
77
import io.iohk.ethereum.db.storage.FastSyncStateStorage
88

99
import scala.concurrent.Future

‎src/main/scala/io/iohk/ethereum/blockchain/sync/LoadableBloomFilter.scala renamed to ‎src/main/scala/io/iohk/ethereum/blockchain/sync/fast/LoadableBloomFilter.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
1-
package io.iohk.ethereum.blockchain.sync
1+
package io.iohk.ethereum.blockchain.sync.fast
22

33
import com.google.common.hash.{BloomFilter, Funnel}
4-
import io.iohk.ethereum.blockchain.sync.LoadableBloomFilter.BloomFilterLoadingResult
4+
import io.iohk.ethereum.blockchain.sync.fast.LoadableBloomFilter.BloomFilterLoadingResult
55
import io.iohk.ethereum.db.dataSource.RocksDbDataSource.IterationError
66
import monix.eval.Task
77
import monix.reactive.{Consumer, Observable}

‎src/main/scala/io/iohk/ethereum/blockchain/sync/PivotBlockSelector.scala renamed to ‎src/main/scala/io/iohk/ethereum/blockchain/sync/fast/PivotBlockSelector.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,8 @@
1-
package io.iohk.ethereum.blockchain.sync
1+
package io.iohk.ethereum.blockchain.sync.fast
22

33
import akka.actor.{Actor, ActorLogging, ActorRef, Cancellable, Props, Scheduler}
44
import akka.util.ByteString
5+
import io.iohk.ethereum.blockchain.sync.{BlacklistSupport, PeerListSupport}
56
import io.iohk.ethereum.domain.BlockHeader
67
import io.iohk.ethereum.network.EtcPeerManagerActor.PeerInfo
78
import io.iohk.ethereum.network.PeerEventBusActor.PeerEvent.MessageFromPeer
@@ -10,6 +11,7 @@ import io.iohk.ethereum.network.PeerEventBusActor.{PeerSelector, Subscribe, Unsu
1011
import io.iohk.ethereum.network.p2p.messages.PV62.{BlockHeaders, GetBlockHeaders}
1112
import io.iohk.ethereum.network.{EtcPeerManagerActor, Peer, PeerId}
1213
import io.iohk.ethereum.utils.Config.SyncConfig
14+
1315
import scala.concurrent.ExecutionContext.Implicits.global
1416
import scala.concurrent.duration.FiniteDuration
1517

‎src/main/scala/io/iohk/ethereum/blockchain/sync/SyncBlocksValidator.scala renamed to ‎src/main/scala/io/iohk/ethereum/blockchain/sync/fast/SyncBlocksValidator.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,10 @@
1-
package io.iohk.ethereum.blockchain.sync
1+
package io.iohk.ethereum.blockchain.sync.fast
22

33
import akka.util.ByteString
44
import io.iohk.ethereum.consensus.validators.Validators
55
import io.iohk.ethereum.consensus.validators.std.StdBlockValidator
6-
import io.iohk.ethereum.domain.{BlockHeader, BlockBody, Blockchain}
76
import io.iohk.ethereum.consensus.validators.std.StdBlockValidator.BlockValid
7+
import io.iohk.ethereum.domain.{BlockBody, BlockHeader, Blockchain}
88

99
trait SyncBlocksValidator {
1010

‎src/main/scala/io/iohk/ethereum/blockchain/sync/SyncSchedulerActorState.scala renamed to ‎src/main/scala/io/iohk/ethereum/blockchain/sync/fast/SyncSchedulerActorState.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,10 @@
1-
package io.iohk.ethereum.blockchain.sync
1+
package io.iohk.ethereum.blockchain.sync.fast
22

33
import akka.actor.ActorRef
44
import akka.util.ByteString
55
import cats.data.NonEmptyList
6-
import io.iohk.ethereum.blockchain.sync.SyncStateScheduler.{ProcessingStatistics, SchedulerState}
7-
import io.iohk.ethereum.blockchain.sync.SyncStateSchedulerActor.{PeerRequest, RequestResult}
6+
import io.iohk.ethereum.blockchain.sync.fast.SyncStateScheduler.{ProcessingStatistics, SchedulerState}
7+
import io.iohk.ethereum.blockchain.sync.fast.SyncStateSchedulerActor.{PeerRequest, RequestResult}
88
import io.iohk.ethereum.network.{Peer, PeerId}
99

1010
import scala.collection.immutable.Queue

‎src/main/scala/io/iohk/ethereum/blockchain/sync/SyncStateScheduler.scala renamed to ‎src/main/scala/io/iohk/ethereum/blockchain/sync/fast/SyncStateScheduler.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,15 @@
1-
package io.iohk.ethereum.blockchain.sync
1+
package io.iohk.ethereum.blockchain.sync.fast
22

33
import java.util.Comparator
44

55
import akka.util.ByteString
66
import com.google.common.hash.{BloomFilter, Funnel, PrimitiveSink}
7-
import io.iohk.ethereum.blockchain.sync.LoadableBloomFilter.BloomFilterLoadingResult
8-
import io.iohk.ethereum.blockchain.sync.SyncStateScheduler._
7+
import io.iohk.ethereum.blockchain.sync.fast.LoadableBloomFilter.BloomFilterLoadingResult
8+
import io.iohk.ethereum.blockchain.sync.fast.SyncStateScheduler._
99
import io.iohk.ethereum.domain.{Account, Blockchain}
1010
import io.iohk.ethereum.mpt.{BranchNode, ExtensionNode, HashNode, LeafNode, MerklePatriciaTrie, MptNode}
11+
import io.iohk.ethereum.network.p2p.messages.PV63.MptNodeEncoders.MptNodeDec
1112
import io.vavr.collection.PriorityQueue
12-
import io.iohk.ethereum.network.p2p.messages.PV63.MptNodeEncoders._
1313
import monix.eval.Task
1414

1515
import scala.annotation.tailrec

‎src/main/scala/io/iohk/ethereum/blockchain/sync/SyncStateSchedulerActor.scala renamed to ‎src/main/scala/io/iohk/ethereum/blockchain/sync/fast/SyncStateSchedulerActor.scala

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,23 +1,25 @@
1-
package io.iohk.ethereum.blockchain.sync
1+
package io.iohk.ethereum.blockchain.sync.fast
22

33
import akka.actor.{Actor, ActorLogging, ActorRef, Props, Timers}
44
import akka.pattern.pipe
55
import akka.util.ByteString
66
import cats.data.NonEmptyList
7-
import io.iohk.ethereum.blockchain.sync.LoadableBloomFilter.BloomFilterLoadingResult
87
import io.iohk.ethereum.blockchain.sync.PeerRequestHandler.ResponseReceived
9-
import io.iohk.ethereum.blockchain.sync.SyncStateScheduler.{
8+
import io.iohk.ethereum.blockchain.sync.fast.LoadableBloomFilter.BloomFilterLoadingResult
9+
import io.iohk.ethereum.blockchain.sync.fast.SyncStateScheduler.{
1010
CriticalError,
1111
ProcessingStatistics,
1212
SchedulerState,
1313
SyncResponse
1414
}
15-
import io.iohk.ethereum.blockchain.sync.SyncStateSchedulerActor._
15+
import io.iohk.ethereum.blockchain.sync.fast.SyncStateSchedulerActor._
16+
import io.iohk.ethereum.blockchain.sync.{BlacklistSupport, PeerListSupport, PeerRequestHandler}
1617
import io.iohk.ethereum.network.Peer
1718
import io.iohk.ethereum.network.p2p.messages.PV63.{GetNodeData, NodeData}
1819
import io.iohk.ethereum.utils.ByteStringUtils
1920
import io.iohk.ethereum.utils.Config.SyncConfig
2021
import monix.execution.Scheduler
22+
2123
import scala.concurrent.Future
2224
import scala.concurrent.duration._
2325

‎src/main/scala/io/iohk/ethereum/db/storage/FastSyncStateStorage.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ import java.nio.ByteBuffer
55
import akka.util.ByteString
66
import boopickle.CompositePickler
77
import boopickle.Default._
8-
import io.iohk.ethereum.blockchain.sync.FastSync._
8+
import io.iohk.ethereum.blockchain.sync.fast.FastSync._
99
import io.iohk.ethereum.db.dataSource.DataSource
1010
import io.iohk.ethereum.utils.ByteUtils.compactPickledBytes
1111

‎src/test/scala/io/iohk/ethereum/blockchain/sync/FastSyncSpec.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@ import io.iohk.ethereum.{FreeSpecBase, ObjectGenerators, SpecFixtures, WithActor
1212
import monix.eval.Task
1313
import monix.reactive.Observable
1414
import io.iohk.ethereum.BlockHelpers
15+
import io.iohk.ethereum.blockchain.sync.fast.FastSync
1516
import io.iohk.ethereum.domain.ChainWeight
1617

1718
import scala.concurrent.duration.DurationInt

‎src/test/scala/io/iohk/ethereum/blockchain/sync/FastSyncStateStorageActorSpec.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,9 @@ import akka.actor.ActorSystem
44
import akka.pattern._
55
import akka.testkit.{TestActorRef, TestKit}
66
import io.iohk.ethereum.{Fixtures, NormalPatience, WithActorSystemShutDown}
7-
import io.iohk.ethereum.blockchain.sync.FastSync.SyncState
8-
import io.iohk.ethereum.blockchain.sync.FastSyncStateStorageActor.GetStorage
7+
import io.iohk.ethereum.blockchain.sync.fast.FastSync.SyncState
8+
import io.iohk.ethereum.blockchain.sync.fast.FastSyncStateStorageActor.GetStorage
9+
import io.iohk.ethereum.blockchain.sync.fast.FastSyncStateStorageActor
910
import io.iohk.ethereum.db.dataSource.EphemDataSource
1011
import io.iohk.ethereum.db.storage.FastSyncStateStorage
1112
import org.scalatest.concurrent.Eventually

‎src/test/scala/io/iohk/ethereum/blockchain/sync/LoadableBloomFilterSpec.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ package io.iohk.ethereum.blockchain.sync
22

33
import com.google.common.hash.{Funnel, Funnels, PrimitiveSink}
44
import io.iohk.ethereum.FlatSpecBase
5+
import io.iohk.ethereum.blockchain.sync.fast.LoadableBloomFilter
56
import io.iohk.ethereum.db.dataSource.RocksDbDataSource.IterationError
67
import monix.eval.Task
78
import monix.reactive.Observable

‎src/test/scala/io/iohk/ethereum/blockchain/sync/PivotBlockSelectorSpec.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ import akka.actor.{ActorRef, ActorSystem}
44
import akka.testkit.{TestKit, TestProbe}
55
import akka.util.ByteString
66
import com.miguno.akka.testing.VirtualTime
7-
import io.iohk.ethereum.blockchain.sync.PivotBlockSelector.{Result, SelectPivotBlock}
7+
import io.iohk.ethereum.blockchain.sync.fast.PivotBlockSelector.{Result, SelectPivotBlock}
88
import io.iohk.ethereum.domain.{BlockHeader, ChainWeight}
99
import io.iohk.ethereum.network.EtcPeerManagerActor.{HandshakedPeers, PeerInfo}
1010
import io.iohk.ethereum.network.PeerEventBusActor.PeerEvent.MessageFromPeer
@@ -18,6 +18,7 @@ import io.iohk.ethereum.utils.Config.SyncConfig
1818
import io.iohk.ethereum.{Fixtures, WithActorSystemShutDown}
1919
import java.net.InetSocketAddress
2020

21+
import io.iohk.ethereum.blockchain.sync.fast.PivotBlockSelector
2122
import org.scalatest.BeforeAndAfter
2223
import org.scalatest.flatspec.AnyFlatSpecLike
2324
import org.scalatest.matchers.should.Matchers

‎src/test/scala/io/iohk/ethereum/blockchain/sync/StateSyncSpec.scala

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -8,13 +8,8 @@ import akka.testkit.TestActor.AutoPilot
88
import akka.testkit.{TestKit, TestProbe}
99
import akka.util.ByteString
1010
import io.iohk.ethereum.blockchain.sync.StateSyncUtils.{MptNodeData, TrieProvider}
11-
import io.iohk.ethereum.blockchain.sync.SyncStateSchedulerActor.{
12-
RestartRequested,
13-
StartSyncingTo,
14-
StateSyncFinished,
15-
StateSyncStats,
16-
WaitingForNewTargetBlock
17-
}
11+
import io.iohk.ethereum.blockchain.sync.fast.{SyncStateScheduler, SyncStateSchedulerActor}
12+
import io.iohk.ethereum.blockchain.sync.fast.SyncStateSchedulerActor.{RestartRequested, StartSyncingTo, StateSyncFinished, StateSyncStats, WaitingForNewTargetBlock}
1813
import io.iohk.ethereum.db.dataSource.RocksDbDataSource.IterationError
1914
import io.iohk.ethereum.domain.{Address, BlockchainImpl, ChainWeight}
2015
import io.iohk.ethereum.network.EtcPeerManagerActor.{GetHandshakedPeers, HandshakedPeers, PeerInfo, SendMessage}

‎src/test/scala/io/iohk/ethereum/blockchain/sync/StateSyncUtils.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package io.iohk.ethereum.blockchain.sync
22

33
import akka.util.ByteString
4-
import io.iohk.ethereum.blockchain.sync.SyncStateScheduler.SyncResponse
4+
import io.iohk.ethereum.blockchain.sync.fast.SyncStateScheduler.SyncResponse
55
import io.iohk.ethereum.domain.{Account, Address, Blockchain, BlockchainImpl}
66
import io.iohk.ethereum.ledger.InMemoryWorldStateProxy
77
import io.iohk.ethereum.mpt.MerklePatriciaTrie

‎src/test/scala/io/iohk/ethereum/blockchain/sync/SyncControllerSpec.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,8 @@ import akka.actor.{ActorRef, ActorSystem, Props}
44
import akka.testkit.TestActor.AutoPilot
55
import akka.testkit.{TestActorRef, TestProbe}
66
import akka.util.ByteString
7-
import io.iohk.ethereum.blockchain.sync.FastSync.SyncState
7+
import io.iohk.ethereum.blockchain.sync.fast.FastSync
8+
import io.iohk.ethereum.blockchain.sync.fast.FastSync.SyncState
89
import io.iohk.ethereum.consensus.TestConsensus
910
import io.iohk.ethereum.consensus.blocks.CheckpointBlockGenerator
1011
import io.iohk.ethereum.consensus.validators.BlockHeaderError.HeaderPoWError

‎src/test/scala/io/iohk/ethereum/blockchain/sync/SyncSchedulerSpec.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,8 @@ package io.iohk.ethereum.blockchain.sync
33
import akka.util.ByteString
44
import io.iohk.ethereum.Fixtures
55
import io.iohk.ethereum.blockchain.sync.StateSyncUtils.{MptNodeData, TrieProvider, checkAllDataExists}
6-
import io.iohk.ethereum.blockchain.sync.SyncStateScheduler.{
6+
import io.iohk.ethereum.blockchain.sync.fast.SyncStateScheduler
7+
import io.iohk.ethereum.blockchain.sync.fast.SyncStateScheduler.{
78
AlreadyProcessedItem,
89
CannotDecodeMptNode,
910
NotRequestedItem,

‎src/test/scala/io/iohk/ethereum/blockchain/sync/SyncSchedulerStateSpec.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package io.iohk.ethereum.blockchain.sync
22

33
import akka.util.ByteString
4-
import io.iohk.ethereum.blockchain.sync.SyncStateScheduler.{SchedulerState, StateNode, StateNodeRequest}
4+
import io.iohk.ethereum.blockchain.sync.fast.SyncStateScheduler.{SchedulerState, StateNode, StateNodeRequest}
55
import org.scalatest.flatspec.AnyFlatSpec
66
import org.scalatest.matchers.must.Matchers
77

‎src/test/scala/io/iohk/ethereum/blockchain/sync/SyncStateDownloaderStateSpec.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,13 +7,14 @@ import akka.testkit.{TestKit, TestProbe}
77
import akka.util.ByteString
88
import cats.data.NonEmptyList
99
import io.iohk.ethereum.WithActorSystemShutDown
10-
import io.iohk.ethereum.blockchain.sync.SyncStateScheduler.SyncResponse
11-
import io.iohk.ethereum.blockchain.sync.SyncStateSchedulerActor.{
10+
import io.iohk.ethereum.blockchain.sync.fast.SyncStateScheduler.SyncResponse
11+
import io.iohk.ethereum.blockchain.sync.fast.SyncStateSchedulerActor.{
1212
NoUsefulDataInResponse,
1313
ResponseProcessingResult,
1414
UnrequestedResponse,
1515
UsefulData
1616
}
17+
import io.iohk.ethereum.blockchain.sync.fast.DownloaderState
1718
import io.iohk.ethereum.crypto.kec256
1819
import io.iohk.ethereum.network.Peer
1920
import io.iohk.ethereum.network.p2p.messages.PV63.NodeData

0 commit comments

Comments
 (0)