Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Release v4.7.6 merge to Nile_v4.7.6 #5963

Merged
merged 48 commits into from
Aug 16, 2024
Merged
Changes from 1 commit
Commits
Show all changes
48 commits
Select commit Hold shift + click to select a range
ff69595
test(CI): add test-retry plugin for test
halibobo1205 Jul 1, 2024
ee7765f
Merge pull request #5916 from halibobo1205/release/4.7.6_add_retry
lvs007 Jul 18, 2024
496d64d
feat(version): update version to 4.7.6
halibobo1205 Jul 18, 2024
f092d0e
Merge pull request #5919 from halibobo1205/version/update_version
lvs007 Jul 18, 2024
0dc7a3f
feat(net) : optimize the isIdle method
zeusoo001 Jun 24, 2024
ddbe8f1
feat(net): add isSyncIdle method
zeusoo001 Jul 1, 2024
0779c00
feat(net): optimize fetch inventory message check logic
zeusoo001 Jun 25, 2024
fdbfa17
feat(net) : optimizing the sortPeers method
zeusoo001 Jun 21, 2024
ea14933
feat(net): use comparingLong method for sortPeers
zeusoo001 Jul 1, 2024
3b3b668
initial commit of test isolated
317787106 Jul 18, 2024
6466458
init commit of set_block_both_have2
317787106 Jul 18, 2024
6a08ac6
test(MerkleTree): ignore testConcurrent
halibobo1205 Jul 1, 2024
f5961f4
add testcase testProcessBlock for BlockMsgHandler
317787106 Jul 19, 2024
6706d83
add testcase testProcessBlock for BlockMsgHandler
317787106 Jul 19, 2024
4211348
Merge pull request #5927 from halibobo1205/test/remove_unstable_test
lvs007 Jul 19, 2024
90a6e8f
fix(http/metric): change endpoint variable from member to local
tomatoishealthy May 14, 2024
27cd42f
Merge pull request #5920 from halibobo1205/fix/endpoint-concurrent-ac…
lvs007 Jul 22, 2024
e670386
set lastactivetime in P2pEventHandlerImpl
317787106 Jul 22, 2024
4791cdf
Merge branch 'release_v4.7.6' into feature/test_isolated3
317787106 Jul 22, 2024
ecd43b7
Merge pull request #5923 from zeusoo001/f-sortpeers-method-opt
lvs007 Jul 22, 2024
afc3979
Merge pull request #5921 from zeusoo001/f-isidle-method-opt
lvs007 Jul 23, 2024
729a99b
Merge pull request #5922 from zeusoo001/f-sync-fetch-block-opt
lvs007 Jul 23, 2024
735bccb
add updateLastActiveTime
317787106 Jul 23, 2024
cae19ea
Merge branch 'release_v4.7.6' into feature/test_isolated3
317787106 Jul 23, 2024
343c5f6
optimize log method of PeerConnection
317787106 Jul 23, 2024
34eb577
Merge branch 'release_v4.7.6' into hotfix/set_block_both_have2
317787106 Jul 23, 2024
d6bbbe4
Merge pull request #5925 from 317787106/hotfix/set_block_both_have2
lvs007 Jul 25, 2024
a718006
catch exception of sort peers
317787106 Jul 25, 2024
4f234be
Merge branch 'release_v4.7.6' into feature/test_isolated3
317787106 Jul 25, 2024
14fda8f
catch exception min of peers
317787106 Jul 25, 2024
54b0395
Merge pull request #5924 from 317787106/feature/test_isolated3
lvs007 Jul 29, 2024
d6faee8
feat(monitor): add tcp out traffic and udp in traffic statistics
zeusoo001 Jul 31, 2024
21f0cb5
Merge pull request #5942 from zeusoo001/net_traffic_monitor3
lvs007 Aug 6, 2024
81bb50b
add some log for isolated2 disconnection
317787106 Aug 7, 2024
0d21388
add log of candidate disconnect size when node is isolated
317787106 Aug 7, 2024
0acc84b
set blockNotChangeThreshold from 90 to 60 seconds
317787106 Aug 9, 2024
0fc9acb
remove the condition of peer.isDisconnect
317787106 Aug 9, 2024
0f7c7f4
don't disconnect with syncing node when random disconnect
317787106 Aug 13, 2024
7bdae32
add DisConnectCause
317787106 Aug 13, 2024
ffbb69e
add DisConnectCause
317787106 Aug 13, 2024
abf8c42
change the condition of isLanNode
317787106 Aug 13, 2024
40cb055
don't disconnect with syncing peer if i am lan node
317787106 Aug 13, 2024
14a0750
modify testcase of ResilienceServiceTest
317787106 Aug 14, 2024
424a3dd
Merge pull request #5944 from 317787106/feature/test_isolated3
lvs007 Aug 14, 2024
471b522
use the condition: active size >= min active size in isolate2
317787106 Aug 15, 2024
553fbb4
change varible name from lastActiveTime to lastInteractiveTime
317787106 Aug 16, 2024
1a7abf3
fix the testcase of testUpdateLastInteractiveTime
317787106 Aug 16, 2024
ea7ef8e
Merge pull request #5956 from 317787106/feature/test_isolated3
lvs007 Aug 16, 2024
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
feat(net) : optimizing the sortPeers method
zeusoo001 committed Jul 18, 2024

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
commit fdbfa17e1d99a5627fc8863e719889ff38ab7537
Original file line number Diff line number Diff line change
@@ -94,7 +94,11 @@ private static void remove(PeerConnection peerConnection) {
}

public static synchronized void sortPeers() {
peers.sort(Comparator.comparingDouble(c -> c.getChannel().getAvgLatency()));
try {
peers.sort(Comparator.comparingDouble(c -> c.getChannel().getAvgLatency()));
} catch (Exception e) {
logger.warn("Sort peers failed. {}", e.getMessage());
}
}

public static PeerConnection getPeerConnection(Channel channel) {
Original file line number Diff line number Diff line change
@@ -135,4 +135,32 @@ public void testGetPeers() throws Exception {
Assert.assertEquals(2, peers.size());
}

@Test
public void testSortPeers() throws Exception {
PeerConnection p1 = new PeerConnection();
PeerConnection p2 = new PeerConnection();

List<PeerConnection> peers = new ArrayList<>();
peers.add(p1);
peers.add(p2);

Field field = PeerManager.class.getDeclaredField("peers");
field.setAccessible(true);
field.set(PeerManager.class, Collections.synchronizedList(peers));

PeerManager.sortPeers();

Channel c1 = new Channel();
c1.updateAvgLatency(100000L);
ReflectUtils.setFieldValue(p1, "channel", c1);

Channel c2 = new Channel();
c2.updateAvgLatency(1000L);
ReflectUtils.setFieldValue(p2, "channel", c2);

PeerManager.sortPeers();

Assert.assertEquals(PeerManager.getPeers().get(0), p2);
}

}