anchor.diff:      lager:info("Beginning sync for peers: ~p", [Peers]),
   
       %% Ship buffered updates for the fanout value.
  -    lists:foreach(fun(Peer) ->
  -                          init_aae_sync(Peer)
  -                  end, Peers),
  +    lists:foreach(fun(Peer) -> init_aae_sync(Peer, Store) end, Peers),
   
       %% Schedule next synchronization.
       schedule_aae_synchronization(),
  
positive.code: 
  %% @private
  memory_report() ->
      case lasp_config:get(memory_report, false) of
          true ->
              PlumtreeBroadcast = erlang:whereis(plumtree_broadcast),
              lager:info("Plumtree message queue: ~p",
                         [process_info(PlumtreeBroadcast, message_queue_len)]),
              ok;
          false ->
              ok
  
negative.code:     {Type, Payload}.
  
  %% @private
  init_aae_sync(Peer, Store) ->
      lager:info("Initializing AAE synchronization with peer: ~p", [Peer]),
      Function = fun({Id, #dv{type=Type, metadata=Metadata, value=Value}}, Acc0) ->
                      case orddict:find(dynamic, Metadata) of
                          {ok, true} ->
                              %% Ignore: this is a dynamic variable.
                              ok;
                          _ ->
                              lager:info("*** Sending: ~p", [Id]),
                              send({aae_send, node(), {Id, Type, Metadata, Value}}, Peer)
                      end,
                      [{ok, {Id, Type, Metadata, Value}}|Acc0]
                 end,
      do(fold, [Store, Function, []]),
      lager:info("Finished AAE synchronization with peer: ~p", [Peer]).
  
  %% @private
  init_delta_sync(Peer) ->
  