92ff4e196b
Issue #14666 : stop multiprocessing's resource-sharing thread after the tests are done.
...
Also, block delivery of signals to that thread. Patch by Richard Oudkerk.
This will hopefully fix sporadic freezes on the FreeBSD 9.0 buildbot.
2012-04-27 23:51:03 +02:00
5438ed1572
Issue #4892 : multiprocessing Connections can now be transferred over multiprocessing Connections.
...
Patch by Richard Oudkerk (sbt).
2012-04-24 22:56:57 +02:00
23bba4ca39
Issue #11750 : The Windows API functions scattered in the _subprocess and
...
_multiprocessing.win32 modules now live in a single module "_winapi".
Patch by sbt.
2012-04-18 20:51:15 +02:00
c8ce715a82
Issue #14087 : multiprocessing: add Condition.wait_for(). Patch by sbt.
2012-04-17 18:45:57 +02:00
df97cbe7a1
Issue #14522 : Avoid duplicating socket handles in multiprocessing.connection.
...
Patch by sbt.
2012-04-07 22:38:52 +02:00
5c73e8eaf4
Issue #14482 : Raise a ValueError, not a NameError, when trying to create
...
a multiprocessing Client or Listener with an AF_UNIX type address under
Windows. Patch by Popa Claudiu.
2012-04-03 20:13:45 +02:00
6d20cba8d6
Issue #14482 : Raise a ValueError, not a NameError, when trying to create
...
a multiprocessing Client or Listener with an AF_UNIX type address under
Windows. Patch by Popa Claudiu.
2012-04-03 20:12:23 +02:00
93bba8fb8a
Issue #14151 : Raise a ValueError, not a NameError, when trying to create
...
a multiprocessing Client or Listener with an AF_PIPE type address under
non-Windows platforms. Patch by Popa Claudiu.
2012-04-01 17:25:49 +02:00
709176f10c
Issue #14151 : Raise a ValueError, not a NameError, when trying to create
...
a multiprocessing Client or Listener with an AF_PIPE type address under
non-Windows platforms. Patch by Popa Claudiu.
2012-04-01 17:19:09 +02:00
846fd302a0
Issue #14335 : multiprocessing's custom Pickler subclass now inherits from the C-accelerated implementation.
...
Patch by sbt.
2012-03-17 00:23:04 +01:00
bdb1cf1ca5
Issue #12328 : Fix multiprocessing's use of overlapped I/O on Windows.
...
Also, add a multiprocessing.connection.wait(rlist, timeout=None) function
for polling multiple objects at once. Patch by sbt.
Complete changelist from sbt's patch:
* Adds a wait(rlist, timeout=None) function for polling multiple
objects at once. On Unix this is just a wrapper for
select(rlist, [], [], timeout=None).
* Removes use of the SentinelReady exception and the sentinels argument
to certain methods. concurrent.futures.process has been changed to
use wait() instead of SentinelReady.
* Fixes bugs concerning PipeConnection.poll() and messages of zero
length.
* Fixes PipeListener.accept() to call ConnectNamedPipe() with
overlapped=True.
* Fixes Queue.empty() and SimpleQueue.empty() so that they are
threadsafe on Windows.
* Now PipeConnection.poll() and wait() will not modify the pipe except
possibly by consuming a zero length message. (Previously poll()
could consume a partial message.)
* All of multiprocesing's pipe related blocking functions/methods are
now interruptible by SIGINT on Windows.
2012-03-05 19:28:37 +01:00
cd77815e4c
Issue #11836 : document and expose multiprocessing.SimpleQueue
2012-02-15 23:27:00 +01:00
ed4a8fc095
Issue #8184 : multiprocessing: On Windows, don't set SO_REUSEADDR on Connection
...
sockets, and set FILE_FLAG_FIRST_PIPE_INSTANCE on named pipes, to make sure two
listeners can't bind to the same socket/pipe (or any existing socket/pipe).
2012-02-08 21:15:58 +01:00
edc67feaa4
Issue #8184 : Fix a potential file descriptor leak when a
...
multiprocessing.Connection socket can't be bound.
2012-02-04 15:12:08 +01:00
992ca5278e
Issue #8184 : Fix a potential file descriptor leak when a
...
multiprocessing.Connection socket can't be bound.
2012-02-04 14:55:53 +01:00
2d843d2520
Issue #13812 : When a multiprocessing Process child raises an exception, flush stderr after printing the exception traceback.
2012-01-27 10:53:35 +01:00
84a0fbf6b0
Issue #13812 : When a multiprocessing Process child raises an exception, flush stderr after printing the exception traceback.
2012-01-27 10:52:37 +01:00
fe8039b3e5
Issue #13565 : Increase multiprocessing's server socket backlog, to avoid
...
dropped connections in case of simultaneous connection requests.
2011-12-23 19:06:48 +01:00
78c1b42fde
Issue #13565 : Increase multiprocessing's server socket backlog, to avoid
...
dropped connections in case of simultaneous connection requests.
2011-12-23 19:07:58 +01:00
de911b2915
Issue #12708 : Add starmap() and starmap_async() methods (similar to itertools.starmap()) to multiprocessing.Pool.
...
Patch by Hynek Schlawack.
2011-12-21 11:03:24 +01:00
e6eabd4345
Issue #13215 : multiprocessing.Connection: don't hammer the remote end with
...
retries in case of ECONNREFUSED.
2011-11-19 09:59:43 +01:00
04842a84c3
Remove unused or redundant imports in concurrent.futures and multiprocessing.
2011-11-11 20:05:50 +01:00
021572431b
Issue #13373 : multiprocessing.Queue.get() could sometimes block indefinitely
...
when called with a timeout. Patch by Arnaud Ysmal.
2011-11-10 00:38:25 +01:00
a365113679
Issue #13373 : multiprocessing.Queue.get() could sometimes block indefinitely
...
when called with a timeout. Patch by Arnaud Ysmal.
2011-11-10 00:37:09 +01:00
5d1155c08e
Closes #13258 : Use callable() built-in in the standard library.
2011-10-28 14:45:05 +02:00
f8859e1808
Issue #10332 : multiprocessing: fix a race condition when a Pool is closed
...
before all tasks have completed.
2011-10-24 18:45:29 +02:00
e130a52d8a
Remove duplication.
2011-10-19 10:58:56 +03:00
aabbda5354
Merge 3.2
2011-10-28 14:52:29 +02:00
feeb3a366c
Issue #10332 : multiprocessing: fix a race condition when a Pool is closed
...
before all tasks have completed.
2011-10-24 18:47:43 +02:00
24d659daaf
Use InterruptedError instead of checking for EINTR
2011-10-23 23:49:42 +02:00
f10644983e
Merge with 3.2.
2011-10-19 11:06:26 +03:00
6b4883dec0
PEP 3151 / issue #12555 : reworking the OS and IO exception hierarchy.
2011-10-12 02:54:14 +02:00
dc863ddf79
Issue #12981 : rewrite multiprocessing_{sendfd,recvfd} in Python.
2011-09-24 20:04:29 +02:00
225aa4f8ec
Issue #12996 : multiprocessing.connection: transmit the header in network byte
...
order (endpoints machines can have different endianness).
2011-09-20 19:27:39 +02:00
0cdd4454f3
Remove indirection in threading (issue #10968 ).
...
The public names (Thread, Condition, etc.) used to be factory functions
returning instances of hidden classes (_Thread, _Condition, etc.),
because (if Guido recalls correctly) this code pre-dates the ability to
subclass extension types.
It is now possible to inherit from Thread and other classes, without
having to import the private underscored names like multiprocessing did.
A doc update will follow: a patch is under discussion on the issue.
2011-07-28 00:28:28 +02:00
fb96089b13
Fix test_multiprocessing failure under Windows.
...
(followup to dfaa3a149a92)
2011-07-20 02:01:39 +02:00
dc19c24832
Silence spurious "broken pipe" tracebacks when shutting down a ProcessPoolExecutor.
2011-07-16 01:51:58 +02:00
428bc6c48f
Issue #12573 : Add resource checks for dangling Thread and Process objects.
2011-07-15 22:15:38 +02:00
c081c0c6a0
Issue #12573 : Add resource checks for dangling Thread and Process objects.
2011-07-15 22:12:24 +02:00
600012028e
Add comment
2011-07-09 01:03:46 +02:00
71a28a9174
Rebind locally the globals which can be looked up at shutdown
...
(to avoid the warnings seen on a buildbot)
2011-07-09 01:03:00 +02:00
723585bbaf
Merge issue #12352 : Fix a deadlock in multiprocessing.Heap when a block is
...
freed by the garbage collector while the Heap lock is held.
2011-07-02 14:43:11 +02:00
a4a04069fd
Merge issue #12352 : Fix a deadlock in multiprocessing.Heap when a block is
...
freed by the garbage collector while the Heap lock is held.
2011-07-02 14:39:53 +02:00
778db49da9
Issue #12352 : Fix a deadlock in multiprocessing.Heap when a block is freed by
...
the garbage collector while the Heap lock is held.
2011-07-02 14:35:49 +02:00
395dc58ee7
(merge 3.2) Issue #12285 : multiprocessing.Pool() raises a ValueError if the
...
number of processes if negative or null.
2011-06-20 17:54:03 +02:00
2fae27b735
Issue #12285 : multiprocessing.Pool() raises a ValueError if the number of
...
processes if negative or null.
2011-06-20 17:53:35 +02:00
3bcc0170bd
(Merge 3.2) Issue #12310 : finalize the old process after _run_after_forkers()
...
multiprocessing: Process._bootstrap() keeps a reference to the old process to
delay its finalization until after _run_after_forkers() as been executed. This
change should fix a crash on Mac OS X Tiger when a lock is released after a
fork.
Patch written by Charles-François Nataliv and Antoine Pitrou.
2011-06-17 12:36:26 +02:00
0f83b1511c
Issue #12310 : finalize the old process after _run_after_forkers()
...
multiprocessing: Process._bootstrap() keeps a reference to the old process to
delay its finalization until after _run_after_forkers() as been executed. This
change should fix a crash on Mac OS X Tiger when a lock is released after a
fork.
Patch written by Charles-François Nataliv and Antoine Pitrou.
2011-06-17 12:31:49 +02:00
dd69649660
Issue #9205 : concurrent.futures.ProcessPoolExecutor now detects killed
...
children and raises BrokenProcessPool in such a situation. Previously it
would reliably freeze/deadlock.
2011-06-08 17:21:55 +02:00
34b312e33d
Whitespace normalization
2011-06-06 19:36:01 +02:00
Antoine Pitrou
Charles-François Natali
Sandro Tosi
Florent Xicluna
Ezio Melotti
Éric Araujo
Victor Stinner