mirror of
https://github.com/matrix-org/dendrite
synced 2024-06-01 03:59:03 +02:00
Err()...
This commit is contained in:
parent
1f723362c0
commit
43ac98dfbe
|
@ -295,7 +295,7 @@ 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() != nil {
|
||||
if oq.process.Context().Err() != nil {
|
||||
return
|
||||
}
|
||||
// Check if a worker is already running, and if it isn't, then
|
||||
|
|
Loading…
Reference in a new issue