Class: Net::Telnet
- Inherits:
-
Object
- Object
- Net::Telnet
- Defined in:
- lib/oxidized/input/telnet.rb
Instance Attribute Summary collapse
-
#output ⇒ Object
readonly
how to do this, without redefining the whole damn thing FIXME: we also need output (not sure I’m going to support this).
Instance Method Summary collapse
-
#oxidized_expect(options) ⇒ Object
:yield: recvdata.
Instance Attribute Details
#output ⇒ Object (readonly)
how to do this, without redefining the whole damn thing FIXME: we also need output (not sure I’m going to support this)
75 76 77 |
# File 'lib/oxidized/input/telnet.rb', line 75 def output @output end |
Instance Method Details
#oxidized_expect(options) ⇒ Object
:yield: recvdata
76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 |
# File 'lib/oxidized/input/telnet.rb', line 76 def oxidized_expect() # :yield: recvdata model = @options["Model"] @log = @options["Log"] expects = [[:expect]].flatten time_out = [:timeout] || @options["Timeout"] || Oxidized.config.timeout? Timeout::timeout(time_out) do line = "" rest = "" buf = "" loop do c = @sock.readpartial(1024 * 1024) @output = c c = rest + c if Integer(c.rindex(/#{IAC}#{SE}/no) || 0) < Integer(c.rindex(/#{IAC}#{SB}/no) || 0) buf = preprocess(c[0...c.rindex(/#{IAC}#{SB}/no)]) rest = c[c.rindex(/#{IAC}#{SB}/no)..-1] elsif pt = c.rindex(/#{IAC}[^#{IAC}#{AO}#{AYT}#{DM}#{IP}#{NOP}]?\z/no) || c.rindex(/\r\z/no) buf = preprocess(c[0...pt]) rest = c[pt..-1] else buf = preprocess(c) rest = '' end if Oxidized.config.input.debug? @log.print buf @log.flush end line += buf line = model.expects line match = expects.find { |re| line.match re } return match if match end end end |