python (3.11.7)
e(% H d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZddl m
Z
g dZ ej dk p( e
ed o e
ed o 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 j" e d Z# e e!e$j% e# e e!e&j' e# d! Z(d" Z) eej* e( ej dk rd# Z+d$ Z, eej e+ nd% Z+d& Z, eej e+ G d' d(e) Z-dS ), )ABCMetaN )context) send_handle recv_handleForkingPicklerregisterdumpwin32CMSG_LEN
SCM_RIGHTSsendmsgc n e Zd Z i Zej Z fdZed Z edd Z
e j Z xZ
S )r c t j | | j | _ | j | j d S N)super__init___copyreg_dispatch_tablecopydispatch_tableupdate_extra_reducers)selfargs __class__s M/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/multiprocessing/reduction.pyr zForkingPickler.__init__& sN $ " : ? ? A A ""4#788888 c || j |< d S r )r )clstypereduces r r zForkingPickler.register+ s 4$*D!!!r Nc t j } | || | | S r )ioBytesIOr
getbuffer)r objprotocolbufs r dumpszForkingPickler.dumps0 s; jll C $$$}} r r )__name__
__module__ __qualname__r copyregr r r classmethodr r) pickleloads
__classcell__)r s @r r r ! s 3O % 49 9 9 9 9
+ + [+ [
LEEEEEr r c N t || | d S r )r r
)r& filer' s r r
r
: s) =4""'',,,,,r ) DupHandle duplicate steal_handleF)source_processc t j }||}||}t j || |d|t j S )Nr )_winapiGetCurrentProcessDuplicateHandleDUPLICATE_SAME_ACCESS)handletarget_process inheritabler7 current_processs r r5 r5 G sO J!355 ! ,N ! ,N& FN
{G 9; ; ;r c " 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 &z!; !; 7*%v)++Q-0NNP P
5 6 6 6 6G 5 6 6 6 6s A A8 8Bc h t |t j | }| | d S r )r4 r9 r< send)connr= destination_piddhs r r r _ s, 4
vw <o
N
N "
r c P | S r )recvdetach)rK s r r r d s 7yy{{!!###r c e Zd Z ddZd ZdS )r4 Nc H |t j }t j t j d| } t j t j |||dd | _ t j | n# t j | w xY w|| _ || _
d S rB ) osgetpidr9 rC rD r; r: _handlerF _access_pid)r r= accesspidprocs r r zDupHandle.__init__j s { ikk&w'A5#NND
* & 6-//D&% 4 4 #D))))#D))))!DLDIIIs /A; ;Bc l | 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 CyBIKK''|#&w'A5'+y2 2D
* .$,(A(C(CL%)GI I #D))))#D))))s =B B3r )r* r+ r, r rP r r r4 r4 h s: -
* * * * *r r4 )DupFdsendfdsrecvfdsdarwinc 2 t j d| }t t | dz g }| |gt j t j |fg t r(| d dk rt d d S d S )Ni r Az%did not receive acknowledgement of fd)
arraybyteslenr socket
SOL_SOCKETr
ACKNOWLEDGErO RuntimeError)sockfdsmsgs r r_ r_ s :k#s##SXX^$%% cUf /1BC H IJJJ H499Q<<4// FGG G H H//r c $ t j d }|j |z }| dt j | \ }}}}|s |st
t r| d t | dk r t dt | z |d \ }} }
|t j
k r| t j k rt |
|j z dk rt |
|
t | dz |d k r6t d t | |d t! | S n# t t" f$ r Y nw xY wt d ) 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` s = K Z$&
$(LLF4Ej4Q4Q$R$R!WeT 7 N
$7||q "#A#&w<<$0 1 1 1/6qz ,J 9f ///V ...y>>AJ.!33$$ I&&&q66C<3q6))(:AA FFCF, ,- - - AwwJ' D 2333s DE, ,F ?F c t j | t j t j 5 }t ||g d d d d S # 1 swxY w Y d S r )ri fromfdfilenoAF_UNIX SOCK_STREAMr_ )rK r= rL ss r r r s 4
]4;;==&.&:L
M
M !QR Ax ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! !s A A!$A!c t j | t j t j 5 }t |d d cd d d S # 1 swxY w Y d S )Nr r )ri r r r r r` )rK r s r r r s 7
]4;;==&.&:L
M
M $QR1a==# $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s A!!A%(A%c t j }|(| | | S t rddlm} | | 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^ sw ).00 ??9#@#@#D#DEE E
G ) ) ) ) ) )"((,, , EFF Fr c x | j t | j | j j ffS t | j | j j ffS r )__self__getattrr __func__r* ms r _reduce_methodr s8 zaj&9:::QZ%8999r c e Zd Zd ZdS )_Cc d S 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^QZ0 00r c < t | j | j | j pi ffS r )_rebuild_partialfuncr keywords)ps r _reduce_partialr s afafaj.>B ? ??r c , t j | g|R i |S r ) functoolspartial)r r r s r r r s# T 5D 5 5 5H 5 55r c 4 ddl m} t || ffS )Nr ) DupSocket)r r _rebuild_socket)r r s r _reduce_socketr s) ...... 1 //r c * | S r )rP )dss r r r s yy{{r c | t | }t || j | j | j ffS r )r^ r r familyr proto)r dfs r r r s1
188::
QXqvqw ???r c Z | }t j |||| S )N)r )rP ri )r r r r r s r r r s(
YY[[}VT5<<<<r c n e Zd Z eZeZeZeZeZej dk re
Z
e Z e Z ne
Z
eZeZeZeZeZeZeZd ZdS )AbstractReducerr c t t t j t t t t
j t t t t j t t t j t t t j
t d S r )r r r r r ry appendr int__add__r r r ri r )r r s r r zAbstractReducer.__init__ s bddf ~...dk""$=>>>ck""$=>>>"O444 /////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 s $NH D K K
|w # #N 9 '#N%O0 0 0 0 0r 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
N
N LG+ 8 WVZ00 7 WV\227 WV]I66 V^ . "- - - - <7 9999GNNN
;$(
;
;
;
;
;
7
7
7
$ $ $ * * * * *F * * * *F ....GLLL ,(*KH H H4 4 48! ! !
$ $ $
G G G : : :
bbddf ~ & & &1 1 1 dk 5 6 6 6 ck 5 6 6 6@ @ @6 6 6 O , , , <70 0 0 HV]N++++@ @ @= = =
HV]N+++ 0 0 0 0 0 0 0 0 0 0 0r 
Browse
Usage
Versions