anchor.diff:      end.
   
   send_tasks(0, L, State, _) ->
  -    {L, false, State};
  +    {lists:reverse(L), false, State};
   
   send_tasks(Count, L, State, Dispatcher) ->
       Name = "/tests/hexpi",
  
positive.code:                          step = Step,
                           index = Index,
                           timeout = Timeout * 2},
              recv_tasks(L, cloudi_task_size:put(TaskSize,
                                                 TargetTime,
                                                 ElapsedTime,
                                                 Pid,
                                                 TaskSizeLookup),
                         State#state{tasks_failed = [Task | Failed]},
                         Dispatcher);
          {error, Reason} ->
              ?LOG_ERROR("recv_async error ~p~n", [Reason]),
              recv_tasks(L, TaskSizeLookup, State, Dispatcher)
      end.
  
  send_results(DigitIndex, PiResult, Pid,
  
negative.code:     {noreply, setup(State, Dispatcher)};
  
  cloudi_job_handle_info(task,
                         #state{concurrent_tasks = ConcurrentTasks} = State,
                         Dispatcher) ->
      {Requests, Done, NewState} = send_tasks(ConcurrentTasks, [],
                                              State, Dispatcher),
      {noreply, recv_tasks(Requests, Done, NewState, Dispatcher)};
  
  cloudi_job_handle_info(Request, State, _) ->
      ?LOG_WARN("Unknown info \"~p\"", [Request]),
  