diff --git a/bitswap/client/internal/messagequeue/messagequeue.go b/bitswap/client/internal/messagequeue/messagequeue.go index 627a17550..c820f28c2 100644 --- a/bitswap/client/internal/messagequeue/messagequeue.go +++ b/bitswap/client/internal/messagequeue/messagequeue.go @@ -594,7 +594,7 @@ func (mq *MessageQueue) sendMessage() { mq.simulateDontHaveWithTimeout(wantlist) // If the message was too big and only a subset of wants could be sent, - // send more if the the workcount is above the cutoff. Otherwise, + // send more if the workcount is above the cutoff. Otherwise, // schedule sending the rest of the wants in the next iteration of the // event loop. pendingWork := mq.pendingWorkCount() diff --git a/bitswap/network/httpnet/error_tracker.go b/bitswap/network/httpnet/error_tracker.go index 72eb6ae1c..213bd8e7d 100644 --- a/bitswap/network/httpnet/error_tracker.go +++ b/bitswap/network/httpnet/error_tracker.go @@ -29,7 +29,7 @@ func (et *errorTracker) stopTracking(p peer.ID) { et.mux.Unlock() } -// logErrors adds n to the current error count for p. If the total count is above the threshold, then an error is returned. If n is 0, the the total count is reset to 0. +// logErrors adds n to the current error count for p. If the total count is above the threshold, then an error is returned. If n is 0, the total count is reset to 0. func (et *errorTracker) logErrors(p peer.ID, n int, threshold int) error { et.mux.Lock() defer et.mux.Unlock()