VcI csDddlZddlZddlmZdgZGddeZdS)N)utilPopencsXeZdZdZdZdZejfdZd dZ dZ dZ d Z d Z d ZdS) rforkcsrtjd|_d|_||dSN)rZ_flush_std_streams returncode finalizer_launch)self process_obj 3/usr/lib64/python3.11/multiprocessing/popen_fork.py__init__zPopen.__init__s7 !!! [!!!!!cs|Sr)r Zfdr r duplicate_for_childzPopen.duplicate_for_childs rcs|jT tj|j|\}}n#t$rYdSwxYw||jkrtj||_|jSr)rosZwaitpidpidOSErrorZwaitstatus_to_exitcode)r ZflagrZstss r pollz Popen.pollsz ? A :dh55SS   tt dh A"$";C"@"@s ' 55Ncs|jC|ddlm}||jg|sdS||dkr t jndS|jS)Nr)waitg)rZmultiprocessing.connectionrsentinelrrWNOHANG)r timeoutrs r rz Popen.wait$sm ? B ;;;;;;tT]OW55 4997c>@RZZqAA Arcs|jQ tj|j|dS#t$rYdSt $r|dYdSwxYwdS)Ng?)r)rrkillrZProcessLookupErrorrr)r Zsigr r _send_signalzPopen._send_signal.s ?  #&&&&&%      99S9))    s% A AAcD|tjdSr)rsignalZSIGTERMr  r terminatezPopen.terminate8 &.)))))rcrr)rrZSIGKILLrrr rz Popen.kill;r rcs0d}tj\}}tj\}}tj|_|jdkrn tj|tj|||}tj|dS#tj|wxYwtj|tj|tj|tj ||f|_ ||_ dS)Nrr)Zparent_sentinel) rZpiperrcloseZ _bootstrapZ_exitrZFinalizeZ close_fdsrr)r r ZcodeZparent_rZchild_wZchild_rZparent_ws r rz Popen._launch>sGII'GII799 8q= % """""""--g-FF HW    HW   !]4,4h+@BBDN$DMMMs >B''B=cs@|j|dSdSr)rrrr r!z Popen.closeQs, >  NN       rr)Z__name__Z __module__Z __qualname__Zmethodr rrrrrrrrrr!rrr rr s F"""     ******%%%&r)rrZrZ__all__Zobjectrrrr r"sn  ) GGGGGFGGGGGr