anchor.diff:  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),
  +                                             riak_pg_memberships),
       Preflist2 = [{Index, Node} || {{Index, Node}, _Type} <- Preflist],
       {next_state, execute, State#state{preflist=Preflist2}, 0}.
   
  
positive.code: 
  %% @doc Pull a unique list of memberships from replicas, and
  %%      relay the message to it.
  waiting({ok, _ReqId, IndexNode, Reply},
          #state{from=From,
                 req_id=ReqId,
                 num_responses=NumResponses0,
  
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.
  