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

Fix broken SST cache

Browse source
This commit is contained in:
martinsumner 2017-01-03 13:03:59 +00:00
parent d28e5d639c
commit b6ae0e1af5
2 changed files with 14 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/leveled_log.erl
View file

@ -433,7 +433,7 @@ sst_timing({N, SSTTimerD}, SW, TimerType) ->
end.
sst_keylist() ->
[summary_bloom, slot_cache, slot_bloom, slot_fetch].
[slot_cache, slot_bloom, slot_fetch].
get_timing(undefined, SW, TimerType) ->

17
src/leveled_sst.erl
View file

@ -303,12 +303,12 @@ reader({get_kv, LedgerKey, Hash}, _From, State) ->
case {Result, Stage} of
{not_present, _} ->
{reply, Result, reader, UpdState#state{sst_timings = UpdTimings}};
{KV, slot_lookup_hit} ->
{_KV, slot_cache} ->
{reply, Result, reader, UpdState#state{sst_timings = UpdTimings}};
{KV, _} ->
UpdCache = array:set(SlotID - 1, KV, State#state.lastfetch_cache),
{reply, Result, reader, UpdState#state{lastfetch_cache = UpdCache,
sst_timings = UpdTimings}};
_ ->
{reply, Result, reader, UpdState#state{sst_timings = UpdTimings}}
sst_timings = UpdTimings}}
end;
reader({get_kvrange, StartKey, EndKey, ScanWidth}, _From, State) ->
{reply,
@ -1477,6 +1477,15 @@ simple_persisted_test() ->
1,
KVList1,
length(KVList1)),
SW0 = os:timestamp(),
lists:foreach(fun({K, V}) ->
?assertMatch({K, V}, sst_get(Pid, K))
end,
KVList1),
io:format(user,
"Checking for ~w keys (once) in file with cache hit took ~w "
++ "microseconds~n",
[length(KVList1), timer:now_diff(os:timestamp(), SW0)]),
SW1 = os:timestamp(),
lists:foreach(fun({K, V}) ->
?assertMatch({K, V}, sst_get(Pid, K)),