Skip to content

Commit f1a1d3e

Browse files
committed
merge conflicts
1 parent 56678e5 commit f1a1d3e

File tree

1 file changed

+5
-14
lines changed

1 file changed

+5
-14
lines changed

replication_test.go

Lines changed: 5 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -320,16 +320,15 @@ func testReplicationEmptyNotarizations(t *testing.T, nodes []simplex.NodeID, end
320320
net.SetAllNodesMessageFilter(AllowAllMessages)
321321
net.Connect(laggingNode.E.ID)
322322
net.TriggerLeaderBlockBuilder(endRound)
323-
for i, n := range net.Instances {
323+
for _, n := range net.Instances {
324324
if n.E.ID.Equals(laggingNode.E.ID) {
325325
// maybe lagging node has requested finalizations to a node without it, we may need to resend the request
326326
for {
327327
if n.Storage.NumBlocks() == 2 {
328328
break
329329
}
330330
time.Sleep(10 * time.Millisecond)
331-
startTimes[i] = startTimes[i].Add(2 * simplex.DefaultMaxProposalWaitTime)
332-
n.E.AdvanceTime(startTimes[i])
331+
n.AdvanceTime(2 * simplex.DefaultMaxProposalWaitTime)
333332
}
334333
continue
335334
}
@@ -1136,9 +1135,7 @@ func TestReplicationVotesForNotarizations(t *testing.T) {
11361135
ReplicationEnabled: true,
11371136
})
11381137

1139-
startTimes := make([]time.Time, 0, len(nodes))
11401138
for _, n := range net.Instances {
1141-
startTimes = append(startTimes, n.E.StartTime)
11421139
if n.E.ID.Equals(laggingNode.E.ID) {
11431140
require.Equal(t, uint64(0), n.Storage.NumBlocks())
11441141
continue
@@ -1157,7 +1154,7 @@ func TestReplicationVotesForNotarizations(t *testing.T) {
11571154
emptyRound := bytes.Equal(simplex.LeaderForRound(nodes, round), laggingNode.E.ID)
11581155
if emptyRound {
11591156
missedSeqs++
1160-
net.AdvanceWithoutLeader(startTimes, round, laggingNode.E.ID)
1157+
net.AdvanceWithoutLeader(round, laggingNode.E.ID)
11611158
} else {
11621159
net.TriggerLeaderBlockBuilder(round)
11631160
for _, n := range net.Instances {
@@ -1212,8 +1209,7 @@ func TestReplicationVotesForNotarizations(t *testing.T) {
12121209
break
12131210
}
12141211

1215-
startTimes[3] = startTimes[3].Add(simplex.DefaultReplicationRequestTimeout)
1216-
laggingNode.E.AdvanceTime(startTimes[3])
1212+
laggingNode.AdvanceTime(simplex.DefaultReplicationRequestTimeout)
12171213
}
12181214

12191215
for _, n := range net.Instances {
@@ -1262,17 +1258,12 @@ func testReplicationEmptyNotarizationsTail(t *testing.T, nodes []simplex.NodeID,
12621258
}
12631259
}
12641260

1265-
startTimes := make([]time.Time, 0, len(nodes))
12661261
NewSimplexNode(t, nodes[0], net, newNodeConfig(nodes[0]))
12671262
NewSimplexNode(t, nodes[1], net, newNodeConfig(nodes[1]))
12681263
NewSimplexNode(t, nodes[2], net, newNodeConfig(nodes[2]))
12691264
NewSimplexNode(t, nodes[3], net, newNodeConfig(nodes[3]))
12701265
NewSimplexNode(t, nodes[4], net, newNodeConfig(nodes[4]))
12711266
laggingNode := NewSimplexNode(t, nodes[5], net, newNodeConfig(nodes[5]))
1272-
for _, n := range net.Instances {
1273-
require.Equal(t, uint64(0), n.Storage.NumBlocks())
1274-
startTimes = append(startTimes, n.E.StartTime)
1275-
}
12761267

12771268
net.StartInstances()
12781269

@@ -1286,7 +1277,7 @@ func testReplicationEmptyNotarizationsTail(t *testing.T, nodes []simplex.NodeID,
12861277
net.TriggerLeaderBlockBuilder(i)
12871278
}
12881279

1289-
net.AdvanceWithoutLeader(startTimes, i, laggingNode.E.ID)
1280+
net.AdvanceWithoutLeader(i, laggingNode.E.ID)
12901281
}
12911282

12921283
for _, n := range net.Instances {

0 commit comments

Comments
 (0)