a
XC?h 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Ú threadingZEventÚ_BaseServer__is_shut_downÚ _BaseServer__shutdown_request)Úselfr r © r ú1/opt/alt/python39/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 ) ÚsocketZ
gettimeoutÚtimeoutÚminÚtimer& r' r( r) r* r+ Úhandle_timeout)r r5 Zdeadliner. r/ 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 r8 F s zBaseServer.handle_timeoutc C s dS r1 r rA r r r r< M s zBaseServer.verify_requestc C s | ||¡ | |¡ d S r! )Úfinish_requestr@ rA 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 rA r r r rD f s zBaseServer.finish_requestc C s | |¡ d S r! ©Ú
close_request©r rB r r r r@ j s zBaseServer.shutdown_requestc C s d S r! r rH r r r rG 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 rB rC rM r r r r? r s ÿzBaseServer.handle_errorc C s | S r! r r" r r r Ú __enter__ s zBaseServer.__enter__c G s | ¡ d S r! )rE )r Úargsr r r Ú__exit__‚ s zBaseServer.__exit__)r$ )Ú__name__Ú
__module__Ú __qualname__r5 r r# r0 r3 r, r9 r+ r8 r< r= rE rD r@ rG r? rO rQ 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 r4 Úaddress_familyÚ socket_typeÚ server_bindr# rE )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_addressr4 Ú
setsockoptZ
SOL_SOCKETZ SO_REUSEADDRZbindr Z getsocknamer" r r r rX Ê s zTCPServer.server_bindc C s | j | j¡ d S r! )r4 ZlistenÚrequest_queue_sizer" r r r r# Õ s zTCPServer.server_activatec C s | j ¡ d S r! )r4 Úcloser" r r r rE Ý s zTCPServer.server_closec C s
| j ¡ S r! )r4 Úfilenor" r r r r^ å s zTCPServer.filenoc C s
| j ¡ S r! )r4 Zacceptr" r r r r: í s zTCPServer.get_requestc C s2 z| tj¡ W n ty" Y n0 | |¡ d S r! )r3 r4 ZSHUT_WRr; rG rH r r r r@ õ s
zTCPServer.shutdown_requestc C s | ¡ d S r! )r] rH r r r rG ÿ s zTCPServer.close_requestN)T)rR rS rT r4 ZAF_INETrV Z SOCK_STREAMrW r\ rZ r rX r# rE r^ r: r@ rG 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! )r4 ZrecvfromÚ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! rF rH r r r r@ s zUDPServer.shutdown_requestc C s d S r! r rH r r r rG s zUDPServer.close_requestN) rR rS rT rZ r4 Z
SOCK_DGRAMrW r_ r: r# r@ rG 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 rc ÚpidÚ_Úflagsr r r Úcollect_children( s&
z ForkingMixIn.collect_childrenc C s | ¡ d S r! ©rq r" r r r r8 K s zForkingMixIn.handle_timeoutc C s | ¡ d S r! rr 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 )NrY r ) rh r
re r- ÚaddrG rD r> r? r@ Ú_exit)r rB rC rn Zstatusr r r r= Y s&
ý z ForkingMixIn.process_requestc s t ƒ ¡ | j| jd d S )Nrb )ÚsuperrE rq Úblock_on_closer" ©Ú __class__r r rE r s
zForkingMixIn.server_close)
rR rS rT r5 re rg rv rq r8 r, r= rE Ú
__classcell__r r rw r r s #r c s4 e Zd Z‡ fdd„Zdd„ Zdd„ Zdd„ Z‡ ZS ) Ú_Threadsc s" | ¡ |jrd S tƒ |¡ d S r! )ÚreapÚdaemonru Úappend©r Úthreadrw 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 Ú Š ó z _Threads.reap..r r" r r r r{ ‰ s z
_Threads.reap)rR rS rT r} r r‚ r{ ry r r rw r rz w s rz c @ s e Zd Zdd„ Zdd„ ZdS )Ú
_NoThreadsc C s d S r! r r~ r r r r} ‘ s z_NoThreads.appendc C s d S r! r r" r r r r‚ ” s z_NoThreads.joinN)rR rS rT r} r‚ r r r r r† s r† c s: e Zd ZdZdZeƒ Zdd„ Zdd„ Z‡ fdd„Z ‡ Z
S ) r FTc C sP z>z| ||¡ W n ty0 | ||¡ Y n0 W | |¡ n | |¡ 0 d S r! )rD r> r? r@ rA r r r Úprocess_request_thread¤ s
z%ThreadingMixIn.process_request_threadc C sL | j rt| ƒ dtƒ ¡ tj| j||fd}| j|_| j
|¡ | ¡ d S )NÚ_threads)ÚtargetrP ) rv ÚvarsÚ
setdefaultrz r ZThreadr‡ Údaemon_threadsr| rˆ r} Ústart)r rB rC Útr r r r= ± s ÿ z ThreadingMixIn.process_requestc s t ƒ ¡ | j ¡ d S r! )ru rE rˆ r‚ r" rw r r rE » s
zThreadingMixIn.server_close) rR rS rT rŒ rv r† rˆ r‡ r= rE ry r r rw r r ˜ s
r c @ s e Zd ZdS )r N©rR rS rT r r r r r Á r… r c @ s e Zd ZdS )r Nr r r r r r  r… r c @ s e Zd ZdS )r Nr r r r r r Ä r… r c @ s e Zd ZdS )r Nr r r r r r Å r… r c @ s e Zd ZejZdS )r N©rR rS rT r4 r rV r r r r r É s r c @ s e Zd ZejZdS )r Nr r r r r r Ì s r c @ s e Zd ZdS )r Nr r r r r r Ï r… r c @ s e Zd ZdS )r Nr r r r r r Ñ r… r c @ s, e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd S )
r c C s> || _ || _|| _| ¡ z| ¡ W | ¡ n
| ¡ 0 d S r! )rB rC ÚserverÚsetupÚhandleÚfinish)r rB rC r‘ r r r r å s
zBaseRequestHandler.__init__c C s d S r! r r" r r r r’ ï s zBaseRequestHandler.setupc C s d S r! r r" r r r r“ ò s zBaseRequestHandler.handlec C s d S r! r r" r r r r” õ s zBaseRequestHandler.finishN)rR rS rT r r’ r“ r” r r r r r Ó s
r c @ s, e Zd ZdZdZdZdZdd„ Zdd„ ZdS ) r
rd r NFc C sz | j | _| jd ur | j | j¡ | jr:| j tjtjd¡ | j d| j
¡| _ | j dkrdt
| jƒ| _n| j d| j ¡| _d S )NTÚrbr Úwb)rB Z
connectionr5 Z
settimeoutÚdisable_nagle_algorithmr[ r4 Z IPPROTO_TCPZ TCP_NODELAYZmakefileÚrbufsizeÚrfileÚwbufsizeÚ
_SocketWriterÚwfiler" r r r r’ s
ÿ
zStreamRequestHandler.setupc C sD | j js,z| j ¡ W n tjy* Y n0 | j ¡ | j ¡ d S r! )rœ ÚclosedÚflushr4 Úerrorr] r™ r" r r r r” # s
zStreamRequestHandler.finish) rR rS rT r˜ rš r5 r— r’ r” r r r r r
s
r
c @ s, e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd S )
r› c C s
|| _ d S r! )Ú_sock)r Zsockr r r r 3 s z_SocketWriter.__init__c C s dS r1 r r" r r r Úwritable6 s z_SocketWriter.writablec C s> | j |¡ t|ƒ}|jW d ƒ S 1 s00 Y d S r! )r ZsendallÚ
memoryviewÚnbytes)r ÚbZviewr r r Úwrite9 s
z_SocketWriter.writec C s
| j ¡ S r! )r r^ r" r r r r^ > s z_SocketWriter.filenoN)rR rS rT r r¡ r¥ r^ r r r r r› . s r› c @ s e Zd Zdd„ Zdd„ ZdS )r c C s2 ddl m} | j\| _| _|| jƒ| _|ƒ | _d S )Nr )ÚBytesIO)Úior¦ rB Zpacketr4 r™ rœ )r r¦ r r r r’ E s z DatagramRequestHandler.setupc C s | j | j ¡ | j¡ d S r! )r4 Zsendtorœ ÚgetvaluerC r" r r r r” K s z DatagramRequestHandler.finishN)rR rS rT r’ r” r r r r r A s r )$Ú __version__r4 r( rh rK r r§ r r7 r Ú__all__ÚhasattrÚextendr r& ZSelectSelectorr r r r Úlistrz r† r r r r r r r r r r r
r› r r r r r Ú{ sL
n~
X ( .-