mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-16 19:33:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Add comments

Browse source
This commit is contained in:
Neil Alexander 2020-04-03 12:33:26 +01:00
parent b91ac954e4
commit 54f168a99c
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
federationsender/queue/destinationqueue.go
View file

@ -101,8 +101,8 @@ func (oq *destinationQueue) backgroundSend() {
} }
// nextTransaction creates a new transaction from the pending event // nextTransaction creates a new transaction from the pending event
// queue and sends it. // queue and sends it. Returns true if a transaction was sent or
// Returns nil if the queue was empty. // false otherwise.
func (oq *destinationQueue) nextTransaction() bool { func (oq *destinationQueue) nextTransaction() bool {
oq.runningMutex.Lock() oq.runningMutex.Lock()
defer oq.runningMutex.Unlock() defer oq.runningMutex.Unlock()
@ -154,6 +154,8 @@ func (oq *destinationQueue) nextTransaction() bool {
return true return true
} }
// nextInvite takes pending invite events from the queue and sends
// them. Returns true if a transaction was sent or false otherwise.
func (oq *destinationQueue) nextInvites() bool { func (oq *destinationQueue) nextInvites() bool {
oq.runningMutex.Lock() oq.runningMutex.Lock()
defer oq.runningMutex.Unlock() defer oq.runningMutex.Unlock()