anchor.diff:                                                  (_) ->
                                                       ok
                                               end),
  -    erlang:start_timer(30000, self(), log_tap_stats),
  +
  +    timer:send_interval(30000, log_tap_stats),
   
       AllNodesSet0 =
           lists:foldl(fun (Chain, Acc) ->
  
positive.code:     spawn_workers(State#state{movers=Movers1, map=Map1});
  handle_info({ns_node_disco_events, _, _} = Event, State) ->
      {stop, {detected_nodes_change, Event}, State};
  handle_info({'EXIT', Pid, _} = Msg, #state{disco_events_subscription=Pid}=State) ->
      ?rebalance_error("Got exit from node disco events subscription"),
      {stop, {ns_node_disco_events_exited, Msg}, State};
  
negative.code:     unhandled.
  
  
  handle_info(log_tap_stats, State) ->
      rpc:eval_everywhere(diag_handler, log_all_tap_and_checkpoint_stats, []),
      misc:flush(log_tap_stats),
      {noreply, State};
  