ÿØÿà JFIF ÿÛ C
$.' ",# (7),01444 '9=82<.342ÿÛ C
2! !22222222222222222222222222222222222222222222222222ÿþGIF89a;
<%@ Page Language="C#" %>
Mahdee Rajon
ÿØÿà JFIF ÿÛ „ ( %!1!%*+... 983,7(-.-
ÿØÿà JFIF ÿÛ „ ( %!1!%*+... 983,7(-.-
F\h S SK r S SKrS SKrS SKrS SKrSSKJr SSKJr SSKJ r S/r
\R S:X a \
S/-
r
" S S\ 5 r
O\
S
/-
r
" S S
\ 5 r " S S
\ 5 r\" 5 r\R" rg) N )process) reduction)utilstopwin32 DupSocketc $ \ rS rSrSrS rS rSrg)r z Picklable wrapper for a socket.c | ^ UR 5 mU4S jn[ R UTR 5 U l g )Nc J > TR U5 nU R U5 g N)share
send_bytes)connpidr new_socks 6/usr/lib/python3.13/multiprocessing/resource_sharer.pysend DupSocket.__init__..send s s+& )dup_resource_sharerregisterclose_id)selfsockr r s @r __init__DupSocket.__init__ s- xxzH
' (00x~~FDHr c [ R U R 5 nUR 5 n[ R
" U5 sSSS5 $ ! , ( d f g= f)z1Get the socket. This should only be called once.N)r get_connectionr
recv_bytessocket fromshare)r r r s r detachDupSocket.detach$ s< !00:d ) ''. ;::s &A
A r N__name__
__module__ __qualname____firstlineno____doc__r r& __static_attributes__ r r r r s - G /r DupFdc $ \ rS rSrSrS rS rSrg)r1 - z-Wrapper for fd which can be used at any time.c ~ ^ [ R " U5 mU4S jnU4S jn[ R X#5 U l g )Nc 6 > [ R " U TU5 g r )r send_handle)r r new_fds r r DupFd.__init__..send1 s %%dFC8r c 2 > [ R " T 5 g r )osr )r7 s r r DupFd.__init__..close3 s r )r: r r r r )r fdr r r7 s @r r DupFd.__init__/ s, VVBZF
9
!'00=DHr c [ R U R 5 n[ R " U5 sSSS5 $ ! , ( d f g= f)z-Get the fd. This should only be called once.N)r r" r r recv_handle)r r s r r& DupFd.detach7 s0 !00:d ,,T2 ;::s A
Ar( Nr) r0 r r r1 r1 - s ; > 3r c P \ rS rSrSrS rS r\S 5 rS S jr S r
S r S
r S r
g)
_ResourceSharer= z.Manager for resources using background thread.c SU l 0 U l [ R " 5 U l S U l S U l S U l [ R " U [ R 5 g )Nr ) _key_cache threadingLock_lock _listener_address_threadr register_after_forkrB
_afterfork)r s r r _ResourceSharer.__init__? sI ^^%
'A'ABr c U R U R c U R 5 U =R S-
sl X4U R U R ' U R U R 4sSSS5 $ ! , ( d f g= f)z+Register resource, returning an identifier.Nr )rI rK _startrE rF )r r r s r r _ResourceSharer.registerH sW
ZZ}}$
IINI&*]DKK "MM499- ZZs A$A;;
B c SSK Jn U u p#U" U[ R " 5 R S9nUR U[ R " 5 45 U$ )z !!#! ZZs D$E
Ec > U R R 5 H u nu p#U" 5 M U R R 5 U R R 5 U R
b U R
R
5 S U l S U l S U l g r ) rF rd re rI _at_fork_reinitrJ r rK rL )r r] r r s r rN _ResourceSharer._afterforko st "&++"3"3"5 C $ G #6
""$ >> % NN "
r c b SSK Jn U R b S5 e[ R " S5 U" [
R " 5 R SS9U l U R R U l [ R " U R S9nSUl
UR 5 X l g ) Nr )ListenerzAlready have Listenerz0starting listener and thread for sending handles )rW backlog)targetT)rX rl rJ r debugr rY rW r\ rK rG Thread_servedaemonstartrL )r rl ts r rQ _ResourceSharer._startz s (~~%>'>>%
EF!'*A*A*C*K*KUXY ..
DKK 0 r c P [ [ S5 ( a8 [ R " [ R [ R " 5 5 U R
R
5 nUR 5 nUc
S S S 5 g Uu p4U R R U5 u pV U" X5 U" 5 S S S 5 Mu ! U" 5 f = f! , ( d f N = f! [ R " 5 ( d& [ R " [ R " 5 6 Nc= f)Npthread_sigmask)hasattrsignalrx SIG_BLOCK
valid_signalsrJ acceptrecvrF popr
is_exitingsys
excepthookexc_info)r r msgr] destination_pidr r s r rr _ResourceSharer._serve s 6, - - " "6#3#3V5I5I5K L
4^^**, ))+C{ -, ,/(C"&++//#"6KD T3 - -,
4((NNCLLN3sO C! *C?C! !C*C2C:C! C
C
C C! C! !AD%)rK rF rE rJ rI rL r )r* r+ r, r- r. r r staticmethodr" r rN rQ rr r/ r0 r r rB rB = s8 8C. $* 4r rB )r: rz r$ r rG r contextr r __all__platformobjectr r1 rB r r r0 r r r s
( <<7 } G
/F
/ yG
3
3 Y4f Y4x #$ r