valitydev/riak_test
14
0
Fork 0
mirror of https://github.com/valitydev/riak_test.git synced 2024-11-06 16:45:29 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Change env var name

Browse Source
This commit is contained in:
Russell Brown 2015-01-27 18:00:48 +00:00
parent d22fbfbdc7
commit bc8a3b240b
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tests/riak667_mixed.erl
View File

@ -33,7 +33,7 @@
[{ring_creation_size, 8}] [{ring_creation_size, 8}]
}, },
{riak_kv, {riak_kv,
[{crdt_mixed_versions, true}]} [{mdc_crdt_epoch, 1}]}
]). ]).
confirm() -> confirm() ->
@ -46,7 +46,7 @@ confirm() ->
CurrentVer = rt:get_version(), CurrentVer = rt:get_version(),
lager:info("crdt_mixed_versions? ~p", [rpc:multicall(Nodes, application, get_env, [riak_kv, crdt_mixed_versions])]), lager:info("mdc_crdt_epoch? ~p", [rpc:multicall(Nodes, application, get_env, [riak_kv, mdc_crdt_epoch])]),
%% Create PB connection. %% Create PB connection.
Pid = rt:pbc(Node1), Pid = rt:pbc(Node1),
@ -219,13 +219,13 @@ confirm() ->
{ok, Robj2} = riakc_pb_socket:get(Pid4, ?BUCKET, ?KEY2), {ok, Robj2} = riakc_pb_socket:get(Pid4, ?BUCKET, ?KEY2),
lager:info("crdt_mixed_versions? ~p", [rpc:multicall(Nodes, application, get_env, [riak_kv, crdt_mixed_versions])]), lager:info("mdc_crdt_epoch? ~p", [rpc:multicall(Nodes, application, get_env, [riak_kv, mdc_crdt_epoch])]),
?assert(map_contents_are_lists(Robj2)), ?assert(map_contents_are_lists(Robj2)),
%% unset env var %% unset env var
rpc:multicall(Nodes, application, set_env, [riak_kv, crdt_mixed_versions, false]), rpc:multicall(Nodes, application, set_env, [riak_kv, mdc_crdt_epoch, false]),
lager:info("crdt_mixed_versions? ~p", [rpc:multicall(Nodes, application, get_env, [riak_kv, crdt_mixed_versions])]), lager:info("mdc_crdt_epoch? ~p", [rpc:multicall(Nodes, application, get_env, [riak_kv, mdc_crdt_epoch])]),
%% read and write maps %% read and write maps
{ok, Up1N1} = riakc_pb_socket:fetch_type(Pid4, ?BUCKET, ?KEY), {ok, Up1N1} = riakc_pb_socket:fetch_type(Pid4, ?BUCKET, ?KEY),