anchor.diff:  
   maybe_adjust_xdc_replication(XDocId, SrcBucket, TgtBucket, PrevVbuckets,
                                CurrVbuckets) ->
  -    {VbucketsAcquired, VbucketsLost} =
  +    {AcquiredVbuckets, LostVbuckets} =
           xdc_rep_utils:lists_difference(CurrVbuckets, PrevVbuckets),
   
       % Start Couch replications for the newly acquired vbuckets
       {ok, {TgtVbMap, TgtNodes}} =
           xdc_rep_utils:remote_vbucketmap_nodelist(TgtBucket),
  -    lists:map(
  -        fun(Vb) ->
  +    FailedVbuckets = lists:foldl(
  +        fun(Vb, VbList) ->
               SrcURI = xdc_rep_utils:local_couch_uri_for_vbucket(SrcBucket, Vb),
               TgtURI = xdc_rep_utils:remote_couch_uri_for_vbucket(
                   TgtVbMap, TgtNodes, Vb),
  -            start_couch_replication(SrcURI, TgtURI, Vb, XDocId, 0)
  -        end,
  -        VbucketsAcquired),
  +            case start_couch_replication(SrcURI, TgtURI, Vb, XDocId, 0) of
  +            {ok, _Res} ->
  +                VbList;
  +            _Error ->
  +                VbList ++ [Vb]
  +            end
  +        end,
  +        [], AcquiredVbuckets),
   
       % Add entries for the new Couch replications to the replication info doc
       couch_replication_manager:update_rep_doc(
  
positive.code:             fun(Vb) ->
                  {?l2b("replication_state_vb_" ++ ?i2l(Vb)), <<"cancelled">>}
              end,
              VbucketsLost)),
  
      % Update XSTORE with the current active vbuckets list
      true = ets:update_element(?XSTORE, XDocId, {3, CurrVbuckets}).
  
  
  %
  
negative.code:         {error, not_present};
      {{ok, SrcBucketConfig}, {ok, {TgtVbMap, TgtNodes}}} ->
          MyVbuckets = xdc_rep_utils:my_active_vbuckets(SrcBucketConfig),
          TriggeredVbuckets = lists:foldl(
              fun(Vb, VbList) ->
                  SrcURI = xdc_rep_utils:local_couch_uri_for_vbucket(
                      SrcBucket, Vb),
                  TgtURI = xdc_rep_utils:remote_couch_uri_for_vbucket(
                      TgtVbMap, TgtNodes, Vb),
                  case start_couch_replication(SrcURI, TgtURI, Vb, XDocId, 0) of
                  {ok, _Res} ->
                      VbList ++ [Vb];
                  _Error ->
                      VbList
                  end
              end,
              [], MyVbuckets),
          true = ets:insert(?XSTORE, {XDocId, XRep, TriggeredVbuckets}),
          create_xdc_rep_info_doc(XDocId, XRepId, TriggeredVbuckets, RepDbName,
                                  XDocBody),
          ok
      end.
  
  