@@ -147,7 +147,8 @@ acc_preflists(Pl, PlCounts) ->
147147 end , PlCounts , Pl ).
148148
149149test_data_ts (Start , End ) ->
150- ts_data :get_valid_select_data (fun () -> lists :seq (Start , End ) end ).
150+ StepSize = 1000 * 60 * 5 ,
151+ ts_data :get_valid_select_data (fun () -> lists :seq (1 + StepSize * Start , 1 + StepSize * End , StepSize ) end ).
151152
152153key_ts (Data ) ->
153154 lists :sublist (tuple_to_list (Data ), 3 ).
@@ -159,7 +160,6 @@ write_data_ts(Node, KVs, Table) ->
159160 write_data_ts (Node , KVs , Table , []).
160161
161162write_data_ts (Node , KVs , Table , _Opts ) ->
162- % PB = rt:pbc(Node),
163163 [begin
164164 O =
165165 case ts_ops :get ([Node ], Table , key_ts (TS_Data_Tuple )) of
@@ -170,7 +170,6 @@ write_data_ts(Node, KVs, Table, _Opts) ->
170170 end ,
171171 ? assertMatch (ok , ts_ops :put ([Node ], Table , O ))
172172 end || TS_Data_Tuple <- KVs ],
173- % riakc_pb_socket:stop(PB),
174173 ok .
175174
176175% @doc Verifies that the data is eventually restored to the expected set.
@@ -324,11 +323,7 @@ wipe_out_aae_data(Node, Partition) ->
324323 rt :clean_data_dir (Node , " anti_entropy/" ++ integer_to_list (Partition )),
325324 ok .
326325
327- base_dir_for_backend (undefined ) ->
328- base_dir_for_backend (bitcask );
329- base_dir_for_backend (bitcask ) ->
330- " bitcask" ;
331- base_dir_for_backend (eleveldb ) ->
326+ base_dir_for_backend () ->
332327 " leveldb" .
333328
334329restart_vnode (Node , Service , Partition ) ->
@@ -352,9 +347,7 @@ restart_vnode(Node, Service, Partition) ->
352347 [Partition , NewPid ]).
353348
354349dir_for_partition (Partition ) ->
355- TestMetaData = riak_test_runner :metadata (),
356- KVBackend = proplists :get_value (backend , TestMetaData ),
357- BaseDir = base_dir_for_backend (KVBackend ),
350+ BaseDir = base_dir_for_backend (),
358351 filename :join ([BaseDir , integer_to_list (Partition )]).
359352
360353% @doc True if the AAE stats report zero data repairs for last exchange
@@ -398,4 +391,14 @@ all_hashtrees_upgraded(Node) when is_atom(Node) ->
398391 _ ->
399392 false
400393 end .
394+ get_trees_version , []),
395+ case [Idx || {Idx , undefined } <- Trees ] of
396+ [] ->
397+ true ;
398+ _ ->
399+ false
400+ end ;
401+ _ ->
402+ false
403+ end .
401404
0 commit comments