Merge pull request #6844 from lafirest/fix/slow_subs_index

fix(emqx_slow_subs): fix index update error
2022-01-24 20:07:36 +08:00 · 2022-01-24 20:07:36 +08:00 · 7e012b7b90
parent 0fadc85c15 1f718fbb94
commit 7e012b7b90
1 changed files with 1 additions and 1 deletions
--- a/apps/emqx_plugin_libs/src/emqx_slow_subs/emqx_slow_subs.erl
+++ b/apps/emqx_plugin_libs/src/emqx_slow_subs/emqx_slow_subs.erl
@ -262,7 +262,7 @@ try_insert_to_topk(MaxSize, Now, LastUpdateValue, TimeSpan, Id) ->
 -spec find_last_update_value(id()) -> non_neg_integer().
 find_last_update_value(Id) ->
    case ets:next(?INDEX_TAB,  ?INDEX(0, Id)) of
-        #index_tab{index = ?INDEX(LastUpdateValue, Id)} ->
+        ?INDEX(LastUpdateValue, Id) ->
            LastUpdateValue;
        _ ->
            0