logos-messaging/logos-messaging-go
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-go.git synced 2026-01-04 23:13:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: move selectWithLowestRTT to the end

Browse Source
This commit is contained in:
Igor Sirotin 2025-12-08 18:20:25 +00:00
parent 24ba9a86e9
commit 2dc85894be
No known key found for this signature in database
GPG Key ID: 0EABBCB40CB9AD4A
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
waku/v2/peermanager/peer_manager_test.go
View File

@ -144,10 +144,6 @@ func TestPeerSelection(t *testing.T) {
_, err = pm.SelectPeers(PeerSelectionCriteria{SelectionType: Automatic, Proto: protocol, PubsubTopics: []string{"/waku/2/rs/2/1"}})
require.NoError(t, err)
//Test for selectWithLowestRTT
_, err = pm.SelectPeers(PeerSelectionCriteria{SelectionType: LowestRTT, Proto: protocol, PubsubTopics: []string{"/waku/2/rs/2/1"}})
require.NoError(t, err)
peerIDs, err = pm.SelectPeers(PeerSelectionCriteria{SelectionType: Automatic, Proto: protocol, PubsubTopics: []string{"/waku/2/rs/2/1"}, MaxPeers: 2})
require.Equal(t, 2, peerIDs.Len())
require.NoError(t, err)
@ -166,6 +162,11 @@ func TestPeerSelection(t *testing.T) {
require.Equal(t, 3, peerIDs.Len())
require.NoError(t, err)
//Test for selectWithLowestRTT
// NOTE: This test must go the last because it involves pinging peers, which modifies the list of supported protocols
peerIDs, err = pm.SelectPeers(PeerSelectionCriteria{SelectionType: LowestRTT, Proto: protocol, PubsubTopics: []string{"/waku/2/rs/2/1"}, MaxPeers: 2})
require.NoError(t, err)
require.Len(t, peerIDs, 1) // With LowestRTT, only 1 peer is returned, even if MaxPeers is set
}
func TestDefaultProtocol(t *testing.T) {