Revision 94265508 ncclient/transport/ssh.py
| b/ncclient/transport/ssh.py | ||
|---|---|---|
| 21 | 21 |
import paramiko |
| 22 | 22 |
|
| 23 | 23 |
from . import logger |
| 24 |
from errors import SSHError, SSHUnknownHostError, SSHAuthenticationError, SSHSessionClosedError
|
|
| 24 |
from errors import SSHError, SSHUnknownHostError, SSHAuthenticationError, SessionCloseError
|
|
| 25 | 25 |
from session import Session |
| 26 | 26 |
|
| 27 | 27 |
BUF_SIZE = 4096 |
| ... | ... | |
| 258 | 258 |
self._buffer.write(data) |
| 259 | 259 |
self._parse() |
| 260 | 260 |
else: |
| 261 |
raise SSHSessionClosedError(self._buffer.getvalue())
|
|
| 261 |
raise SessionCloseError(self._buffer.getvalue())
|
|
| 262 | 262 |
if not q.empty() and chan.send_ready(): |
| 263 | 263 |
data = q.get() + MSG_DELIM |
| 264 | 264 |
while data: |
| 265 | 265 |
n = chan.send(data) |
| 266 | 266 |
if n <= 0: |
| 267 |
raise SSHSessionClosedError(self._buffer.getvalue(), data)
|
|
| 267 |
raise SessionCloseError(self._buffer.getvalue(), data)
|
|
| 268 | 268 |
data = data[n:] |
| 269 | 269 |
except Exception as e: |
| 270 | 270 |
self.close() |
Also available in: Unified diff