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

Cleanup dialyzer errrors in leveled_penciller

Browse source
This commit is contained in:
Heinz N. Gies 2017-07-31 19:39:40 +02:00
parent 858ee9a915
commit 369bdece5f
2 changed files with 12 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

8
include/leveled.hrl
View file

@ -51,12 +51,12 @@
max_run_length}). max_run_length}).
-record(penciller_options, -record(penciller_options,
{root_path :: string(), {root_path :: string() | undefined,
max_inmemory_tablesize :: integer(), max_inmemory_tablesize :: integer() | undefined,
start_snapshot = false :: boolean(), start_snapshot = false :: boolean(),
snapshot_query, snapshot_query,
bookies_mem :: tuple(), bookies_mem :: tuple() | undefined,
source_penciller :: pid(), source_penciller :: pid() | undefined,
snapshot_longrunning = true :: boolean(), snapshot_longrunning = true :: boolean(),
levelzero_cointoss = false :: boolean()}). levelzero_cointoss = false :: boolean()}).

18
src/leveled_penciller.erl
View file

@ -223,25 +223,25 @@
ledger_sqn = 0 :: integer(), % The highest SQN added to L0 ledger_sqn = 0 :: integer(), % The highest SQN added to L0
root_path = "../test" :: string(), root_path = "../test" :: string(),
clerk :: pid(), clerk :: pid() | undefined,
levelzero_pending = false :: boolean(), levelzero_pending = false :: boolean(),
levelzero_constructor :: pid(), levelzero_constructor :: pid() | undefined,
levelzero_cache = [] :: list(), % a list of trees levelzero_cache = [] :: list(), % a list of trees
levelzero_size = 0 :: integer(), levelzero_size = 0 :: integer(),
levelzero_maxcachesize :: integer(), levelzero_maxcachesize :: integer() | undefined,
levelzero_cointoss = false :: boolean(), levelzero_cointoss = false :: boolean(),
levelzero_index, % An array levelzero_index, % An array
is_snapshot = false :: boolean(), is_snapshot = false :: boolean(),
snapshot_fully_loaded = false :: boolean(), snapshot_fully_loaded = false :: boolean(),
source_penciller :: pid(), source_penciller :: pid() | undefined,
levelzero_astree :: list(), levelzero_astree :: list() | undefined,
work_ongoing = false :: boolean(), % i.e. compaction work work_ongoing = false :: boolean(), % i.e. compaction work
work_backlog = false :: boolean(), % i.e. compaction work work_backlog = false :: boolean(), % i.e. compaction work
head_timing :: tuple()}). head_timing :: tuple() | undefined}).
-type penciller_options() :: #penciller_options{}. -type penciller_options() :: #penciller_options{}.
-type bookies_memory() :: {tuple()|empty_cache, -type bookies_memory() :: {tuple()|empty_cache,
@ -1269,9 +1269,7 @@ keyfolder({[{IMMKey, IMMVal}|NxIMMiterator], SSTiterator}, KeyRange,
generate_randomkeys({Count, StartSQN}) -> generate_randomkeys({Count, StartSQN}) ->
generate_randomkeys(Count, StartSQN, []); generate_randomkeys(Count, StartSQN, []).
generate_randomkeys(Count) ->
generate_randomkeys(Count, 0, []).
generate_randomkeys(0, _SQN, Acc) -> generate_randomkeys(0, _SQN, Acc) ->
lists:reverse(Acc); lists:reverse(Acc);
@ -1622,7 +1620,7 @@ foldwithimm_simple_test() ->
create_file_test() -> create_file_test() ->
{RP, Filename} = {"../test/", "new_file.sst"}, {RP, Filename} = {"../test/", "new_file.sst"},
ok = file:write_file(filename:join(RP, Filename), term_to_binary("hello")), ok = file:write_file(filename:join(RP, Filename), term_to_binary("hello")),
KVL = lists:usort(generate_randomkeys(10000)), KVL = lists:usort(generate_randomkeys({10000, 0})),
Tree = leveled_tree:from_orderedlist(KVL, ?CACHE_TYPE), Tree = leveled_tree:from_orderedlist(KVL, ?CACHE_TYPE),
FetchFun = fun(Slot) -> lists:nth(Slot, [Tree]) end, FetchFun = fun(Slot) -> lists:nth(Slot, [Tree]) end,
{ok, {ok,