class RIMS::Protocol::ConnectionTimer

Public Class Methods

new(limits, read_io) click to toggle source
# File lib/rims/protocol/connection.rb, line 33
def initialize(limits, read_io)
  @limits = limits
  @read_poll = Riser::ReadPoll.new(read_io)
  @command_wait_timeout = false
end

Public Instance Methods

command_wait() click to toggle source
# File lib/rims/protocol/connection.rb, line 39
def command_wait
  if (@limits.command_wait_timeout_seconds == 0) then
    if (@read_poll.call(0) != nil) then
      return self
    else
      @command_wait_timeout = true
      return
    end
  end

  @read_poll.reset_timer
  until (@read_poll.call(@limits.read_polling_interval_seconds) != nil)
    if (@read_poll.interval_seconds >= @limits.command_wait_timeout_seconds) then
      @command_wait_timeout = true
      return
    end
  end

  self
end
command_wait_timeout?() click to toggle source
# File lib/rims/protocol/connection.rb, line 60
def command_wait_timeout?
  @command_wait_timeout
end