anchor.diff:  
   on({create_struct, RMethod, SenderI, Params, RcvInitiator} = _Msg, State) ->
       ?TRACE1(_Msg, State),
  -    This = comm:reply_as(comm:this(), 3, {create_struct, SenderI, '_'}),
  +    This = comm:reply_as(comm:this(), 2, {create_struct2, '_'}),
       comm:send_local(State#rr_recon_state.dhtNodePid, {get_state, This, my_range}),
  -    State#rr_recon_state{method = RMethod, initiator = RcvInitiator, struct = Params};
  -
  -on({create_struct, SenderI, {get_state_response, MyI}} = _Msg,
  +    State#rr_recon_state{method = RMethod, initiator = RcvInitiator, dest_interval = SenderI, struct = Params};
  +
  +on({create_struct2, {get_state_response, MyI}} = _Msg,
      State = #rr_recon_state{stage = req_shared_interval, initiator = false,
                              method = RMethod,            dhtNodePid = DhtPid,
  -                           dest_rr_pid = DestRRPid}) ->
  +                           dest_rr_pid = DestRRPid,     dest_interval = SenderI}) ->
       ?TRACE1(_Msg, State),
       % target node got sync request, asked for its interval
       % struct contains the interval of the initiator
       % -> client creates recon structure based on common interval, sends it to initiator
       RMethod =:= merkle_tree andalso fd:subscribe(DestRRPid),
       SyncI = find_intersection(MyI, SenderI),
  -    NewState = State#rr_recon_state{stage = build_struct,
  -                                    sync_interval = SyncI},
  +    NewState = State#rr_recon_state{stage = build_struct},
       case intervals:is_empty(SyncI) of
           false ->
               send_chunk_req(DhtPid, self(), SyncI, SyncI, get_max_items(RMethod)),
  
positive.code: -define(TRACE1(Msg, State),
          ?TRACE("~n  Msg: ~.0p~n"
                 "  State: method: ~.0p  stage: ~.0p  initiator: ~.0p~n"
                 "          syncI: ~.0p~n"
                 "         params: ~.0p~n",
                 [Msg, State#rr_recon_state.method, State#rr_recon_state.stage,
                  State#rr_recon_state.initiator, State#rr_recon_state.sync_interval,
                  ?IIF(is_list(State#rr_recon_state.struct), State#rr_recon_state.struct, [])])).
  
  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  
negative.code:          dest_rr_pid        = ?required(rr_recon_state, dest_rr_pid)    :: comm:mypid(), %dest rrepair pid
           dest_recon_pid     = undefined                                 :: comm:mypid() | undefined, %dest recon process pid
           method             = undefined                                 :: method(),
           dest_interval      = intervals:empty()                         :: intervals:interval(),
           struct             = {}                                        :: struct() | {},
           stage              = req_shared_interval                       :: stage(),
           initiator          = false                                     :: boolean(),
  