File "forkserver.cpython-37.pyc"
Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/opt/alt/python37/lib64/python3.7/multiprocessing/__pycache__/forkserver.cpython-37.pyc
File size: 8.01 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit
B
fq0 @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZddl m
Z
ddl m Z ddl m
Z
ddl mZ ddl mZ ddl mZ d d
d d gZd
ZedZG dd deZdddZdd Zdd Zdd Ze Zej Z ej Z ej Z ej Z dS ) N )
connection)process) reduction)semaphore_tracker)spawn)utilensure_runningget_inherited_fdsconnect_to_new_processset_forkserver_preload qc @ sD e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
d Z dS )
ForkServerc C s. d | _ d | _d | _d | _t | _dg| _d S )N__main__)_forkserver_address_forkserver_alive_fd_forkserver_pid_inherited_fds threadingZLock_lock_preload_modules)self r ?/opt/alt/python37/lib64/python3.7/multiprocessing/forkserver.py__init__" s
zForkServer.__init__c C s | j | W d Q R X d S )N)r _stop_unlocked)r r r r _stop* s zForkServer._stopc C sJ | j d krd S t| j d | _t| j d d | _ t| j d | _d S )Nr )r oscloser waitpidunlinkr )r r r r r / s
zForkServer._stop_unlockedc C s& t dd | jD s td|| _dS )z>Set list of module names to try to load in forkserver process.c s s | ]}t |tkV qd S )N)typestr).0modr r r <genexpr>? s z4ForkServer.set_forkserver_preload.<locals>.<genexpr>z&module_names must be a list of stringsN)allr TypeError)r Z
modules_namesr r r r = s z!ForkServer.set_forkserver_preloadc C s | j S )zReturn list of fds inherited from parent process.
This returns None if the current process was not started by fork
server.
)r )r r r r r
C s z ForkServer.get_inherited_fdsc
C s | t|d tkr tdttj}|| j t \}}t \}}||| j
t g}||7 }z<yt
|| ||fS t| t| Y nX W dt| t| X W dQ R X dS )a; Request forkserver to create a child process.
Returns a pair of fds (status_r, data_w). The calling process can read
the child process's pid and (eventually) its returncode from status_r.
The calling process should write to data_w the pickled preparation and
process data.
z too many fdsN)r lenMAXFDS_TO_SEND
ValueErrorsocketAF_UNIXZconnectr r piper r Zgetfdr Zsendfdsr )r fdsZclientZparent_rchild_wchild_rZparent_wZallfdsr r r r K s&
z!ForkServer.connect_to_new_processc s | j t t | jdk rVt| jtj\}}|s8dS t| j d| _ d| _d| _d}| j
rddh t d} fdd|
D }ni }ttj}td}|| t|st|d | t \}}ztyV| |g} || || j
|f; }t }
|
gt } | d
|g7 } t|
| | }W n t| Y nX W dt| X || _ || _|| _W dQ R X W dQ R X dS ) zMake sure that a fork server is running.
This can be called from any process. Note that usually a child
process will just reuse the forkserver started by its parent, so
ensure_running() will do nothing.
NzCfrom multiprocessing.forkserver import main; main(%d, %d, %r, **%r) main_pathsys_pathignorec s i | ]\}}| kr||qS r r )r$ xy) desired_keysr r
<dictcomp> s z-ForkServer.ensure_running.<locals>.<dictcomp>r. i z-c) r r r r r r WNOHANGr r r r r Zget_preparation_dataitemsr- r. r Zarbitrary_addressZbindr Z is_abstract_socket_namespacechmodZlistenr/ filenoZget_executableZ _args_from_interpreter_flagsZspawnv_passfds) r pidZstatuscmddatalistenerZaddressalive_rZalive_wZ fds_to_passZexeargsr )r8 r r h sL
zForkServer.ensure_runningN)
__name__
__module__ __qualname__r r r r r
r r r r r r r s r c C s |rhd|kr8|dk r8dt _zt| W dt `X x.|D ]&}y t| W q> tk
rb Y q>X q>W t t
\}}t |d t |d dd }t j
|t jt ji} dd | D }
t | i } tjtj| d } t }
| t_|
| tj |
|tj |
|tj xʐyx d
d |
D }|r,P q,W ||krtt |d d
kspt dt ||krdt |d xyt dt j \}}W n t!k
r P Y nX |dkrP | "|d}|dk rPt #|rt $| }n&t %|st d&||t '|}yt(|| W n t)k
rB Y nX t *| nt+,d| qW | |kr| - d 0}t./|t0d }t1|t0krt2d&t1||^}}}|* t 3 }|dkrVd }zpy<| * |
* ||||g}|4| 5 t6||||
}W n. t7k
rB t8j9t8: t8j;< Y nX W dt =| X nRyt(|| W n t)k
rz Y nX || |< t *| x|D ]}t *| qW W dQ R X W n4 t>k
r } z|j?t?j@kr W dd}~X Y nX q&W W dQ R X W dQ R X dS )zRun forkserver.r NTFc W s d S )Nr )Z_unusedr r r sigchld_handler s z main.<locals>.sigchld_handlerc S s i | ]\}}t |||qS r )signal)r$ sigvalr r r r9 s zmain.<locals>.<dictcomp>)r= c S s g | ]\}}|j qS r )Zfileobj)r$ keyZeventsr r r
<listcomp> s zmain.<locals>.<listcomp>r z Not at EOF?i r zChild {0:n} status is {1:n}z.forkserver: waitpid returned unexpected pid %dz Too many ({0:n}) fds to send)Ar Zcurrent_processZ _inheritingr Zimport_main_path
__import__ ImportErrorr Z _close_stdinr r/ set_blockingrH SIGCHLDSIGINTSIG_IGNr;
set_wakeup_fdr- r. selectorsZDefaultSelectorZ getsockname _forkserverr registerZ
EVENT_READZselectreadAssertionError
SystemExitr r: ChildProcessErrorpop WIFSIGNALEDWTERMSIG WIFEXITEDformat WEXITSTATUS write_signedBrokenPipeErrorr warningswarnZacceptr Zrecvfdsr+ r* RuntimeErrorforkextendvalues
_serve_one Exceptionsys
excepthookexc_infostderrflush_exitOSErrorerrnoZ ECONNABORTED)Z listener_fdrB Zpreloadr3 r4 modnameZsig_rZsig_wrG handlersZ old_handlersZ pid_to_fdrA ZselectorZrfdsr> stsr1
returncodesr0 r2 code
unused_fdsfder r r main s
r~ c C sd t d x | D ]\}}t || qW x|D ]}t| q2W |^t_tj_ t_
t | }|S )NrN )
rH rU r; r r rW r r Z_semaphore_trackerZ_fdr r _main)r2 r0 r{ rv rI rJ r| rz r r r rk 0 s
rk c C sR d}t j}x8t||k rBt| |t| }|s8td||7 }q W t |d S )NrM zunexpected EOFr )
SIGNED_STRUCTsizer* r rY EOFErrorZunpack)r| r@ lengthry r r r read_signedF s r c C s@ t |}x0|r:t| |}|dkr,td||d }q W d S )Nr zshould not get here)r Zpackr writerg )r| nmsgnbytesr r r rc P s
rc )NN) rt r rV rH r- Zstructrm r re r r contextr r r r __all__r+ ZStructr objectr r~ rk r rc rW r r
r r r r r r <module> s<