Rietveld Code Review Tool
Help | Bug tracker | Discussion group | Source code | Sign in
(8)

Unified Diff: Lib/multiprocessing/queues.py

Issue 10639: reindent.py converts newlines to platform default
Patch Set: Created 8 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Please Sign in to add in-line comments.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « Lib/multiprocessing/process.py ('k') | Lib/multiprocessing/util.py » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
--- a/Lib/multiprocessing/queues.py Tue Jul 26 09:37:46 2011 +0300
+++ b/Lib/multiprocessing/queues.py Mon Jul 25 09:47:18 2011 -0400
@@ -41,7 +41,6 @@
import time
import atexit
import weakref
-import errno
from queue import Empty, Full
import _multiprocessing
@@ -68,8 +67,6 @@
else:
self._wlock = Lock()
self._sem = BoundedSemaphore(maxsize)
- # For use by concurrent.futures
- self._ignore_epipe = False
self._after_fork()
@@ -78,11 +75,11 @@
def __getstate__(self):
assert_spawning(self)
- return (self._ignore_epipe, self._maxsize, self._reader, self._writer,
+ return (self._maxsize, self._reader, self._writer,
self._rlock, self._wlock, self._sem, self._opid)
def __setstate__(self, state):
- (self._ignore_epipe, self._maxsize, self._reader, self._writer,
+ (self._maxsize, self._reader, self._writer,
self._rlock, self._wlock, self._sem, self._opid) = state
self._after_fork()
@@ -181,7 +178,7 @@
self._thread = threading.Thread(
target=Queue._feed,
args=(self._buffer, self._notempty, self._send,
- self._wlock, self._writer.close, self._ignore_epipe),
+ self._wlock, self._writer.close),
name='QueueFeederThread'
)
self._thread.daemon = True
@@ -232,7 +229,7 @@
notempty.release()
@staticmethod
- def _feed(buffer, notempty, send, writelock, close, ignore_epipe):
+ def _feed(buffer, notempty, send, writelock, close):
debug('starting thread to feed data to pipe')
from .util import is_exiting
@@ -274,8 +271,6 @@
except IndexError:
pass
except Exception as e:
- if ignore_epipe and getattr(e, 'errno', 0) == errno.EPIPE:
- return
# Since this runs in a daemon thread the resources it uses
# may be become unusable while the process is cleaning up.
# We ignore errors which happen after the process has
« no previous file with comments | « Lib/multiprocessing/process.py ('k') | Lib/multiprocessing/util.py » ('j') | no next file with comments »

RSS Feeds Recent Issues | This issue
This is Rietveld 894c83f36cb7+