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

Set Jitter correctly this time

Browse source
This commit is contained in:
martinsumner 2016-12-08 21:02:39 +00:00
parent b03ef664c8
commit 2f4013f430
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/leveled_bookie.erl
View file

@ -231,7 +231,7 @@ init([Opts]) ->
% Start from file not snapshot % Start from file not snapshot
{InkerOpts, PencillerOpts} = set_options(Opts), {InkerOpts, PencillerOpts} = set_options(Opts),
{Inker, Penciller} = startup(InkerOpts, PencillerOpts), {Inker, Penciller} = startup(InkerOpts, PencillerOpts),
CacheJitter = ?CACHE_SIZE div ?CACHE_SIZE_JITTER, CacheJitter = ?CACHE_SIZE div (100 div ?CACHE_SIZE_JITTER),
CacheSize = get_opt(cache_size, Opts, ?CACHE_SIZE) CacheSize = get_opt(cache_size, Opts, ?CACHE_SIZE)
+ erlang:phash2(self()) band CacheJitter, + erlang:phash2(self()) band CacheJitter,
leveled_log:log("B0001", [Inker, Penciller]), leveled_log:log("B0001", [Inker, Penciller]),
@ -666,7 +666,7 @@ snapshot_store(State, SnapType) ->
set_options(Opts) -> set_options(Opts) ->
MaxJournalSize0 = get_opt(max_journalsize, Opts, 10000000000), MaxJournalSize0 = get_opt(max_journalsize, Opts, 10000000000),
JournalSizeJitter = MaxJournalSize0 div ?JOURNAL_SIZE_JITTER, JournalSizeJitter = MaxJournalSize0 div (100 div ?JOURNAL_SIZE_JITTER),
MaxJournalSize = MaxJournalSize0 - MaxJournalSize = MaxJournalSize0 -
erlang:phash2(self()) band JournalSizeJitter, erlang:phash2(self()) band JournalSizeJitter,