anchor.diff:                  erlang:monotonic_time(),
                   erlang:unique_integer()),
   
  +    schedule_aae_synchronization(),
       schedule_delta_synchronization(),
       schedule_delta_garbage_collection(),
   
  
positive.code:     log_transmission(extract_type_and_payload(Msg), 1),
      PeerServiceManager = lasp_config:get(peer_service_manager,
                                           partisan_peer_service),
      PeerServiceManager:forward_message(Peer, ?MODULE, Msg).
  
  %% @private
  extract_type_and_payload({Type, _From, Payload}) ->
  
negative.code:             Pid = spawn_link(fun() -> ok end),
              {ok, Pid};
          state_based ->
              case lasp_config:get(broadcast, false) of
                  true ->
                      %% Plumtree AAE.
                      gen_server:call(?MODULE, {exchange, Peer}, infinity);
                  false ->
                      %% No AAE through this mechanism.
                      %%
                      %% Spawn a process that terminates immediately, because the
                      %% broadcast exchange timer tracks the number of in progress
                      %% exchanges and bounds it by that limit.
                      %%
                      Pid = spawn_link(fun() -> ok end),
                      {ok, Pid}
              end
      end.
  
  %%%===================================================================
  