֦i d dl Z d dlZddlmZmZ ddlmZ ddlmZ ddlmZ dgZ G d d e
Z G d
dej Z y) N ) reductionset_spawning_popen)
popen_fork)spawn)utilPopenc e Zd Zd Zd Zy)_DupFdc || _ y Nfdselfr s :/usr/lib64/python3.12/multiprocessing/popen_spawn_posix.py__init__z_DupFd.__init__ s c | j S r
r )r s r detachz
_DupFd.detach s wwr N)__name__
__module__ __qualname__r r r r r r s r r c 2 e Zd ZdZeZ fdZd Zd Z xZ S )r r c 2 g | _ t | | y r
)_fdssuperr )r process_obj __class__s r r zPopen.__init__ s
%r c < | j j | |S r
)r appendr s r duplicate_for_childzPopen.duplicate_for_child" s r c ddl m} |j }| j j | t j |j }t j }t | t j || t j || t d d x}x}x}} t j \ }}t j \ }} t j || }
| j j! ||g t# j$ t j& |
| j | _ || _ t- | dd 5 } | j/ |j1 d d d g } || fD ] }
|
| j |
t# j2 | t" j4 | | _ ||fD ] }
|
t j8 |
y # t d w xY w# 1 sw Y xY w# g } || fD ] }
|
| j |
t# j2 | t" j4 | | _ ||fD ] }
|
t j8 |
w xY w)Nr )resource_tracker)
tracker_fd pipe_handlewbF)closefd) r% getfdr r" r get_preparation_data_nameioBytesIOr r dumpospipeget_command_lineextendr spawnv_passfdsget_executablepidsentinelopenwrite getbufferFinalize close_fds finalizerclose)r r r% r& prep_datafpparent_rchild_wchild_rparent_wcmdf fds_to_closer s r _launchz
Popen._launch& s &%++-
$..{/@/@A
ZZ\4 % NN9b ) NN; + t $266676Wx ! " Hg " GX((J5<>C II gw / 0**5+?+?+A+. ;DH $DMhe4 ' 5 L *> ''+ + "]]4 NDN (>HHRL )+
t $ 54 L *> ''+ + "]]4 NDN (>HHRL )s> 1,G3 1B/H H H 3
H H H I; AI;#I;)
r r r methodr DupFdr r# rI
__classcell__)r s @r r r s
F E&"!r )
r. r1 contextr r r* r r r __all__objectr r r r r rP s< 2 )V .!J .!r