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: %% @private
  code_change(_OldVsn, StateName, State, _Extra) -> {ok, StateName, State}.
  
  merge(VResponses, AllowMult) ->
     merge_robjs([R || {R,_I} <- VResponses],AllowMult).
  
  respond(Client,VResponses,AllowMult,ReqId) ->
      Merged = merge(VResponses, AllowMult),
      case Merged of
          tombstone ->
  
negative.code:     end;
  waiting_vnode_r({r, {error, notfound}, Idx, ReqId},
                    StateData=#state{r=R,allowmult=AllowMult,replied_fail=Fails,
                                     req_id=ReqId,n=N,
                                     replied_r=Replied,
                                     replied_notfound=NotFound0}) ->
      NotFound = [Idx|NotFound0],
  