yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(metric): incr the messages.retained counter

This commit is contained in:
JianBo He 2021-05-11 14:16:21 +08:00 committed by Yudai Kiyofuji
parent 52e02b251e
commit d317d57f3f
2 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
apps/emqx_retainer/src/emqx_retainer.appup.src Normal file
View File

@ -0,0 +1,15 @@
%% -*-: erlang -*-
{VSN,
[
{"4.3.0", [
{load_module, emqx_retainer, brutal_purge, soft_purge, []}
]},
{<<".*">>, []}
],
[
{"4.3.0", [
{load_module, emqx_retainer, brutal_purge, soft_purge, []}
]},
{<<".*">>, []}
]
}.

2
apps/emqx_retainer/src/emqx_retainer.erl
View File

@ -200,7 +200,7 @@ sort_retained(Msgs) ->
store_retained(Msg = #message{topic = Topic, payload = Payload}, Env) -> store_retained(Msg = #message{topic = Topic, payload = Payload}, Env) ->
case {is_table_full(Env), is_too_big(size(Payload), Env)} of case {is_table_full(Env), is_too_big(size(Payload), Env)} of
{false, false} -> {false, false} ->
ok = emqx_metrics:set('messages.retained', retained_count()), ok = emqx_metrics:inc('messages.retained'),
mnesia:dirty_write(?TAB, #retained{topic = topic2tokens(Topic), mnesia:dirty_write(?TAB, #retained{topic = topic2tokens(Topic),
msg = Msg, msg = Msg,
expiry_time = get_expiry_time(Msg, Env)}); expiry_time = get_expiry_time(Msg, Env)});