Skip to content

GitLab

Commit 6c412605 authored by Dirk McCormick's avatar Dirk McCormick
Browse files
Options

refactor: remove unnecessary func param

parent efd006e9
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 3 deletions
internal/messagequeue/messagequeue.go
View file @ 6c412605
......@@ -439,7 +439,7 @@ func (mq *MessageQueue) sendMessage() {
for i := 0; i < maxRetries; i++ {
if mq.attemptSendAndRecovery(message) {
// We were able to send successfully.
onSent(wantlist)
onSent()
mq.simulateDontHaveWithTimeout(wantlist)
......@@ -540,7 +540,7 @@ func (mq *MessageQueue) pendingWorkCount() int {
}
// Convert the lists of wants into a Bitswap message
func (mq *MessageQueue) extractOutgoingMessage(supportsHave bool) (bsmsg.BitSwapMessage, func([]bsmsg.Entry)) {
func (mq *MessageQueue) extractOutgoingMessage(supportsHave bool) (bsmsg.BitSwapMessage, func()) {
mq.wllock.Lock()
defer mq.wllock.Unlock()
......@@ -595,7 +595,7 @@ func (mq *MessageQueue) extractOutgoingMessage(supportsHave bool) (bsmsg.BitSwap
}
// Called when the message has been successfully sent.
onMessageSent := func(wantlist []bsmsg.Entry) {
onMessageSent := func() {
mq.wllock.Lock()
defer mq.wllock.Unlock()
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment