Skip to content
Merged
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions bitswap/client/internal/messagequeue/messagequeue_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -133,6 +133,7 @@ func collectMessages(ctx context.Context,
messagesSent <-chan []bsmsg.Entry,
timeout time.Duration,
) [][]bsmsg.Entry {
t.Helper()
var messagesReceived [][]bsmsg.Entry
timeoutctx, cancel := context.WithTimeout(ctx, timeout)
defer cancel()
Expand Down Expand Up @@ -317,7 +318,6 @@ func TestSendingMessagesPriority(t *testing.T) {
}

func TestCancelOverridesPendingWants(t *testing.T) {
t.Parallel()
ctx := context.Background()
messagesSent := make(chan []bsmsg.Entry)
resetChan := make(chan struct{}, 1)
Expand Down Expand Up @@ -400,7 +400,7 @@ func TestWantOverridesPendingCancels(t *testing.T) {

messages = collectMessages(ctx, t, messagesSent, collectTimeout)
if totalEntriesLength(messages) != 3 {
t.Fatal("Wrong message count", totalEntriesLength(messages))
t.Fatalf("Wrong message count, expected 3 got %d", totalEntriesLength(messages))
}

// Should send 1 want-block and 2 cancels
Expand Down
Loading