anchor.diff:  %%%===================================================================
   
   %% state_based messages:
  -extract_log_type_and_payload({state_send, _Node, {Id, Type, _Metadata, State}}) ->
  +extract_log_type_and_payload({state_send, _Node, {Id, Type, _Metadata, State}, _AckRequired}) ->
       [{Id, State}, {Type, State}, {state_send, State}, {state_send_protocol, Id}].
   
   %%%===================================================================
  
positive.code: 
      %% Send the object.
      SyncFun = fun(Peer) ->
                        {Peer, init_state_sync(Peer, ObjectFilterFun, Store)}
                end,
      Objects = lists:flatmap(SyncFun, Peers),
  
  
negative.code:     ok.
  
  %% @private
  init_state_sync(Peer, ObjectFilterFun, Blocking, Store) ->
      lasp_logger:extended("Initializing state propagation with peer: ~p", [Peer]),
      Function = fun({Id, #dv{type=Type, metadata=Metadata, value=Value}}, Acc0) ->
                      case orddict:find(dynamic, Metadata) of
                          {ok, true} ->
  