File "process.cpython-37.pyc"
Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/opt/alt/python37/lib64/python3.7/multiprocessing/__pycache__/process.cpython-37.pyc
File size: 9.2 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit
B
f4) @ 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 )z@
Return process object representing the current process
)_current_process r r </opt/alt/python37/lib64/python3.7/multiprocessing/process.pyr $ s c C s t ttS )zN
Return list of process objects corresponding to live child processes
)_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 ZdZdd Zddddi fddddZd d
Zd d Zd
d Zdd Z dd Z
d,ddZ dd Z dd Z
edd Zejdd Zed d Zejd d Zed d Zejd!d Zed"d# Zed$d% ZeZed&d' Zd(d) Zd*d+ ZdS )-r z
Process objects represent activity that is run in a separate process
The class is analogous to `threading.Thread`
c C s t d S )N)NotImplementedError)selfr r r _PopenE s zBaseProcess._PopenNr )daemonc C s |d kst dtt}tj|f | _tj | _t | _ d | _
d| _ || _ t
|| _t|| _|pt| jd ddd | jD | _|d k r|| _t| d S )Nz#group argument must be None for nowF-:c s s | ]}t |V qd S )N)str).0ir r r <genexpr>U s z'BaseProcess.__init__.<locals>.<genexpr>)AssertionErrornext_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 dS )zQ
Method to be run in sub-process; can be overridden in sub-class
N)r$ r& r( )r r r r run^ s zBaseProcess.runc C sz | | jdkstd| jt ks0tdtjdrDtdt |
| | _| jj | _ | `
| `| `t| dS )z%
Start child process
Nz cannot start a process twicez:can only start a process object created by current processr z3daemonic processes are not allowed to have children)r7 r r r" r r! r r getr r sentinel _sentinelr$ r& r( r r. )r r r r starte s
zBaseProcess.startc C s | | j dS )zT
Terminate process; sends SIGTERM signal or uses TerminateProcess()
N)r7 r terminate)r r r r r= w s zBaseProcess.terminatec C s | | j dS )zT
Terminate process; sends SIGKILL signal or uses TerminateProcess()
N)r7 r kill)r r r r r> ~ s zBaseProcess.killc C sR | | jt ks td| jdk s0td| j|}|dk rNt| dS )z5
Wait until child process terminates
z can only join a child processNz can only join a started process) r7 r" r r! r r waitr r )r ZtimeoutZresr r r r+ s zBaseProcess.joinc C s` | | tkrdS | jt ks*td| jdkr8dS | j }|dkrNdS t | dS dS )z1
Return whether process is alive
Tz can only test a child processNF)
r7 r r" r r! r r r
r r )r
returncoder r r is_alive s
zBaseProcess.is_alivec C sH | j dk r>| j dkr td| j d| _ | `t| d| _dS )z
Close the Process object.
This method releases resources held by the Process object. It is
an error to call this method if the child process is still running.
Nz^Cannot close a process while it is still running. You should first call join() or terminate().T)r r
r6 closer; r r r# )r r r r rB s
zBaseProcess.closec C s | j S )N)r, )r r r r r1 s zBaseProcess.namec C s t |tstd|| _d S )Nzname must be a string)
isinstancer r r, )r r1 r r r r1 s c C s | j ddS )z4
Return whether process is a daemon
r F)r r9 )r r r r r s zBaseProcess.daemonc C s | j dkstd|| jd< dS )z1
Set whether process is a daemon
Nzprocess has already startedr )r r r )r Zdaemonicr r r r s c C s
| j d S )Nauthkey)r )r r r r rD s zBaseProcess.authkeyc C s t || jd< dS )z2
Set authorization key of process
rD N)AuthenticationStringr )r rD r r r rD s c C s" | | jdkr| jS | j S )zM
Return exit code of process or `None` if it has yet to stop
N)r7 r r
)r r r r exitcode s
zBaseProcess.exitcodec C s* | | tkrt S | jo$| jjS dS )zU
Return identifier (PID) of process or `None` if it has yet to start
N)r7 r r r! r pid)r r r r ident s zBaseProcess.identc C s2 | y| jS tk
r, tddY nX dS )z{
Return a file descriptor (Unix) or handle (Windows) suitable for
waiting for process termination.
zprocess not startedN)r7 r; AttributeErrorr6 )r r r r r: 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
rF r) int_exitcode_to_namer9 r* r, r )r Zstatusr 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) rM rR rS Z
_start_methodZ_force_start_method itertoolsr4 r setr Z _close_stdinr Z_finalizer_registryclearZ_run_after_forkersinfor8 Z_exit_function
SystemExitr2 rC rN sysstderrwriter tracebackr1 print_exc threadingZ _shutdownZ_flush_std_streams)r rR rS Z old_processrF er] r r r
_bootstrap sD
zBaseProcess._bootstrap)N)r*
__module__ __qualname____doc__r r5 r7 r8 r< r= r> r+ rA rB propertyr1 setterr rD rF rH rG r: rP ra r r r r r ? s0
c @ s e Zd Zdd ZdS )rE c C s, ddl m} | d kr tdtt| ffS )NrQ )get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)rS rg TypeErrorrE bytes)r rg r r r
__reduce__F s
z AuthenticationString.__reduce__N)r* rb rc rj r r r r rE E s rE c @ s e Zd Zdd Zdd ZdS ) _MainProcessc C s8 d| _ d| _d | _d | _d| _ttddd| _d S )Nr Z MainProcessF z/mp)rD Z semprefix) r r, r" r r# rE r urandomr )r r r r r5 U s z_MainProcess.__init__c C s d S )Nr )r r r r rB g s z_MainProcess.closeN)r* rb rc r5 rB r r r r rk S s rk rQ ZSIG_)!__all__r rZ signalrU r_ Z _weakrefsetr pathabspathgetcwdZ ORIGINAL_DIROSErrorr r r objectr ri rE rk r r4 r rV r rO r
__dict__itemsr1 Zsignumr- r r r r <module>
s6