X-Git-Url: https://git.xandkar.net/?p=beam_stats.git;a=blobdiff_plain;f=src%2Fbeam_stats_processes.erl;h=2505178132606005c0178399fd1bd36f56c63806;hp=707a534d5d81bc6c018422dfcf44095f04cbaf2d;hb=fa175c943c5d08ca2fdf2156abc3023ccf8b9baa;hpb=5acc9b7d2c0966e92e539f9906ae9f0786ae3389 diff --git a/src/beam_stats_processes.erl b/src/beam_stats_processes.erl index 707a534..2505178 100644 --- a/src/beam_stats_processes.erl +++ b/src/beam_stats_processes.erl @@ -9,6 +9,8 @@ -export( [ collect/0 + , collect_and_print/0 + , print/1 ]). -define(T, #?MODULE). @@ -40,3 +42,51 @@ collect() -> , count_waiting = length([P || P <- Ps, P#beam_stats_process.status =:= waiting]) }. + +collect_and_print() -> + print(collect()). + +-spec print(t()) -> + ok. +print( + ?T + { individual_stats = PerProcessStats + , count_all = CountAll + , count_exiting = CountExiting + , count_garbage_collecting = CountGarbageCollecting + , count_registered = CountRegistered + , count_runnable = CountRunnable + , count_running = CountRunning + , count_suspended = CountSuspended + , count_waiting = CountWaiting + } +) -> + PerProcessStatsSorted = lists:sort( + fun (#beam_stats_process{memory=A}, #beam_stats_process{memory=B}) -> + % From lowest to highest: + A < B + end, + PerProcessStats + ), + lists:foreach(fun beam_stats_process:print/1, PerProcessStatsSorted), + io:format("==================================================~n"), + io:format( + "CountAll : ~b~n" + "CountExiting : ~b~n" + "CountGarbageCollecting : ~b~n" + "CountRegistered : ~b~n" + "CountRunnable : ~b~n" + "CountRunning : ~b~n" + "CountSuspended : ~b~n" + "CountWaiting : ~b~n" + "~n", + [ CountAll + , CountExiting + , CountGarbageCollecting + , CountRegistered + , CountRunnable + , CountRunning + , CountSuspended + , CountWaiting + ] + ).