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

fix: trace len > 1 return 500

This commit is contained in:
zhongwencool 2021-12-03 10:24:36 +08:00
parent 20a98bee62
commit 28e76e498c
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
apps/emqx_plugin_libs/src/emqx_trace/emqx_trace_api.erl
View File

@ -38,7 +38,8 @@ list_trace(_, _Params) ->
case emqx_trace:list() of case emqx_trace:list() of
[] -> {ok, []}; [] -> {ok, []};
List0 -> List0 ->
List = lists:sort(fun(#{start_at := A}, #{start_at := B}) -> A > B end, List0), List = lists:sort(fun(#{start_at := A}, #{start_at := B}) -> A > B end,
emqx_trace:format(List0)),
Nodes = ekka_mnesia:running_nodes(), Nodes = ekka_mnesia:running_nodes(),
TraceSize = cluster_call(?MODULE, get_trace_size, [], 30000), TraceSize = cluster_call(?MODULE, get_trace_size, [], 30000),
AllFileSize = lists:foldl(fun(F, Acc) -> maps:merge(Acc, F) end, #{}, TraceSize), AllFileSize = lists:foldl(fun(F, Acc) -> maps:merge(Acc, F) end, #{}, TraceSize),
@ -50,12 +51,12 @@ list_trace(_, _Params) ->
LogSize = collect_file_size(Nodes, FileName, AllFileSize), LogSize = collect_file_size(Nodes, FileName, AllFileSize),
Trace0 = maps:without([enable, filter], Trace), Trace0 = maps:without([enable, filter], Trace),
Trace0#{ log_size => LogSize Trace0#{ log_size => LogSize
, Type => Filter , Type => iolist_to_binary(Filter)
, start_at => list_to_binary(calendar:system_time_to_rfc3339(Start)) , start_at => list_to_binary(calendar:system_time_to_rfc3339(Start))
, end_at => list_to_binary(calendar:system_time_to_rfc3339(End)) , end_at => list_to_binary(calendar:system_time_to_rfc3339(End))
, status => status(Enable, Start, End, Now) , status => status(Enable, Start, End, Now)
} }
end, emqx_trace:format(List)), end, List),
{ok, Traces} {ok, Traces}
end. end.