Skip to content

Commit 87acf8b

Browse files
committed
add order to make test deterministic
1 parent b900b72 commit 87acf8b

File tree

2 files changed

+4
-6
lines changed

2 files changed

+4
-6
lines changed

src/main/scala/io/iohk/ethereum/blockchain/sync/FastSync.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -331,10 +331,12 @@ trait FastSync {
331331
val peers = unassignedPeers
332332
(peers -- blockChainOnlyPeers)
333333
.take(maxConcurrentRequests - assignedHandlers.size)
334+
.toSeq.sortBy(_.ref.toString())
334335
.foreach(assignWork)
335336
peers
336337
.intersect(blockChainOnlyPeers)
337338
.take(maxConcurrentRequests - assignedHandlers.size)
339+
.toSeq.sortBy(_.ref.toString())
338340
.foreach(assignBlockChainWork)
339341
}
340342
}

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

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -69,21 +69,17 @@ class SyncControllerSpec extends FlatSpec with Matchers {
6969
peerMessageBus.expectMsg(Subscribe(MessageClassifier(Set(BlockHeaders.code), PeerSelector.WithId(peer2.id))))
7070
etcPeerManager.expectMsg(
7171
EtcPeerManagerActor.SendMessage(GetBlockHeaders(Left(expectedTargetBlock), 1, 0, reverse = false), peer2.id))
72-
syncController ! MessageFromPeer(BlockHeaders(Seq(targetBlockHeader)), peer2.id)
7372

7473
storagesInstance.storages.appStateStorage.putBestBlockNumber(targetBlockHeader.number)
74+
syncController ! MessageFromPeer(BlockHeaders(Seq(targetBlockHeader)), peer2.id)
7575

7676
peerMessageBus.expectMsg(Unsubscribe(MessageClassifier(Set(BlockHeaders.code), PeerSelector.WithId(peer2.id))))
7777
etcPeerManager.expectMsg(EtcPeerManagerActor.SendMessage(GetBlockHeaders(Left(1), 10, 0, reverse = false), peer2.id))
7878
peerMessageBus.expectMsg(Subscribe(MessageClassifier(Set(BlockHeaders.code), PeerSelector.WithId(peer2.id))))
7979

80-
val blockHeadersRequestHandler: ActorRef = peerMessageBus.sender()
81-
peerMessageBus.send(syncController, PeerDisconnected(peer1.id))
82-
peerMessageBus.send(blockHeadersRequestHandler, PeerDisconnected(peer1.id))
83-
8480
etcPeerManager.expectMsg(EtcPeerManagerActor.SendMessage(GetNodeData(Seq(targetBlockHeader.stateRoot)), peer1.id))
8581
peerMessageBus.expectMsg(Subscribe(MessageClassifier(Set(NodeData.code), PeerSelector.WithId(peer1.id))))
86-
peerMessageBus.expectNoMsg()
82+
etcPeerManager.expectNoMsg()
8783
}
8884

8985
it should "download target block, request state, blocks and finish when downloaded" in new TestSetup() {

0 commit comments

Comments
 (0)