Method: Packet::Core::CommonMethods#schedule_write

Defined in:
lib/packet/packet_core.rb

#schedule_write(t_sock, internal_instance = nil) ⇒ Object 



154
155
156
157
158
159
160
161
162
163
 
# File 'lib/packet/packet_core.rb', line 154

def schedule_write(t_sock,internal_instance = nil)
  fileno = t_sock.fileno
  if UNIXSocket === t_sock && internal_scheduled_write[fileno].nil?
    write_ios << t_sock
    internal_scheduled_write[t_sock.fileno] ||= internal_instance
  elsif write_scheduled[fileno].nil? && !(t_sock.is_a?(UNIXSocket))
    write_ios << t_sock
    write_scheduled[fileno] ||= connections[fileno][:instance]
  end
end