Š¹¼]µ) ã @ sW 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 rÉGd 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 d! e ƒ d" e ƒ d# e ƒ i Z e e d! ƒ Z nN Gd$ d „ d e j
ƒ Z Gd% d „ d e ƒ Z d" e ƒ i Z 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/python35/lib64/python3.5/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$ d8 d; d< „ Z% d= d> „ Z& d S)?Ú BaseContextc C s/ t j ƒ } | d k r' t d ƒ ‚ n | Sd S)Nz cannot determine number of cpus)ÚosÚ cpu_countÚNotImplementedError)ÚselfÚnumr r r r ' s zBaseContext.cpu_countc C s3 d d l m } | d | j ƒ ƒ } | j ƒ | S)Nr )Ú SyncManagerÚctx)Úmanagersr Ú get_contextÚstart)r r Úmr r r ÚManager/ s
zBaseContext.ManagerTc C s d d l m } | | ƒ S)Nr )ÚPipe)Ú
connectionr )r Úduplexr r r r r : s zBaseContext.Pipec C s# d d l m } | d | j ƒ ƒ S)Nr )ÚLockr )Ú synchronizer r )r r r r r r ? s zBaseContext.Lockc C s# d d l m } | d | j ƒ ƒ S)Nr )ÚRLockr )r r r )r r r r r r D s zBaseContext.RLockNc C s& d d l m } | | d | j ƒ ƒS)Nr )Ú Conditionr )r r r )r Úlockr r r r r I s zBaseContext.Conditionr c C s& d d l m } | | d | j ƒ ƒS)Nr )Ú Semaphorer )r r" r )r Úvaluer" r r r r" N s zBaseContext.Semaphorec C s& d d l m } | | d | j ƒ ƒS)Nr )Ú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)Nr )ÚEventr )r r% r )r r% r r r r% X s zBaseContext.Eventc C s, d d l m } | | | | d | j ƒ ƒS)Nr )ÚBarrierr )r r& r )r ÚpartiesÚactionÚtimeoutr& r r r r& ] s zBaseContext.Barrierr c C s& d d l m } | | d | j ƒ ƒS)Nr )ÚQueuer )Úqueuesr* r )r Úmaxsizer* r r r r* b s zBaseContext.Queuec C s& d d l m } | | d | j ƒ ƒS)Nr )Ú
JoinableQueuer )r+ r- r )r r, r- r r r r- g s zBaseContext.JoinableQueuec C s# d d l m } | d | j ƒ ƒ S)Nr )Ú SimpleQueuer )r+ r. r )r r. r r r r. l s zBaseContext.SimpleQueuec C s/ d d l m } | | | | | d | j ƒ ƒS)Nr )ÚPoolÚcontext)Úpoolr/ r )r Ú processesÚ initializerÚinitargsÚmaxtasksperchildr/ r r r r/ q s zBaseContext.Poolc G s d d l m } | | | Œ S)Nr )ÚRawValue)Ú sharedctypesr6 )r Útypecode_or_typeÚargsr6 r r r r6 x s zBaseContext.RawValuec C s d d l m } | | | ƒ S)Nr )ÚRawArray)r7 r: )r r8 Úsize_or_initializerr: r r r r: } s zBaseContext.RawArrayr! c G s/ d d l m } | | | d | d | j ƒ ŒS)Nr )ÚValuer! r )r7 r< r )r r8 r! r9 r< r r r r< ‚ s zBaseContext.Valuec C s/ d d l m } | | | d | d | j ƒ ƒS)Nr )ÚArrayr! r )r7 r= r )r r8 r; r! r= r r r r= ˆ s zBaseContext.Arrayc C s< t j d k r8 t t d d ƒ r8 d d l m } | ƒ d S)NÚwin32ÚfrozenFr )Úfreeze_support)ÚsysÚplatformÚgetattrÚspawnr@ )r r@ r r r r@ Ž s !zBaseContext.freeze_supportc C s d d l m } | ƒ S)Nr )Ú
get_logger)ÚutilrE )r rE r r r rE – s zBaseContext.get_loggerc C s d d l m } | | ƒ S)Nr )Ú
log_to_stderr)rF rG )r ÚlevelrG r r r rG s zBaseContext.log_to_stderrc C s d d l m } d S)Nr )r )Ú r )r r r r r Úallow_connection_pickling¢ s z%BaseContext.allow_connection_picklingc C s d d l m } | | ƒ d S)Nr )Úset_executable)rD rK )r Ú
executablerK r r r rK ª s zBaseContext.set_executablec C s d d l m } | | ƒ d S)Nr )Úset_forkserver_preload)Ú
forkserverrM )r Ú module_namesrM r r r rM ² 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_contextsÚKeyErrorÚ
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)rR )r rT Úforcer r r Úset_start_methodÆ s z BaseContext.set_start_methodc C s d S)Nr )r r r r rS É s z BaseContext._check_available)'r r r r r
r r Ú staticmethodr Úcurrent_processÚactive_childrenr r r r r r r" r$ r% r& r* r- r. r/ r6 r: r< r= r@ rE rG rJ rK rM r rW rY rS 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 r] Ú_Popen)Ú process_objr r r r_ Ò s zProcess._Popen)r r r Ú
_start_methodrZ r_ r r r r r] Ð s r] 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)r^ Ú_actual_context)r r0 r r r Ú__init__Ù s zDefaultContext.__init__Nc sB | d k r. | j d k r' | j | _ | j St ƒ j | ƒ Sd S)N)rc r^ Úsuperr )r rT )Ú __class__r r r Ý s
zDefaultContext.get_contextFc C sW | j d k r" | r" t d ƒ ‚ | d k rA | rA d | _ d S| j | ƒ | _ d S)Nz context has already been set)rc Ú RuntimeErrorr )r rT rX r r r rY å s z DefaultContext.set_start_methodc C s/ | j d k r% | r d S| j | _ | j j S)N)rc r^ rU )r rV r r r rW í 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)Nr> rD r )Ú reductionÚforkrN )rA rB rI rh ÚHAVE_SEND_HANDLE)r rh r r r Úget_all_start_methodsô s
z$DefaultContext.get_all_start_methods) r r r r] rd r rY rW rk r r )rf r rb Ö s rb c c s% | ] } | d d k r | Vq d S)r Ú_Nr )Ú.0Úxr r r ú þ s ro r> c @ s( e Z d Z d Z e d d „ ƒ Z d S)Ú ForkProcessri c C s d d l m } | | ƒ S)Nr )ÚPopen)Ú
popen_forkrq )r` rq r r r r_ s zForkProcess._PopenN)r r r ra rZ r_ r r r r rp s rp c @ s( e Z d Z d Z e d d „ ƒ Z d S)Ú SpawnProcessrD c C s d d l m } | | ƒ S)Nr )rq )Úpopen_spawn_posixrq )r` rq r r r r_ s zSpawnProcess._PopenN)r r r ra rZ r_ r r r r rs
s rs c @ s( e Z d Z d Z e d d „ ƒ Z d S)ÚForkServerProcessrN c C s d d l m } | | ƒ S)Nr )rq )Úpopen_forkserverrq )r` rq r r r r_ s zForkServerProcess._PopenN)r r r ra rZ r_ r r r r ru s ru c @ s e Z d Z d Z e Z d S)Ú ForkContextri N)r r r rU rp r] r r r r rw s rw c @ s e Z d Z d Z e Z d S)Ú SpawnContextrD N)r r r rU rs r] r r r r rx s rx c @ s( e Z d Z d Z e Z d d „ Z d S)ÚForkServerContextrN c C s) d d l m } | j s% t d ƒ ‚ d S)Nr )rh z%forkserver start method not available)rI rh rj rR )r rh r r r rS & s z"ForkServerContext._check_availableN)r r r rU ru r] rS r r r r ry # s ry ri rD rN c @ s( e Z d Z d Z e d d „ ƒ Z d S)rs rD c C s d d l m } | | ƒ S)Nr )rq )Zpopen_spawn_win32rq )r` rq r r r r_ 6 s zSpawnProcess._PopenN)r r r ra rZ r_ r r r r rs 4 s c @ s e Z d Z d Z e Z d S)rx rD N)r r r rU rs r] r r r r rx ; s c C s t | t _ d S)N)rP r^ rc )rT r r r Ú_force_start_methodH s rz c C s t t d d ƒ S)NÚspawning_popen)rC Ú_tlsr r r r Úget_spawning_popenQ s r} c C s
| t _ d S)N)r| r{ )Úpopenr r r Úset_spawning_popenT s r c C s, t ƒ d k r( t d t | ƒ j ƒ ‚ d S)NzF%s objects should only be shared between processes through inheritance)r} rg Útyper )Úobjr r r Úassert_spawningW s r‚ )!r rA Ú threadingrI r Ú__all__Ú Exceptionr r
r r Úobjectr
Ú BaseProcessr] rb ÚlistÚdirrB rp rs ru rw rx ry rP r^ rz Úlocalr| r} r r‚ r r r r Ú s@ ³("