anchor.diff:      [{Stat, statistics(Stat)} || Stat <- Stats].
   
   %% Internal fuctions
  +buckets_replication_statuses() ->
  +    BucketConfigs = ns_bucket:get_buckets(),
  +    [{Bucket, replication_status(Bucket, BucketConfig)} ||
  +        {Bucket, BucketConfig} <- BucketConfigs].
  +
   current_status(Expensive) ->
       ClusterCompatVersion = case (catch list_to_integer(os:getenv("MEMBASE_CLUSTER_COMPAT_VERSION"))) of
                                  X when is_integer(X) -> X;
  
positive.code:         _ -> BasicData
      end.
  
  buckets_replication_statuses() ->
      BucketConfigs = ns_bucket:get_buckets(),
      [{Bucket, replication_status(Bucket, BucketConfig)} ||
          {Bucket, BucketConfig} <- BucketConfigs].
  
  replication_status(Bucket, BucketConfig) ->
      %% First, check that replication is running
      case proplists:get_value(map, BucketConfig) of
  
negative.code: init([]) ->
      timer:send_interval(1000, beat),
      timer:send_interval(?EXPENSIVE_CHECK_INTERVAL, do_expensive_checks),
      self() ! do_expensive_checks,
      {ok, undefined}.
  
  handle_call(status, _From, State) ->
      {reply, current_status(State), State};
  