/opt/alt/python37/lib64/python3.7/__pycache__/socketserver.cpython-37.opt-2.pyc (13270B)
r r r r8 M s zBaseServer.verify_requestc C s | ||¡ | |¡ d S )N)Úfinish_requestr< )r r= r> r r r r9 U s zBaseServer.process_requestc C s d S )Nr )r r r r Ú server_close^ s zBaseServer.server_closec C s | ||| ¡ d S )N)r )r r= r> r r r r? f s zBaseServer.finish_requestc C s | |¡ d S )N)Ú
close_request)r r= r r r r< j s zBaseServer.shutdown_requestc C s d S )Nr )r r= r r r rA 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 r= r> rF r r r r; r s zBaseServer.handle_errorc C s | S )Nr )r r r r Ú __enter__ s zBaseServer.__enter__c G s | ¡ d S )N)r@ )r Úargsr r r Ú__exit__‚ s zBaseServer.__exit__)r! )Ú__name__Ú
__module__Ú __qualname__r1 r r r- r/ r) r5 r( r4 r8 r9 r@ r? r< rA r; rH rJ 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¡| _|rPy| ¡ | ¡ W n | ¡ ‚ Y nX d S )N)r r r0 Úaddress_familyÚ socket_typeÚ server_bindr r@ )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_addressr0 Ú
setsockoptZ
SOL_SOCKETZ SO_REUSEADDRZbindr Z getsockname)r r r r rQ Ê s zTCPServer.server_bindc C s | j | j¡ d S )N)r0 ZlistenÚrequest_queue_size)r r r r r Õ s zTCPServer.server_activatec C s | j ¡ d S )N)r0 Úclose)r r r r r@ Ý s zTCPServer.server_closec C s
| j ¡ S )N)r0 Úfileno)r r r r rW å s zTCPServer.filenoc C s
| j ¡ S )N)r0 Zaccept)r r r r r6 í s zTCPServer.get_requestc C s4 y| tj¡ W n tk
r$ Y nX | |¡ d S )N)r/ r0 ZSHUT_WRr7 rA )r r= r r r r< õ s
zTCPServer.shutdown_requestc C s | ¡ d S )N)rV )r r= r r r rA ÿ s zTCPServer.close_requestN)T)rK rL rM r0 ZAF_INETrO Z SOCK_STREAMrP rU rS r rQ r r@ rW r6 r< rA 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 )N)r0 ZrecvfromÚmax_packet_size)r ÚdataZ client_addrr r r r6 s zUDPServer.get_requestc C s d S )Nr )r r r r r s zUDPServer.server_activatec C s | |¡ d S )N)rA )r r= r r r r< s zUDPServer.shutdown_requestc C s d S )Nr )r r= r r r rA s zUDPServer.close_requestN) rK rL rM rS r0 Z
SOCK_DGRAMrP rX r6 r r< rA 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 xht| j ƒ| jkrvy t dd¡\}}| j |¡ W q tk
r^ | j ¡ Y q tk
rr P Y qX qW xt| j ¡ D ]f}y.|r’dntj
}t ||¡\}}| j |¡ W q„ tk
rÖ | j |¡ Y q„ tk
rè Y q„X q„W d S )Néÿÿÿÿr ) Úactive_childrenÚlenÚ max_childrenÚosÚwaitpidÚdiscardÚChildProcessErrorr" r7 ÚcopyÚWNOHANG)r r[ ÚpidÚ_Úflagsr r r Úcollect_children( s&
z ForkingMixIn.collect_childrenc C s | ¡ d S )N)ri )r r r r r4 K s zForkingMixIn.handle_timeoutc C s | ¡ d S )N)ri )r r r r r) R s z ForkingMixIn.service_actionsc C sš t ¡ }|r8| jd kr tƒ | _| j |¡ | |¡ d S d}z:y| ||¡ d}W n tk
rr | ||¡ Y nX W d z| |¡ W d t
|¡ X X d S )NrR r ) r` r
r] r* ÚaddrA r? r: r; r< Ú_exit)r r= r> rf Ústatusr r r r9 Y s
z ForkingMixIn.process_requestc s t ƒ ¡ | j| jd d S )N)r[ )Úsuperr@ ri Úblock_on_close)r )Ú __class__r r r@ r s
zForkingMixIn.server_close)
rK rL rM r1 r] r_ rn ri r4 r) r9 r@ Ú
__classcell__r r )ro r r s #c s8 e Zd ZdZdZdZdd„ Zdd„ Z‡ fdd „Z‡ Z S )
r FTNc C sH z6y| ||¡ W n tk
r2 | ||¡ Y nX W d | |¡ X d S )N)r? r: r; r< )r r= r> r r r Úprocess_request_threadƒ s
z%ThreadingMixIn.process_request_threadc C sP t j| j||fd}| j|_|jsD| jrD| jd kr8g | _| j |¡ | ¡ d S )N)ÚtargetrI ) r ZThreadrq Údaemon_threadsZdaemonrn Ú_threadsÚappendÚstart)r r= r> Útr r r r9 s
z ThreadingMixIn.process_requestc s: t ƒ ¡ | jr6| j}d | _|r6x|D ] }| ¡ q&W d S )N)rm r@ rn rt Újoin)r ZthreadsZthread)ro r r r@ › s
zThreadingMixIn.server_close)
rK rL rM rs rn rt rq r9 r@ rp r r )ro r r w s
c @ s e Zd ZdS )r N)rK rL rM r r r r r ¦ s c @ s e Zd ZdS )r N)rK rL rM r r r r r § s c @ s e Zd ZdS )r N)rK rL rM r r r r r © s c @ s e Zd ZdS )r N)rK rL rM r r r r r ª s c @ s e Zd ZejZdS )r N)rK rL rM r0 r rO r r r r r ® s c @ s e Zd ZejZdS )r N)rK rL rM r0 r rO r r r r r ± s c @ s e Zd ZdS )r N)rK rL rM r r r r r ´ s c @ s e Zd ZdS )r N)rK rL rM r r r r r ¶ s c @ s, e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd S )
r c C s6 || _ || _|| _| ¡ z | ¡ W d | ¡ X d S )N)r= r> ÚserverÚsetupÚhandleÚfinish)r r= r> ry r r r r Ê s zBaseRequestHandler.__init__c C s d S )Nr )r r r r rz Ô s zBaseRequestHandler.setupc C s d S )Nr )r r r r r{ × s zBaseRequestHandler.handlec C s d S )Nr )r r r r r| Ú s zBaseRequestHandler.finishN)rK rL rM r rz r{ r| r r r r r ¸ s
c @ s, e Zd ZdZdZdZdZdd„ Zdd„ ZdS ) r
r\ 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)r= Z
connectionr1 Z
settimeoutÚdisable_nagle_algorithmrT r0 Z IPPROTO_TCPZ TCP_NODELAYZmakefileÚrbufsizeÚrfileÚwbufsizeÚ
_SocketWriterÚwfile)r r r r rz û s
zStreamRequestHandler.setupc C sF | j js.y| j ¡ W n tjk
r, Y nX | j ¡ | j ¡ d S )N)r„ ÚclosedÚflushr0 ÚerrorrV r )r r r r r| s
zStreamRequestHandler.finish) rK rL rM r€ r‚ r1 r rz r| r r r r r
æ s
c @ s, e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd S )
rƒ c C s
|| _ d S )N)Ú_sock)r Zsockr r r r s z_SocketWriter.__init__c C s dS )NTr )r r r r Úwritable s z_SocketWriter.writablec C s& | j |¡ t|ƒ}|jS Q R X d S )N)rˆ ZsendallÚ
memoryviewÚnbytes)r ÚbZviewr r r Úwrite s
z_SocketWriter.writec C s
| j ¡ S )N)rˆ rW )r r r r rW # s z_SocketWriter.filenoN)rK rL rM r r‰ r rW 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Ž r= Zpacketr0 r r„ )r rŽ r r r rz * s z DatagramRequestHandler.setupc C s | j | j ¡ | j¡ d S )N)r0 Zsendtor„ Úgetvaluer> )r r r r r| 0 s z DatagramRequestHandler.finishN)rK rL rM rz r| r r r r r & s )!Ú __version__r0 r% r` rD r r r r3 r Ú__all__ÚhasattrÚextendr r# ZSelectSelectorr r r r r r r r r r r r r r r
rƒ r r r r r Ú