diff options
author | Robey Pointer <robey@lag.net> | 2006-11-20 11:21:37 -0800 |
---|---|---|
committer | Robey Pointer <robey@lag.net> | 2006-11-20 11:21:37 -0800 |
commit | 48bb10694b67a66f2c524dcca8a867319e60b87c (patch) | |
tree | eb0331ece837e585e9c17e45f73beab5155f7152 /paramiko/pipe.py | |
parent | b956cc48317dcc2440a64a9295b8fdd6cc021fe3 (diff) | |
download | paramiko-48bb10694b67a66f2c524dcca8a867319e60b87c.tar.gz |
[project @ robey@lag.net-20061120192137-1rcpiiq9mcd58m76]
reorder the closing of the pipe in Channel.close() to make sure it happens even when the channel is closed by the remote host first
Diffstat (limited to 'paramiko/pipe.py')
-rw-r--r-- | paramiko/pipe.py | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/paramiko/pipe.py b/paramiko/pipe.py index 52300996..0fa2bbf6 100644 --- a/paramiko/pipe.py +++ b/paramiko/pipe.py @@ -39,10 +39,13 @@ class PosixPipe (object): self._rfd, self._wfd = os.pipe() self._set = False self._forever = False + self._closed = False def close (self): os.close(self._rfd) os.close(self._wfd) + # used for unit tests: + self._closed = True def fileno (self): return self._rfd @@ -82,10 +85,13 @@ class WindowsPipe (object): serv.close() self._set = False self._forever = False + self._closed = False def close (self): self._rsock.close() self._wsock.close() + # used for unit tests: + self._closed = True def fileno (self): return self._rsock.fileno() |