anchor.diff:      NewWorker = spawn_link(fun() ->
   				   worker(Queue)
   			   end),
  -    State#state{worker = NewWorker, queue = []}.
  +    State#state{worker = NewWorker, queue = [], worker_start = util:mk_timestamp_us()}.
   
   
   worker(Queue) ->
  
positive.code: 
  -record(request, {requester, foldfun, acc}).
  -record(request_error, {requester, reason}).
  -record(state, {worker = undefined, queue = []}).
  
  -define(SERVER, ?MODULE).
  
  
negative.code: %%                                      {stop, Reason, State}
  %% Description: Handling cast messages
  %%--------------------------------------------------------------------
  handle_cast({worker_done, Worker, ResultQueue}, #state{worker = Worker,
  						       worker_start = WorkerStart} = State) ->
      lists:foreach(fun(#request{requester = Requester, acc = AccOut}) ->
  			  gen_server:reply(Requester, {ok, AccOut});
  		     (#request_error{requester = Requester, reason = Reason}) ->
  			  gen_server:reply(Requester, {error, Reason})
  		  end, ResultQueue),
  
      collectd:set_gauge(delay, torrent_search, [(util:mk_timestamp_us() - WorkerStart) / 1000000]),
      State2 = maybe_start(State#state{worker = undefined,
  				     worker_start = undefined}),
      {noreply, State2}.
  
  %%--------------------------------------------------------------------
  %% Function: handle_info(Info, State) -> {noreply, State} |
  