anchor.diff:  -define(UPSTREAM_TIMEOUT, ns_config_ets_dup:get_timeout(ebucketmigrator_upstream_us, 600000000)).
   -define(TIMEOUT_CHECK_INTERVAL, 15000).
   -define(TERMINATE_TIMEOUT, ns_config_ets_dup:get_timeout(ebucketmigrator_terminate, 110000)).
  -
  +-define(HIBERNATE_TIMEOUT, 10000).
   
   %% gen_server callbacks
   -export([init/1, handle_call/3, handle_cast/2,
  
positive.code:             do_note_tap_stats(State, NoteTapTag)
      end,
  
      gen_server:enter_loop(?MODULE, [], State2).
  
  -define(TAP_STATS_ATTEMPTS, 5).
  do_note_tap_stats(State, NoteTapTag) ->
  
negative.code:         true ->
              case CurrentWaiter of
                  completed ->
                      {reply, ok, State, ?HIBERNATE_TIMEOUT};
                  undefined ->
                      {noreply, State#state{backfill_end_waiter = From}};
                  _ ->
                      {reply, already_waiting, State}
              end;
          _ ->
              {reply, not_backfilling, State, ?HIBERNATE_TIMEOUT}
      end;
  handle_call(_Req, _From, State) ->
      {reply, unhandled, State, ?HIBERNATE_TIMEOUT}.
  
  
  handle_cast(Msg, State) ->
      ?rebalance_warning("Unhandled cast: ~p", [Msg]),
      {noreply, State, ?HIBERNATE_TIMEOUT}.
  
  
  handle_info(retry_not_ready_vbuckets, _State) ->
  