anchor.diff:  
   %% gen_server callbacks
   init(Bucket) ->
  -    timer:send_after(1000, rebalance_if_new),
       timer:send_interval(10000, janitor),
       {ok, #state{bucket=Bucket}}.
   
  
positive.code:                   end),
              {noreply, State#state{rebalancer={Pid, Ref}, progress=[]}};
          _ ->
              {noreply, State}
      end;
  handle_info({Ref, Reason}, State = #state{rebalancer={_Pid, Ref}}) ->
  
negative.code: handle_info(janitor, State = #state{bucket=Bucket, rebalancer=undefined}) ->
      misc:flush(janitor),
      {_, _, Map, Servers} = ns_bucket:config(Bucket),
      case Servers == undefined orelse Servers == [] of
          true ->
              error_logger:info_msg("Performing initial rebalance~n"),
              {ok, Pid, Ref} =
                  misc:spawn_link_safe(
  