177
178
179
180
181
182
183
184
185
186
187
188
|
# File 'lib/packet/packet_core.rb', line 177
def handle_write_event(p_ready_fds)
p_ready_fds.each do |sock_fd|
fileno = sock_fd.fileno
if UNIXSocket === sock_fd && (internal_instance = internal_scheduled_write[fileno])
internal_instance.write_and_schedule(sock_fd)
elsif extern_opts = connection_completion_awaited[fileno]
complete_connection(sock_fd,extern_opts)
elsif handler_instance = write_scheduled[fileno]
handler_instance.write_and_schedule(sock_fd)
end
end
end
|