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