anchor.diff:                                      num_tokens = MaxConcurrentReps,
                                       init_throttle = InitThrottle,
                                       work_throttle = WorkThrottle,
  -                                    vbucket_sup = Sup}
  -    end,
  -    {ok, RepState}.
  +                                    vbucket_sup = Sup},
  +            {ok, RepState}
  +    end.
   
   handle_call(stats, _From, #replication{vb_rep_dict = Dict,
                                          rep = Rep,
  
positive.code:                                 "adjust replicators for new vbs :~p",
                                  [?b2l(SrcBucket), NewVbs]),
                      start_vb_replicators(State#replication{vbs = NewVbs})
              end
      end,
      {noreply, NewState}.
  
  
  terminate(_Reason, #replication{vbucket_sup = Sup}) ->
  
negative.code:             Sup2 = start_vbucket_rep_sup(Rep),
              ?xdcr_debug("bucket gone or never existed, shut down current vb rep "
                          "supervisor: ~p and create a new one :~p", [Sup, Sup2]),
              {noreply, State#replication{vbucket_sup = Sup2}};
          SrcConfig ->
              NewVbs = xdc_rep_utils:my_active_vbuckets(SrcConfig),
              NewState =
  