mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2026-01-01 03:03:10 -06:00
Code Issues Packages Projects Releases Wiki Activity

Use process context

Browse source
This commit is contained in:
Neil Alexander 2022-03-03 15:39:39 +00:00
parent e09019f68c
commit 37b93377b5
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 1 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
userapi/userapi.go
View file

@ -15,7 +15,6 @@
package userapi package userapi
import ( import (
"context"
"time" "time"
"github.com/gorilla/mux" "github.com/gorilla/mux"
@ -90,7 +89,7 @@ func NewInternalAPI(
var cleanOldNotifs func() var cleanOldNotifs func()
cleanOldNotifs = func() { cleanOldNotifs = func() {
logrus.Infof("Cleaning old notifications") logrus.Infof("Cleaning old notifications")
if err := db.DeleteOldNotifications(context.Background()); err != nil { if err := db.DeleteOldNotifications(base.Context()); err != nil {
logrus.WithError(err).Error("Failed to clean old notifications") logrus.WithError(err).Error("Failed to clean old notifications")
} }
time.AfterFunc(time.Hour, cleanOldNotifs) time.AfterFunc(time.Hour, cleanOldNotifs)