Merge pull request #303 from fxposter/master

Fix for high CPU load. Fixes #260 and #299.
2013-01-14 05:06:44 -08:00
parent 2faa3fb6ff aceea1472a
commit 443994d3b5
1 changed files with 6 additions and 2 deletions
@@ -275,8 +275,12 @@ private
        loop do
          io = IO.select(@readers.values, nil, nil, 30)
          (io.nil? ? [] : io.first).each do |reader|
-            data = reader.gets
-            output_with_mutex name_for(@readers.invert[reader]), data
+            if reader.eof?
+              @readers.delete_if { |key, value| value == reader }
+            else
+              data = reader.gets
+              output_with_mutex name_for(@readers.invert[reader]), data
+            end
          end
        end
      rescue Exception => ex