anchor.diff:      {noreply, setup(State, Dispatcher)};
   
   cloudi_job_handle_info(task,
  -                       #state{concurrent_tasks = ConcurrentTasks,
  -                              task_size_lookup = TaskSizeLookup} = State,
  +                       #state{concurrent_tasks = ConcurrentTasks} = State,
                          Dispatcher) ->
       {Requests, Done, NewState} = send_tasks(ConcurrentTasks, [],
                                               State, Dispatcher),
  -    if
  -        Done == false ->
  -            self() ! task;
  -        true ->
  -            ok
  -    end,
  -    {noreply, recv_tasks(Requests, TaskSizeLookup, NewState, Dispatcher)};
  +    {noreply, recv_tasks(Requests, Done, NewState, Dispatcher)};
   
   cloudi_job_handle_info(Request, State, _) ->
       ?LOG_WARN("Unknown info \"~p\"", [Request]),
  
positive.code:             {L, false, State}
      end.
  
  recv_tasks([], TaskSizeLookup, State, _) ->
      State#state{task_size_lookup = TaskSizeLookup};
  
  recv_tasks([{TaskSize, Iterations, Step, Index, Pid, Timeout, TransId} | L],
             TaskSizeLookup,
             #state{tasks_failed = Failed,
                    target_time = TargetTime} = State, Dispatcher) ->
  
      case cloudi_job:recv_async(Dispatcher, Timeout, TransId) of
          {ok, Response} ->
              <<ElapsedTime:32/float-native, PiResult/binary>> = Response,
              send_results(Index, PiResult, Pid, State, Dispatcher),
              recv_tasks(L, cloudi_task_size:put(TaskSize,
                                                 TargetTime,
                                                 ElapsedTime,
                                                 Pid,
                                                 TaskSizeLookup),
                         State, Dispatcher);
          {error, timeout} ->
              ?LOG_ERROR("index ~p result timeout (after ~p ms)~n",
                         [Index, Timeout]),
  
negative.code:     end.
  
  send_tasks(0, L, State, _) ->
      {lists:reverse(L), false, State};
  
  send_tasks(Count, L, State, Dispatcher) ->
      Name = "/tests/hexpi",
  