Revision e91a5349 ncclient/transport/ssh.py
| b/ncclient/transport/ssh.py | ||
|---|---|---|
| 29 | 29 |
TICK = 0.1 |
| 30 | 30 |
|
| 31 | 31 |
class SSHSession(Session): |
| 32 |
|
|
| 32 |
|
|
| 33 | 33 |
def __init__(self): |
| 34 | 34 |
Session.__init__(self) |
| 35 | 35 |
self._host_keys = paramiko.HostKeys() |
| ... | ... | |
| 74 | 74 |
else: # if we didn't break out of the loop, full delim was parsed |
| 75 | 75 |
msg_till = buf.tell() - n |
| 76 | 76 |
buf.seek(0) |
| 77 |
self.dispatch('received', buf.read(msg_till).strip())
|
|
| 77 |
self._dispatch_received(buf.read(msg_till).strip())
|
|
| 78 | 78 |
buf.seek(n+1, os.SEEK_CUR) |
| 79 | 79 |
rest = buf.read() |
| 80 | 80 |
buf = StringIO() |
| ... | ... | |
| 268 | 268 |
except Exception as e: |
| 269 | 269 |
self.close() |
| 270 | 270 |
logger.debug('*** broke out of main loop ***')
|
| 271 |
self.dispatch('error', e)
|
|
| 271 |
self._dispatch_error(e)
|
|
| 272 | 272 |
|
| 273 | 273 |
@property |
| 274 | 274 |
def transport(self): |
| 275 |
'''Get underlying paramiko.transport object; this is provided so methods |
|
| 276 |
like transport.set_keepalive can be called. |
|
| 275 |
'''Get underlying paramiko transport object; this is provided so methods |
|
| 276 |
like set_keepalive can be called on it. See paramiko.Transport |
|
| 277 |
documentation for details. |
|
| 277 | 278 |
''' |
| 278 | 279 |
return self._transport |
Also available in: Unified diff