anchor.diff:      end.
   
   %% @doc Wait for the remainder of responses from replicas.
  -waiting_n({ok, _ReqId, IndexNode, Reply},
  +waiting_n({ok, _ReqId, IndexNode, {ok, Reply}},
           #state{num_responses=NumResponses0,
                  replies=Replies0}=State0) ->
       NumResponses = NumResponses0 + 1,
  
positive.code: prepare(timeout, #state{group=Group}=State) ->
      DocIdx = riak_core_util:chash_key({<<"memberships">>, Group}),
      Preflist = riak_core_apl:get_primary_apl(DocIdx, ?N,
                                               riak_pg_messaging),
      Preflist2 = [{Index, Node} || {{Index, Node}, _Type} <- Preflist],
      {next_state, execute, State#state{preflist=Preflist2}, 0}.
  
  
negative.code: 
  %% @doc Perform merge of replicas.
  merge(Replies) ->
      lists:foldl(fun({_IndexNode, Pids}, Acc) ->
                  riak_dt_orswot:merge(Pids, Acc) end,
                  riak_dt_orswot:new(), Replies).
  
  %% @doc Trigger repair if necessary.
  