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

Add timer for SST creation

Browse source
This commit is contained in:
martinsumner 2016-12-29 02:55:28 +00:00
parent c3999110e2
commit 3f3b36597a
1 changed files with 8 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

10
src/leveled_sst.erl
View file

@ -224,6 +224,7 @@ starting({sst_open, Filename}, _From, State) ->
reader, reader,
UpdState}; UpdState};
starting({sst_new, Filename, Level, KVList, MaxSQN}, _From, State) -> starting({sst_new, Filename, Level, KVList, MaxSQN}, _From, State) ->
SW = os:timestamp(),
{FirstKey, L, SlotIndex, AllHashes, SlotsBin} = build_all_slots(KVList), {FirstKey, L, SlotIndex, AllHashes, SlotsBin} = build_all_slots(KVList),
SummaryBin = build_table_summary(SlotIndex, SummaryBin = build_table_summary(SlotIndex,
AllHashes, AllHashes,
@ -234,7 +235,9 @@ starting({sst_new, Filename, Level, KVList, MaxSQN}, _From, State) ->
ActualFilename = write_file(Filename, SummaryBin, SlotsBin), ActualFilename = write_file(Filename, SummaryBin, SlotsBin),
UpdState = read_file(ActualFilename, State), UpdState = read_file(ActualFilename, State),
Summary = UpdState#state.summary, Summary = UpdState#state.summary,
leveled_log:log("SST08", [ActualFilename, Level, Summary#summary.max_sqn]), leveled_log:log_timer("SST08",
[ActualFilename, Level, Summary#summary.max_sqn],
SW),
{reply, {reply,
{ok, {Summary#summary.first_key, Summary#summary.last_key}}, {ok, {Summary#summary.first_key, Summary#summary.last_key}},
reader, reader,
@ -242,6 +245,7 @@ starting({sst_new, Filename, Level, KVList, MaxSQN}, _From, State) ->
starting({sst_newlevelzero, Filename, Slots, FetchFun, Penciller, MaxSQN}, starting({sst_newlevelzero, Filename, Slots, FetchFun, Penciller, MaxSQN},
State) -> State) ->
SW = os:timestamp(),
KVList = leveled_pmem:to_list(Slots, FetchFun), KVList = leveled_pmem:to_list(Slots, FetchFun),
{FirstKey, L, SlotIndex, AllHashes, SlotsBin} = build_all_slots(KVList), {FirstKey, L, SlotIndex, AllHashes, SlotsBin} = build_all_slots(KVList),
SummaryBin = build_table_summary(SlotIndex, SummaryBin = build_table_summary(SlotIndex,
@ -253,7 +257,9 @@ starting({sst_newlevelzero, Filename, Slots, FetchFun, Penciller, MaxSQN},
ActualFilename = write_file(Filename, SummaryBin, SlotsBin), ActualFilename = write_file(Filename, SummaryBin, SlotsBin),
UpdState = read_file(ActualFilename, State), UpdState = read_file(ActualFilename, State),
Summary = UpdState#state.summary, Summary = UpdState#state.summary,
leveled_log:log("SST08", [ActualFilename, 0, Summary#summary.max_sqn]), leveled_log:log_timer("SST08",
[ActualFilename, 0, Summary#summary.max_sqn],
SW),
case Penciller of case Penciller of
undefined -> undefined ->
{next_state, reader, UpdState}; {next_state, reader, UpdState};