anchor.diff:  
   waiting({ok, ReqID, IdxNode, Obj},
           SD0=#state{from=From, num_r=NumR0, replies=Replies0,
  -                   r=R, n=N, timeout=Timeout}) when is_tuple(IdxNode) ->
  +                   r=R, n=N, timeout=Timeout}) ->
       NumR = NumR0 + 1,
       Replies = [{IdxNode, Obj}|Replies0],
       SD = SD0#state{num_r=NumR, replies=Replies},
  
positive.code:     end.
  
  wait_for_n({ok, _ReqID, IdxNode, Obj},
             SD0=#state{n=N, num_r=NumR, replies=Replies0})
    when NumR == N - 1, is_tuple(IdxNode) ->
      Replies = [{IdxNode, Obj}|Replies0],
      {next_state, finalize, SD0#state{num_r=N, replies=Replies}, 0};
  
  wait_for_n({ok, _ReqID, IdxNode, Obj},
             SD0=#state{num_r=NumR0, replies=Replies0, timeout=Timeout})
    when is_tuple(IdxNode) ->
      NumR = NumR0 + 1,
      Replies = [{IdxNode, Obj}|Replies0],
      {next_state, wait_for_n, SD0#state{num_r=NumR, replies=Replies}, Timeout};
  
negative.code: 
  %% States
  -export([prepare/2, execute/2, waiting/2, wait_for_n/2, finalize/2]).
  
  -type partition() :: chash:index_as_int().
  -type reply_src() :: {partition(), node()}.
  
  -record(state, {req_id,
                  from,
  