# File lib/map_reduce/file.rb, line 26 def get_lines t = Time.now lines = [] (@lines_per_client || 1).times do begin if @lock sleep locked_queue_wait || 1 retry else if line = queue.shift lines << line else sleep empty_queue_wait || 30 retry end end rescue MapReduceError retry end end @time_spent_grabbing_objects += (Time.now - t) @num_objects_grabbed += 1 return lines.join end