python (3.12.0)
Browse
Usage
Versions
̑e(% f d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZddl m
Z
g dZ ej dk( xs) e
ed xr e
ed xr e
ej d Z G d
d ej Zej" Zd)d Zej dk( r'e g d
z
Z d dlZd*dddZd Zd Zd Z G d de Zn)e g dz
Z d dlZej dk( Zd Z d Z d Zd Zd Z d Z G d d Z e e! e jD e d Z# e e!e$jJ e# e e!e&jN e# d Z(d! Z) eejT e( ej dk( rd" Z+d# Z, eej e+ nd$ Z+d% Z, eej e+ G d& d'e( Z-y)+ )ABCMetaN )context) send_handle recv_handleForkingPicklerregisterdumpwin32CMSG_LEN
SCM_RIGHTSsendmsgc v e Zd Z i Zej
Z fdZed Z edd Z
e j Z xZ
S )r c t | | | j j | _ | j j | j y N)super__init___copyreg_dispatch_tablecopydispatch_tableupdate_extra_reducers)selfargs __class__s M/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/multiprocessing/reduction.pyr zForkingPickler.__init__& sA
$ " : : ? ? A ""4#7#78 c $ || j |< y r )r )clstypereduces r r zForkingPickler.register+ s 4$*D!r c z t j } | || j | |j S r )ioBytesIOr
getbuffer)r objprotocolbufs r dumpszForkingPickler.dumps0 s. jjl C $}} r r )__name__
__module__ __qualname__r copyregr r r classmethodr r) pickleloads
__classcell__)r s @r r r ! sO 3O % 4 49
+ +
LLEr r c < t || j | y r )r r
)r& filer' s r r
r
: s =4"'',r ) DupHandle duplicate steal_handle)source_processc t j }||}||}t j || |d|t j S )Nr )_winapiGetCurrentProcessDuplicateHandleDUPLICATE_SAME_ACCESS)handletarget_process inheritabler7 current_processs r r5 r5 G sP J!335 ! ,N ! ,N&& FN
{G 9 9; ;r c D t j t j d| } t j ||t j ddt j
t j z t j | S # t j | w xY wNFr )r9 OpenProcessPROCESS_DUP_HANDLEr; r: r< DUPLICATE_CLOSE_SOURCE CloseHandle)
source_pidr= source_process_handles r r6 r6 S s C ' 3 3 & &z!; 7**%v))+Q--0N0NNP
5 6G 5 6s A
B B c ^ t |t j | }| j | y r )r4 r9 r< send)connr= destination_piddhs r r r _ s$ 4
vw < <o
N "
r c @ | j j S r )recvdetach)rK s r r r d s 7yy{!!##r c e Zd Z ddZd Zy)r4 Nc X |t j }t j t j d| } t j
t j |||dd | _ t j | || _ || _
y # t j | w xY wrB ) osgetpidr9 rC rD r; r: _handlerF _access_pid)r r= accesspidprocs r r zDupHandle.__init__j s { iik&&w'A'A5#ND
* & 6 6--/D&% 4 ##D)!DLDI ##D)s 1B B)c | j t j k( r | j S t j
t j d| j } t j || j t j | j dt j t j | S # t j | w xY wNF) rW rS rT rU r9 rC rD r; r: rV rE rF )r rZ s r rP zDupHandle.detachy s CyyBIIK'||#&&w'A'A5'+yy2D
* ..$,,(A(A(CLL%)G)GI ##D)##D)s
A
C Cr )r* r+ r, r rP r r r4 r4 h s -
*r r4 )DupFdsendfdsrecvfdsdarwinc t j d| }t t | dz g }| j |gt j
t j |fg t r | j d dk7 r t d y y )Ni r Az%did not receive acknowledgement of fd)
arraybyteslenr socket
SOL_SOCKETr
ACKNOWLEDGErO RuntimeError)sockfdsmsgs r r_ r_ su :kk#s#SX^$% cUf / /1B1BC H IJ 499Q<4/ FG G 0;r c t j d }|j |z }| j dt j | \ }}}}|s|st
t r| j d t | dk7 rt dt | z |d \ }} }
|t j k( r| t j k( rxt |
|j z dk7 rt |j |
t | dz |d k7 r't dj t | |d t! | S t d # t t" f$ r
Y t d w xY w) Nrc r re z received %d items of ancdatar rd z Len is {0:n} but msg[0] is {1!r}zInvalid data received)rf itemsizerecvmsgri
CMSG_SPACEEOFErrorrk rJ rh rl rj r
ValueError frombytesAssertionErrorformatlist
IndexError) rm sizea
bytes_sizero ancdataflagsaddr
cmsg_level cmsg_type cmsg_datas r r` r` sW = KK ZZ$&
$(LLF4E4Ej4Q$R!WeT7N $7|q "#A#&w<$0 1 1/6qz ,J 9f / //V . ..y>AJJ.!3$$ I&q6C<3q6)(:AA FCF,- - Aw 233 J' 233 s C"E E%$E%c t j | j t j t j 5 }t ||g d d d y # 1 sw Y y xY wr )ri fromfdfilenoAF_UNIX SOCK_STREAMr_ )rK r= rL ss r r r sI 4
]]4;;=&..&:L:L
M !QR Ax ! ! !s AA#c t j | j t j t j 5 }t |d d cd d d S # 1 sw Y y xY w)Nr r )ri r r r r r` )rK r s r r r sK 7
]]4;;=&..&:L:L
M $QR1a=# $ $ $s A A%c t j }| |j |j | S t rddlm} |j | S t d )Nr )resource_sharerz&SCM_RIGHTS appears not to be available)r get_spawning_popenr^ duplicate_for_childHAVE_SEND_HANDLE r ru )fd popen_objr s r r^ r^ sV )..0 ??9#@#@#DE E
)"((, , EF Fr c | j (t | j | j j ffS t | j | j j ffS r )__self__getattrr __func__r* ms r _reduce_methodr sH zzajj&9&9:::QZZ%8%8999r c e Zd Zd Zy)_Cc y r r] )r s r fz_C.f s r N)r* r+ r, r r] r r r r s
r r c > t | j | j ffS r )r __objclass__r* r s r _reduce_method_descriptorr s Q^^QZZ0 00r c \ t | j | j | j xs i ffS r )_rebuild_partialfuncr keywords)ps r _reduce_partialr s% affaffajj.>B ? ??r c 4 t j | g|i |S r ) functoolspartial)r r r s r r r s T 5D 5H 55r c , ddl m} t || ffS )Nr ) DupSocket)r r _rebuild_socket)r r s r _reduce_socketr s . 1 //r c " | j S r )rP )dss r r r s yy{r c t | j }t || j | j | j
ffS r )r^ r r familyr proto)r dfs r r r s2
188:
QXXqvvqww ???r c T | j }t j |||| S )N)r )rP ri )r r r r r s r r r s"
YY[}}VT5<<r c t e Zd Z eZeZeZeZeZej dk( re
Z
e Z e Z ne
Z
eZeZeZeZeZeZeZd Zy)AbstractReducerr c n t t t j t t t t
j t t t t j t t t j t t t j t y r )r r r r r ry appendr int__add__r r r ri r )r r s r r zAbstractReducer.__init__ s\ bdff ~.dkk"$=>ckk"$=>""O4 /r N)r* r+ r, r r r
r r sysplatformr6 r5 r4 r_ r` r^ r r r r r r r] r r r r sl $NH D K K
||w # #N 9 '#N%O0r r ) metaclassr r\ ).abcr r- r r# rS r/ ri r r r __all__r hasattrr Picklerr r r
r9 r5 r6 r r objectr4 rf rk r_ r` r^ r r r r r ry r r r r r r r r r r] r r <module>r s
N LLG+ 8 VZ0 7 V\27 V]]I6 V^^ . " "- <<7 99G
;$(
;
7
$ *F *F ..G ,,(*KH48!
$
G :
bdff ~ &1 dkk 5 6 ckk 5 6@6 O , <<70 V]]N+@=
V]]N+ 0 0r