*j(% S SK Jr S SKrS SKrS SKrS SKrS SKrS SKrS SKrSSK J
r
/ SQr \R S:H =( d3 \
" \S5 =( a# \
" \S5 =( a \
" \R S 5 r " S
S \R 5 r\R" rS)S jr\R S:X a) \ / S
Q-
r S SKrS*SS.S jjrS rS rS r " S S\5 rO)\ / SQ-
r S SKr\R S:H rS r S r S rS rS r S r " S S 5 r \" \!" \ " 5 RD 5 \ 5 S r#\" \!" \$RJ 5 \#5 \" \!" \&RN 5 \#5 S r(S! r)\" \RT \(5 \R S:X a S" r+S# r,\" \R \+5 OS$ r+S% r,\" \R \+5 " S& S'\S(9r-g)+ )ABCMetaN )context) send_handle recv_handleForkingPicklerregisterdumpwin32CMSG_LEN
SCM_RIGHTSsendmsgc ^ \ rS rSrSr0 r\R rU 4S jr \
S 5 r \
SS j5 r \
R rSrU =r$ )r ! z)Pickler subclass used by multiprocessing.c > [ TU ] " U6 U R R 5 U l U R R U R 5 g N)super__init___copyreg_dispatch_tablecopydispatch_tableupdate_extra_reducers)selfargs __class__s @/opt/alt/python313/lib64/python3.13/multiprocessing/reduction.pyr ForkingPickler.__init__& sA
$ " : : ? ? A ""4#7#78 c X R U' g)z&Register a reduce function for a type.N)r )clstypereduces r r ForkingPickler.register+ s %+D!r c z [ R " 5 nU " X25 R U5 UR 5 $ r )ioBytesIOr
getbuffer)r! objprotocolbufs r dumpsForkingPickler.dumps0 s, jjl C $}} r )r r )__name__
__module__ __qualname____firstlineno____doc__r copyregr r r classmethodr r, pickleloads__static_attributes__
__classcell__)r s @r r r ! sO 3O % 4 49
+ +
LLEr r c 8 [ X5 R U 5 g)z3Replacement for pickle.dump() using ForkingPickler.N)r r
)r) filer* s r r
r
: s 4"'',r ) DupHandle duplicate steal_handle)source_processc [ R " 5 nUc UnUc Un[ R " X0USU[ R 5 $ )z current_processs r r< r< G sM "335 ! ,N ! ,N&& N
{G 9 9; ;r c J [ R " [ R SU 5 n [ R " X![ R " 5 SS[ R
[ R - 5 [ R " U5 $ ! [ R " U5 f = f)z5Steal a handle from process identified by source_pid.Fr )r@ OpenProcessPROCESS_DUP_HANDLErB rA rC DUPLICATE_CLOSE_SOURCE CloseHandle)
source_pidrD source_process_handles r r= r= S s| ' 3 3 & &z!; 7**%))+Q--0N0NNP
5 6G 5 6s A B
B"c \ [ U[ R U5 nU R U5 gz&Send a handle over a local connection.N)r; r@ rC send)connrD destination_piddhs r r r _ s!
vw < U R 5 R 5 $ ))Receive a handle over a local connection.)recvdetach)rR s r r r d s yy{!!##r c ( \ rS rSrSrSS jrS rSrg)r; h z Picklable wrapper for a handle.Nc ` Uc [ R " 5 n[ R " [ R SU5 n [ R
" [ R " 5 XUSS5 U l [ R " U5 X l X0l
g ! [ R " U5 f = f)NFr ) osgetpidr@ rI rJ rB rA _handlerL _access_pid)r rD accesspidprocs r r DupHandle.__init__j s { iik&&w'A'A5#ND
* & 6 6--/&% 4 ##D)!LI ##D)s 2B B-c U R [ R " 5 :X a U R $ [ R
" [ R SU R 5 n [ R " XR [ R " 5 U R S[ R 5 [ R " U5 $ ! [ R " U5 f = f)z1Get the handle. This should only be called once.F) r` r\ r] r^ r@ rI rJ rB rA r_ rK rL )r rc s r rX DupHandle.detachy s yyBIIK'||#&&w'A'A5'+yy2D
* ..,,(A(A(CLL%)G)GI ##D)##D)s
!AC C )r_ r^ r` r )r. r/ r0 r1 r2 r rX r7 r r r; r; h s -
*r r; )DupFdsendfdsrecvfdsdarwinc [ R " SU5 n[ [ U5 S- /5 nU R U/[ R
[ R U4/5 [ ( a! U R S5 S:w a [ S5 egg)z,Send an array of fds over an AF_UNIX socket.i r Az%did not receive acknowledgement of fdN)
arraybyteslenr socket
SOL_SOCKETr
ACKNOWLEDGErW RuntimeError)sockfdsmsgs r ri ri st kk#s#SX^$% cUf / /1B1BC H IJ ;499Q<4/ FG G 0;r c [ R " S5 nUR U- nU R S[ R " U5 5 u pEpgU( d
U( d [
e [ ( a U R S5 [ U5 S:w a [ S[ U5 - 5 eUS u pn
U[ R :X a U [ R :X az [ U
5 UR - S:w a [ eUR U
5 [ U5 S- US :w a' [ SR [ U5 US 5 5 e[! U5 $ [ S5 e! [ [" 4 a N f = f) z/Receive an array of fds over an AF_UNIX socket.rm r ro z received %d items of ancdatar rn z Len is {0:n} but msg[0] is {1!r}zInvalid data received)rp itemsizerecvmsgrs
CMSG_SPACEEOFErrorru rQ rr rv rt r
ValueError frombytesAssertionErrorformatlist
IndexError) rw sizea
bytes_sizery ancdataflagsaddr
cmsg_level cmsg_type cmsg_datas r rj rj sD KK ZZ$&
$(LLF4E4Ej4Q$R!e7N { $7|q "#A#&w<$0 1 1/6qz ,J9f / //V . ..y>AJJ.!3$$ I&q6C<3q6)(:AA FCF,- - Aw 233 J' s $C+E E.-E.c [ R " U R 5 [ R [ R 5 n[ X1/5 SSS5 g! , ( d f g= frP )rs fromfdfilenoAF_UNIX SOCK_STREAMri )rR rD rS ss r r r s<
]]4;;=&..&:L:L
MQR Ax N
M
Ms
A
A'c [ R " U R 5 [ R [ R 5 n[ US5 S sSSS5 $ ! , ( d f g= f)rV r r N)rs r r r r rj )rR r s r r r s@
]]4;;=&..&:L:L
MQR1a=# N
M
Ms A
A*c [ R " 5 nUb UR UR U 5 5 $ [ ( a SSKJn UR U 5 $ [ S5 e)zReturn a wrapper for an fd.r )resource_sharerz&SCM_RIGHTS appears not to be available)r get_spawning_popenrh duplicate_for_childHAVE_SEND_HANDLE r r )fd popen_objr s r rh rh sV ..0 ??9#@#@#DE E
)"((, , EF Fr c U R c( [ U R U R R 44$ [ U R U R R 44$ r )__self__getattrr __func__r. ms r _reduce_methodr sH zzajj&9&9:::QZZ%8%8999r c \ rS rSrS rSrg)_C c g r rg )r s r f_C.f s r rg N)r. r/ r0 r1 r r7 rg r r r r s
r r c > [ U R U R 44$ r )r __objclass__r. r s r _reduce_method_descriptorr s Q^^QZZ0 00r c f [ U R U R U R =( d 0 44$ r )_rebuild_partialfuncr keywords)ps r _reduce_partialr s% affaffajj.>B ? ??r c 6 [ R " U /UQ70 UD6$ r ) functoolspartial)r r r s r r r s T 5D 5H 55r c , SSK Jn [ U" U 5 44$ )Nr ) DupSocket)r r _rebuild_socket)r r s r _reduce_socketr s . 1 //r c " U R 5 $ r )rX )dss r r r s yy{r c [ U R 5 5 n[ XR U R U R
44$ r )rh r r familyr" proto)r dfs r r r s0
188:
XXqvvqww ???r c L U R 5 n[ R " XX4S9$ )N)r )rX rs )r r r" r r s r r r s
YY[}}V5<ckk"$=>""O4 /r rg N)r. r/ r0 r1 r2 r r r
r r sysplatformr= r< r; ri rj rh r r r r r r r7 rg r r r r sl $NH D K K
||w # #N 9 '#N%O0r r ) metaclassr )NF).abcr r3 r r& r\ r5 rs r r r __all__r hasattrr Picklerr r r
r@ r< r= r r objectr; rp ru ri rj rh r r r" r r r r r r r r r r r r rg r r 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