Packages
otpbp
6.3.2
7.18.0
7.16.1
7.15.0
7.14.0
7.13.0
7.12.0
7.11.0
7.10.2
7.9.3
7.9.2
7.9.1
7.8.7
7.8.6
7.8.5
7.8.4
7.7.1
7.7.0
7.6.3
7.6.2
7.6.1
7.6.0
7.5.1
7.5.0
7.4.0
7.3.4
7.3.3
7.3.2
7.3.1
7.3.0
7.2.0
7.1.1
7.1.0
7.0.4
7.0.3
7.0.2
7.0.1
6.26.0
6.25.0
6.24.0
6.23.0
6.22.2
6.21.3
6.21.2
6.21.1
6.20.2
6.19.1
6.19.0
6.18.3
6.18.2
6.18.1
6.18.0
6.17.1
6.17.0
6.16.0
6.15.4
6.15.3
6.15.2
6.15.1
6.15.0
6.14.0
6.13.5
6.13.4
6.13.3
6.13.2
6.13.1
6.13.0
6.12.0
6.11.2
6.11.1
6.10.0
6.9.2
6.9.1
6.9.0
6.8.0
6.7.1
6.7.0
6.6.4
6.6.3
6.6.2
6.6.1
6.6.0
6.5.0
6.4.0
6.3.3
6.3.2
6.3.1
6.3.0
6.2.1
6.2.0
6.1.0
6.0.0
5.39.0
5.38.0
5.37.0
5.36.0
5.35.2
5.34.3
5.34.2
5.34.1
5.33.1
5.32.1
5.32.0
5.31.3
5.31.2
5.31.1
5.31.0
5.30.1
5.30.0
5.29.0
5.28.4
5.28.3
5.28.2
5.28.1
5.28.0
5.27.0
5.26.5
5.26.4
5.26.3
5.26.2
5.26.1
5.26.0
5.25.0
5.24.2
5.24.1
5.23.0
5.22.2
5.22.1
5.22.0
5.21.0
5.20.1
5.20.0
5.19.4
5.19.3
5.19.2
5.19.1
5.19.0
5.18.0
5.17.0
5.16.3
5.16.1
5.16.0
5.15.1
5.15.0
5.14.0
5.13.1
5.13.0
5.12.1
5.12.0
5.11.2
5.11.1
5.10.1
5.10.0
5.9.0
5.8.0
5.7.0
5.6.1
5.6.0
5.5.0
5.4.2
5.4.1
5.4.0
5.3.0
5.2.2
5.2.1
5.2.0
5.1.2
5.1.1
4.79.0
4.78.0
4.77.0
4.76.2
4.75.3
4.75.2
4.75.1
4.74.0
4.73.1
4.73.0
4.72.3
4.72.2
4.72.1
4.72.0
4.71.1
4.71.0
4.70.0
4.69.4
4.69.3
4.69.2
4.69.1
4.69.0
4.68.0
4.67.5
4.67.4
4.67.3
4.67.2
4.67.0
4.66.0
4.65.2
4.65.1
4.64.0
4.63.2
4.63.1
4.63.0
4.62.0
4.61.1
4.61.0
4.60.4
4.60.3
4.60.2
4.60.1
4.60.0
4.59.0
4.58.0
4.57.2
4.57.1
4.57.0
4.56.2
4.56.1
4.56.0
4.55.0
4.54.0
4.53.0
4.52.1
4.52.0
4.51.3
4.51.2
4.51.0
4.50.0
4.49.3
4.49.2
OTP backports
Current section
Files
Jump to
Current section
Files
src/otpbp_scheduler.erl
-module(otpbp_scheduler).
-ifndef(HAVE_scheduler__sample_0).
% OTP 21.0
-export([sample/0]).
-endif.
-ifndef(HAVE_scheduler__sample_all_0).
% OTP 21.0
-export([sample_all/0]).
-endif.
-ifndef(HAVE_scheduler__utilization_1).
% OTP 21.0
-export([utilization/1]).
-endif.
-ifndef(HAVE_scheduler__utilization_2).
% OTP 21.0
-export([utilization/2]).
-endif.
-ifndef(HAVE_scheduler__get_sample_0).
% OTP 24.3
-export([get_sample/0]).
-endif.
-ifndef(HAVE_scheduler__get_sample_all_0).
% OTP 24.3
-export([get_sample_all/0]).
-endif.
-ifndef(HAVE_scheduler__utilization_1).
-ifdef(HAVE_scheduler__utilization_2).
-import(scheduler, [utilization/2]).
-endif.
-endif.
-ifndef(HAVE_scheduler__sample_0).
sample() -> sample(scheduler_wall_time).
-ifndef(NEED_sample_1).
-define(NEED_sample_1, true).
-endif.
-endif.
-ifndef(HAVE_scheduler__sample_all_0).
sample_all() -> sample(scheduler_wall_time_all).
-ifndef(NEED_sample_1).
-define(NEED_sample_1, true).
-endif.
-endif.
-ifndef(HAVE_scheduler__utilization_1).
utilization(Seconds) when is_integer(Seconds), Seconds > 0 ->
erlang:system_flag(scheduler_wall_time, true),
T0 = sample(),
receive
after Seconds * 1000 -> ok
end,
T1 = sample(),
erlang:system_flag(scheduler_wall_time, false),
utilization(T0, T1);
utilization({Stats, _} = T0) when Stats =:= scheduler_wall_time; Stats =:= scheduler_wall_time_all ->
utilization(T0, sample(Stats)).
-ifndef(NEED_sample_1).
-define(NEED_sample_1, true).
-endif.
-endif.
-ifndef(HAVE_scheduler__utilization_2).
utilization({Stats, Ts0}, {Stats, Ts1}) ->
{Lst0, {A, T, N}} = lists:foldl(fun({Tag, I, Adiff, Tdiff}, {Lst, Acc}) ->
R = safe_div(Adiff, Tdiff),
{[{Tag, I, R, percent(R)}|Lst], acc(Tag, Adiff, Tdiff, Acc)}
end,
{[], {0, 0, 0}},
lists:map(fun({{Tag, I, A0, T0}, {Tag, I, A1, T1}}) ->
{Tag, I, (A1 - A0), (T1 - T0)}
end,
lists:zip(Ts0,Ts1))),
Total = safe_div(A, T),
Lst1 = lists:reverse(Lst0),
[{total, Total, percent(Total)}|case erlang:system_info(logical_processors_available) of
unknown -> Lst1;
LPA ->
Weighted = Total * (N / LPA),
[{weighted, Weighted, percent(Weighted)}|Lst1]
end];
utilization({scheduler_wall_time, _} = T0, {scheduler_wall_time_all, Ts1}) -> utilization(T0, remove_io(Ts1));
utilization({scheduler_wall_time_all, Ts0}, {scheduler_wall_time, _} = T1) -> utilization(remove_io(Ts0), T1).
safe_div(_, B) when B == 0.0 -> 0.0;
safe_div(A, B) -> A / B.
percent(F) -> float_to_list(F * 100, [{decimals, 1}]) ++ [$%].
acc(io, _, _, Acc) -> Acc;
acc(Tag, Adiff, Tdiff, {Asum, Tsum, N}) when Tag =:= normal; Tag =:= cpu -> {Adiff + Asum, Tdiff + Tsum, N + 1}.
remove_io(Ts) ->
{scheduler_wall_time,
lists:filter(fun({io, _, _, _}) -> false;
(_) -> true
end,
Ts)}.
-endif.
-ifndef(HAVE_scheduler__get_sample_0).
get_sample() -> get_sample(scheduler_wall_time).
-ifndef(NEED_get_sample_1).
-define(NEED_get_sample_1, true).
-endif.
-endif.
-ifndef(HAVE_scheduler__get_sample_all_0).
get_sample_all() -> get_sample(scheduler_wall_time_all).
-ifndef(NEED_get_sample_1).
-define(NEED_get_sample_1, true).
-endif.
-endif.
-ifdef(NEED_sample_1).
sample(Stats) ->
case statistics(Stats) of
undefined ->
erlang:system_flag(scheduler_wall_time, true),
sample(Stats);
List -> create_sample(Stats, List)
end.
-ifndef(NEED_create_sample_2).
-define(NEED_create_sample_2, true).
-endif.
-endif.
-ifdef(NEED_get_sample_1).
get_sample(Stats) ->
case statistics(Stats) of
undefined -> undefined;
List -> create_sample(Stats, List)
end.
-ifndef(NEED_create_sample_2).
-define(NEED_create_sample_2, true).
-endif.
-endif.
-ifdef(NEED_create_sample_2).
create_sample(Stats, List) ->
Normal = erlang:system_info(schedulers),
Cpu = erlang:system_info(dirty_cpu_schedulers) + Normal,
{Stats,
lists:map(fun({I, A, T}) ->
{if
Normal >= I -> normal;
Cpu >= I -> cpu;
true -> io
end,
I, A, T}
end,
lists:sort(List))}.
-endif.