e(%SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK J r /SQr \RS:H=(d3 \ "\S5=(a# \ "\S5=(a \ "\RS 5r"S S \R5r\R"rS)S jr\RS:Xa)\ /S Q- r SSKrS*SS.SjjrSrSrSr"SS\5rO)\ /SQ- r SSKr\RS:HrSrSrSrSrSrSr"SS5r \"\!"\ "5RD5\5 Sr#\"\!"\$RJ5\#5 \"\!"\&RN5\#5 S r(S!r)\"\RT\(5 \RS:XaS"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^\rSrSrSr0r\RrU4Sjr \ S5r \ SSj5r \ RrSrU=r$)r!z)Pickler subclass used by multiprocessing.c>[TU]"U6 URR5UlURR UR 5 gN)super__init___copyreg_dispatch_tablecopydispatch_tableupdate_extra_reducers)selfargs __class__s ?/opt/imh/python3.13/lib/python3.13/multiprocessing/reduction.pyrForkingPickler.__init__&sA $"::??A ""4#7#78c X RU'g)z&Register a reduce function for a type.N)r)clstypereduces rr ForkingPickler.register+s%+D!rcz[R"5nU"X25RU5 UR5$r)ioBytesIOr getbuffer)r!objprotocolbufs rdumpsForkingPickler.dumps0s,jjl C$}}r)rr)__name__ __module__ __qualname____firstlineno____doc__rcopyregrrr classmethodr r,pickleloads__static_attributes__ __classcell__)rs@rrr!sO3O%449 ++ LLErrc8[X5RU5 g)z3Replacement for pickle.dump() using ForkingPickler.N)rr )r)filer*s rr r :s4"'',r) DupHandle duplicate steal_handle)source_processc[R"5nUcUnUcUn[R"X0USU[R5$)zcurrent_processs rr<r<GsM"335  !,N  !,N&& N {G99; ;rc J[R"[RSU5n[R"X![R"5SS[R [R -5[R"U5 $![R"U5 f=f)z5Steal a handle from process identified by source_pid.Fr)r@ OpenProcessPROCESS_DUP_HANDLErBrArCDUPLICATE_CLOSE_SOURCE CloseHandle) source_pidrDsource_process_handles rr=r=Ss| ' 3 3  & &z!; 7**%))+Q--0N0NNP    5 6G   5 6s A B B"c\[U[RU5nURU5 gz&Send a handle over a local connection.N)r;r@rCsend)connrDdestination_piddhs rrr_s! vw<UR5R5$))Receive a handle over a local connection.)recvdetach)rRs rrrdsyy{!!##rc(\rSrSrSrSSjrSrSrg)r;hzPicklable wrapper for a handle.Nc`Uc[R"5n[R"[RSU5n[R "[R "5XUSS5Ul[R"U5 X l X0l g![R"U5 f=f)NFr) osgetpidr@rIrJrBrA_handlerL_access_pid)rrDaccesspidprocs rrDupHandle.__init__js{iik&&w'A'A5#ND *&66--/&% 4 ##D)!LI##D)s 2BB-cUR[R"5:Xa UR$[R "[R SUR5n[R"XR[R"5URS[R5[R"U5 $![R"U5 f=f)z1Get the handle. This should only be called once.F) r`r\r]r^r@rIrJrBrAr_rKrL)rrcs rrXDupHandle.detachysyyBIIK'||#&&w'A'A5'+yy2D *..,,(A(A(CLL%)G)GI##D)##D)s !ACC)r_r^r`r)r.r/r0r1r2rrXr7rrr;r;hs-  *rr;)DupFdsendfdsrecvfdsdarwinc [R"SU5n[[U5S-/5nURU/[R [R U4/5 [(a!URS5S:wa [S5egg)z,Send an array of fds over an AF_UNIX socket.irAz%did not receive acknowledgement of fdN) arraybyteslenrsocket SOL_SOCKETr ACKNOWLEDGErW RuntimeError)sockfdsmsgs rriristkk#s#SX^$% cUf//1B1BCHIJ ;499Q<4/FG G0;rc[R"S5nURU-nURS[R"U55upEpgU(d U(d[ e[ (aURS5 [U5S:wa[S[U5-5eUSupn U[R:XaU [R:Xaz[U 5UR-S:wa[eURU 5 [U5S-US:wa'[SR[U5US55e[!U5$[S5e![["4a Nf=f) z/Receive an array of fds over an AF_UNIX socket.rmrrozreceived %d items of ancdatarrnz Len is {0:n} but msg[0] is {1!r}zInvalid data received)rpitemsizerecvmsgrs CMSG_SPACEEOFErrorrurQrrrvrtr ValueError frombytesAssertionErrorformatlist IndexError) rwsizea bytes_sizeryancdataflagsaddr cmsg_level cmsg_type cmsg_datas rrjrjsD KK ZZ$& $(LLF4E4Ej4Q$R!e7N { $7|q "#A#&w<$011/6qz ,J9f///V...y>AJJ.!3$$ I&q6C<3q6)(:AAFCF,--Aw233J'   s$C+EE.-E.c[R"UR5[R[R5n[ X1/5 SSS5 g!,(df  g=frP)rsfromfdfilenoAF_UNIX SOCK_STREAMri)rRrDrSss rrrs< ]]4;;=&..&:L:L MQR Ax N M Ms  A A'c[R"UR5[R[R5n[ US5SsSSS5 $!,(df  g=f)rVrrN)rsrrrrrj)rRrs rrrs@ ]]4;;=&..&:L:L MQR1a=#N M Ms A A*c[R"5nUb URURU55$[(aSSKJn URU5$[S5e)zReturn a wrapper for an fd.r)resource_sharerz&SCM_RIGHTS appears not to be available)rget_spawning_popenrhduplicate_for_childHAVE_SEND_HANDLErr)fd popen_objrs rrhrhsV..0  ??9#@#@#DE E   )"((, ,EF FrcURc([URURR44$[URURR44$r)__self__getattrr__func__r.ms r_reduce_methodrsHzzajj&9&9:::QZZ%8%8999rc\rSrSrSrSrg)_Ccgrrg)rs rf_C.fs rrgN)r.r/r0r1rr7rgrrrrs rrc>[URUR44$r)r __objclass__r.rs r_reduce_method_descriptorrs Q^^QZZ0 00rcf[URURUR=(d 044$r)_rebuild_partialfuncrkeywords)ps r_reduce_partialrs% affaffajj.>B? ??rc6[R"U/UQ70UD6$r) functoolspartial)rrrs rrrs   T 5D 5H 55rc,SSKJn [U"U544$)Nr) DupSocket)rr_rebuild_socket)rrs r_reduce_socketrs.1//rc"UR5$r)rX)dss rrrsyy{rc[UR55n[XRURUR 44$r)rhrrfamilyr"proto)rdfs rrrs0 188: XXqvvqww ???rcLUR5n[R"XX4S9$)N)r)rXrs)rrr"rrs rrrs YY[}}V5<ckk"$=>""O4/rrgN)r.r/r0r1r2rr r rrsysplatformr=r<r;rirjrhrrrrrrr7rgrrrrsl $NH DKK ||w#   #N 9'#N%O0rr) metaclassr)NF).abcrr3rr&r\r5rsrrr__all__rhasattrrPicklerrr r r@r<r=rrobjectr;rprurirjrhrrr"rrrrrrrrrrrrrgrrrs  NLLG+8VZ07V\27V]]I6V^^.  " "-<<7 99G ;$( ; 7 $*F*F ..G,,(*KH48! $ G:    bdff~&1dkk 56ckk 56@6  O, <<70 V]]N+@= V]]N+00r