f d dl Z d dlZddlmZmZ ej s ed ddlmZ ddlm Z ddlm
Z
ddlm Z d gZ G d
d e
Z G d d e j ZdS )
N ) reductionset_spawning_popenz,No support for sending fds between processes)
forkserver)
popen_fork)spawn)utilPopenc e Zd Zd Zd ZdS )_DupFdc || _ d S N)ind)selfr s G/opt/alt/python311/lib64/python3.11/multiprocessing/popen_forkserver.py__init__z_DupFd.__init__ s
c > t j | j S r )r get_inherited_fdsr )r s r detachz
_DupFd.detach s +--dh77r N)__name__
__module__ __qualname__r r r r r r s2 8 8 8 8 8r r c F e Zd ZdZeZ fdZd Zd Ze j
fdZ xZ S )r
r c X g | _ t | d S r )_fdssuperr )r process_obj __class__s r r zPopen.__init__! s(
%%%%%r c d | j | t | j dz
S )Nr )r appendlen)r fds r duplicate_for_childzPopen.duplicate_for_child% s+ 49~~!!r c t j |j }t j }t | t
j || t
j || t d n# t d w xY wt j | j
\ | _ }t j
| }t j | t j || j f | _ t% |dd 5 }| | d d d n # 1 swxY w Y t j | j | _ d S )NwbT)closefd)r get_preparation_data_nameioBytesIOr r dumpr connect_to_new_processr sentinelosdupr Finalize close_fds finalizeropenwrite getbuffer read_signedpid)r r prep_databufw _parent_wfs r _launchz
Popen._launch) sc .{/@AA jll4 % N9c * * * N; , , , t $ $ $ $ t $ $ $ $%<TYGG
q F1II tT^(14='AC C
!T4
(
(
( %A
GGCMMOO $ $ $ % % % % % % % % % % % % % % % )$-88s *A7 7B>(D22D69D6c | j lddlm} |t j k rdnd } || j g| sd S t
j | j | _ n # t t f$ r
d| _ Y nw xY w| j S )Nr )wait )
returncodemultiprocessing.connectionrA r0 WNOHANGr/ r r8 OSErrorEOFError)r flagrA timeouts r pollz
Popen.poll= s ? " 7 7 7 7 7 7 2:--aa4G4 11
t
&","8 "G"GX&
&
&
& #&
&
s A A10A1)
r r r methodr DupFdr r% r? r0 rE rJ
__classcell__)r s @r r
r
s{
F E& & & & &" " "9 9 9(
r )r+ r0 contextr r HAVE_SEND_HANDLE ImportError r r r r __all__objectr r
r r r <module>rT s 2 2 2 2 2 2 2 2! F
+D
E
EE ) 8 8 8 8 8V 8 8 8- - - - - J - - - - - r