84 |
self.transport.connect(username=username, |
self.transport.connect(username=username, |
85 |
password=password, |
password=password, |
86 |
hostkey=self.hostkey) |
hostkey=self.hostkey) |
87 |
|
|
88 |
except paramiko.ssh_exception.SSHException, e: |
except paramiko.ssh_exception.SSHException, e: |
89 |
print e |
print e |
90 |
# let's force close chans |
# let's force close chans |
111 |
def __del__(self): |
def __del__(self): |
112 |
if self.transport: |
if self.transport: |
113 |
self.transport.close() |
self.transport.close() |
114 |
|
|
115 |
def open_session(self): |
def open_session(self): |
116 |
chan = self.transport.open_session() |
chan = self.transport.open_session() |
117 |
chan.get_pty() |
chan.get_pty() |
125 |
|
|
126 |
if pcc is None or not pcc.invoke_subsystem('proxy-control'): |
if pcc is None or not pcc.invoke_subsystem('proxy-control'): |
127 |
raise SSHproxyError('Failed to invoke proxy-control subsystem') |
raise SSHproxyError('Failed to invoke proxy-control subsystem') |
128 |
|
|
129 |
pcc.ultra_debug = 1 |
pcc.ultra_debug = 1 |
130 |
pcc.settimeout(0.0) |
pcc.settimeout(0.0) |
131 |
self.proxy_control = pcc |
self.proxy_control = pcc |
132 |
self.chan.append(pcc) |
self.chan.append(pcc) |
133 |
return pcc |
return pcc |
134 |
|
|
135 |
def close_session(self): |
def close_session(self): |
136 |
if self.session: |
if self.session: |
137 |
# let's force close chans |
# let's force close chans |
198 |
def reset_term(self): |
def reset_term(self): |
199 |
if self.fdin == sys.stdin: |
if self.fdin == sys.stdin: |
200 |
termios.tcsetattr(self.fdin, termios.TCSADRAIN, self.oldtty) |
termios.tcsetattr(self.fdin, termios.TCSADRAIN, self.oldtty) |
201 |
|
|
202 |
|
|
203 |
def start_client(username, password, proxy=None, port=None, |
def start_client(username, password, proxy=None, port=None, |
204 |
ruser=None, hostname='localhost', rport=None): |
ruser=None, hostname='localhost', rport=None): |