mirror of
https://github.com/valitydev/riak_test.git
synced 2024-11-06 00:25:22 +00:00
Correct path in tests
This commit is contained in:
parent
c2b589b323
commit
427aa12dac
@ -1,3 +1,4 @@
|
||||
cuttlefish_configuration
|
||||
verify_2i_aae
|
||||
verify_2i_mixed_cluster
|
||||
cuttlefish_configuration
|
||||
verify_kv1356
|
||||
|
@ -38,18 +38,29 @@
|
||||
-define(KEY, <<"k">>).
|
||||
-define(VALUE, <<"v">>).
|
||||
|
||||
confirm() ->
|
||||
Conf = [{eleveldb, [{data_root, "leveldb"},
|
||||
-define(HARNESS, (rt_config:get(rt_harness))).
|
||||
|
||||
-define(ELEVELDB_CONF(Path),
|
||||
[{eleveldb, [{data_root, "leveldb"},
|
||||
{tiered_slow_level, 4},
|
||||
{tiered_fast_prefix, "/opt/riak/fast/"},
|
||||
{tiered_slow_prefix, "/opt/riak/slow/"}
|
||||
]},
|
||||
{riak_kv, [{handoff_concurrency, 100},
|
||||
{tiered_fast_prefix, Path ++ "/fast"},
|
||||
{tiered_slow_prefix, Path ++ "/slow"}
|
||||
]}]).
|
||||
|
||||
confirm() ->
|
||||
Conf = [{riak_kv, [{handoff_concurrency, 100},
|
||||
{storage_backend, riak_kv_eleveldb_backend}]},
|
||||
{riak_core, [ {ring_creation_size, 8},
|
||||
{vnode_management_timer, 1000}]}],
|
||||
lager:info("Deploy a node"),
|
||||
[Node] = rt:deploy_nodes(1, Conf),
|
||||
[NodeInit] = rt:deploy_nodes(1, Conf),
|
||||
Path = data_path(NodeInit),
|
||||
rt:clean_cluster([NodeInit]),
|
||||
ok = filelib:ensure_dir(Path ++ "/fast/leveldb/"),
|
||||
ok = filelib:ensure_dir(Path ++ "/slow/leveldb/"),
|
||||
|
||||
[Node] = rt:deploy_nodes(1, ?ELEVELDB_CONF(Path) ++ Conf),
|
||||
|
||||
Client = rt:pbc(Node, [{auto_reconnect, true}, {queue_if_disconnected, true}]),
|
||||
lager:info("write value"),
|
||||
ok = rt:pbc_write(Client, ?BUCKET, ?KEY, ?VALUE),
|
||||
@ -65,3 +76,6 @@ confirm() ->
|
||||
|
||||
assertObjectValueEqual(Val, Obj) ->
|
||||
?assertEqual(Val, riakc_obj:get_value(Obj)).
|
||||
|
||||
data_path(Node) ->
|
||||
?HARNESS:node_path(Node) ++ "tiered_path".
|
||||
|
@ -295,7 +295,7 @@ base_dir_for_backend(leveled) ->
|
||||
base_dir_for_backend(bitcask) ->
|
||||
"bitcask";
|
||||
base_dir_for_backend(eleveldb) ->
|
||||
"leveledb".
|
||||
"leveldb".
|
||||
|
||||
restart_vnode(Node, Service, Partition) ->
|
||||
VNodeName = list_to_atom(atom_to_list(Service) ++ "_vnode"),
|
||||
|
Loading…
Reference in New Issue
Block a user