anchor.diff:              NewState = State2#rep_state{
                            workers = [],
                            status = VbStatus3,
  -                         src_master_db = undefined,
                            target = undefined,
                            current_through_snapshot_seq = NewSnapshotSeq,
                            current_through_snapshot_end_seq = NewSnapshotEndSeq},
  
positive.code:     %% check if we need do checkpointing, replicator will crash if checkpoint failure
      State1 = State#rep_state{
                 xmem_location = XMemLoc,
                 target = Target,
                 src_master_db = SrcMasterDb},
  
      {Succ, CkptErrReason, NewState} =
          case TimeSinceLastCkpt > IntervalSecs of
  
negative.code: 
  terminate_cleanup(State0) ->
      State = xdc_vbucket_rep_ckpt:cancel_timer(State0),
      Dbs = [State#rep_state.target],
      [catch couch_api_wrap:db_close(Db) || Db <- Dbs, Db /= undefined].
  
  
  