anchor.diff:                                                processed_files = Status#index_status.processed_files + 1
                                                }, StatusFn)
               end;
  -
           stop ->
  -            StatusFn(NewStatus)
  +            StatusFn(NewStatus),
  +            stop
       end.
  -
   
   index_worker_loop0(QueuePid, Index) ->
       {ok, Client} = riak_search:local_client(),
  
positive.code:                         last_status_time }).
  
  -define(STATUS_INTERVAL, 10000).                % Milliseconds between status callbacks
  
  %% ===================================================================
  %% API functions
  
negative.code: %% Internal functions
  %% ===================================================================
  
  console_status(done) ->
      io:format("Finished indexing.\n");
  console_status(Status) ->
      ElapsedSecs = timer:now_diff(now(), Status#index_status.start_time) / 1000000,
      AvgKbSec = (Status#index_status.processed_bytes / ElapsedSecs) / 1024,
  