Class: HrrRbSsh::Connection::RequestHandler::ReferencePtyReqRequestHandler

Inherits:
HrrRbSsh::Connection::RequestHandler show all
Defined in:
lib/hrr_rb_ssh/connection/request_handler/reference_pty_req_request_handler.rb

Instance Method Summary collapse

Methods inherited from HrrRbSsh::Connection::RequestHandler

#run

Constructor Details

#initialize ⇒ ReferencePtyReqRequestHandler

Returns a new instance of ReferencePtyReqRequestHandler.



14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
 
# File 'lib/hrr_rb_ssh/connection/request_handler/reference_pty_req_request_handler.rb', line 14

def initialize
  @proc = Proc.new { |context|
    begin
      ptm, pts = PTY.open
      passwd = Etc.getpwnam(context.username)
      FileUtils.chown passwd.uid, -1, pts
      FileUtils.chmod 'u+rw,g+w', pts
      ptm.winsize = [context.terminal_height_rows, context.terminal_width_characters, context.terminal_width_pixels, context.terminal_height_pixels]
      context.vars[:ptm] = ptm
      context.vars[:pts] = pts
      context.vars[:env] ||= Hash.new
      context.vars[:env]['TERM'] = context.term_environment_variable_value
      context.chain_proc { |chain|
        begin
          ptm_read_thread = Thread.start {
            loop do
              begin
                context.io[1].write ptm.readpartial(10240)
              rescue EOFError => e
                context.log_info { "ptm is EOF in ptm_read_thread" }
                break
              rescue IOError => e
                context.log_warn { "IO Error in ptm_read_thread" }
                break
              rescue Errno::EIO => e
                context.log_info { "EIO Error in ptm_read_thread" }
                break
              rescue => e
                context.log_error { [e.backtrace[0], ": ", e.message, " (", e.class.to_s, ")\n\t", e.backtrace[1..-1].join("\n\t")].join }
                break
              end
            end
          }
          ptm_write_thread = Thread.start {
            loop do
              begin
                ptm.write context.io[0].readpartial(10240)
              rescue EOFError => e
                context.log_info { "IO is EOF in ptm_write_thread" }
                break
              rescue IOError => e
                context.log_warn { "IO Error in ptm_write_thread" }
                break
              rescue Errno::EIO => e
                context.log_info { "EIO Error in ptm_read_thread" }
                break
              rescue => e
                context.log_error { [e.backtrace[0], ": ", e.message, " (", e.class.to_s, ")\n\t", e.backtrace[1..-1].join("\n\t")].join }
                break
              end
            end
          }
          chain.call_next
        ensure
          context.log_info { "closing pty-req request handler chain_proc" }
          context.vars[:ptm].close rescue nil
          context.vars[:pts].close rescue nil
          ptm_read_thread.join
          ptm_write_thread.exit
          ptm_write_thread.join
          context.log_info { "pty-req request handler chain_proc closed" }
        end
      }
    rescue => e
      ptm.close rescue nil
      pts.close rescue nil
      context.chain_proc{ |chain|
        exitstatus = 1
      }
      raise e
    end
  }
end