mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-17 03:43:11 -06:00
Code Issues Packages Projects Releases Wiki Activity

Dispatch sends again

Browse source
This commit is contained in:
Neil Alexander 2020-05-06 14:15:33 +01:00
parent 18cb75b0ac
commit 7ac699bc77
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
federationsender/queue/queue.go
View file

@ -89,7 +89,7 @@ func (oqs *OutgoingQueues) SendEvent(
oqs.queuesMutex.Unlock() oqs.queuesMutex.Unlock()
} }
oq.sendEvent(ev) go oq.sendEvent(ev)
} }
return nil return nil
@ -138,7 +138,7 @@ func (oqs *OutgoingQueues) SendInvite(
oqs.queuesMutex.Unlock() oqs.queuesMutex.Unlock()
} }
oq.sendInvite(inviteReq) go oq.sendInvite(inviteReq)
return nil return nil
} }
@ -182,7 +182,7 @@ func (oqs *OutgoingQueues) SendEDU(
oqs.queuesMutex.Unlock() oqs.queuesMutex.Unlock()
} }
oq.sendEDU(e) go oq.sendEDU(e)
} }
return nil return nil