home
/
code
/
beam_stats.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge pull request #20 from ibnfirnas/per-process-reductions
[beam_stats.git]
/
src
/
beam_stats_processes.erl
diff --git
a/src/beam_stats_processes.erl
b/src/beam_stats_processes.erl
index
90c3886
..
d369314
100644
(file)
--- a/
src/beam_stats_processes.erl
+++ b/
src/beam_stats_processes.erl
@@
-8,8
+8,8
@@
]).
-export(
]).
-export(
- [ collect/
0
- , collect_and_print/
0
+ [ collect/
1
+ , collect_and_print/
1
, print/1
]).
, print/1
]).
@@
-18,11
+18,12
@@
-type t() ::
?T{}.
-type t() ::
?T{}.
--spec collect() ->
+-spec collect(
beam_stats_delta:t()
) ->
t().
t().
-collect() ->
+collect(
DeltasServer
) ->
Pids = beam_stats_source:erlang_processes(),
Pids = beam_stats_source:erlang_processes(),
- Ps = [beam_stats_process:of_pid(P) || P <- Pids],
+ PsOpts = [beam_stats_process:of_pid(P, DeltasServer) || P <- Pids],
+ Ps = [P || {some, P} <- PsOpts],
?T
{ individual_stats
= Ps
?T
{ individual_stats
= Ps
@@
-44,8
+45,10
@@
collect() ->
= length([P || P <- Ps, P#beam_stats_process.status =:= waiting])
}.
= length([P || P <- Ps, P#beam_stats_process.status =:= waiting])
}.
-collect_and_print() ->
- print(collect()).
+-spec collect_and_print(beam_stats_delta:t()) ->
+ ok.
+collect_and_print(DeltasServer) ->
+ print(collect(DeltasServer)).
-spec print(t()) ->
ok.
-spec print(t()) ->
ok.
This page took
0.023843 seconds
and
4
git commands to generate.