From 534a741b0e347b32a3d67c53c0b5689ce11a2daa Mon Sep 17 00:00:00 2001 From: Andrew Mayorov Date: Thu, 3 Aug 2023 15:34:24 +0400 Subject: [PATCH] perf(retainer): do not GC on replicant nodes --- apps/emqx_retainer/src/emqx_retainer_mnesia.erl | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/apps/emqx_retainer/src/emqx_retainer_mnesia.erl b/apps/emqx_retainer/src/emqx_retainer_mnesia.erl index 0d407ea78..73c86fe04 100644 --- a/apps/emqx_retainer/src/emqx_retainer_mnesia.erl +++ b/apps/emqx_retainer/src/emqx_retainer_mnesia.erl @@ -153,6 +153,14 @@ store_retained(_, Msg = #message{topic = Topic}) -> end. clear_expired(_) -> + case mria_rlog:role() of + core -> + clear_expired(); + _ -> + ok + end. + +clear_expired() -> NowMs = erlang:system_time(millisecond), QH = qlc:q([ RetainedMsg