anchor.diff:                     timeout = new_timeout()},
       ContentCheck = generic_content_check(L2, New, merge_step4),
       DB = get_db_for_id(Id),
  -    Self = comm:reply_as(self(), 5, {l_on_cseq, merge_reply_step4, L1, ReplyTo, '_'}),
  +    Self = comm:reply_as(self(), 5, {l_on_cseq, merge_reply_step4,
  +                                     L1, ReplyTo, '_'}),
       rbrcseq:qwrite(DB, Self, Id,
                      ContentCheck,
                      New),
  
positive.code: % lease merge (step2)
  %
  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  on({l_on_cseq, merge_reply_step1,
      L2 = #lease{id=Id,epoch=OldEpoch,version=OldVersion}, ReplyTo,
      {qwrite_done, _ReqId, _Round, L1}}, State) ->
      % @todo if success update lease in State
      New = L2#lease{epoch   = OldEpoch + 1,
  
negative.code:             timeout = new_timeout()},
      ContentCheck = generic_content_check(L2, New, split_reply_step1),
      DB = get_db_for_id(Id),
      Self = comm:reply_as(self(), 9, {l_on_cseq, split_reply_step2,
                                       L1, R1, R2, Keep, ReplyTo, PostAux, '_'}),
      rbrcseq:qwrite(DB, Self, Id,
                     ContentCheck,
                     New),
      case Keep of
          first -> true = false, % TS: not supported at the moment
                   lease_list:update_lease_in_dht_node_state(L1, State, active,
                                                             split_reply_step1);
          second -> lease_list:update_lease_in_dht_node_state(L1, State, passive,
                                                              split_reply_step1)
  
      end;
  
  