logos-messaging/go-libp2p-pubsub
1
0
Fork 0
mirror of https://github.com/logos-messaging/go-libp2p-pubsub.git synced 2026-01-05 06:13:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

be less dependent on accurate time calculations in test

Browse Source 
thanks travis...
This commit is contained in:
Yusef Napora 2020-04-23 14:19:48 -04:00 committed by vyzo
parent ae4bc44c12
commit ac70e7e738
1 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
score_test.go
View File

@ -42,9 +42,8 @@ func TestScoreTimeInMesh(t *testing.T) {
ps.refreshScores()
aScore = ps.Score(peerA)
expected := topicScoreParams.TopicWeight * topicScoreParams.TimeInMeshWeight * float64(elapsed/topicScoreParams.TimeInMeshQuantum)
variance := 0.5
if !withinVariance(aScore, expected, variance) {
t.Fatalf("Score: %f. Expected %f ± %f", aScore, expected, variance*expected)
if aScore < expected {
t.Fatalf("Score: %f. Expected >= %f", aScore, expected)
}
}
@ -251,8 +250,7 @@ func TestScoreMeshMessageDeliveries(t *testing.T) {
ps.Graft(p, mytopic)
}
// wait for half the activation time, and assert that nobody has been penalized yet for not delivering messages
time.Sleep(topicScoreParams.MeshMessageDeliveriesActivation / time.Duration(2))
// assert that nobody has been penalized yet for not delivering messages before activation time
ps.refreshScores()
for _, p := range peers {
score := ps.Score(p)
@ -260,8 +258,8 @@ func TestScoreMeshMessageDeliveries(t *testing.T) {
t.Fatalf("expected no mesh delivery penalty before activation time, got score %f", score)
}
}
// wait the remainder of the activation time
time.Sleep(topicScoreParams.MeshMessageDeliveriesActivation / time.Duration(2))
// wait for the activation time to kick in
time.Sleep(topicScoreParams.MeshMessageDeliveriesActivation)
// deliver a bunch of messages from peer A, with duplicates within the window from peer B,
// and duplicates outside the window from peer C.