summaryrefslogtreecommitdiff
path: root/paramiko/pipe.py
diff options
context:
space:
mode:
authorRobey Pointer <robey@lag.net>2006-11-20 11:21:37 -0800
committerRobey Pointer <robey@lag.net>2006-11-20 11:21:37 -0800
commit48bb10694b67a66f2c524dcca8a867319e60b87c (patch)
treeeb0331ece837e585e9c17e45f73beab5155f7152 /paramiko/pipe.py
parentb956cc48317dcc2440a64a9295b8fdd6cc021fe3 (diff)
downloadparamiko-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.py6
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()