anchor.diff:           -> {ok | forward_preflist | {error, term()}, state()}.
   process(Input, Last, #state{partition=Partition, fd=FittingDetails}=State) ->
       ReqId = make_req_id(),
  +    Start = erlang:now(),
       riak_core_vnode_master:command(
         {Partition, node()}, %% assume local chashfun was used
         ?KV_GET_REQ{bkey=bkey(Input), req_id=ReqId},
  
positive.code:       riak_kv_vnode_master),
      receive
          {ReqId, {r, {ok, Obj}, _, _}} ->
              case riak_pipe_vnode_worker:send_output(
                     {ok, Obj, keydata(Input)}, Partition, FittingDetails) of
                  ok ->
  
negative.code:                     {ER, State}
              end;
          {ReqId, {r, {error, _} = Error, _, _}} ->
              ?T(FittingDetails, [kv_get], [{Error, timer:now_diff(erlang:now(), Start)}]),
              if Last ->
                      case riak_pipe_vnode_worker:send_output(
                             {Error, bkey(Input), keydata(Input)},
  