use first index instead of hd(preflist) to bin inputs

saves garbage, comparison time
beerriot · May 17, 2012 · 3156f93 · 3156f93
1 parent bc78433
commit 3156f93
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/src/riak_pipe_vnode.erl b/src/riak_pipe_vnode.erl
@@ -228,16 +228,18 @@ queue_work(Fitting, Input, Timeout) ->
         {[term()], [qerror()]}.
 queue_work_list(Fitting, Inputs) ->
     InputBins = bin_inputs(Fitting, Inputs),
-    Results = [ queue_work_list(Fitting, Bin, [], work_hash(Fitting, I))
+    Results = [ queue_work_list(Fitting, Bin, [],
+                                work_hash(Fitting, I))
                 || {_, [I|_]=Bin} <- InputBins ],
     {Leftover, Errors} = lists:unzip(Results),
     {lists:append(Leftover), lists:append(Errors)}.
 
 bin_inputs(Fitting, Inputs) ->
+    {ok, Ring} = riak_core_ring_manager:get_my_ring(),
     lists:foldr(
       fun(I, Acc) ->
-              P = remaining_preflist(
+              P = riak_core_ring:responsible_index(
-                    I, work_hash(Fitting, I), 1, []),
+                    work_hash(Fitting, I), Ring),
               case lists:keytake(P, 1, Acc) of
                   {value, {_, RestI}, NewAcc} ->
                       [{P,[I|RestI]}|NewAcc];