anchor.diff:  %% @private
   -spec handle_info(term(), #state{}) -> {noreply, #state{}}.
   
  -handle_info(state_sync, #state{store=Store, gossip_peers=GossipPeers} = State) ->
  +handle_info({state_sync, ObjectFilterFun},
  +            #state{store=Store, gossip_peers=GossipPeers} = State) ->
       lasp_marathon_simulations:log_message_queue_size("state_sync"),
   
       PeerServiceManager = lasp_config:peer_service_manager(),
  
positive.code:     end.
  
  %% @private
  init_state_sync(Peer, Store) ->
      ObjectFilterFun = fun(_) -> true end,
      init_state_sync(Peer, ObjectFilterFun, Store).
  
  %% @private
  init_reverse_topological_sync(Peer, Store) ->
      lasp_logger:extended("Initializing reverse toplogical state synchronization with peer: ~p", [Peer]),
  
      SendFun = fun({Id, #dv{type=Type, metadata=Metadata, value=Value}}) ->
  
negative.code:     case ShouldSync of
          true ->
              Interval = lasp_config:get(state_interval, 10000),
              ObjectFilterFun = fun(_) -> true end,
              case lasp_config:get(jitter, false) of
                  true ->
                      %% Add random jitter.
                      Jitter = rand_compat:uniform(Interval),
                      timer:send_after(Interval + Jitter, {state_sync, ObjectFilterFun});
                  false ->
                      timer:send_after(Interval, {state_sync, ObjectFilterFun})
              end;
          false ->
              ok
  