/prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/ |
reduction.py | 43 import _multiprocessing namespace 54 if not(sys.platform == 'win32' or hasattr(_multiprocessing, 'recvfd')): 63 from _multiprocessing import win32 80 _multiprocessing.sendfd(conn.fileno(), handle) 83 return _multiprocessing.recvfd(conn.fileno()) 162 # Register `_multiprocessing.Connection` with `ForkingPickler` 171 return _multiprocessing.Connection( 175 ForkingPickler.register(_multiprocessing.Connection, reduce_connection) 200 # Register `_multiprocessing.PipeConnection` with `ForkingPickler` 211 return _multiprocessing.PipeConnection [all...] |
connection.py | 45 import _multiprocessing namespace 191 c1 = _multiprocessing.Connection(os.dup(s1.fileno())) 192 c2 = _multiprocessing.Connection(os.dup(s2.fileno())) 197 c1 = _multiprocessing.Connection(fd1, writable=False) 198 c2 = _multiprocessing.Connection(fd2, readable=False) 203 from _multiprocessing import win32 238 c1 = _multiprocessing.PipeConnection(h1, writable=duplex) 239 c2 = _multiprocessing.PipeConnection(h2, readable=duplex) 276 conn = _multiprocessing.Connection(fd) 309 conn = _multiprocessing.Connection(fd [all...] |
synchronize.py | 45 import _multiprocessing namespace 54 from _multiprocessing import SemLock 66 SEM_VALUE_MAX = _multiprocessing.SemLock.SEM_VALUE_MAX 69 # Base class for semaphores and mutexes; wraps `_multiprocessing.SemLock` 75 sl = self._semlock = _multiprocessing.SemLock(kind, value, maxvalue) 100 self._semlock = _multiprocessing.SemLock._rebuild(*state)
|
heap.py | 43 import _multiprocessing namespace 55 from _multiprocessing import win32 249 address, length = _multiprocessing.address_of_buffer(arena.buffer)
|
__init__.py | 83 # This is down here because _multiprocessing uses BufferTooShort 84 import _multiprocessing namespace
|
queues.py | 46 import _multiprocessing namespace 60 maxsize = _multiprocessing.SemLock.SEM_VALUE_MAX
|
forking.py | 190 from _multiprocessing import win32, Connection, PipeConnection
|
/prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/ |
reduction.py | 43 import _multiprocessing namespace 54 if not(sys.platform == 'win32' or hasattr(_multiprocessing, 'recvfd')): 63 from _multiprocessing import win32 80 _multiprocessing.sendfd(conn.fileno(), handle) 83 return _multiprocessing.recvfd(conn.fileno()) 162 # Register `_multiprocessing.Connection` with `ForkingPickler` 171 return _multiprocessing.Connection( 175 ForkingPickler.register(_multiprocessing.Connection, reduce_connection) 200 # Register `_multiprocessing.PipeConnection` with `ForkingPickler` 211 return _multiprocessing.PipeConnection [all...] |
connection.py | 45 import _multiprocessing namespace 191 c1 = _multiprocessing.Connection(os.dup(s1.fileno())) 192 c2 = _multiprocessing.Connection(os.dup(s2.fileno())) 197 c1 = _multiprocessing.Connection(fd1, writable=False) 198 c2 = _multiprocessing.Connection(fd2, readable=False) 203 from _multiprocessing import win32 238 c1 = _multiprocessing.PipeConnection(h1, writable=duplex) 239 c2 = _multiprocessing.PipeConnection(h2, readable=duplex) 276 conn = _multiprocessing.Connection(fd) 309 conn = _multiprocessing.Connection(fd [all...] |
synchronize.py | 45 import _multiprocessing namespace 54 from _multiprocessing import SemLock 66 SEM_VALUE_MAX = _multiprocessing.SemLock.SEM_VALUE_MAX 69 # Base class for semaphores and mutexes; wraps `_multiprocessing.SemLock` 75 sl = self._semlock = _multiprocessing.SemLock(kind, value, maxvalue) 100 self._semlock = _multiprocessing.SemLock._rebuild(*state)
|
heap.py | 43 import _multiprocessing namespace 55 from _multiprocessing import win32 249 address, length = _multiprocessing.address_of_buffer(arena.buffer)
|
__init__.py | 83 # This is down here because _multiprocessing uses BufferTooShort 84 import _multiprocessing namespace
|
queues.py | 46 import _multiprocessing namespace 60 maxsize = _multiprocessing.SemLock.SEM_VALUE_MAX
|
forking.py | 190 from _multiprocessing import win32, Connection, PipeConnection
|
/prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
test_multiprocessing.py | 22 _multiprocessing = test_support.import_module('_multiprocessing') variable 23 # import threading after _multiprocessing to raise a more relevant error 24 # message: "No module named _multiprocessing". _multiprocessing is not compiled 79 HAVE_GETVALUE = not getattr(_multiprocessing, [all...] |
/prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
test_multiprocessing.py | 22 _multiprocessing = test_support.import_module('_multiprocessing') variable 23 # import threading after _multiprocessing to raise a more relevant error 24 # message: "No module named _multiprocessing". _multiprocessing is not compiled 79 HAVE_GETVALUE = not getattr(_multiprocessing, [all...] |