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

test: Fix flaky TestMessageBatchPublish (#616)

Browse Source 
Messages where being dropped in the validation queue if the machine was
not fast enough.
This commit is contained in:
Marco Munizaga 2025-05-27 09:04:26 -07:00 committed by GitHub
parent 9e5145fb29
commit 38ad16a687
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
gossipsub_test.go
View File

@ -3591,7 +3591,7 @@ func BenchmarkRoundRobinMessageIDScheduler(b *testing.B) {
}
func TestMessageBatchPublish(t *testing.T) {
ctx, cancel := context.WithCancel(context.Background())
ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
defer cancel()
hosts := getDefaultHosts(t, 20)
@ -3602,7 +3602,7 @@ func TestMessageBatchPublish(t *testing.T) {
}
const numMessages = 100
// +8 to account for the gossiping overhead
psubs := getGossipsubs(ctx, hosts, WithMessageIdFn(msgIDFn), WithPeerOutboundQueueSize(numMessages+8))
psubs := getGossipsubs(ctx, hosts, WithMessageIdFn(msgIDFn), WithPeerOutboundQueueSize(numMessages+8), WithValidateQueueSize(numMessages+8))
var topics []*Topic
var msgs []*Subscription
@ -3643,7 +3643,7 @@ func TestMessageBatchPublish(t *testing.T) {
for _, sub := range msgs {
got, err := sub.Next(ctx)
if err != nil {
t.Fatal(sub.err)
t.Fatal(err)
}
id := msgIDFn(got.Message)
expected := []byte(fmt.Sprintf("%s it's not a floooooood %s", id, id))