o
0ij @ s d Z ddlZddlZddlZddlZddlZddlmZ ddlm Z g dZ
e edr3e
g d e edr?e
g d e ed
rHej
ZnejZG d d d ZG d
d deZG dd deZe edrnG dd dZG dd deZG dd dZG dd dZe edrG dd deeZG dd d eeZG d d d eeZG d d d eeZe edrG d!d" d"eZ G d#d$ d$eZ G d%d& d&ee Z G d'd( d(ee Z G d)d* d*Z G d+d, d,e Z!G d-d. d.eZ"G d/d0 d0e Z#dS )1z0.4 N)BufferedIOBase) monotonic)
BaseServer TCPServer UDPServerThreadingUDPServerThreadingTCPServerBaseRequestHandlerStreamRequestHandlerDatagramRequestHandlerThreadingMixInfork)ForkingUDPServerForkingTCPServer ForkingMixInAF_UNIX)UnixStreamServerUnixDatagramServerThreadingUnixStreamServerThreadingUnixDatagramServer PollSelectorc @ s e Zd Z dZdd Zdd Zd%ddZd d
Zd d Zd
d Z dd Z
dd Z dd Z dd Z
dd Zdd Zdd Zd d Zd d Zd!d" Zd#d$ ZdS )&r Nc C s" || _ || _t | _d| _d S NF)server_addressRequestHandlerClass threadingZEvent_BaseServer__is_shut_down _BaseServer__shutdown_request)selfr r r 3/opt/alt/python310/lib64/python3.10/socketserver.py__init__ s
zBaseServer.__init__c C d S Nr r r r r server_activate zBaseServer.server_activate ?c C s | j zIt (}|| tj | js+||}| jr n
|r$| | | jrW d n1 s5w Y W d| _| j
d S W d| _| j
d S d| _| j
w r ) r clear_ServerSelectorregister selectors
EVENT_READr select_handle_request_noblockservice_actionsset)r Z
poll_intervalselectorreadyr r r
serve_forever s,
zBaseServer.serve_foreverc C s d| _ | j d S NT)r r waitr# r r r shutdown s zBaseServer.shutdownc C r! r" r r# r r r r. r% zBaseServer.service_actionsc C s | j }|d u r| j}n | jd urt|| j}|d ur"t | }t 4}|| tj | |}|r@|
W d S |d urX|t }|dk rX| W d S q.1 s\w Y d S )NTr ) socketZ
gettimeouttimeoutmintimer( r) r* r+ r, r- handle_timeout)r r7 Zdeadliner0 r1 r r r handle_request s,
zBaseServer.handle_requestc C s z| \}}W n
ty Y d S w | ||rAz | || W d S ty8 | || | | Y d S | | | | d S r" ) get_requestOSErrorverify_requestprocess_request Exception handle_errorshutdown_requestr requestclient_addressr r r r- / s
z"BaseServer._handle_request_noblockc C r! r" r r# r r r r: F s zBaseServer.handle_timeoutc C s dS r3 r rC r r r r> M r% zBaseServer.verify_requestc C s | || | | d S r" )finish_requestrB rC r r r r? U s zBaseServer.process_requestc C r! r" r r# r r r server_close^ r% zBaseServer.server_closec C s | ||| d S r" )r rC r r r rF f s zBaseServer.finish_requestc C s | | d S r"
close_requestr rD r r r rB j s zBaseServer.shutdown_requestc C r! r" r rJ r r r rI n s zBaseServer.close_requestc C sB t dtjd t d|tjd dd l}| t dtjd d S )Nz(----------------------------------------)filez4Exception occurred during processing of request fromr )printsysstderr traceback print_exc)r rD rE rO r r r rA r s zBaseServer.handle_errorc C s | S r" r r# r r r __enter__ zBaseServer.__enter__c G s | d S r" )rG )r argsr r r __exit__ s zBaseServer.__exit__)r& )__name__
__module__ __qualname__r7 r r$ r2 r5 r. r; r- r: r> r? rG rF rB rI rA rQ rT r r r r r s( +
r c @ sd e Zd Z ejZejZdZdZ dddZ
dd Z dd Z d
d Z
d d
Zdd Zdd Zdd ZdS )r FTc C sR t | || t| j| j| _|r'z | | W d S | d S r" )r r r6 address_family socket_type server_bindr$ rG )r r r Zbind_and_activater r r r s zTCPServer.__init__c C s: | j r| jtjtjd | j| j | j | _d S )N )allow_reuse_addressr6
setsockoptZ
SOL_SOCKETZ SO_REUSEADDRZbindr Z getsocknamer# r r r r[ s
zTCPServer.server_bindc C s | j | j d S r" )r6 Zlistenrequest_queue_sizer# r r r r$ s zTCPServer.server_activatec C s | j d S r" )r6 closer# r r r rG s zTCPServer.server_closec C | j S r" )r6 filenor# r r r rb
zTCPServer.filenoc C ra r" )r6 Zacceptr# r r r r< rc zTCPServer.get_requestc C s4 z| tj W n ty Y nw | | d S r" )r5 r6 ZSHUT_WRr= rI rJ r r r rB s zTCPServer.shutdown_requestc C s | d S r" )r` rJ r r r rI s zTCPServer.close_requestN)T)rU rV rW r6 ZAF_INETrY Z SOCK_STREAMrZ r_ r] r r[ r$ rG rb r< rB rI r r r r r s -
r c @ s< e Zd Z dZejZdZdd Zdd Z dd Z
d d
Z d S ) r Fi c C s | j | j\}}|| j f|fS r" )r6 Zrecvfrommax_packet_size)r dataZ client_addrr r r r< s zUDPServer.get_requestc C d S r" r r# r r r r$ zUDPServer.server_activatec C s | | d S r" rH rJ r r r rB s zUDPServer.shutdown_requestc C rf r" r rJ r r r rI rg zUDPServer.close_requestN) rU rV rW r] r6 Z
SOCK_DGRAMrZ rd r< r$ rB rI r r r r r s r c sT e Zd Z dZdZdZdZddddZd d
Zd d Z d
d Z
fddZ Z S )r i, N( TFblockingc C s | j d u rd S t| j | jkr?ztdd\}}| j | W n ty. | j Y n ty6 Y n w t| j | jks| j D ]0}z|rKdntj
}t||\}}| j | W qD tyl | j | Y qD tyt Y qDw d S )Nr ) active_childrenlen max_childrenoswaitpiddiscardChildProcessErrorr' r= copyWNOHANG)r rj pid_flagsr r r collect_children( s0
z ForkingMixIn.collect_childrenc C | d S r" rx r# r r r r: K zForkingMixIn.handle_timeoutc C ry r" rz r# r r r r. R r{ z ForkingMixIn.service_actionsc C s t }|r | jd u rt | _| j| | | d S d}z/z
| || d}W n ty9 | || Y nw W z
| | W t
| d S t
| w z | | W t
| w t
| w )Nr\ r ) ro r
rl r/ addrI rF r@ rA rB _exit)r rD rE ru Zstatusr r r r? Y s,
z ForkingMixIn.process_requestc s t | j| jd d S )Nri )superrG rx block_on_closer# __class__r r rG r s
zForkingMixIn.server_close)
rU rV rW r7 rl rn r rx r: r. r? rG
__classcell__r r r r r s #r c s6 e Zd Z fddZdd Zdd Zdd Z ZS ) _Threadsc s" | |jr d S t | d S r" )reapdaemonr~ appendr threadr r r r { s z_Threads.appendc C s g | d d | d d < }|S r" r )r resultr r r pop_all s z_Threads.pop_allc C s | D ]}| qd S r" )r joinr r r r r s
z
_Threads.joinc C s dd | D | d d < d S )Nc s s | ] }| r|V qd S r" )Zis_alive).0r r r r s z _Threads.reap..r r# r r r r z
_Threads.reap)rU rV rW r r r r r r r r r r w s r c @ e Zd Z dd Zdd ZdS )
_NoThreadsc C rf r" r r r r r r rR z_NoThreads.appendc C rf r" r r# r r r r rR z_NoThreads.joinN)rU rV rW r r r r r r r s r c s< e Zd Z dZdZe Zdd Zdd Z fddZ Z
S ) r FTc C s` z(z| || W n ty | || Y n w W | | d S W | | d S | | w r" )rF r@ rA rB rC r r r process_request_thread s z%ThreadingMixIn.process_request_threadc C sN | j r
t| dt tj| j||fd}| j|_| j
| | d S )N_threads)targetrS ) r vars
setdefaultr r ZThreadr daemon_threadsr r r start)r rD rE tr r r r? s z ThreadingMixIn.process_requestc s t | j d S r" )r~ rG r r r# r r r rG s
zThreadingMixIn.server_close) rU rV rW r r r r r r? rG r r r r r r s
r c @ e Zd ZdS )r NrU rV rW r r r r r r c @ r )r Nr r r r r r r r c @ r )r Nr r r r r r r r c @ r )r Nr r r r r r r r c @ e Zd ZejZdS )r NrU rV rW r6 r rY r r r r r
r c @ r )r Nr r r r r r r r c @ r )r Nr r r r r r r r c @ r )r Nr r r r r r r r c @ . e Zd Z dd Zdd Zdd Zdd Zd S )
r c C s< || _ || _|| _| z | W | d S | w r" )rD rE serversetuphandlefinish)r rD rE r r r r r s
zBaseRequestHandler.__init__c C rf r" r r# r r r r rR zBaseRequestHandler.setupc C rf r" r r# r r r r rR zBaseRequestHandler.handlec C rf r" r r# r r r r rR zBaseRequestHandler.finishN)rU rV rW r r r r r r r r r s
r c @ s. e Zd Z dZdZdZdZdd Zdd ZdS ) r
rk r NFc C s| | j | _| jd ur| j| j | jr | jtjtjd | j d| j
| _ | j dkr3t
| j| _d S | j d| j | _d S )NTrbr wb)rD Z
connectionr7 Z
settimeoutdisable_nagle_algorithmr^ r6 Z IPPROTO_TCPZ TCP_NODELAYZmakefilerbufsizerfilewbufsize
_SocketWriterwfiler# r r r r s
zStreamRequestHandler.setupc C sD | j jsz| j W n
tjy Y nw | j | j d S r" )r closedflushr6 errorr` r r# r r r r # s
zStreamRequestHandler.finish) rU rV rW r r r7 r r r r r r r r
s
r
c @ r )
r c C s
|| _ d S r" )_sock)r Zsockr r r r 3
z_SocketWriter.__init__c C s dS r3 r r# r r r writable6 rR z_SocketWriter.writablec C s> | j | t| }|jW d S 1 sw Y d S r" )r Zsendall
memoryviewnbytes)r bZviewr r r write9 s
$z_SocketWriter.writec C s
| j S r" )r rb r# r r r rb > r z_SocketWriter.filenoN)rU rV rW r r r rb r r r r r . s r c @ r )r c C s2 ddl m} | j\| _| _|| j| _| | _d S )Nr )BytesIO)ior rD Zpacketr6 r r )r r r r r r E s z DatagramRequestHandler.setupc C s | j | j | j d S r" )r6 Zsendtor getvaluerE r# r r r r K r z DatagramRequestHandler.finishN)rU rV rW r r r r r r r A s r )$ __version__r6 r* ro rM r r r r9 r __all__hasattrextendr r( ZSelectSelectorr r r r listr r r r r r r r r r r r r
r r r r r r sP z
n~
X
(
.-