anchor.diff:              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, '_'}),
  +    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)
  +                 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;
   
  
positive.code:                    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, '_'}),
      rbrcseq:qwrite(DB, Self, Id,
                     ContentCheck,
                     New),
  
negative.code: % lease merge (step1)
  %
  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  on({l_on_cseq, merge, L1 = #lease{id=Id, epoch=OldEpoch}, L2, ReplyTo}, State) ->
      New = L1#lease{epoch    = OldEpoch + 1,
                      version = 0,
                      aux     = {invalid, merge, get_range(L1), get_range(L2)},
                      timeout = new_timeout()},
      ContentCheck = generic_content_check(L1, New, merge_step1),
      DB = get_db_for_id(Id),
      Self = comm:reply_as(self(), 5, {l_on_cseq, merge_reply_step1,
                                       L2, ReplyTo, '_'}),
      rbrcseq:qwrite(DB, Self, Id,
                     ContentCheck,
                     New),
      State;
  
  on({l_on_cseq, merge_reply_step1, L2, _ReplyTo,
      {qwrite_deny, _ReqId, _Round, L1, Reason}}, State) ->
      % @todo if success update lease in State
      ct:pal("merge step1 failed~n~w~n~w~n~w~n", [Reason, L1, L2]),
      % retry?
      State;
  
  