lib/rainbows/thread_pool.rb in rainbows-0.90.0 vs lib/rainbows/thread_pool.rb in rainbows-0.90.1
- old
+ new
@@ -42,11 +42,10 @@
end
def sync_worker
s = LISTENERS.first
begin
- process_client(s.accept)
- rescue Errno::EINTR, Errno::ECONNABORTED
+ c = Rainbows.sync_accept(s) and process_client(c)
rescue => e
Error.listen_loop(e)
end while G.alive
end