mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-18 04:13:10 -06:00
Code Issues Packages Projects Releases Wiki Activity

Clean up expired events before sleep

Browse source
This commit is contained in:
Neil Alexander 2020-02-10 14:10:36 +00:00
parent b60cc7283d
commit 47a9256d1e
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
federationsender/queue/queue.go
View file

@ -164,13 +164,14 @@ func (oqs *OutgoingQueues) SendEDU(
func (oqs *OutgoingQueues) processRetries() { func (oqs *OutgoingQueues) processRetries() {
ctx := context.Background() ctx := context.Background()
for { for {
time.Sleep(retryInterval)
if err := oqs.db.DeleteRetryExpiredEvents(ctx); err != nil { if err := oqs.db.DeleteRetryExpiredEvents(ctx); err != nil {
log.WithFields(log.Fields{ log.WithFields(log.Fields{
log.ErrorKey: err, log.ErrorKey: err,
}).Warn("Error cleaning expired retry events") }).Warn("Error cleaning expired retry events")
} }
time.Sleep(retryInterval)
retries, err := oqs.db.SelectRetryEventsPending(ctx) retries, err := oqs.db.SelectRetryEventsPending(ctx)
if err != nil { if err != nil {
log.WithFields(log.Fields{ log.WithFields(log.Fields{