@@ -241,7 +241,7 @@ run(listkeys, _KeyGen, _ValueGen, State) ->
241
241
run (search , _KeyGen , _ValueGen , # state {search_queries = SearchQs }= State ) ->
242
242
[{Index , Query , Options }|_ ] = SearchQs ,
243
243
244
- NewState = State # state {search_queries = roll_search_query_list (SearchQs )},
244
+ NewState = State # state {search_queries = roll_list (SearchQs )},
245
245
246
246
case riakc_pb_socket :search (NewState # state .pid , Index , Query , Options , NewState # state .timeout_read ) of
247
247
{ok , _Results } ->
@@ -255,7 +255,7 @@ run(search_interval, _KeyGen, _ValueGen, #state{search_queries=SearchQs, start_t
255
255
Now = erlang :now (),
256
256
case timer :now_diff (Now , StartTime ) of
257
257
_MicroSec when _MicroSec > (Interval * 1000000 ) ->
258
- NewState = State # state {search_queries = roll_search_query_list (SearchQs ),start_time = Now };
258
+ NewState = State # state {search_queries = roll_list (SearchQs ),start_time = Now };
259
259
_MicroSec ->
260
260
NewState = State
261
261
end ,
@@ -372,7 +372,7 @@ make_keylist(Bucket, KeyGen, Count) ->
372
372
[{Bucket , list_to_binary (KeyGen ())}
373
373
|make_keylist (Bucket , KeyGen , Count - 1 )].
374
374
375
- roll_search_query_list (List ) ->
375
+ roll_list (List ) ->
376
376
[lists :last (List ) | lists :sublist (List , length (List ) - 1 )].
377
377
378
378
mapred_valgen (_Id , MaxRand ) ->
0 commit comments