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

read_concurrency

This commit is contained in:
Ery Lee 2015-04-10 20:24:26 +08:00
parent aee3d3b3f9
commit 1a81a4cc68
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqttd/src/emqttd_acl.erl
View File

@ -141,7 +141,7 @@ stop() ->
%%% gen_server callbacks. %%% gen_server callbacks.
%%%============================================================================= %%%=============================================================================
init([AclMods]) -> init([AclMods]) ->
ets:new(?ACL_TABLE, [set, protected, named_table]), ets:new(?ACL_TABLE, [set, protected, named_table, {read_concurrency, true}]),
AclMods1 = lists:map( AclMods1 = lists:map(
fun({M, Opts}) -> fun({M, Opts}) ->
AclMod = aclmod(M), AclMod = aclmod(M),

2
apps/emqttd/src/emqttd_acl_internal.erl
View File

@ -60,7 +60,7 @@ all_rules() ->
%% @doc init internal ACL. %% @doc init internal ACL.
-spec init(AclOpts :: list()) -> {ok, State :: any()}. -spec init(AclOpts :: list()) -> {ok, State :: any()}.
init(AclOpts) -> init(AclOpts) ->
ets:new(?ACL_RULE_TABLE, [set, public, named_table]), ets:new(?ACL_RULE_TABLE, [set, public, named_table, {read_concurrency, true}]),
AclFile = proplists:get_value(file, AclOpts), AclFile = proplists:get_value(file, AclOpts),
Default = proplists:get_value(nomatch, AclOpts, allow), Default = proplists:get_value(nomatch, AclOpts, allow),
State = #state{acl_file = AclFile, nomatch = Default}, State = #state{acl_file = AclFile, nomatch = Default},