Pipe are closed properly (fix fd leaks)

fix #2
bombela · Apr 12, 2012 · 2a5dac5 · 2a5dac5
1 parent 9fd7821
commit 2a5dac5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/gevent_subprocess/gevent_subprocess.py b/gevent_subprocess/gevent_subprocess.py
@@ -69,7 +69,7 @@ def write(self, data):
                 data = data[bytes_written:]
             except OSError as e:
                 if e.errno == errno.EPIPE:
-                    self._closed = True
+                    self.close()
                     raise IOError(e)
                 if e.errno != errno.EAGAIN:
                     raise
@@ -86,7 +86,7 @@ def _read(self, size=-1, greedy=True):
                 buffer = os.read(self._fd, size if size > 0 else 64 * 1024)
                 bytes_read = len(buffer)
                 if bytes_read == 0:
-                    self._closed = True
+                    self.close()
                     break
                 if size > 0:
                     size -= bytes_read