anchor.diff:          index,
           index_start,
           index_end,
  -        done = false,
  +        map_done = false,
           step = ?PI_DIGIT_STEP_SIZE,
           task_size,
           queue,
  
positive.code:                       task_size = TaskSize,
                        queue = Queue}, Dispatcher)}.
  
  cloudi_service_map_reduce_send(#state{done = true} = State, _) ->
      {done, State};
  cloudi_service_map_reduce_send(#state{destination = Name,
                                        index = Index,
  
negative.code:     end,
      State#state{queue = QueueN}.
  
  reduce_done_check(#state{map_done = false} = State) ->
      {ok, State};
  reduce_done_check(#state{map_done = true,
                           queue = Queue} = State) ->
      ReduceSize = cloudi_queue:size(Queue),
      if
  