HomeSort by relevance Sort by last modified time
    Searched refs:_multiprocessing (Results 1 - 25 of 48) sorted by null

1 2

  /external/python/cpython2/Lib/multiprocessing/
reduction.py 43 import _multiprocessing
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
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)
283 conn = _multiprocessing.Connection(fd)
321 conn = _multiprocessing.Connection(fd
    [all...]
synchronize.py 45 import _multiprocessing
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
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
  /prebuilts/gdb/darwin-x86/lib/python2.7/multiprocessing/
reduction.py 43 import _multiprocessing
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
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
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
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
  /prebuilts/gdb/linux-x86/lib/python2.7/multiprocessing/
reduction.py 43 import _multiprocessing
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
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
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
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
  /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/
reduction.py 43 import _multiprocessing
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
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
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
55 from _multiprocessing import win32
249 address, length = _multiprocessing.address_of_buffer(arena.buffer)
  /prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/
reduction.py 43 import _multiprocessing
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
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
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
55 from _multiprocessing import win32
249 address, length = _multiprocessing.address_of_buffer(arena.buffer)
  /external/python/cpython3/Lib/multiprocessing/
semaphore_tracker.py 19 import _multiprocessing
139 _multiprocessing.sem_unlink(name)
synchronize.py 17 import _multiprocessing
29 from _multiprocessing import SemLock, sem_unlink
41 SEM_VALUE_MAX = _multiprocessing.SemLock.SEM_VALUE_MAX
44 # Base class for semaphores and mutexes; wraps `_multiprocessing.SemLock`
58 sl = self._semlock = _multiprocessing.SemLock(
111 self._semlock = _multiprocessing.SemLock._rebuild(*state)

Completed in 214 milliseconds

1 2