# File lib/pr_eventmachine.rb, line 956 956: def eventable_write 957: 40.times { 958: break if @outbound_q.empty? 959: begin 960: data,target = @outbound_q.first 961: 962: # This damn better be nonblocking. 963: io.send data.to_s, 0, target 964: 965: @outbound_q.shift 966: rescue Errno::EAGAIN 967: # It's not been observed in testing that we ever get here. 968: # True to the definition, packets will be accepted and quietly dropped 969: # if the system is under pressure. 970: break 971: rescue EOFError, Errno::ECONNRESET 972: @close_scheduled = true 973: @outbound_q.clear 974: end 975: } 976: end