Merge pull request #479 from ipfs/fix/deflake-large-message-test

test: deflake large-message test

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) {

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: