anchor.diff:  
   terminate_cleanup(State0) ->
       State = xdc_vbucket_rep_ckpt:cancel_timer(State0),
  -    Dbs = [State#rep_state.target,
  -           State#rep_state.src_master_db],
  +    Dbs = [State#rep_state.target],
       [catch couch_api_wrap:db_close(Db) || Db <- Dbs, Db /= undefined].
   
   
  
positive.code: 
              %% allow another replicator to go
              State2 = replication_turn_is_done(State),
              couch_api_wrap:db_close(State2#rep_state.src_master_db),
              couch_api_wrap:db_close(State2#rep_state.target),
  
              update_work_time(State2),
  
negative.code:     ResultState = NewState#rep_state{
                      changes_queue = ChangesQueue,
                      workers = Workers,
                      target_name = TgtURI,
                      target = Target,
                      timer = xdc_vbucket_rep_ckpt:start_timer(State),
  