anchor.diff:      {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).
  -
  -get_failover_uuid(BucketName, Vb) ->
  -    {U, _} = lists:last(xdcr_upr_streamer:get_failover_log(couch_util:to_list(BucketName), Vb)),
  -    U.
  
positive.code:      TotalDataReplicated,
       RemoteVBOpaque}.
  
  parse_validate_checkpoint_doc(Rep, Vb, Body, ApiRequestBase) ->
      try
          do_parse_validate_checkpoint_doc(Rep, Vb, Body, ApiRequestBase)
      catch T:E ->
              S = erlang:get_stacktrace(),
              ?xdcr_debug("Got parse_validate_checkpoint_doc exception: ~p:~p~n~p", [T, E, S]),
              erlang:raise(T, E, S)
      end.
  
  do_parse_validate_checkpoint_doc(Rep, Vb, Body0, ApiRequestBase) ->
      Body = case Body0 of
                 {XB} -> XB;
                 _ -> []
  
negative.code:         false ->
              handle_no_checkpoint(ApiRequestBase);
          true ->
              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]),
  