eSSKrSSKrSSKrSSKrSSKrSSKJr SSKJr SSKJ r S/r \RS:Xa\ S/- r "S S\ 5r O\ S /- r "S S \ 5r"S S \ 5r\"5r\R"rg)N)process) reduction)utilstopwin32 DupSocketc$\rSrSrSrSrSrSrg)r zPicklable wrapper for a socket.c|^UR5mU4Sjn[RUTR5Ulg)NcJ>TRU5nURU5 gN)share send_bytes)connpidrnew_socks E/opt/imh/python3.13/lib/python3.13/multiprocessing/resource_sharer.pysend DupSocket.__init__..sends s+&)dup_resource_sharerregisterclose_id)selfsockrrs @r__init__DupSocket.__init__s-xxzH '(00x~~FDHrc[RUR5nUR5n[R "U5sSSS5 $!,(df  g=f)z1Get the socket. This should only be called once.N)rget_connectionr recv_bytessocket fromshare)rrrs rdetachDupSocket.detach$s<!00:d)''.;::s &A ArN__name__ __module__ __qualname____firstlineno____doc__rr&__static_attributes__rrr r s- G /rDupFdc$\rSrSrSrSrSrSrg)r1-z-Wrapper for fd which can be used at any time.c~^[R"U5mU4SjnU4Sjn[RX#5Ulg)Nc6>[R"UTU5 gr)r send_handle)rrnew_fds rrDupFd.__init__..send1s%%dFC8rc2>[R"T5 gr)osr)r7srrDupFd.__init__..close3s r)r:rrrr)rfdrrr7s @rrDupFd.__init__/s,VVBZF 9 !'00=DHrc[RUR5n[R"U5sSSS5 $!,(df  g=f)z-Get the fd. This should only be called once.N)rr"rr recv_handle)rrs rr& DupFd.detach7s0!00:d ,,T2;::s A Ar(Nr)r0rrr1r1-s; > 3rcP\rSrSrSrSrSr\S5rS Sjr Sr S r S r S r g) _ResourceSharer=z.Manager for resources using background thread.cSUl0Ul[R"5UlSUlSUlSUl[R"U[R5 g)Nr) _key_cache threadingLock_lock _listener_address_threadrregister_after_forkrB _afterfork)rs rr_ResourceSharer.__init__?sI  ^^%      'A'ABrcUR URcUR5 U=RS- slX4URUR'URUR4sSSS5 $!,(df  g=f)z+Register resource, returning an identifier.Nr)rIrK_startrErF)rrrs rr_ResourceSharer.registerHsW ZZ}}$ IINI&*]DKK "MM499- ZZs A$A;; B cSSKJn Uup#U"U[R"5RS9nUR U[ R"545 U$)z !!#!ZZs D$E Ec>URR5Hunup#U"5 M URR5 URR 5 UR bUR R 5 SUlSUlSUlgr) rFrdrerI_at_fork_reinitrJrrKrL)rr]rrs rrN_ResourceSharer._afterforkost"&++"3"3"5 C$ G#6  ""$ >> % NN "  rcbSSKJn URbS5e[R"S5 U"[ R "5RSS9UlURRUl [R"URS9nSUl UR5 X lg) Nr)ListenerzAlready have Listenerz0starting listener and thread for sending handles)rWbacklog)targetT)rXrlrJrdebugrrYrWr\rKrGThread_servedaemonstartrL)rrlts rrQ_ResourceSharer._startzs(~~%>'>>% EF!'*A*A*C*K*KUXY..   DKK 0   rcP[[S5(a8[R"[R[R"55 UR R 5nUR5nUc SSS5 gUup4URRU5upVU"X5 U"5 SSS5 Mu!U"5 f=f!,(df  N=f! [R"5(d&[R"[R"56 Nc=f)Npthread_sigmask)hasattrsignalrx SIG_BLOCK valid_signalsrJacceptrecvrFpopr is_exitingsys excepthookexc_info)rrmsgr]destination_pidrrs rrr_ResourceSharer._serves 6, - -  " "6#3#3V5I5I5K L 4^^**,))+C{-,,/(C"&++//#"6KD T3--, 4((NNCLLN3sOC!*C?C!!C*C2C:C! C  C CC!C!!AD%)rKrFrErJrIrLr)r*r+r,r-r.rr staticmethodr"rrNrQrrr/r0rrrBrB=s88C.$*  4rrB)r:rzr$rrGrcontextrr__all__platformobjectr r1rBrrr0rrrs  (<<7 }G /F /  yG 3 3 Y4fY4x#$r