mirror of
https://github.com/matrix-org/dendrite
synced 2024-05-19 22:03:46 +02:00
Merge branch 'main' of github.com:matrix-org/dendrite into s7evink/v0137
This commit is contained in:
commit
bfd6230f27
|
@ -294,6 +294,10 @@ func (oq *destinationQueue) checkNotificationsOnClose() {
|
|||
|
||||
// backgroundSend is the worker goroutine for sending events.
|
||||
func (oq *destinationQueue) backgroundSend() {
|
||||
// Don't try to send transactions if we are shutting down.
|
||||
if oq.process.Context().Err() != nil {
|
||||
return
|
||||
}
|
||||
// Check if a worker is already running, and if it isn't, then
|
||||
// mark it as started.
|
||||
if !oq.running.CompareAndSwap(false, true) {
|
||||
|
|
Loading…
Reference in a new issue