anchor.diff:      R = riak_kv_util:expand_rw_value(r, R0, BucketProps, N),
       case R > N of
           true ->
  -            Client ! {ReqId, {error, {n_val_violation, N}}},
  +            client_reply({error, {n_val_violation, N}}, StateData0),
               {stop, normal, StateData0};
           false -> 
               AllowMult = proplists:get_value(allow_mult,BucketProps),
  
positive.code:                 req_id=ReqId, bkey={Bucket,Key}, ring=Ring},
      {ok,initialize,StateData,0}.
  
  
  
  %% @private
  initialize(timeout, StateData0=#state{timeout=Timeout, r=R0, req_id=ReqId,
                                        bkey={Bucket,Key}=BKey, ring=Ring,
                                        client=Client}) ->
      StartNow = now(),
      TRef = erlang:send_after(Timeout, self(), timeout),
      DocIdx = riak_core_util:chash_key({Bucket, Key}),
  
negative.code:             {next_state,waiting_vnode_r,NewStateData};
          true ->
              update_stats(StateData),
              client_reply({error,notfound}, StateData),
              Final = merge(Replied,AllowMult),
              finalize(NewStateData#state{final_obj=Final})
      end;
  waiting_vnode_r({r, {error, Err}, Idx, ReqId},
                    StateData=#state{r=R,n=N,allowmult=AllowMult,
                                     replied_r=Replied,
                                     replied_fail=Failed0,req_id=ReqId,
                                     replied_notfound=NotFound}) ->
  