/opt/alt/python36/lib64/python3.6/__pycache__/socketserver.cpython-36.opt-1.pyc (24265B)
r r r r8 Q s zBaseServer.verify_requestc C s | j || | j| dS )zVCall finish_request.
Overridden by ForkingMixIn and ThreadingMixIn.
N)finish_requestr< )r r= r> r r r r9 Y s zBaseServer.process_requestc C s dS )zDCalled to clean-up the server.
May be overridden.
Nr )r r r r server_closeb s zBaseServer.server_closec C s | j ||| dS )z8Finish one request by instantiating RequestHandlerClass.N)r )r r= r> r r r r? j s zBaseServer.finish_requestc C s | j | dS )z3Called to shutdown and close an individual request.N)
close_request)r r= r r r r< n s zBaseServer.shutdown_requestc C s dS )z)Called to clean up an individual request.Nr )r r= r r r rA r s zBaseServer.close_requestc C sH t dd tjd t d|tjd ddl}|j t dd tjd dS )ztHandle an error gracefully. May be overridden.
The default is to print a traceback and continue.
-( )filez4Exception happened during processing of request fromr N)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____doc__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 @ sf e Zd ZdZejZejZdZ dZ
dddZ dd Z d d
Z
d d Zd
d Zdd Zdd Zdd ZdS )r a3 Base class for various socket-based server classes.
Defaults to synchronous IP stream (i.e., TCP).
Methods for the caller:
- __init__(server_address, RequestHandlerClass, bind_and_activate=True)
- serve_forever(poll_interval=0.5)
- shutdown()
- handle_request() # if you don't use serve_forever()
- fileno() -> int # for selector
Methods that may be overridden:
- server_bind()
- server_activate()
- get_request() -> request, client_address
- handle_timeout()
- verify_request(request, client_address)
- process_request(request, client_address)
- shutdown_request(request)
- close_request(request)
- handle_error()
Methods for derived classes:
- finish_request(request, client_address)
Class variables that may be overridden by derived classes or
instances:
- timeout
- address_family
- socket_type
- request_queue_size (only for stream sockets)
- allow_reuse_address
Instance variables:
- server_address
- RequestHandlerClass
- socket
FTc C sT t j| || tj| j| j| _|rPy| j | j W n | j Y nX dS )z/Constructor. May be extended, do not override.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 | _dS )zOCalled by constructor to bind the socket.
May be overridden.
N)allow_reuse_addressr0
setsockoptZ
SOL_SOCKETZ SO_REUSEADDRZbindr Z getsockname)r r r r rT s zTCPServer.server_bindc C s | j j| j dS )zSCalled by constructor to activate the server.
May be overridden.
N)r0 Zlistenrequest_queue_size)r r r r r s zTCPServer.server_activatec C s | j j dS )zDCalled to clean-up the server.
May be overridden.
N)r0 close)r r r r r@ s zTCPServer.server_closec C s
| j j S )zMReturn socket file number.
Interface required by selector.
)r0 fileno)r r r r rZ s zTCPServer.filenoc C s
| j j S )zYGet the request and client address from the socket.
May be overridden.
)r0 Zaccept)r r r r r6 s zTCPServer.get_requestc C s4 y|j tj W n tk
r$ Y nX | j| dS )z3Called to shutdown and close an individual request.N)r/ r0 ZSHUT_WRr7 rA )r r= r r r r< s
zTCPServer.shutdown_requestc C s |j dS )z)Called to clean up an individual request.N)rY )r r= r r r rA s zTCPServer.close_requestN)T)rM rN rO rP r0 ZAF_INETrR Z SOCK_STREAMrS rX rV r rT r r@ rZ r6 r< rA r r r r r s -
c @ s> e Zd ZdZdZejZdZdd Z dd Z
dd Z d
d Z d S )
r zUDP server class.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 rP rV r0 Z
SOCK_DGRAMrS r[ r6 r r< rA r r r r r s c sV e Zd ZdZdZdZdZdZddddZd d
Z d d Z
d
d Z fddZ Z
S )r z5Mix-in class to handle each request in a new process.i, NrC F)blockingc C s | j dkrdS 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 dS )z7Internal routine to wait for children that have exited.NrU r ) active_childrenlen max_childrenoswaitpiddiscardChildProcessErrorr" r7 copyWNOHANG)r r] pid_flagsr r r collect_children, s&
z ForkingMixIn.collect_childrenc C s | j dS )zvWait for zombies after self.timeout seconds of inactivity.
May be extended, do not override.
N)rk )r r r r r4 O s zForkingMixIn.handle_timeoutc C s | j dS )zCollect the zombie child processes regularly in the ForkingMixIn.
service_actions is called in the BaseServer's serve_forver loop.
N)rk )r r r r r) V s z ForkingMixIn.service_actionsc C s t j }|r8| jdkr t | _| jj| | j| dS d}z:y| j|| d}W n tk
rr | j|| Y nX W dz| j | W dt j
| X X dS )z-Fork a new subprocess to process the request.NrU r ) rb r
r_ r* addrA r? r: r; r< _exit)r r= r> rh Zstatusr r r r9 ] s
z ForkingMixIn.process_requestc s t j | j| jd d S )N)r] )superr@ rk _block_on_close)r ) __class__r r r@ v s
zForkingMixIn.server_close)rM rN rO rP r1 r_ ra ro rk r4 r) r9 r@
__classcell__r r )rp r r # s #c s< e Zd ZdZdZdZdZdd Zdd Z fdd Z Z
S )
r z4Mix-in class to handle each request in a new thread.FNc C sH z6y| j || W n tk
r2 | j|| Y nX W d| j| X dS )zgSame as in BaseServer but as a thread.
In addition, exception handling is done here.
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| jdkr:g | _| jj| |j dS )z*Start a new thread to process the request.)targetrK N) r ZThreadrr daemon_threadsZdaemonro _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)rn r@ ro ru join)r ZthreadsZthread)rp r r r@ s
zThreadingMixIn.server_close) rM rN rO rP rt ro ru rr r9 r@ rq r r )rp 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 rR r r r r r s c @ s e Zd ZejZdS )r N)rM rN rO r0 r rR 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 @ s0 e Zd ZdZdd Zdd Zdd Zdd Zd
S ) r a Base class for request handler classes.
This class is instantiated for each request to be handled. The
constructor sets the instance variables request, client_address
and server, and then calls the handle() method. To implement a
specific service, all you need to do is to derive a class which
defines a handle() method.
The handle() method can find the request as self.request, the
client address as self.client_address, and the server (in case it
needs access to per-server information) as self.server. Since a
separate instance is created for each request, the handle() method
can define other arbitrary instance variables.
c
C s6 || _ || _|| _| j z | j W d | j X d S )N)r= r> serversetuphandlefinish)r r= r> rz r r r r s zBaseRequestHandler.__init__c C s d S )Nr )r r r r r{ 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 rP r r{ r| r} r r r r r s
c @ s0 e Zd ZdZd
ZdZdZdZdd Zdd Z dS ) r
z4Define self.rfile and self.wfile for stream sockets.rU 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_algorithmrW r0 Z IPPROTO_TCPZ TCP_NODELAYmakefilerbufsizerfilewbufsize
_SocketWriterwfile)r r r r r{ s
zStreamRequestHandler.setupc C sF | j js.y| j j W n tjk
r, Y nX | j j | jj d S )N)r closedflushr0 errorrY r )r r r r r} s
zStreamRequestHandler.finishr^ )
rM rN rO rP r r r1 r r{ r} r r r r r
s
c @ s0 e Zd ZdZdd Zdd Zdd Zdd Zd
S ) r zSimple writable BufferedIOBase implementation for a socket
Does not hold data in a buffer, avoiding any need to call flush().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 rZ )r r r r rZ ' s z_SocketWriter.filenoN)rM rN rO rP r r r rZ r r r r r s
r c @ s e Zd ZdZdd Zdd ZdS )r z6Define self.rfile and self.wfile for datagram sockets.c C s2 ddl m} | j\| _| _|| j| _| | _d S )Nr )BytesIO)ior r= Zpacketr0 r r )r r r r r r{ . 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 rP r{ r} r r r r r * s )%rP __version__r0 r% rb 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