anchor.diff:      DocId = build_commit_doc_id(Rep, Vb),
       case couch_db:open_doc_int(DB, DocId, [ejson_body]) of
           {ok, #doc{body = Body}} ->
  -            parse_validate_checkpoint_doc(Rep, Vb, Body, ApiRequestBase);
  +            parse_validate_checkpoint_doc(Vb, Body, ApiRequestBase);
           {not_found, _} ->
               ?xdcr_debug("Found no local checkpoint document for vb: ~B. Will start from scratch", [Vb]),
               handle_no_checkpoint(ApiRequestBase)
  
positive.code:         false ->
              handle_no_checkpoint(ApiRequestBase);
          true ->
              case get_failover_uuid(Rep#rep.source, Vb) =/= FailoverUUID of
                  true ->
                      ?xdcr_debug("local checkpoint for vb ~B does not match due to local side. Checkpoint seqno: ~B. But will still let upr producer decide on true start seqno", [Vb, Seqno]),
                      ok;
                  false ->
                      ok
              end,
              case perform_pre_replicate(CommitOpaque, ApiRequestBase) of
                  {mismatch, RemoteVBOpaque} ->
                      ?xdcr_debug("local checkpoint for vb ~B does not match due to remote side. Checkpoint seqno: ~B. xdcr will start from scratch", [Vb, Seqno]),
  
negative.code:     {ok, KV} = ns_memcached:stats(couch_util:to_list(BucketName), io_lib:format("vbucket-seqno ~B", [Vb])),
      Key = iolist_to_binary(io_lib:format("vb_~B:uuid", [Vb])),
      misc:expect_prop_value(Key, KV).
  