style: code format fix
This commit is contained in:
parent
585c4892ce
commit
19456d84a5
|
@ -408,7 +408,7 @@ cast(Msg) -> gen_server:cast(?CM, Msg).
|
||||||
|
|
||||||
init([]) ->
|
init([]) ->
|
||||||
TabOpts = [public, {write_concurrency, true}],
|
TabOpts = [public, {write_concurrency, true}],
|
||||||
ok = emqx_tables:new(?CHAN_TAB, [bag, {read_concurrency, true}|TabOpts]),
|
ok = emqx_tables:new(?CHAN_TAB, [bag, {read_concurrency, true} | TabOpts]),
|
||||||
ok = emqx_tables:new(?CHAN_CONN_TAB, [bag | TabOpts]),
|
ok = emqx_tables:new(?CHAN_CONN_TAB, [bag | TabOpts]),
|
||||||
ok = emqx_tables:new(?CHAN_INFO_TAB, [set, compressed | TabOpts]),
|
ok = emqx_tables:new(?CHAN_INFO_TAB, [set, compressed | TabOpts]),
|
||||||
ok = emqx_stats:update_interval(chan_stats, fun ?MODULE:stats_fun/0),
|
ok = emqx_stats:update_interval(chan_stats, fun ?MODULE:stats_fun/0),
|
||||||
|
|
|
@ -108,7 +108,7 @@ clients_insta(get, #{ bindings := #{name := Name0,
|
||||||
{?MODULE, format_channel_info}) of
|
{?MODULE, format_channel_info}) of
|
||||||
[ClientInfo] ->
|
[ClientInfo] ->
|
||||||
{200, ClientInfo};
|
{200, ClientInfo};
|
||||||
[ClientInfo|_More] ->
|
[ClientInfo | _More] ->
|
||||||
?LOG(warning, "More than one client info was returned on ~s",
|
?LOG(warning, "More than one client info was returned on ~s",
|
||||||
[ClientId]),
|
[ClientId]),
|
||||||
{200, ClientInfo};
|
{200, ClientInfo};
|
||||||
|
@ -261,7 +261,7 @@ fuzzy_filter_fun(Fuzzy) ->
|
||||||
|
|
||||||
run_fuzzy_filter(_, []) ->
|
run_fuzzy_filter(_, []) ->
|
||||||
true;
|
true;
|
||||||
run_fuzzy_filter(E = {_, #{clientinfo := ClientInfo}, _}, [{Key, _, RE}|Fuzzy]) ->
|
run_fuzzy_filter(E = {_, #{clientinfo := ClientInfo}, _}, [{Key, _, RE} | Fuzzy]) ->
|
||||||
Val = case maps:get(Key, ClientInfo, "") of
|
Val = case maps:get(Key, ClientInfo, "") of
|
||||||
undefined -> "";
|
undefined -> "";
|
||||||
V -> V
|
V -> V
|
||||||
|
@ -319,12 +319,12 @@ eval(Ls) ->
|
||||||
eval(Ls, #{}).
|
eval(Ls, #{}).
|
||||||
eval([], AccMap) ->
|
eval([], AccMap) ->
|
||||||
AccMap;
|
AccMap;
|
||||||
eval([{K, Vx}|More], AccMap) ->
|
eval([{K, Vx} | More], AccMap) ->
|
||||||
case valuex_get(K, Vx) of
|
case valuex_get(K, Vx) of
|
||||||
undefined -> eval(More, AccMap#{K => null});
|
undefined -> eval(More, AccMap#{K => null});
|
||||||
Value -> eval(More, AccMap#{K => Value})
|
Value -> eval(More, AccMap#{K => Value})
|
||||||
end;
|
end;
|
||||||
eval([{K, Vx, Default}|More], AccMap) ->
|
eval([{K, Vx, Default} | More], AccMap) ->
|
||||||
case valuex_get(K, Vx) of
|
case valuex_get(K, Vx) of
|
||||||
undefined -> eval(More, AccMap#{K => Default});
|
undefined -> eval(More, AccMap#{K => Default});
|
||||||
Value -> eval(More, AccMap#{K => Value})
|
Value -> eval(More, AccMap#{K => Value})
|
||||||
|
@ -363,7 +363,7 @@ metadata(APIs) ->
|
||||||
metadata(APIs, []).
|
metadata(APIs, []).
|
||||||
metadata([], APIAcc) ->
|
metadata([], APIAcc) ->
|
||||||
lists:reverse(APIAcc);
|
lists:reverse(APIAcc);
|
||||||
metadata([{Path, Fun}|More], APIAcc) ->
|
metadata([{Path, Fun} | More], APIAcc) ->
|
||||||
Methods = [get, post, put, delete, patch],
|
Methods = [get, post, put, delete, patch],
|
||||||
Mds = lists:foldl(fun(M, Acc) ->
|
Mds = lists:foldl(fun(M, Acc) ->
|
||||||
try
|
try
|
||||||
|
|
|
@ -67,18 +67,18 @@ paginate(Tables, MatchSpec, Params, RowFun) ->
|
||||||
data => [RowFun(Row) || Row <- Rows]}.
|
data => [RowFun(Row) || Row <- Rows]}.
|
||||||
|
|
||||||
query_handle(Table) when is_atom(Table) ->
|
query_handle(Table) when is_atom(Table) ->
|
||||||
qlc:q([R|| R <- ets:table(Table)]);
|
qlc:q([R || R <- ets:table(Table)]);
|
||||||
query_handle([Table]) when is_atom(Table) ->
|
query_handle([Table]) when is_atom(Table) ->
|
||||||
qlc:q([R|| R <- ets:table(Table)]);
|
qlc:q([R || R <- ets:table(Table)]);
|
||||||
query_handle(Tables) ->
|
query_handle(Tables) ->
|
||||||
qlc:append([qlc:q([E || E <- ets:table(T)]) || T <- Tables]).
|
qlc:append([qlc:q([E || E <- ets:table(T)]) || T <- Tables]).
|
||||||
|
|
||||||
query_handle(Table, MatchSpec) when is_atom(Table) ->
|
query_handle(Table, MatchSpec) when is_atom(Table) ->
|
||||||
Options = {traverse, {select, MatchSpec}},
|
Options = {traverse, {select, MatchSpec}},
|
||||||
qlc:q([R|| R <- ets:table(Table, Options)]);
|
qlc:q([R || R <- ets:table(Table, Options)]);
|
||||||
query_handle([Table], MatchSpec) when is_atom(Table) ->
|
query_handle([Table], MatchSpec) when is_atom(Table) ->
|
||||||
Options = {traverse, {select, MatchSpec}},
|
Options = {traverse, {select, MatchSpec}},
|
||||||
qlc:q([R|| R <- ets:table(Table, Options)]);
|
qlc:q([R || R <- ets:table(Table, Options)]);
|
||||||
query_handle(Tables, MatchSpec) ->
|
query_handle(Tables, MatchSpec) ->
|
||||||
Options = {traverse, {select, MatchSpec}},
|
Options = {traverse, {select, MatchSpec}},
|
||||||
qlc:append([qlc:q([E || E <- ets:table(T, Options)]) || T <- Tables]).
|
qlc:append([qlc:q([E || E <- ets:table(T, Options)]) || T <- Tables]).
|
||||||
|
@ -140,7 +140,7 @@ do_node_query( Node, Tab, Qs, QueryFun, Continuation
|
||||||
end;
|
end;
|
||||||
{cutrows, NMeta} ->
|
{cutrows, NMeta} ->
|
||||||
{SubStart, NeedNowNum} = rows_sub_params(Len, NMeta),
|
{SubStart, NeedNowNum} = rows_sub_params(Len, NMeta),
|
||||||
ThisRows = lists:sublist(Rows, SubStart, NeedNowNum),
|
ThisRows = lists:sublist(Rows, SubStart, NeedNowNum),
|
||||||
NResults = lists:sublist( lists:append(Results, ThisRows)
|
NResults = lists:sublist( lists:append(Results, ThisRows)
|
||||||
, SubStart, Limit),
|
, SubStart, Limit),
|
||||||
case NContinuation of
|
case NContinuation of
|
||||||
|
|
|
@ -502,7 +502,7 @@ unsubscribe(#{clientid := ClientID, topic := Topic}) ->
|
||||||
end.
|
end.
|
||||||
|
|
||||||
subscribe_batch(#{clientid := ClientID, topics := Topics}) ->
|
subscribe_batch(#{clientid := ClientID, topics := Topics}) ->
|
||||||
ArgList = [[ClientID, Topic, Qos]|| #{topic := Topic, qos := Qos} <- Topics],
|
ArgList = [[ClientID, Topic, Qos] || #{topic := Topic, qos := Qos} <- Topics],
|
||||||
emqx_mgmt_util:batch_operation(?MODULE, do_subscribe, ArgList).
|
emqx_mgmt_util:batch_operation(?MODULE, do_subscribe, ArgList).
|
||||||
|
|
||||||
%%--------------------------------------------------------------------
|
%%--------------------------------------------------------------------
|
||||||
|
@ -628,7 +628,7 @@ fuzzy_filter_fun(Fuzzy) ->
|
||||||
|
|
||||||
run_fuzzy_filter(_, []) ->
|
run_fuzzy_filter(_, []) ->
|
||||||
true;
|
true;
|
||||||
run_fuzzy_filter(E = {_, #{clientinfo := ClientInfo}, _}, [{Key, _, RE}|Fuzzy]) ->
|
run_fuzzy_filter(E = {_, #{clientinfo := ClientInfo}, _}, [{Key, _, RE} | Fuzzy]) ->
|
||||||
Val = case maps:get(Key, ClientInfo, "") of
|
Val = case maps:get(Key, ClientInfo, "") of
|
||||||
undefined -> "";
|
undefined -> "";
|
||||||
V -> V
|
V -> V
|
||||||
|
|
|
@ -165,7 +165,7 @@ fuzzy_filter_fun(Fuzzy) ->
|
||||||
|
|
||||||
run_fuzzy_filter(_, []) ->
|
run_fuzzy_filter(_, []) ->
|
||||||
true;
|
true;
|
||||||
run_fuzzy_filter(E = {{_, Topic}, _}, [{topic, match, TopicFilter}|Fuzzy]) ->
|
run_fuzzy_filter(E = {{_, Topic}, _}, [{topic, match, TopicFilter} | Fuzzy]) ->
|
||||||
emqx_topic:match(Topic, TopicFilter) andalso run_fuzzy_filter(E, Fuzzy).
|
emqx_topic:match(Topic, TopicFilter) andalso run_fuzzy_filter(E, Fuzzy).
|
||||||
|
|
||||||
%%--------------------------------------------------------------------
|
%%--------------------------------------------------------------------
|
||||||
|
|
Loading…
Reference in New Issue