anchor.diff:      [] ->
           % A new XDC replication document.
           ?log_info("~s: triggering xdc replication~n", [XDocId]),
  -        start_xdc_replication(XRep, RepDbName);
  +        start_xdc_replication(XRep, RepDbName, XDocBody);
       [XDocId] ->
           % An XDC replication document previously seen. Ignore.
           ?log_info("~s: ignoring doc previously seen.~n", [XDocId]),
  
positive.code: % XDC replication and replication info document related functions
  %
  
  create_xdc_rep_info_doc(XDocId, {Base, Ext}, Vbuckets, RepDbName) ->
      IDocId = xdc_rep_utils:info_doc_id(XDocId),
      UserCtx = #user_ctx{roles = [<<"_admin">>, <<"_replicator">>]},
      {ok, RepDb} = couch_db:open(RepDbName, [sys_db, {user_ctx, UserCtx}]),
  
negative.code:                            source = SrcBucketBinary,
                             target = {_, TgtBucket, _, _, _, _, _, _, _, _},
                             doc_id = XDocId} = XRep,
                        RepDbName,
                        XDocBody) ->
      SrcBucket = ?b2l(SrcBucketBinary),
      SrcBucketLookup = ns_bucket:get_bucket(SrcBucket),
      TgtBucketLookup = xdc_rep_utils:remote_vbucketmap_nodelist(TgtBucket),
  