LT n t d Z ddlZddlZddlZddlZddlZddlmZ ddlm Z g dZ
e ed re
g d e ed re
g d e ed
rej
Znej Z G d d Z G d
de Z G d de Z e ed r
G d d Z G d de Z G d d Z G d d Z e ed r G d dee Z G d d ee Z G d d ee Z G d d ee Z e ed r: G d! d"e Z G d# d$e Z G d% d&ee Z G d' d(ee Z G d) d* Z G d+ d,e Z! G d- d.e Z" G d/ d0e Z#dS )1z0.4 N)BufferedIOBase) monotonic)
BaseServer TCPServer UDPServerThreadingUDPServerThreadingTCPServerBaseRequestHandlerStreamRequestHandlerDatagramRequestHandlerThreadingMixInfork)ForkingUDPServerForkingTCPServer ForkingMixInAF_UNIX)UnixStreamServerUnixDatagramServerThreadingUnixStreamServerThreadingUnixDatagramServer PollSelectorc | e Zd Z dZd Zd ZddZd Zd Zd Z d Z
d
Z d Z d Z
d
Zd Zd Zd Zd Zd Zd ZdS )r Nc b || _ || _ t j | _ d| _ d S NF)server_addressRequestHandlerClass threadingEvent_BaseServer__is_shut_down _BaseServer__shutdown_request)selfr r s 3/opt/alt/python311/lib64/python3.11/socketserver.py__init__zBaseServer.__init__ s3 = ,#6 'o / /"' c d S N r! s r" server_activatezBaseServer.server_activate
r$ ?c | j t 5 }| | t j | j sN| | }| j rn1|r| | | j Nd d d n # 1 swxY w Y d| _ | j
d S # d| _ | j
w xY wr ) r clear_ServerSelectorregister selectors
EVENT_READr select_handle_request_noblockservice_actionsset)r!
poll_intervalselectorreadys r"
serve_foreverzBaseServer.serve_forever sJ
!!### &
!""
+h!!$ (<=== 1 + $OOM : :E. 7 44666((*** 1 +
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ ',D # # # % % % % % ',D # # # % % % %s/ C A6B, C ,B00C 3B04C "C;c H d| _ | j d S NT)r r waitr( s r" shutdownzBaseServer.shutdown s, #' """""r$ c d S r& r' r( s r" r4 zBaseServer.service_actions r* r$ c | j }|| j }n | j t || j }|t |z }t 5 }| | t j | | }|r |
cd d d S |7|t z
}|dk r | cd d d S q# 1 swxY w Y d S )NTr ) socket
gettimeouttimeoutmintimer. r/ r0 r1 r2 r3 handle_timeout)r! rB deadliner7 r8 s r" handle_requestzBaseServer.handle_request sg +((** ?lGG
\
%'4<00G vv'H
9( dI$8 9 9 9
9 00 9 7799
9 9 9 9 9 9 9 9 *"*TVV"3"Q;;#'#6#6#8#8 9 9 9 9 9 9 9 9
9 9 9 9 9 9 9 9 9 9 9s "A C5;,C54C55C9<C9c | \ }}n# t $ r Y d S w xY w| || rk | || d S # t $ r/ | || | | Y d S | | xY w| | d S r& ) get_requestOSErrorverify_requestprocess_request Exception handle_errorshutdown_requestr! requestclient_addresss r" r3 z"BaseServer._handle_request_noblock0 s &*&6&6&8&8 #G^^ FF w 7 7
+
$$Wn=====
/
/
/!!'>:::%%g......
%%g... ! !' * * * * *s
))A 5B*B*c d S r& r' r( s r" rE zBaseServer.handle_timeoutG s
r$ c dS r; r' rP s r" rK zBaseServer.verify_requestN s
tr$ c ^ | || | | d S r& )finish_requestrO rP s r" rL zBaseServer.process_requestV s9
G^444 g&&&&&r$ c d S r& r' r( s r" server_closezBaseServer.server_close_ r* r$ c 6 | ||| d S r& )r rP s r" rV zBaseServer.finish_requestg s# F .$?????r$ c 2 | | d S r&
close_requestr! rQ s r" rO zBaseServer.shutdown_requestk s A 7#####r$ c d S r& r' r] s r" r\ zBaseServer.close_requesto s
7 r$ c t dt j t d|t j dd l}| t dt j d S )Nz(----------------------------------------)filez4Exception occurred during processing of request fromr )printsysstderr traceback print_exc)r! rQ rR rd s r" rN zBaseServer.handle_errors sx
f3:&&&&
D - - - -
f3:&&&&&&r$ c | S r& r' r( s r" __enter__zBaseServer.__enter__ s r$ c . | d S r& )rX )r! argss r" __exit__zBaseServer.__exit__ s r$ )r+ )__name__
__module__ __qualname__rB r# r) r9 r= r4 rG r3 rE rK rL rX rV rO r\ rN rg rj r' r$ r" r r s( *X G( ( (
& & & &:# # #
& 9 9 9<+ + +.
' ' '
@ @ @$ $ $
' ' ' r$ r c j e Zd Z ej Zej ZdZdZ dZ
d
dZ d Z d Z
d Zd Zd Zd
Zd Zd S )r FTc t | || t j | j | j | _ |rE | | d S # | xY wd S r& )r r# r@ address_family socket_type server_bindr) rX )r! r r bind_and_activates r" r# zTCPServer.__init__ s =D.2EFFF mD$7$($46 6
"""$$&&&&&
!!###
s (A/ /Bc | j rEt t d r0| j t j t j d | j rEt t d r0| j t j t j d | j | j | j
| _ d S )N SO_REUSEADDR SO_REUSEPORT) allow_reuse_addresshasattrr@
setsockopt
SOL_SOCKETrv allow_reuse_portrx bindr getsocknamer( s r" rs zTCPServer.server_bind s
# N(G(G N K " "6#4f6I1 M M M NWV^%D%D N K " "6#4f6I1 M M M ,--- "k 5 5 7 7r$ c F | j | j d S r& )r@ listenrequest_queue_sizer( s r" r) zTCPServer.server_activate s(
4233333r$ c : | j d S r& )r@ closer( s r" rX zTCPServer.server_close s#
r$ c 6 | j S r& )r@ filenor( s r" r zTCPServer.fileno
{!!###r$ c 6 | j S r& )r@ acceptr( s r" rI zTCPServer.get_request r r$ c | t j n# t $ r Y nw xY w| | d S r& )r= r@ SHUT_WRrJ r\ r] s r" rO zTCPServer.shutdown_request s_ A
V^ , , , , D 7#####s #
00c 0 | d S r& )r r] s r" r\ zTCPServer.close_request s 7
r$ N)T)rk rl rm r@ AF_INETrq SOCK_STREAMrr r ry r} r# rs r) rX r rI rO r\ r' r$ r" r r s ,\ ^N$K 8 8 84 4 4 $ $ $$ $ $$ $ $ r$ r c B e Zd Z dZdZej ZdZd Z d Z
d Z d Z dS )r Fi c \ | j | j \ }}|| j f|fS r& )r@ recvfrommax_packet_size)r! data client_addrs r" rI zUDPServer.get_request s1 K 0 01E F Fkdk"K//r$ c d S r& r' r( s r" r) zUDPServer.server_activate r$ c 0 | | d S r& r[ r] s r" rO zUDPServer.shutdown_request s 7#####r$ c d S r& r' r] s r" r\ zUDPServer.close_request" r r$ N)
rk rl rm ry r} r@
SOCK_DGRAMrr r rI r) rO r\ r' r$ r" r r
sl #KO0 0 0
$ $ $
r$ r c N e Zd Z dZdZdZdZdddZd Zd Z d
Z
fd Z xZ S ) r i, N( TFblockingc | j d S t | j | j k r t j dd \ }}| j | n4# t $ r | j Y nt $ r Y n!w xY wt | j | j k | j D ]z} |rdn t j
}t j || \ }}| j | F# t $ r | j | Y lt $ r Y ww xY wd S )Nr ) active_childrenlen max_childrenoswaitpiddiscardChildProcessErrorr- rJ copyWNOHANG)r! r pid_flagss r" collect_childrenz ForkingMixIn.collect_children0 s I#+ d*++t/@@@ ZA . .FC(005555( 1 1 1(..00000 E d*++t/@@@ +0022
!) 9AArzE ZU 3 3FC (005555( 6 6 6(0055555 D
s0 2A #B
B
B
AD $D>2 D>=D>c 0 | d S r& r r( s r" rE zForkingMixIn.handle_timeoutS !
! ! # # # # #r$ c 0 | d S r& r r( s r" r4 z ForkingMixIn.service_actionsZ r r$ c b t j }|rK| j t | _ | j | | | d S d} | || d}n&# t $ r | || Y nw xY w | | t j
| d S # t j
| w xY w# | | t j
| w # t j
| w xY wxY w)Nrw r ) r r r r5 addr\ rV rM rN rO _exit)r! rQ rR r statuss r" rL z ForkingMixIn.process_requesta sH ?'))C
)'/+.55D($((---""7+++ )'' @@@ FF ? ? ?%%g~>>>>>?) --g666((((((((() --g666((((((((sN %A> =C) > B! C) B!!C) %C C&)D.+D D.D++D.c ~ t | | j d S )Nr )superrX r block_on_closer! __class__s r" rX zForkingMixIn.server_closez s9 GG " " " ! !4+> ! ? ? ? ? ?r$ )
rk rl rm rB r r r r rE r4 rL rX
__classcell__r s @r" r r ' s C /4 ! ! ! ! ! F $ $ $ $ $ $ ) ) )2 @ @ @ @ @ @ @ @ @r$ r c 2 e Zd Z fdZd Zd Zd Z xZS )_Threadsc | |j rd S t | d S r& )reapdaemonr append)r! threadr s r" r z_Threads.append s; = F
v r$ c * g | d d c| d d < }|S r& r' )r! results r" pop_allz_Threads.pop_all s" d111gQQQ
r$ c \ | D ]}| d S r& )r joinr! r s r" r z
_Threads.join s2 llnn F KKMMMM r$ c ( d | D | d d < d S )Nc 3 B K | ]}| |V d S r& )is_alive).0r s r"