From 0d90d5c66b4784429eebe2b0cb0a637ec66a142d Mon Sep 17 00:00:00 2001 From: Zaiming Shi Date: Wed, 4 Nov 2020 13:41:48 +0100 Subject: [PATCH] fix(emqx_acl_cache): Dialyzer warnings --- src/emqx_acl_cache.erl | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/src/emqx_acl_cache.erl b/src/emqx_acl_cache.erl index ef549d8d3..5e327e210 100644 --- a/src/emqx_acl_cache.erl +++ b/src/emqx_acl_cache.erl @@ -107,9 +107,7 @@ put_acl_cache(PubSub, Topic, AclResult) -> %% delete all the acl entries -spec(empty_acl_cache() -> ok). empty_acl_cache() -> - map_acl_cache(fun({CacheK, _CacheV}) -> - erlang:erase(CacheK) - end), + foreach_acl_cache(fun({CacheK, _CacheV}) -> erlang:erase(CacheK) end), set_cache_size(0), keys_queue_set(queue:new()). @@ -139,9 +137,13 @@ get_cache_size() -> dump_acl_cache() -> map_acl_cache(fun(Cache) -> Cache end). + map_acl_cache(Fun) -> [Fun(R) || R = {{SubPub, _T}, _Acl} <- get(), SubPub =:= publish orelse SubPub =:= subscribe]. +foreach_acl_cache(Fun) -> + _ = map_acl_cache(Fun), + ok. %%-------------------------------------------------------------------- %% Internal functions