r r r r8 Q s zBaseServer.verify_requestc C s | j || | j| d S )N)finish_requestr< )r r= r> r r r r9 Y s zBaseServer.process_requestc C s d S )Nr )r r r r server_closeb s zBaseServer.server_closec C s | j ||| d S )N)r )r r= r> r r r r? j s zBaseServer.finish_requestc C s | j | d S )N)
close_request)r r= r r r r< n s zBaseServer.shutdown_requestc C s d S )Nr )r r= r r r rA r s zBaseServer.close_requestc C sH t dd tjd t d|tjd dd l}|j t dd tjd d S )N-( )filez4Exception happened during processing of request fromr )printsysstderr traceback print_exc)r r= r> rH r r r r; v s zBaseServer.handle_errorc C s | S )Nr )r r r r __enter__ s zBaseServer.__enter__c G s | j 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; rJ rL r r r r r s$ -
c @ sb e Zd ZejZejZdZdZ dddZ
dd Z dd Z d
d Z
d d
Zdd Zdd Zdd ZdS )r FTc C sT t j| || tj| j| j| _|rPy| j | j W n | j 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| jjtjtjd | jj| j | jj | _d S )N )allow_reuse_addressr0
setsockoptZ
SOL_SOCKETZ SO_REUSEADDRZbindr Z getsockname)r r r r rS s zTCPServer.server_bindc C s | j j| j d S )N)r0 Zlistenrequest_queue_size)r r r r r s zTCPServer.server_activatec C s | j j d S )N)r0 close)r r r r r@ s zTCPServer.server_closec C s
| j j S )N)r0 fileno)r r r r rY s zTCPServer.filenoc C s
| j j S )N)r0 Zaccept)r r r r r6 s zTCPServer.get_requestc C s4 y|j tj W n tk
r$ Y nX | j| d S )N)r/ r0 ZSHUT_WRr7 rA )r r= r r r r< s
zTCPServer.shutdown_requestc C s |j d S )N)rX )r r= r r r rA s zTCPServer.close_requestN)T)rM rN rO r0 ZAF_INETrQ Z SOCK_STREAMrR rW rU r rS r r@ rY 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\}}|| j f|fS )N)r0 Zrecvfrommax_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 | j | 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) rM rN rO rU r0 Z
SOCK_DGRAMrR rZ r6 r r< rA r r r r r s c sR e Zd ZdZdZdZdZddddZdd Zd
d Z d d
Z
fddZ Z S )r i, NrC F)blockingc C s | j d krd S xht| j | jkrvy tjdd\}}| j j| W q tk
r^ | j j Y q tk
rr P Y qX qW xt| j j D ]f}y.|rdntj
}tj||\}}| j j| W q tk
r | j j| Y q tk
r Y qX qW d S )NrT r ) active_childrenlen max_childrenoswaitpiddiscardChildProcessErrorr" r7 copyWNOHANG)r r\ pid_flagsr r r collect_children, s&
z ForkingMixIn.collect_childrenc C s | j d S )N)rj )r r r r r4 O s zForkingMixIn.handle_timeoutc C s | j d S )N)rj )r r r r r) V s z ForkingMixIn.service_actionsc C s t j }|r8| jd kr t | _| jj| | j| d S d}z:y| j|| d}W n tk
rr | j|| Y nX W d z| j | W d t j
| X X d S )NrT r ) ra r
r^ r* addrA r? r: r; r< _exit)r r= r> rg Zstatusr r r r9 ] s
z ForkingMixIn.process_requestc s t j | j| jd d S )N)r\ )superr@ rj _block_on_close)r ) __class__r r r@ v s
zForkingMixIn.server_close)
rM rN rO r1 r^ r` rn rj r4 r) r9 r@
__classcell__r r )ro r r # s #c s8 e Zd ZdZdZdZdd Zdd Z fddZ Z S ) r FNc C sH z6y| j || W n tk
r2 | j|| Y nX W d | j| X d S )N)r? r: r; r< )r r= r> r r r process_request_thread s
z%ThreadingMixIn.process_request_threadc C sR t j| j||fd}| j|_|j rF| jrF| jd kr:g | _| jj| |j d S )N)targetrK ) r ZThreadrq daemon_threadsZdaemonrn _threadsappendstart)r r= r> tr r r r9 s
z ThreadingMixIn.process_requestc s: t j | jr6| j}d | _|r6x|D ] }|j q&W d S )N)rm r@ rn rt join)r ZthreadsZthread)ro r r r@ s
zThreadingMixIn.server_close)
rM rN rO rs rn rt rq r9 r@ rp r r )ro r r { s
c @ s e Zd ZdS )r N)rM rN rO r r r r r s c @ s e Zd ZdS )r N)rM rN rO r r r r r s c @ s e Zd ZdS )r N)rM rN rO r r r r r s c @ s e Zd ZdS )r N)rM rN rO r r r r r s c @ s e Zd ZejZdS )r N)rM rN rO r0 r rQ r r r r r s c @ s e Zd ZejZdS )r N)rM rN rO r0 r rQ r r r r r s c @ s e Zd ZdS )r N)rM rN rO r r r r r s c @ s e Zd ZdS )r N)rM rN rO r r r r r s c @ s, e Zd Zdd Zdd Zdd Zdd Zd S )
r c
C s6 || _ || _|| _| j z | j W d | j X d S )N)r= r> serversetuphandlefinish)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)rM rN rO r rz r{ r| r r r r r s
c @ s, e Zd Zd ZdZdZdZdd Zdd ZdS )
r
rT r NFc C sz | j | _| jd k r | jj| j | jr:| jjtjtjd | jj d| j
| _ | j dkrdt
| j| _n| jj d| j | _d S )NTrbr wb)r= Z
connectionr1 Z
settimeoutdisable_nagle_algorithmrV r0 Z IPPROTO_TCPZ TCP_NODELAYmakefilerbufsizerfilewbufsize
_SocketWriterwfile)r r r r rz s
zStreamRequestHandler.setupc C sF | j js.y| j j W n tjk
r, Y nX | j j | jj d S )N)r closedflushr0 errorrX r )r r r r r| s
zStreamRequestHandler.finishr] ) rM rN rO 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 j| t|}|jS Q R X d S )N)r Zsendall
memoryviewnbytes)r bZviewr r r write" s
z_SocketWriter.writec C s
| j j S )N)r rY )r r r r rY ' s z_SocketWriter.filenoN)rM rN rO r r r rY 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| jj | j d S )N)r0 Zsendtor getvaluer> )r r r r r| 4 s z DatagramRequestHandler.finishN)rM rN rO rz r| r r r r r * s )$ __version__r0 r% ra errnorF r ImportErrorZdummy_threadingr r r3 r __all__hasattrextendr r# ZSelectSelectorr r r r r r r r r r r r r r r
r r r r r r