anchor.diff:      end.
   
   %% @private
  -init_state_sync(Peer, Store) ->
  -    ObjectFilterFun = fun(_) -> true end,
  -    init_state_sync(Peer, ObjectFilterFun, Store).
  -
  -%% @private
  -init_reverse_topological_sync(Peer, Store) ->
  +init_reverse_topological_sync(Peer, ObjectFilterFun, Store) ->
       lasp_logger:extended("Initializing reverse toplogical state synchronization with peer: ~p", [Peer]),
   
       SendFun = fun({Id, #dv{type=Type, metadata=Metadata, value=Value}}) ->
  
positive.code:     case ShouldSync of
          true ->
              Interval = lasp_config:get(state_interval, 10000),
              case lasp_config:get(jitter, false) of
                  true ->
                      %% Add random jitter.
                      Jitter = rand_compat:uniform(Interval),
                      timer:send_after(Interval + Jitter, state_sync);
                  false ->
                      timer:send_after(Interval, state_sync)
              end;
          false ->
              ok
  
negative.code:                             %% Ignore: this is a dynamic variable.
                              ok;
                          _ ->
                              case ObjectFilterFun(Id) of
                                  true ->
                                      ?SYNC_BACKEND:send(?MODULE,
                                                         {state_send, node(), {Id, Type, Metadata, Value}},
                                                         Peer);
                                  false ->
                                      ok
                              end
                      end
                 end,
  
  