anchor.diff:              case ns_bucket:bucket_type(BucketConfig) of
                   membase ->
                       dcp = ns_bucket:replication_type(BucketConfig),
  -                    cleanup_with_membase_bucket_check_servers(Bucket, Options,
  -                                                              BucketConfig, FullConfig);
  +                    cleanup_membase_bucket(Bucket,
  +                                           Options, BucketConfig, FullConfig);
                   _ -> ok
               end
       end.
  +
  +cleanup_membase_bucket(Bucket, Options, BucketConfig, FullConfig) ->
  +    {ok, RV} =
  +        leader_activities:run_activity(
  +          {ns_janitor, Bucket, cleanup}, majority,
  +          fun () ->
  +                  {ok, cleanup_with_membase_bucket_check_servers(Bucket,
  +                                                                 Options,
  +                                                                 BucketConfig,
  +                                                                 FullConfig)}
  +          end,
  +          [quiet]),
  +
  +    RV.
   
   cleanup_with_membase_bucket_check_servers(Bucket, Options, BucketConfig, FullConfig) ->
       case compute_servers_list_cleanup(BucketConfig, FullConfig) of
  
positive.code:     ?log_debug("janitor decided to update "
                 "servers list for bucket ~p to ~p", [Bucket, Servers]),
  
      ns_bucket:set_servers(Bucket, Servers).
  
  cleanup_with_membase_bucket_check_map(Bucket, Options, BucketConfig) ->
      case proplists:get_value(map, BucketConfig, []) of
  
negative.code: %%
  -module(ns_janitor).
  
  -include("cut.hrl").
  -include("ns_common.hrl").
  
  -include_lib("eunit/include/eunit.hrl").
  