֦im Z d Z ddlZddlZddlZddlZddlZddlmZ ddlm Z g dZ
e ed re
j g d e ed r/e
j g d e ed re
j d
d g e ed r
ej Zn ej 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 d ee Z G d d ee Z G d d ee Z G d! d"ee Z e ed rO G d# d$e Z G d% d&e Z G d' d(ee Z G d) d*ee Z e ed r G d+ d
ee Z G d, d ee Z! G d- d. Z" G d/ d0e" Z# G d1 d2e Z$ G d3 d4e" Z%y)5z0.4 N)BufferedIOBase) monotonic)
BaseServer TCPServer UDPServerThreadingUDPServerThreadingTCPServerBaseRequestHandlerStreamRequestHandlerDatagramRequestHandlerThreadingMixInfork)ForkingUDPServerForkingTCPServer ForkingMixInAF_UNIX)UnixStreamServerUnixDatagramServerThreadingUnixStreamServerThreadingUnixDatagramServerForkingUnixStreamServerForkingUnixDatagramServer PollSelectorc z e Zd Z dZd Zd ZddZd Zd Zd Z d Z
d Z d
Z d Z
d Zd
Zd Zd Zd Zd Zd Zy)r Nc b || _ || _ t j | _ d| _ y NF)server_addressRequestHandlerClass threadingEvent_BaseServer__is_shut_down _BaseServer__shutdown_request)selfr r s %/usr/lib64/python3.12/socketserver.py__init__zBaseServer.__init__ s, = ,#6 'oo /"' c y N r# s r$ server_activatezBaseServer.server_activate
r& c | j j t 5 }|j | t j
| j sM|j | }| j rn/|r| j | j | j sMd d d d| _ | j j y # 1 sw Y +xY w# d| _ | j j w xY wr ) r! clear_ServerSelectorregister selectors
EVENT_READr" select_handle_request_noblockservice_actionsset)r#
poll_intervalselectorreadys r$
serve_foreverzBaseServer.serve_forever s
!!# &
!"h!!$ (<(<= 11 $OOM :E.. 446((* 11 # ',D # # # % #" ',D # # # %s#
C A9C !C CC #C:c H d| _ | j j y NT)r" r! waitr* s r$ shutdownzBaseServer.shutdown s# #' "r& c y r( r) r* s r$ r5 zBaseServer.service_actions r, r& c | j j }|
| j }n"| j t || j }|
t |z }t 5 }|j
| t j |j | r| j cd d d S |+t z
}|dk r| j cd d d S X# 1 sw Y y xY w)Nr ) socket
gettimeouttimeoutmintimer/ r0 r1 r2 r3 r4 handle_timeout)r# rC deadliner8 s r$ handle_requestzBaseServer.handle_request s ++((* ?llG
\\
%'4<<0G v'H
( dI$8$8 9??7+ 779
*"*TV"3"Q;#'#6#6#8
s &AC 2#C C C)c B | j \ }}| j || r | j || y | j
| y # t $ r Y y w xY w# t $ r& | j || | j
| Y y | j
| xY wr( ) get_requestOSErrorverify_requestprocess_request Exception handle_errorshutdown_requestr# requestclient_addresss r$ r4 z"BaseServer._handle_request_noblock1 s &*&6&6&8 #G^ w 7
$$Wn=
! !' *
/!!'>:%%g.
%%g.s" A A AA ,B B c y r( r) r* s r$ rF zBaseServer.handle_timeoutH s
r& c yr< r) rQ s r$ rL zBaseServer.verify_requestO s
r& c L | j || | j | y r( )finish_requestrP rQ s r$ rM zBaseServer.process_requestW s'
G^4 g&r& c y r( r) r* s r$ server_closezBaseServer.server_close` r, r& c , | j ||| y r( )r rQ s r$ rW zBaseServer.finish_requesth s F .$?r& c ( | j | y r(
close_requestr# rR s r$ rP zBaseServer.shutdown_requestl s A 7#r& c y r( r) r^ s r$ r] zBaseServer.close_requestp s 7 r& c t dt j t d|t j dd l}|j t dt j y )Nz(----------------------------------------)filez4Exception occurred during processing of request fromr )printsysstderr traceback print_exc)r# rR rS re s r$ rO zBaseServer.handle_errort sH
f3::&
D -
f3::&r& c | S r( r) r* s r$ __enter__zBaseServer.__enter__ s r& c $ | j y r( )rY )r# argss r$ __exit__zBaseServer.__exit__ s r& )g ?)__name__
__module__ __qualname__rC r% r+ r: r> r5 rH r4 rF rL rM rY rW rP r] rO rh rk r) r& r$ r r se *X G(
&:#
&9:+.
'
@$
' r& r c | e Zd Z ej Zej ZdZdZ dZ
d dZ d Z d Z
d Zd Zd Zd Zd
Zy )
r Fc t j | || t j | j | j | _ |r" | j | j
y y # | j xY wr( )r r% rA address_family socket_type server_bindr+ rY )r# r r bind_and_activates r$ r% zTCPServer.__init__ st =D.2EF mmD$7$7$($4$46
"$$&
!!#s A- -B c : | j rIt t d r9| j j t j t j
d | j rut t d re| j t j t j fv r9| j j t j t j d | j j | j | j j | _ y )N SO_REUSEADDR SO_REUSEPORT)allow_reuse_addresshasattrrA
setsockopt
SOL_SOCKETrw allow_reuse_portrr AF_INETAF_INET6ry bindr getsocknamer* s r$ rt zTCPServer.server_bind s
# #(G KK " "6#4#4f6I6I1 M
! !gfn&E##'HH KK " "6#4#4f6I6I1 M ,,- "kk 5 5 7r& c P | j j | j y r( )rA listenrequest_queue_sizer* s r$ r+ zTCPServer.server_activate s!
4223r& c : | j j y r( )rA closer* s r$ rY zTCPServer.server_close s
r& c 8 | j j S r( )rA filenor* s r$ r zTCPServer.fileno
{{!!##r& c 8 | j j S r( )rA acceptr* s r$ rJ zTCPServer.get_request r r& c |j t j | j | y # t $ r Y w xY wr( )r> rA SHUT_WRrK r] r^ s r$ rP zTCPServer.shutdown_request sB A
V^^ ,
7# s 4 A A c & |j y r( )r r^ s r$ r] zTCPServer.close_request s 7
r& N)T)rl rm rn rA r rr SOCK_STREAMrs r rz r~ r% rt r+ rY r rJ rP r] r) r& r$ r r sX ,\ ^^N$$K 8$4 $$$r& r c J e Zd Z dZdZej ZdZd Z d Z
d Z d Z y)r Fi c r | j j | j \ }}|| j f|fS r( )rA recvfrommax_packet_size)r# data client_addrs r$ rJ zUDPServer.get_request s5 KK 0 01E1E Fkdkk"K//r& c y r( r) r* s r$ r+ zUDPServer.server_activate r& c & | j | y r( r\ r^ s r$ rP zUDPServer.shutdown_request$ s 7#r& c y r( r) r^ s r$ r] zUDPServer.close_request( r r& N)
rl rm rn rz r~ rA
SOCK_DGRAMrs r rJ r+ rP r] r) r& r$ r r s5 ##KO0
$
r& r c N e Zd Z dZdZdZdZdddZd Zd Z d
Z
fd Z xZ S ) r i, N( TFblockingc | j y t | j | j k\ rX t j dd \ }}| j j | t | j | j k\ rX| j j D ]K } |rdnt j }t j || \ }}| j j | M y # t $ r | j j Y t $ r Y w xY w# t $ r | j j | Y t $ r Y w xY w)Nr ) active_childrenlen max_childrenoswaitpiddiscardChildProcessErrorr. rK copyWNOHANG)r# r pid_flagss r$ collect_childrenz ForkingMixIn.collect_children6 s+ I##+ d**+t/@/@@ ZZA .FC((005 d**+t/@/@@ ++002
!)ArzzE ZZU 3FC ((005
3 ) 1((..0 ) 6((005 s0 4C2 'AD%2#D"D"!D"%$E EEc & | j y r( r r* s r$ rF zForkingMixIn.handle_timeoutY
! ! #r& c & | j y r( r r* s r$ r5 z ForkingMixIn.service_actions` r r& c @ t j }|rH| j t | _ | j j | | j | y d} | j
|| d} | j | t j | y # t $ r | j || Y Ew xY w# t j | w xY w# | j | t j | w # t j | w xY wxY w)Nrx r ) r r r r6 addr] rW rN rO rP _exit)r# rR rS r statuss r$ rM z ForkingMixIn.process_requestg s ?'')C''/+.5D($$((-""7+ )'' @ F) --g6(
! ?%%g~>? () --g6((sH #B 8C B=:C <B==C CD D-D DD c Z t | | j | j y )Nr )superrY r block_on_closer# __class__s r$ rY zForkingMixIn.server_close s% G " ! !4+>+> ! ?r& )
rl rm rn rC r r r r rF r5 rM rY
__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 |j ry t |
| y r( )reapdaemonr append)r# threadr s r$ r z_Threads.append s" ==
v r& c g | d d c| d d }|S r( r) )r# results r$ pop_allz_Threads.pop_all s d1gQ
r& c N | j D ] }|j y r( )r joinr# r s r$ r z
_Threads.join s llnF KKM %r& c d | D | d d y )Nc 3 B K | ] }|j s| y wr( )is_alive).0r s r$