Skip to content

Commit 43ce382

Browse files
committed
Merge branch 'vovchyk/snap/pow-weighted-peer-selection' into vovchyk/snap/fetch-leaves-only
2 parents ca3234c + fd29a44 commit 43ce382

File tree

7 files changed

+71
-20
lines changed

7 files changed

+71
-20
lines changed

rskj-core/src/main/java/co/rsk/net/sync/PeersInformation.java

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,14 @@
3131

3232
import java.security.SecureRandom;
3333
import java.time.Instant;
34-
import java.util.*;
34+
import java.util.Collection;
35+
import java.util.Comparator;
36+
import java.util.HashMap;
37+
import java.util.List;
38+
import java.util.Map;
39+
import java.util.Optional;
40+
import java.util.Random;
41+
import java.util.Set;
3542
import java.util.function.Predicate;
3643
import java.util.stream.Collectors;
3744
import java.util.stream.Stream;

rskj-core/src/test/java/co/rsk/net/messages/SnapStateChunkV2RequestMessageTest.java

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,8 +24,14 @@
2424

2525
import java.util.Arrays;
2626

27-
import static org.junit.jupiter.api.Assertions.*;
28-
import static org.mockito.Mockito.*;
27+
import static org.junit.jupiter.api.Assertions.assertArrayEquals;
28+
import static org.junit.jupiter.api.Assertions.assertEquals;
29+
import static org.junit.jupiter.api.Assertions.assertNotNull;
30+
import static org.junit.jupiter.api.Assertions.assertNull;
31+
import static org.junit.jupiter.api.Assertions.assertTrue;
32+
import static org.mockito.Mockito.mock;
33+
import static org.mockito.Mockito.times;
34+
import static org.mockito.Mockito.verify;
2935

3036
class SnapStateChunkV2RequestMessageTest {
3137

@@ -271,4 +277,4 @@ void testNegativeId() {
271277
assertArrayEquals(blockHash, message.getBlockHash());
272278
assertArrayEquals(fromKey, message.getFromKey());
273279
}
274-
}
280+
}

rskj-core/src/test/java/co/rsk/net/messages/SnapStateChunkV2ResponseMessageTest.java

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -25,8 +25,15 @@
2525

2626
import java.util.LinkedHashMap;
2727

28-
import static org.junit.jupiter.api.Assertions.*;
29-
import static org.mockito.Mockito.*;
28+
import static org.junit.jupiter.api.Assertions.assertArrayEquals;
29+
import static org.junit.jupiter.api.Assertions.assertEquals;
30+
import static org.junit.jupiter.api.Assertions.assertFalse;
31+
import static org.junit.jupiter.api.Assertions.assertInstanceOf;
32+
import static org.junit.jupiter.api.Assertions.assertNotNull;
33+
import static org.junit.jupiter.api.Assertions.assertTrue;
34+
import static org.mockito.Mockito.mock;
35+
import static org.mockito.Mockito.times;
36+
import static org.mockito.Mockito.verify;
3037

3138
class SnapStateChunkV2ResponseMessageTest {
3239

@@ -232,4 +239,4 @@ private TrieChunk createLargeTrieChunk() {
232239

233240
return new TrieChunk(keyValues, TrieChunk.Proof.EMPTY);
234241
}
235-
}
242+
}

rskj-core/src/test/java/co/rsk/net/sync/SnapCapablePeerSelectionSyncStateTest.java

Lines changed: 19 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -37,11 +37,24 @@
3737
import java.math.BigInteger;
3838
import java.net.UnknownHostException;
3939
import java.time.Duration;
40-
import java.util.*;
41-
42-
import static org.junit.jupiter.api.Assertions.*;
43-
import static org.mockito.ArgumentMatchers.*;
44-
import static org.mockito.Mockito.*;
40+
import java.util.ArrayList;
41+
import java.util.Arrays;
42+
import java.util.Collections;
43+
import java.util.List;
44+
import java.util.Set;
45+
46+
import static org.junit.jupiter.api.Assertions.assertEquals;
47+
import static org.mockito.ArgumentMatchers.any;
48+
import static org.mockito.ArgumentMatchers.anyLong;
49+
import static org.mockito.ArgumentMatchers.anyString;
50+
import static org.mockito.ArgumentMatchers.eq;
51+
import static org.mockito.Mockito.atLeast;
52+
import static org.mockito.Mockito.mock;
53+
import static org.mockito.Mockito.never;
54+
import static org.mockito.Mockito.reset;
55+
import static org.mockito.Mockito.times;
56+
import static org.mockito.Mockito.verify;
57+
import static org.mockito.Mockito.when;
4558

4659
class SnapCapablePeerSelectionSyncStateTest {
4760

@@ -459,4 +472,4 @@ private List<BlockHeader> createValidHeaderChain(int count) {
459472

460473
return headers;
461474
}
462-
}
475+
}

rskj-core/src/test/java/co/rsk/trie/TrieChunkIteratorTest.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,11 @@
2727
import java.util.Set;
2828

2929
import static org.bouncycastle.util.encoders.Hex.decode;
30-
import static org.junit.jupiter.api.Assertions.*;
30+
import static org.junit.jupiter.api.Assertions.assertEquals;
31+
import static org.junit.jupiter.api.Assertions.assertFalse;
32+
import static org.junit.jupiter.api.Assertions.assertNotNull;
33+
import static org.junit.jupiter.api.Assertions.assertThrows;
34+
import static org.junit.jupiter.api.Assertions.assertTrue;
3135

3236
class TrieChunkIteratorTest {
3337

@@ -305,4 +309,4 @@ private Trie buildLargeTrie() {
305309

306310
return trie;
307311
}
308-
}
312+
}

rskj-core/src/test/java/co/rsk/trie/TrieChunkTest.java

Lines changed: 13 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -25,9 +25,19 @@
2525
import org.junit.jupiter.api.BeforeEach;
2626
import org.junit.jupiter.api.Test;
2727

28-
import java.util.*;
28+
import java.util.Arrays;
29+
import java.util.LinkedHashMap;
30+
import java.util.List;
31+
import java.util.Map;
32+
import java.util.Optional;
2933

30-
import static org.junit.jupiter.api.Assertions.*;
34+
import static org.junit.jupiter.api.Assertions.assertEquals;
35+
import static org.junit.jupiter.api.Assertions.assertFalse;
36+
import static org.junit.jupiter.api.Assertions.assertNotNull;
37+
import static org.junit.jupiter.api.Assertions.assertNull;
38+
import static org.junit.jupiter.api.Assertions.assertSame;
39+
import static org.junit.jupiter.api.Assertions.assertThrows;
40+
import static org.junit.jupiter.api.Assertions.assertTrue;
3141

3242
class TrieChunkTest {
3343

@@ -276,4 +286,4 @@ void testProofFromFactory() {
276286
// This tests the factory method works without throwing exceptions
277287
assertNotNull(proofOpt);
278288
}
279-
}
289+
}

rskj-core/src/test/java/co/rsk/trie/TrieGetNextChunkTest.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,11 @@
2222
import org.junit.jupiter.api.BeforeEach;
2323
import org.junit.jupiter.api.Test;
2424

25-
import static org.junit.jupiter.api.Assertions.*;
25+
import static org.junit.jupiter.api.Assertions.assertEquals;
26+
import static org.junit.jupiter.api.Assertions.assertFalse;
27+
import static org.junit.jupiter.api.Assertions.assertNotNull;
28+
import static org.junit.jupiter.api.Assertions.assertNull;
29+
import static org.junit.jupiter.api.Assertions.assertTrue;
2630

2731
class TrieGetNextChunkTest {
2832

@@ -264,4 +268,4 @@ void testGetNextChunk_IdenticalSequentialCalls() {
264268
assertEquals(chunk1.keyValues().size(), chunk2.keyValues().size());
265269
}
266270
}
267-
}
271+
}

0 commit comments

Comments
 (0)