anchor.diff:  %% API
   %%
   
  +run_check_config(Bucket, Parent) ->
  +    proc_lib:init_ack(Parent, self()),
  +    perform_very_long_call(
  +      fun(Sock) ->
  +              StartTS = os:timestamp(),
  +              ensure_bucket(Sock, Bucket),
  +              Diff = timer:now_diff(os:timestamp(), StartTS),
  +              if
  +                  Diff > ?SLOW_CALL_THRESHOLD_MICROS ->
  +                      ?log_debug("ensure_bucket took too long: ~p us", [Diff]);
  +                  true ->
  +                      ok
  +              end,
  +              {reply, ok}
  +      end, Bucket).
  +
   -spec active_buckets() -> [bucket_name()].
   active_buckets() ->
       [Bucket || ?MODULE_STRING "-" ++ Bucket <-
  
positive.code:           sock = still_connecting :: port() | still_connecting,
            timer::any(),
            work_requests = [],
            warmup_stats = [] :: [{binary(), binary()}]
           }).
  
  %% external API
  
negative.code:             {ok, S} = Stats,
              {noreply, State#state{warmup_stats = S}}
      end;
  handle_info(check_config, #state{check_config_pid = undefined} = State) ->
      misc:flush(check_config),
      Pid = proc_lib:start_link(erlang, apply, [fun run_check_config/2, [State#state.bucket, self()]]),
      {noreply, State#state{check_config_pid = Pid}};
  handle_info(check_config, State) ->
      {noreply, State};
  handle_info({'EXIT', Pid, normal}, #state{check_config_pid = Pid} = State) ->
      {noreply, State#state{check_config_pid = undefined}};
  handle_info({'EXIT', _, Reason} = Msg, State) ->
      ?log_debug("Got ~p. Exiting.", [Msg]),
      {stop, Reason, State};
  