From 35b757ac9cf27cd843984d7dd45a081e095f8782 Mon Sep 17 00:00:00 2001 From: Till Faelligen Date: Thu, 28 Apr 2022 13:55:43 +0200 Subject: [PATCH] Evict EDUs from cache --- federationapi/storage/shared/storage_edus.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/federationapi/storage/shared/storage_edus.go b/federationapi/storage/shared/storage_edus.go index 28730e8c7..8a6e4abc5 100644 --- a/federationapi/storage/shared/storage_edus.go +++ b/federationapi/storage/shared/storage_edus.go @@ -178,6 +178,9 @@ func (d *Database) DeleteExpiredEDUs(ctx context.Context) error { if len(jsonNIDs) == 0 { return nil } + for i := range jsonNIDs { + d.Cache.EvictFederationQueuedEDU(jsonNIDs[i]) + } if err = d.FederationQueueJSON.DeleteQueueJSON(ctx, txn, jsonNIDs); err != nil { return err