File "context.cpython-34.pyc"
Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/opt/alt/python34/lib64/python3.4/multiprocessing/__pycache__/context.cpython-34.pyc
File size: 13.22 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit
e f) @ s[ d d l Z d d l Z d d l Z d d l m Z g Z Gd d d e Z Gd d d e Z Gd d d e Z Gd
d d e Z
Gd d
d
e Z Gd d d e j
Z Gd d d e Z e d d e e D e _ e j d k rGd d d e j
Z Gd d d e j
Z Gd d d e j
Z Gd d d e Z Gd d d e Z Gd d d e Z i e d! 6e d" 6e d# 6Z e e d! Z nO Gd$ d d e j
Z Gd% d d e Z i e d" 6Z e e d" Z d& d' Z e j Z d( d) Z d* d+ Z d, d- Z d S). N )processc @ s e Z d Z d S) ProcessErrorN)__name__
__module__ __qualname__ r r </opt/alt/python34/lib64/python3.4/multiprocessing/context.pyr
s r c @ s e Z d Z d S)BufferTooShortN)r r r r r r r r
s r
c @ s e Z d Z d S) TimeoutErrorN)r r r r r r r r s r c @ s e Z d Z d S)AuthenticationErrorN)r r r r r r r r s r c @ s e Z d Z e Z e Z e Z e Z e e j Z e e j
Z
d d Z d d Z d d d Z
d d Z d
d Z d d
d Z d d d Z d d d Z d d Z d d d d Z d d d Z d d d Z d d Z d d f d d d Z d! d" Z d# d$ Z d% d d& d' Z d% d d( d) Z d* d+ Z d, d- Z d d. d/ Z d0 d1 Z d2 d3 Z! d4 d5 Z" d d6 d7 Z# d8 d9 d: Z$ d d; d< Z% d= d> Z& d S)? BaseContextc C s/ t j } | d k r' t d n | Sd S)z(Returns the number of CPUs in the systemNz cannot determine number of cpus)os cpu_countNotImplementedError)selfZnumr r r r ' s zBaseContext.cpu_countc C s3 d d l m } | d | j } | j | S)zReturns a manager associated with a running server process
The managers methods such as `Lock()`, `Condition()` and `Queue()`
can be used to create shared objects.
r ) SyncManagerctx)Zmanagersr get_contextstart)r r mr r r Manager/ s
zBaseContext.ManagerTc C s d d l m } | | S)z1Returns two connection object connected by a piper )Pipe)
connectionr )r Zduplexr r r r r : s zBaseContext.Pipec C s# d d l m } | d | j S)z#Returns a non-recursive lock objectr )Lockr ) synchronizer r )r r r r r r ? s zBaseContext.Lockc C s# d d l m } | d | j S)z Returns a recursive lock objectr )RLockr )r r r )r r r r r r D s zBaseContext.RLockNc C s& d d l m } | | d | j S)zReturns a condition objectr ) Conditionr )r r r )r lockr r r r r I s zBaseContext.Conditionr c C s& d d l m } | | d | j S)zReturns a semaphore objectr ) Semaphorer )r r r )r valuer r r r r N s zBaseContext.Semaphorec C s& d d l m } | | d | j S)z"Returns a bounded semaphore objectr )BoundedSemaphorer )r r! r )r r r! r r r r! S s z BaseContext.BoundedSemaphorec C s# d d l m } | d | j S)zReturns an event objectr )Eventr )r r" r )r r" r r r r" X s zBaseContext.Eventc C s, d d l m } | | | | d | j S)zReturns a barrier objectr )Barrierr )r r# r )r ZpartiesactionZtimeoutr# r r r r# ] s zBaseContext.Barrierr c C s& d d l m } | | d | j S)zReturns a queue objectr )Queuer )queuesr% r )r maxsizer% r r r r% b s zBaseContext.Queuec C s& d d l m } | | d | j S)zReturns a queue objectr )
JoinableQueuer )r& r( r )r r' r( r r r r( g s zBaseContext.JoinableQueuec C s# d d l m } | d | j S)zReturns a queue objectr ) SimpleQueuer )r& r) r )r r) r r r r) l s zBaseContext.SimpleQueuec C s/ d d l m } | | | | | d | j S)z Returns a process pool objectr )Poolcontext)Zpoolr* r )r Z processesZ initializerZinitargsZmaxtasksperchildr* r r r r* q s zBaseContext.Poolc G s d d l m } | | | S)zReturns a shared objectr )RawValue) sharedctypesr, )r typecode_or_typeargsr, r r r r, x s zBaseContext.RawValuec C s d d l m } | | | S)zReturns a shared arrayr )RawArray)r- r0 )r r. size_or_initializerr0 r r r r0 } s zBaseContext.RawArrayr c G s/ d d l m } | | d | d | j | S)z$Returns a synchronized shared objectr )Valuer r )r- r2 r )r r. r r/ r2 r r r r2 s zBaseContext.Valuec C s/ d d l m } | | | d | d | j S)z#Returns a synchronized shared arrayr )Arrayr r )r- r3 r )r r. r1 r r3 r r r r3 s zBaseContext.Arrayc C s? t j d k r; t t d d r; d d l m } | n d S)zCheck whether this is a fake forked process in a frozen executable.
If so then run code specified by commandline and exit.
win32frozenFr )freeze_supportN)sysplatformgetattrspawnr6 )r r6 r r r r6 s !zBaseContext.freeze_supportc C s d d l m } | S)zZReturn package logger -- if it does not already exist then
it is created.
r )
get_logger)utilr; )r r; r r r r; s zBaseContext.get_loggerc C s d d l m } | | S)z8Turn on logging and add a handler which prints to stderrr )
log_to_stderr)r< r= )r levelr= r r r r= s zBaseContext.log_to_stderrc C s d d l m } d S)zVInstall support for sending connections and sockets
between processes
r )r N) r )r r r r r allow_connection_pickling s z%BaseContext.allow_connection_picklingc C s d d l m } | | d S)zSets the path to a python.exe or pythonw.exe binary used to run
child processes instead of sys.executable when using the 'spawn'
start method. Useful for people embedding Python.
r )set_executableN)r: rA )r
executablerA r r r rA s zBaseContext.set_executablec C s d d l m } | | d S)zkSet list of module names to try to load in forkserver process.
This is really just a hint.
r )set_forkserver_preloadN)
forkserverrC )r Z module_namesrC r r r rC s z"BaseContext.set_forkserver_preloadc C sQ | d k r | Sy t | } Wn" t k
rB t d | Yn X| j | S)Nzcannot find context for %r)_concrete_contextsKeyError
ValueError_check_available)r methodr r r r r s
zBaseContext.get_contextFc C s | j S)N)_name)r
allow_noner r r get_start_method s z BaseContext.get_start_methodc C s t d d S)Nz+cannot set start method of concrete context)rG )r rI r r r set_start_method s z BaseContext.set_start_methodc C s d S)Nr )r r r r rH s z BaseContext._check_available)'r r r r r
r r staticmethodr Zcurrent_processZactive_childrenr r r r r r r r! r" r# r% r( r) r* r, r0 r2 r3 r6 r; r= r@ rA rC r rL rM rH r r r r r
sF
r
c @ s( e Z d Z d Z e d d Z d S)ProcessNc C s t j j j | S)N)_default_contextr rO _Popen) process_objr r r rQ s zProcess._Popen)r r r
_start_methodrN rQ r r r r rO s rO c sa e Z d Z e Z d d Z d f d d Z d d d Z d d d
Z d d Z S)
DefaultContextc C s | | _ d | _ d S)N)rP _actual_context)r r+ r r r __init__ s zDefaultContext.__init__Nc sE | d k r1 | j d k r* | j | _ n | j St j | Sd S)N)rU rP superr )r rI ) __class__r r r s
zDefaultContext.get_contextFc C sZ | j d k r% | r% t d n | d k rD | rD d | _ d S| j | | _ d S)Nz context has already been set)rU RuntimeErrorr )r rI Zforcer r r rM s z DefaultContext.set_start_methodc C s2 | j d k r( | r d S| j | _ n | j j S)N)rU rP rJ )r rK r r r rL s
z DefaultContext.get_start_methodc C sJ t j d k r d g Sd d l m } | j r< d d d g Sd d g Sd S)Nr4 r: r ) reductionforkrD )r7 r8 r? rZ HAVE_SEND_HANDLE)r rZ r r r get_all_start_methods s
z$DefaultContext.get_all_start_methods) r r r rO rV r rM rL r] r r )rX r rT s rT c c s% | ] } | d d k r | Vq d S)r _Nr ).0xr r r <genexpr> s ra r4 c @ s( e Z d Z d Z e d d Z d S) ForkProcessr[ c C s d d l m } | | S)Nr )Popen)Z
popen_forkrc )rR rc r r r rQ s zForkProcess._PopenN)r r r rS rN rQ r r r r rb s rb c @ s( e Z d Z d Z e d d Z d S) SpawnProcessr: c C s d d l m } | | S)Nr )rc )Zpopen_spawn_posixrc )rR rc r r r rQ s zSpawnProcess._PopenN)r r r rS rN rQ r r r r rd
s rd c @ s( e Z d Z d Z e d d Z d S)ForkServerProcessrD c C s d d l m } | | S)Nr )rc )Zpopen_forkserverrc )rR rc r r r rQ s zForkServerProcess._PopenN)r r r rS rN rQ r r r r re s re c @ s e Z d Z d Z e Z d S) ForkContextr[ N)r r r rJ rb rO r r r r rf s rf c @ s e Z d Z d Z e Z d S) SpawnContextr: N)r r r rJ rd rO r r r r rg s rg c @ s( e Z d Z d Z e Z d d Z d S)ForkServerContextrD c C s, d d l m } | j s( t d n d S)Nr )rZ z%forkserver start method not available)r? rZ r\ rG )r rZ r r r rH & s z"ForkServerContext._check_availableN)r r r rJ re rO rH r r r r rh # s rh r[ r: rD c @ s( e Z d Z d Z e d d Z d S)rd r: c C s d d l m } | | S)Nr )rc )Zpopen_spawn_win32rc )rR rc r r r rQ 6 s zSpawnProcess._PopenN)r r r rS rN rQ r r r r rd 4 s c @ s e Z d Z d Z e Z d S)rg r: N)r r r rJ rd rO r r r r rg ; s c C s t | t _ d S)N)rE rP rU )rI r r r _force_start_methodH s ri c C s t t d d S)Nspawning_popen)r9 _tlsr r r r get_spawning_popenQ s rl c C s
| t _ d S)N)rk rj )popenr r r set_spawning_popenT s rn c C s/ t d k r+ t d t | j n d S)NzF%s objects should only be shared between processes through inheritance)rl rY typer )objr r r assert_spawningW s rq )!r r7 Z threadingr? r __all__ Exceptionr r
r r objectr
Z BaseProcessrO rT listdirr8 rb rd re rf rg rh rE rP ri Zlocalrk rl rn rq r r r r <module> sD ("