anchor.diff:                              timer:send_after(Interval, {state_sync, ObjectFilterFun});
                           JitterInterval ->
                               Jitter = rand_compat:uniform(JitterInterval * 2) - JitterInterval,
  +                            lager:info("Scheduling synchronization for ~p", [Interval + Jitter]),
                               timer:send_after(Interval + Jitter, {state_sync, ObjectFilterFun})
                       end;
                   false ->
  
positive.code:             #state{store=Store, gossip_peers=GossipPeers} = State) ->
      lasp_marathon_simulations:log_message_queue_size("state_sync"),
  
      % PeerServiceManager = lasp_config:peer_service_manager(),
      % lasp_logger:extended("Beginning state synchronization: ~p",
      %                      [PeerServiceManager]),
  
negative.code:     %% Remove ourself and compute exchange peers.
      Peers = ?SYNC_BACKEND:compute_exchange(?SYNC_BACKEND:without_me(Members)),
  
      %% Ship buffered updates for the fanout value.
      SyncFun = fun(Peer) ->
                        case lasp_config:get(reverse_topological_sync, ?REVERSE_TOPOLOGICAL_SYNC) of
                            true ->
                                init_reverse_topological_sync(Peer, ObjectFilterFun, Store);
                            false ->
  