umgeher/leveled
0
Fork 0
Code Issues Pull requests Releases Activity Actions

put-timing default

Browse source 
Remove need for individual actors to know the defaults for put_timing
tuple
This commit is contained in:
Martin Sumner 2016-12-22 14:41:43 +00:00
parent e9e0a7b323
commit 7a0cf22909
4 changed files with 6 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/leveled_bookie.erl
View file

@ -162,7 +162,7 @@
ledger_cache = #ledger_cache{},
is_snapshot :: boolean(),
slow_offer = false :: boolean(),
put_timing = {0, {0, 0}, {0, 0}} :: tuple()}).
put_timing :: tuple()}).
%%%============================================================================

2
src/leveled_cdb.erl
View file

@ -109,7 +109,7 @@
deferred_delete = false :: boolean(),
waste_path :: string(),
sync_strategy = none,
put_timing = {0, {0, 0}, {0, 0}} :: tuple()}).
put_timing :: tuple()}).
%%%============================================================================

2
src/leveled_inker.erl
View file

@ -139,7 +139,7 @@
compaction_pending = false :: boolean(),
is_snapshot = false :: boolean(),
source_inker :: pid(),
put_timing = {0, {0, 0}, {0, 0}} ::tuple()}).
put_timing :: tuple()}).
%%%============================================================================

4
src/leveled_log.erl
View file

@ -328,6 +328,8 @@ log_timer(LogReference, Subs, StartTime) ->
%% Make a log of put timings split out by actor - one log for every
%% PUT_TIMING_LOGPOINT puts
put_timings(_Actor, undefined, T0, T1) ->
{1, {T0, T1}, {T0, T1}};
put_timings(Actor, {?PUT_TIMING_LOGPOINT, {Total0, Total1}, {Max0, Max1}}, T0, T1) ->
LogRef =
case Actor of
@ -336,7 +338,7 @@ put_timings(Actor, {?PUT_TIMING_LOGPOINT, {Total0, Total1}, {Max0, Max1}}, T0, T
journal -> "CDB17"
end,
log(LogRef, [?PUT_TIMING_LOGPOINT, Total0, Total1, Max0, Max1]),
{1, {T0, T1}, {T0, T1}};
put_timings(Actor, undefined, T0, T1);
put_timings(_Actor, {N, {Total0, Total1}, {Max0, Max1}}, T0, T1) ->
{N + 1, {Total0 + T0, Total1 + T1}, {max(Max0, T0), max(Max1, T1)}}.