anchor.diff:      spawn_workers(State#state{movers=Movers1, map=Map1});
   handle_info({ns_node_disco_events, _, _} = Event, State) ->
       {stop, {detected_nodes_change, Event}, State};
  +%% We intentionally don't handle other exits so we'll die if one of
  +%% the movers fails.
   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};
  
positive.code:                                                 (_) ->
                                                      ok
                                              end),
      erlang:start_timer(30000, self(), log_tap_stats),
  
      AllNodesSet0 =
          lists:foldl(fun (Chain, Acc) ->
  
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};
  