anchor.diff:                                          {JPid, _Ref} ->
                                               ok = misc:wait_for_process(JPid)
                                       end,
  -                                    do_rebalance(Bucket, KeepNodes, EjectNodes, Map)
  +                                    do_rebalance(Bucket, KeepNodes, EjectNodes,
  +                                                 Map, 2)
                               end)
                     end),
               {reply, ok, State#state{rebalancer={Pid, Ref}, progress=[]}}
  
positive.code:     catch
          throw:stopped ->
              fixup_replicas(Bucket, KeepNodes, EjectNodes),
              exit(stopped)
      end.
  
  %% Ensure there are replicas for any unreplicated buckets if we stop
  
negative.code:             Moves
      end.
  
  do_rebalance(Bucket, KeepNodes, EjectNodes, Map, Tries) ->
      try
          AllNodes = KeepNodes ++ EjectNodes,
          ns_bucket:set_servers(Bucket, AllNodes),
  