anchor.diff:              StartNow = now(),
               TRef = erlang:send_after(Timeout, self(), timeout),
               RealStartTime = riak_core_util:moment(),
  -            Bucket = riak_object:bucket(RObj1),
               BucketProps = riak_core_bucket:get_bucket(Bucket, Ring),
  -            Key = riak_object:key(RObj1),
               DocIdx = riak_core_util:chash_key({Bucket, Key}),
               Msg = {self(), {Bucket,Key}, RObj1, ReqId, RealStartTime, Options},
               N = proplists:get_value(n_val,BucketProps),
  
positive.code:         [] -> {error, notfound};
          _ -> riak_object:reconcile(RObjs1,AllowMult)
      end.
  
negative.code:     end.
  
  waiting_vnode_w({w, Idx, ReqId},
                  StateData=#state{w=W,dw=DW,req_id=ReqId,client=Client,replied_w=Replied0}) ->
      Replied = [Idx|Replied0],
      case length(Replied) >= W of
          true ->
              case DW of
                  0 ->
                      Client ! {ReqId, ok},
                      update_stats(StateData),
                      {stop,normal,StateData};
                  _ ->
                      NewStateData = StateData#state{replied_w=Replied},
                      {next_state,waiting_vnode_dw,NewStateData}
              end;
          false ->
              NewStateData = StateData#state{replied_w=Replied},
  