anchor.diff:      Results = misc:parallel_map(
                   fun ({Bucket, Type}) ->
                           {ok, _} = timer2:kill_after(Timeout),
  -                        case ns_memcached:stats(Bucket, Type) of
  +                        case get_dcp_ckpt_tap_stats(Bucket, Type) of
                               {ok, V} -> V;
                               Crap -> Crap
                           end
  
positive.code:     {WiB, WiT} = lists:unzip(WorkItems),
      lists:zip3(WiB, WiT, Results).
  
  log_all_tap_and_checkpoint_stats() ->
      ?log_info("logging tap & checkpoint stats"),
      [begin
           ?log_info("~s:~s:~n~p",[Type, Bucket, Values])
       end || {Bucket, Type, Values} <- grab_all_tap_and_checkpoint_stats()],
      ?log_info("end of logging tap & checkpoint stats").
  
  
negative.code:          %% rpc-ed to grab couchdb ets_tables
           grab_all_ets_tables/0]).
  
  %% Read the manifest.xml file
  manifest() ->
      case file:read_file(filename:join(path_config:component_path(bin, ".."), "manifest.xml")) of
          {ok, C} ->
  