anchor.diff:                end,
                 []),
       {reply, Reply, State};
  -handle_call(sync_bucket_config, _From, State) ->
  +do_handle_call(sync_bucket_config, _From, State) ->
       handle_info(check_config, State),
       {reply, ok, State};
  -handle_call(_, _From, State) ->
  +do_handle_call(_, _From, State) ->
       {reply, unhandled, State}.
   
   
  
positive.code: -define(VBUCKET_POLL_INTERVAL, 100).
  -define(TIMEOUT, 30000).
  -define(CONNECTED_TIMEOUT, 5000).
  
  %% gen_server API
  -export([start_link/1]).
  
negative.code:        bucket=Bucket}
      }.
  
  handle_call(Msg, From, State) ->
      StartTS = os:timestamp(),
      try
          do_handle_call(Msg, From, State)
      after
          EndTS = os:timestamp(),
          Diff = timer:now_diff(EndTS, StartTS),
          if
              Diff > ?SLOW_CALL_THRESHOLD_MICROS ->
                  ?log_error("call ~p took too long: ~p us", [Msg, Diff]);
              true ->
                  ok
          end
      end.
  
  do_handle_call({raw_stats, SubStat, StatsFun, StatsFunState}, _From, State) ->
      try mc_client_binary:stats(State#state.sock, SubStat, StatsFun, StatsFunState) of
          Reply ->
              {reply, Reply, State}
      catch T:E ->
              {reply, {exception, {T, E}}, State}
      end;
  do_handle_call(backfilling, _From, State) ->
      End = <<":pending_backfill">>,
      ES = byte_size(End),
      {ok, Reply} = mc_client_binary:stats(
  