a
´i j ã @ sì d Z ddlZddlZddlZddlZddlZddlmZ ddlm Z g d¢Z
e edƒrde
g d¢¡ e edƒr|e
g d ¢¡ e ed
ƒrŽej
ZnejZG d d „ d ƒZG d
d„ deƒZG dd„ deƒZe edƒrÚG dd„ dƒZG dd„ deƒZG dd„ dƒZG dd„ dƒZe edƒr6G dd„ deeƒZG dd „ d eeƒZG d d „ d eeƒZG d d „ d eeƒZe edƒrªG d!d"„ d"eƒZ G d#d$„ d$eƒZ 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.eƒZ"G d/d0„ d0e ƒZ#dS )1z0.4é N)ÚBufferedIOBase)Ú monotonic) Ú
BaseServerÚ TCPServerÚ UDPServerÚThreadingUDPServerÚThreadingTCPServerÚBaseRequestHandlerÚStreamRequestHandlerÚDatagramRequestHandlerÚThreadingMixInÚfork)ÚForkingUDPServerÚForkingTCPServerÚ ForkingMixInÚAF_UNIX)ÚUnixStreamServerÚUnixDatagramServerÚThreadingUnixStreamServerÚThreadingUnixDatagramServerÚ PollSelectorc @ sš e Zd ZdZdd„ Zdd„ Zd%dd„Zd 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_addressÚRequestHandlerClassÚ threadingÚEventÚ_BaseServer__is_shut_downÚ _BaseServer__shutdown_request)Úselfr r © r ú$/usr/lib64/python3.9/socketserver.pyÚ__init__È s
zBaseServer.__init__c C s d S ©Nr ©r r r r Úserver_activateÏ s zBaseServer.server_activateç à?c C s˜ | j ¡ zvtƒ L}| | tj¡ | jsP| |¡}| jr:qP|rF| ¡ | ¡ q"W d ƒ n1 sd0 Y W d| _| j
¡ nd| _| j
¡ 0 d S r ) r ÚclearÚ_ServerSelectorÚregisterÚ selectorsÚ
EVENT_READr ÚselectÚ_handle_request_noblockÚservice_actionsÚset)r Z
poll_intervalÚselectorÚreadyr 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 s d S r" r r# r r r r- þ s zBaseServer.service_actionsc C sÐ | j ¡ }|d u r| j}n| jd ur0t|| jƒ}|d urBtƒ | }tƒ t}| | tj¡ | |¡}|r||
¡ W d ƒ S |d urX|tƒ }|dk rX| ¡ W d ƒ S qXW d ƒ n1 sÂ0 Y d S )Nr ) ÚsocketÚ
gettimeoutÚtimeoutÚminÚtimer' r( r) r* r+ r, Úhandle_timeout)r r7 Údeadliner/ r0 r r r Úhandle_request s
zBaseServer.handle_requestc C s’ z| ¡ \}}W n ty$ Y d S 0 | ||¡r„z| ||¡ W qŽ tyj | ||¡ | |¡ Y qŽ | |¡ ‚ Y qŽ0 n
| |¡ d S r" )Ú get_requestÚOSErrorÚverify_requestÚprocess_requestÚ ExceptionÚ handle_errorÚshutdown_request©r ÚrequestÚclient_addressr r r r, / s
z"BaseServer._handle_request_noblockc C s d S r" r r# r r r r: F s zBaseServer.handle_timeoutc C s dS r2 r rD r r r r? M s zBaseServer.verify_requestc C s | ||¡ | |¡ d S r" )Úfinish_requestrC rD r r r r@ U s zBaseServer.process_requestc C s d S r" r r# r r r Ú server_close^ s zBaseServer.server_closec C s | ||| ¡ d S r" )r rD r r r rG f s zBaseServer.finish_requestc C s | |¡ d S r" ©Ú
close_request©r rE r r r rC j s zBaseServer.shutdown_requestc C s d S r" r rK r r r rJ n s zBaseServer.close_requestc C s@ t dtjd t d|tjd dd l}| ¡ t dtjd d S )Nz(----------------------------------------)Úfilez4Exception occurred during processing of request fromr )ÚprintÚsysÚstderrÚ tracebackÚ print_exc)r rE rF rP r r r rB r s ÿzBaseServer.handle_errorc C s | S r" r r# r r r Ú __enter__ s zBaseServer.__enter__c G s | ¡ d S r" )rH )r Úargsr r r Ú__exit__‚ s zBaseServer.__exit__)r% )Ú__name__Ú
__module__Ú __qualname__r7 r! r$ r1 r4 r- r< r, r: r? r@ rH rG rC rJ rB rR rT r r r r r ™ s$ -
r c @ sb e Zd ZejZejZdZdZ ddd„Z
dd„ Z dd „ Z d
d „ Z
d d
„ Zdd„ Zdd„ Zdd„ ZdS )r é FTc C sT t | ||¡ t | j| j¡| _|rPz| ¡ | ¡ W n | ¡ ‚ Y n0 d S r" )r r! r5 Úaddress_familyÚ socket_typeÚ server_bindr$ rH )r r r Zbind_and_activater r r r! ½ s ÿ zTCPServer.__init__c C s8 | j r| j tjtjd¡ | j | j¡ | j ¡ | _d S )Né )Úallow_reuse_addressr5 Ú
setsockoptÚ
SOL_SOCKETÚ SO_REUSEADDRÚbindr Ú getsocknamer# r r r r[ Ê s zTCPServer.server_bindc C s | j | j¡ d S r" )r5 ÚlistenÚrequest_queue_sizer# r r r r$ Õ s zTCPServer.server_activatec C s | j ¡ d S r" )r5 Úcloser# r r r rH Ý s zTCPServer.server_closec C s
| j ¡ S r" )r5 Úfilenor# r r r rf å s zTCPServer.filenoc C s
| j ¡ S r" )r5 Úacceptr# r r r r= í s zTCPServer.get_requestc C s2 z| tj¡ W n ty" Y n0 | |¡ d S r" )r4 r5 ÚSHUT_WRr> rJ rK r r r rC õ s
zTCPServer.shutdown_requestc C s | ¡ d S r" )re rK r r r rJ ÿ s zTCPServer.close_requestN)T)rU rV rW r5 ÚAF_INETrY Ú SOCK_STREAMrZ rd r] r! r[ r$ rH rf r= rC rJ r r r r r † s /
r c @ s: e Zd ZdZejZdZdd„ Zdd„ Z dd„ Z
d d
„ Z d S ) r Fi c C s | j | j¡\}}|| j f|fS r" )r5 ÚrecvfromÚmax_packet_size)r ÚdataZ client_addrr r r r= s zUDPServer.get_requestc C s d S r" r r# r r r r$ s zUDPServer.server_activatec C s | |¡ d S r" rI rK r r r rC s zUDPServer.shutdown_requestc C s d S r" r rK r r r rJ s zUDPServer.close_requestN) rU rV rW r] r5 Ú
SOCK_DGRAMrZ rl r= r$ rC rJ r r r r r s r c sR e Zd ZdZdZdZdZddœdd„Zd d
„ Zd d „ Z d
d„ Z
‡ fdd„Z ‡ Z S )r i, Né( TF©Úblockingc C sä | j d u rd S t| j ƒ| jkrrz t dd¡\}}| j |¡ W q tyZ | j ¡ Y q tyn Y qrY q0 q| j ¡ D ]b}z.|rŠdntj
}t ||¡\}}| j |¡ W q| tyÌ | j |¡ Y q| tyÜ Y q|0 q|d S )Néÿÿÿÿr ) Úactive_childrenÚlenÚ max_childrenÚosÚwaitpidÚdiscardÚChildProcessErrorr& r> ÚcopyÚWNOHANG)r rq ÚpidÚ_Úflagsr r r Úcollect_children( s&
z ForkingMixIn.collect_childrenc C s | ¡ d S r" ©r r# r r r r: K s zForkingMixIn.handle_timeoutc C s | ¡ d S r" r€ r# r r r r- R s z ForkingMixIn.service_actionsc C sÈ t ¡ }|r8| jd u r tƒ | _| j |¡ | |¡ d S d}z^z| ||¡ d}W n typ | ||¡ Y n0 W z| |¡ W t
|¡ qÄt
|¡ 0 n(z| |¡ W t
|¡ n t
|¡ 0 0 d S )Nr\ r ) rv r
rs r. ÚaddrJ rG rA rB rC Ú_exit)r rE rF r| Ústatusr r r r@ Y s&
ý z ForkingMixIn.process_requestc s t ƒ ¡ | j| jd d S )Nrp )ÚsuperrH r Úblock_on_closer# ©Ú __class__r r rH r s
zForkingMixIn.server_close)
rU rV rW r7 rs ru r… r r: r- r@ rH Ú
__classcell__r r r† r r s #r c s4 e Zd Z‡ fdd„Zdd„ Zdd„ Zdd„ Z‡ ZS ) Ú_Threadsc s" | ¡ |jrd S tƒ |¡ d S r" )ÚreapÚdaemonr„ Úappend©r Ú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" )Úis_alive)Ú.0rŽ r r r Ú