Class: Net::SSH::Connection::SingleSessionEventLoop

Inherits:
EventLoop
  • Object
show all
Defined in:
lib/net/ssh/connection/event_loop.rb

Overview

optimized version for a single session

Instance Attribute Summary

Attributes included from Loggable

#logger

Instance Method Summary collapse

Methods inherited from EventLoop

#initialize, #process, #process_only, #register

Methods included from Loggable

#debug, #error, #fatal, #info, #lwarn

Constructor Details

This class inherits a constructor from Net::SSH::Connection::EventLoop

Instance Method Details

#ev_preprocess(&block) ⇒ Object

Compatibility for original single session event loops: we call block with session as argument


98
99
100
101
102
103
# File 'lib/net/ssh/connection/event_loop.rb', line 98

def ev_preprocess(&block)
  return false if block_given? && !yield(@sessions.first)
  @sessions.each(&:ev_preprocess)
  return false if block_given? && !yield(@sessions.first)
  return true
end

#ev_select_and_postprocess(wait) ⇒ Object


105
106
107
108
109
110
111
112
113
# File 'lib/net/ssh/connection/event_loop.rb', line 105

def ev_select_and_postprocess(wait)
  raise "Only one session expected" unless @sessions.count == 1
  session = @sessions.first
  sr,sw,actwait = session.ev_do_calculate_rw_wait(wait)
  readers, writers, = IO.select(sr, sw, nil, actwait)
    
  session.ev_do_handle_events(readers,writers)
  session.ev_do_postprocess(!((readers.nil? || readers.empty?) && (writers.nil? || writers.empty?)))
end