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

Fix whitespace

This commit is contained in:
Feng Lee 2019-07-25 09:26:02 +08:00
parent 5b3a61b799
commit b4a0a1c228
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/emqx_misc.erl
View File

@ -75,9 +75,12 @@ proc_stats() ->
-spec(proc_stats(pid()) -> list()). -spec(proc_stats(pid()) -> list()).
proc_stats(Pid) -> proc_stats(Pid) ->
Stats = process_info(Pid, [message_queue_len, heap_size, reductions]), case process_info(Pid, [message_queue_len, heap_size,
{value, {_, V}, Stats1} = lists:keytake(message_queue_len, 1, Stats), total_heap_size, reductions, memory]) of
[{mailbox_len, V} | Stats1]. undefined -> [];
[{message_queue_len, Len}|Stats] ->
[{mailbox_len, Len}|Stats]
end.
-define(DISABLED, 0). -define(DISABLED, 0).
@ -145,12 +148,11 @@ drain_down(Cnt) when Cnt > 0 ->
drain_down(0, Acc) -> drain_down(0, Acc) ->
lists:reverse(Acc); lists:reverse(Acc);
drain_down(Cnt, Acc) -> drain_down(Cnt, Acc) ->
receive receive
{'DOWN', _MRef, process, Pid, _Reason} -> {'DOWN', _MRef, process, Pid, _Reason} ->
drain_down(Cnt - 1, [Pid|Acc]) drain_down(Cnt - 1, [Pid|Acc])
after 0 -> after 0 ->
drain_down(0, Acc) drain_down(0, Acc)
end. end.