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

Parameter Experiment

Browse source 
Try some different default parameters
This commit is contained in:
martinsumner 2016-10-26 11:50:59 +01:00
parent 0c331b9c30
commit 6f40869070
3 changed files with 6 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/leveled_cdb.erl
View file

@ -1819,6 +1819,10 @@ mput_test() ->
{ok, P1} = cdb_open_writer("../test/nohash_keysinfile.pnd"), {ok, P1} = cdb_open_writer("../test/nohash_keysinfile.pnd"),
KVList = generate_sequentialkeys(KeyCount, []), KVList = generate_sequentialkeys(KeyCount, []),
ok = cdb_mput(P1, KVList), ok = cdb_mput(P1, KVList),
?assertMatch({"Key1", "Value1"}, cdb_get(P1, "Key1")),
?assertMatch({"Key1024", "Value1024"}, cdb_get(P1, "Key1024")),
?assertMatch(missing, cdb_get(P1, "Key1025")),
?assertMatch(missing, cdb_get(P1, "Key1026")),
{ok, F2} = cdb_complete(P1), {ok, F2} = cdb_complete(P1),
{ok, P2} = cdb_open_reader(F2), {ok, P2} = cdb_open_reader(F2),
?assertMatch("Key1", cdb_firstkey(P2)), ?assertMatch("Key1", cdb_firstkey(P2)),

2
src/leveled_iclerk.erl
View file

@ -79,7 +79,7 @@
-define(JOURNAL_FILEX, "cdb"). -define(JOURNAL_FILEX, "cdb").
-define(PENDING_FILEX, "pnd"). -define(PENDING_FILEX, "pnd").
-define(SAMPLE_SIZE, 200). -define(SAMPLE_SIZE, 200).
-define(BATCH_SIZE, 16). -define(BATCH_SIZE, 32).
-define(BATCHES_TO_CHECK, 8). -define(BATCHES_TO_CHECK, 8).
%% How many consecutive files to compact in one run %% How many consecutive files to compact in one run
-define(MAX_COMPACTION_RUN, 4). -define(MAX_COMPACTION_RUN, 4).

2
src/leveled_sft.erl
View file

@ -265,7 +265,7 @@ sft_deleteconfirmed(Pid) ->
gen_server:cast(Pid, close). gen_server:cast(Pid, close).
sft_checkready(Pid) -> sft_checkready(Pid) ->
gen_server:call(Pid, background_complete, 50). gen_server:call(Pid, background_complete, 20).
sft_getmaxsequencenumber(Pid) -> sft_getmaxsequencenumber(Pid) ->
gen_server:call(Pid, get_maxsqn, infinity). gen_server:call(Pid, get_maxsqn, infinity).