diff --git a/internal/messagequeue/donthavetimeoutmgr_test.go b/internal/messagequeue/donthavetimeoutmgr_test.go index 6f315fea9b933120f325a1bb32d13fbe572f736e..cc0ebb301b1eaabfa841c9b5c7019eb2b27e38f0 100644 --- a/internal/messagequeue/donthavetimeoutmgr_test.go +++ b/internal/messagequeue/donthavetimeoutmgr_test.go @@ -355,7 +355,7 @@ func TestDontHaveTimeoutMgrUsesDefaultTimeoutIfLatencyLonger(t *testing.T) { } // Sleep until after the default timeout - time.Sleep(10 * time.Millisecond) + time.Sleep(defaultTimeout * 2) // Now the keys should have timed out if tr.timedOutCount() != len(ks) { diff --git a/internal/messagequeue/messagequeue_test.go b/internal/messagequeue/messagequeue_test.go index ca0ac7198e1a8a227209a9c956326c25f6495968..4bb538eb0859dbc1dca2b8555bbb74d16d9a0ee2 100644 --- a/internal/messagequeue/messagequeue_test.go +++ b/internal/messagequeue/messagequeue_test.go @@ -501,7 +501,7 @@ func TestSendingLargeMessages(t *testing.T) { messageQueue.Startup() messageQueue.AddWants(wantBlocks, []cid.Cid{}) - messages := collectMessages(ctx, t, messagesSent, 10*time.Millisecond) + messages := collectMessages(ctx, t, messagesSent, 100*time.Millisecond) // want-block has size 44, so with maxMsgSize 44 * 3 (3 want-blocks), then if // we send 10 want-blocks we should expect 4 messages: