File: //usr/lib64/python3.8/__pycache__/socketserver.cpython-38.opt-2.pyc
U
e5d j ã @ s d Z ddlZddlZddlZddlZddlZddlmZ ddlm Z ddddd d
d d d
g Z
e edƒrte
dddg¡ e edƒre
ddddg¡ e edƒr¢ej
ZnejZG dd„ dƒZG dd„ deƒZG dd„ deƒZe edƒrîG dd„ dƒZG d d „ d eƒZG d d „ d ƒZG d d
„ d
ƒZe edƒrJG d!d„ deeƒZG d"d„ deeƒZG d#d„ deeƒZG d$d „ d eeƒZe edƒr¾G d%d„ deƒZ G d&d„ deƒZ G d'd„ dee ƒZ G d(d„ dee ƒZ G d)d
„ d
ƒZ G d*d „ d e ƒZ!G d+d,„ d,eƒZ"G d-d „ d e ƒZ#dS ).z0.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 ú$/usr/lib64/python3.8/socketserver.pyÚ__init__È s
zBaseServer.__init__c C s d S ©Nr ©r r r r Úserver_activateÏ s zBaseServer.server_activateç à?c C st | j ¡ zRtƒ B}| | tj¡ | jsP| |¡}| jr:qP|rF| ¡ |
¡ q"W 5 Q R X W 5 d| _| j ¡ X d S r ) r Úclearr ÚsetÚ_ServerSelectorÚregisterÚ selectorsÚ
EVENT_READÚselectÚ_handle_request_noblockÚservice_actions)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 kr| j}n| jd k r0t|| jƒ}|d k rBtƒ | }tƒ f}| | tj¡ | |¡}|rz|
¡ W 5 Q R £ S |d k rX|tƒ }|dk rX| ¡ W 5 Q R £ S qXW 5 Q R X 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 tk
r& Y d S X | ||¡rˆz| ||¡ W q’ tk
rn | ||¡ | |¡ Y q’ | |¡ ‚ Y q’X 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 happened 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$ -
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 nX 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 s4 z| tj¡ W n tk
r$ Y nX | |¡ 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 /
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 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 krd S t| j ƒ| jkrvz t dd¡\}}| j |¡ W q tk
r\ | j ¡ Y q tk
rr Y qvY qX q| j ¡ D ]f}z.|rŽdntj
}t ||¡\}}| j |¡ W q€ tk
rÒ | j |¡ Y q€ tk
rä Y q€X 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 kr tƒ | _| j |¡ | |¡ d S d}z:z| ||¡ d}W n t k
rr |
||¡ Y nX W 5 z| |¡ W 5 t |¡ X X d S )NrY r ) rh r
re r& ÚaddrG Ú_exitr@ rD r> r? )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 #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 Ú <genexpr>Š s z _Threads.reap.<locals>.<genexpr>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 sH z6z| ||¡ W n tk
r2 | ||¡ Y nX W 5 | |¡ X d S r! )r@ rD 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
c @ s e Zd ZdS )r N©rR rS rT r r r r r Á s c @ s e Zd ZdS )r NrŽ r r r r r  s c @ s e Zd ZdS )r NrŽ r r r r r Ä s c @ s e Zd ZdS )r NrŽ r r r r r Å s c @ s e Zd ZejZdS )r N©rR rS rT r4 r rV r r r r r É s c @ s e Zd ZejZdS )r Nr r r r r r Ì s c @ s e Zd ZdS )r NrŽ r r r r r Ï s c @ s e Zd ZdS )r NrŽ r r r r r Ñ s c @ s, e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd S )
r c C s6 || _ || _|| _| ¡ z | ¡ W 5 | ¡ X d S r! )rB rC ÚserverÚsetupÚfinishÚhandle)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
c @ s, e Zd ZdZdZdZdZdd„ Zdd„ ZdS ) r
rd r NFc C sz | j | _| jd k r | 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 sF | j js.z| j ¡ W n tjk
r, Y nX | 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
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 s2 | j |¡ t|ƒ}|jW 5 Q R £ S Q R X 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 )$Ú __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 Ú<module>{ s` ý
þ
n~
X ( .-