anchor.diff:                  SlideOp1 = slide_op:reset_send_errors(SlideOp),
                   finish_delta_ack1(State, SlideOp1, NextOpMsg)
           end,
  -    safe_operation(WorkerFun, MyState, MoveFullId, [wait_for_delta_ack], delta_ack);
  +    safe_operation(WorkerFun, MyState, MoveFullId, [wait_for_delta_ack], delta_ack, true);
   
   process_move_msg({move, {send_error, Target, Message, _Reason}, {timeouts, Timeouts}} = _Msg, MyState) ->
       ?TRACE1(_Msg, MyState),
  
positive.code:                 send(Target, Message, MoveFullId),
                  dht_node_state:set_slide(State, PredOrSucc, NewSlideOp)
          end,
      safe_operation(WorkerFun, MyState, MoveFullId, all, send_error_retry);
  
  % no reply from the target node within get_wait_for_reply_timeout() ms
  process_move_msg({move, check_for_timeouts} = _Msg, MyState) ->
  
negative.code:                 SlideOp1 = slide_op:reset_send_errors(SlideOp),
                  update_rcv_data1(State, SlideOp1, MovingData, TargetId, NextOp)
          end,
      safe_operation(WorkerFun, MyState, MoveFullId, [wait_for_data, wait_for_other], data, false);
  
  % acknowledgement from neighbor that its node received data for the slide op with the given id
  process_move_msg({move, data_ack, MoveFullId} = _Msg, MyState) ->
  