File "process.cpython-37.opt-2.pyc"
Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/opt/alt/python37/lib64/python3.7/multiprocessing/__pycache__/process.cpython-37.opt-2.pyc
File size: 7.27 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit
B
YI~d4) @ s d ddgZ ddlZddlZddlZddlZddlZddlmZ yej e
Z W n e k
rj dZ Y nX dd Z
dd Zdd ZG d
d d eZG d d d eZG d
d deZe aedae a[i Zx<eej D ]*\Z Z e dd dkrde kre ee < qW e Z dS ) BaseProcesscurrent_processactive_children N)WeakSetc C s t S )N)_current_process r r </opt/alt/python37/lib64/python3.7/multiprocessing/process.pyr $ s c C s t ttS )N)_cleanuplist _childrenr r r r r * s c C s. x(t tD ] } | j d k r
t| q
W d S )N)r
r _popenpolldiscard)pr r r r 5 s r c @ s e Zd Zdd Zddddi fddddZdd Zd
d Zd d
Zdd Zdd Z d+ddZ
dd Z dd Z e
dd Zejdd Ze
dd Zejd d Ze
d d Zejd d Ze
d!d" Ze
d#d$ ZeZe
d%d& Zd'd( Zd)d* ZdS ),r c C s t d S )N)NotImplementedError)selfr r r _PopenE s zBaseProcess._PopenNr )daemonc C s t t}tj|f | _tj | _t | _d | _ d| _
|| _ t || _
t|| _|pxt| jd ddd | jD | _|d k r|| _t| d S )NF-:c s s | ]}t |V qd S )N)str).0ir r r <genexpr>U s z'BaseProcess.__init__.<locals>.<genexpr>)next_process_counterr _identity_configcopyosgetpid _parent_pidr _closed_targettuple_argsdict_kwargstype__name__join_namer _danglingadd)r grouptargetnameargskwargsr countr r r __init__H s
zBaseProcess.__init__c C s | j rtdd S )Nzprocess object is closed)r"
ValueError)r r r r
_check_closedZ s zBaseProcess._check_closedc C s | j r| j | j| j d S )N)r# r% r' )r r r r run^ s zBaseProcess.runc C s> | t | | | _| jj| _| `| `| `t
| d S )N) r6 r r r sentinel _sentinelr# r% r' r r- )r r r r starte s
zBaseProcess.startc C s | | j d S )N)r6 r terminate)r r r r r; w s zBaseProcess.terminatec C s | | j d S )N)r6 r kill)r r r r r< ~ s zBaseProcess.killc C s* | | j|}|d k r&t| d S )N)r6 r waitr r )r ZtimeoutZresr r r r* s zBaseProcess.joinc C sJ | | tkrdS | jd kr"dS | j }|d kr8dS t| dS d S )NTF)r6 r r r
r r )r
returncoder r r is_alive s
zBaseProcess.is_alivec C sH | j d k r>| j d kr td| j d | _ | `t| d| _d S )Nz^Cannot close a process while it is still running. You should first call join() or terminate().T)r r
r5 closer9 r r r" )r r r r r@ s
zBaseProcess.closec C s | j S )N)r+ )r r r r r0 s zBaseProcess.namec C s
|| _ d S )N)r+ )r r0 r r r r0 s c C s | j ddS )Nr F)r get)r r r r r s zBaseProcess.daemonc C s || j d< d S )Nr )r )r Zdaemonicr r r r s c C s
| j d S )Nauthkey)r )r r r r rB s zBaseProcess.authkeyc C s t || jd< d S )NrB )AuthenticationStringr )r rB r r r rB s c C s" | | jd kr| jS | j S )N)r6 r r
)r r r r exitcode s
zBaseProcess.exitcodec C s* | | tkrt S | jo$| jjS d S )N)r6 r r r r pid)r r r r ident s zBaseProcess.identc C s2 | y| jS tk
r, tdd Y nX d S )Nzprocess not started)r6 r9 AttributeErrorr5 )r r r r r8 s
zBaseProcess.sentinelc C s | t krd}nJ| jrd}n>| jt kr.d}n*| jd kr>d}n| j d k rT| j}nd}t|t kr|dkrrd}ndt
|| }dt| j | j
|| jrd pd
f S ) NZstartedclosedunknowninitialr Zstoppedz stopped[%s]z<%s(%s, %s%s)>z daemon )r r" r! r r r r
rD r( int_exitcode_to_namerA r) r+ r )r statusr r r __repr__ s"
zBaseProcess.__repr__c
C sR ddl m}m} zy|| jd k r,|| j tdat a |
t }| a z|j
| W d ~X |d z| d}W d | X W n tk
r } zJ|jsd}n:t|jd tr|jd }n tjt|jd d d}W d d }~X Y n2 d}dd l}tjd| j | Y nX W d t |d| | X |S )N )utilcontextz child process calling self.run()r
z Process %s:
z process exiting with exitcode %d) rK rQ rR Z
_start_methodZ_force_start_method itertoolsr3 r setr Z _close_stdinr Z_finalizer_registryclearZ_run_after_forkersinfor7 Z_exit_function
SystemExitr1
isinstancerL sysstderrwriter tracebackr0 print_exc threadingZ _shutdownZ_flush_std_streams)r rQ rR Z old_processrD er] r r r
_bootstrap sD
zBaseProcess._bootstrap)N)r)
__module__ __qualname__r r4 r6 r7 r: r; r< r* r? r@ propertyr0 setterr rB rD rF rE r8 rO ra r r r r r ? s.
c @ s e Zd Zdd ZdS )rC c C s, ddl m} | d kr tdtt| ffS )NrP )get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)rR rf TypeErrorrC bytes)r rf r r r
__reduce__F s
z AuthenticationString.__reduce__N)r) rb rc ri r r r r rC E s rC c @ s e Zd Zdd Zdd ZdS ) _MainProcessc C s8 d| _ d| _d | _d | _d| _ttddd| _d S )Nr Z MainProcessF z/mp)rB Z semprefix) r r+ r! r r" rC r urandomr )r r r r r4 U s z_MainProcess.__init__c C s d S )Nr )r r r r r@ g s z_MainProcess.closeN)r) rb rc r4 r@ r r r r rj S s rj rP ZSIG_)!__all__r rZ signalrT r_ Z _weakrefsetr pathabspathgetcwdZ ORIGINAL_DIROSErrorr r r objectr rh rC rj r r3 r rU r rM r
__dict__itemsr0 Zsignumr, r r r r <module>
s6