@@ -100,7 +100,7 @@ check_leave_and_expiry(NodeA, NodeB) ->
100100 _ = rt :systest_read (NodeA , 1 , 100 , ? BUCKET , 2 ),
101101 timer :sleep (timer :seconds (5 )),
102102 Res = rt :systest_read (NodeA , 1 , 100 , ? BUCKET , 2 ),
103-
103+
104104 ? assertEqual (100 , length (Res )),
105105 ok .
106106
@@ -201,10 +201,7 @@ put_until_changed(Pid, Node, Key) ->
201201 end .
202202
203203mkconf (Test , Mode ) ->
204- RiakCore = [
205- {ring_creation_size , 4 }
206- ],
207- MembConfig =
204+ MembConfig =
208205 case Test of
209206 ttl ->
210207 [{ttl , 200 }];
@@ -220,7 +217,9 @@ mkconf(Test, Mode) ->
220217 rt :set_backend (memory ),
221218
222219 [
223- {riak_core , RiakCore },
220+ {riak_core , [
221+ {ring_creation_size , 4 }
222+ ]},
224223 {riak_kv , [
225224 {anti_entropy , {off , []}},
226225 {delete_mode , immediate },
@@ -230,7 +229,9 @@ mkconf(Test, Mode) ->
230229 multi ->
231230 rt :set_backend (multi ),
232231 [
233- {riak_core , RiakCore },
232+ {riak_core , [
233+ {ring_creation_size , 4 }
234+ ]},
234235 {riak_kv , [
235236 {anti_entropy , {off , []}},
236237 {delete_mode , immediate },
@@ -255,7 +256,7 @@ get_remote_vnode_pid(Node) ->
255256get_used_space (VNode , Node ) ->
256257 S = rpc :call (Node , sys , get_state , [VNode ]),
257258 Mode = get (mode ),
258- Version = rt :get_version (Node ),
259+ Version = rt :get_version (),
259260 % % lager:info("version mode ~p", [{Version, Mode}]),
260261 TwoOhReg =
261262 fun (X ) ->
@@ -280,10 +281,6 @@ get_used_space(VNode, Node) ->
280281 TwoOhMulti ;
281282 {<<" riak_ee-2.0" ,_ /binary >>, multi } ->
282283 TwoOhMulti ;
283- {<<" head" ,_ /binary >>, regular } ->
284- TwoOhReg ;
285- {<<" head" ,_ /binary >>, multi } ->
286- TwoOhMulti ;
287284 _Else ->
288285 lager :error (" didn't understand version/mode tuple ~p " ,
289286 [{Version , Mode }]),
0 commit comments