Method: Packet::Core::CommonMethods#handle_write_event

Defined in:
lib/packet/packet_core.rb

#handle_write_event(p_ready_fds) ⇒ Object



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