/opt/alt/python37/lib64/python3.7/__pycache__/socketserver.cpython-37.pyc (24197B)
r r r r8 M s zBaseServer.verify_requestc C s | ||¡ | |¡ dS )zVCall finish_request.
Overridden by ForkingMixIn and ThreadingMixIn.
N)Úfinish_requestr< )r r= r> r r r r9 U s zBaseServer.process_requestc C s dS )zDCalled to clean-up the server.
May be overridden.
Nr )r r r r Ú server_close^ s zBaseServer.server_closec C s | ||| ¡ dS )z8Finish one request by instantiating RequestHandlerClass.N)r )r r= r> r r r r? f s zBaseServer.finish_requestc C s | |¡ dS )z3Called to shutdown and close an individual request.N)Ú
close_request)r r= r r r r< j s zBaseServer.shutdown_requestc C s dS )z)Called to clean up an individual request.Nr )r r= r r r rA n s zBaseServer.close_requestc C s@ t dtjd t d|tjd ddl}| ¡ t dtjd dS )ztHandle an error gracefully. May be overridden.
The default is to print a traceback and continue.
z(----------------------------------------)Úfilez4Exception happened during processing of request fromr N)Ú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__Ú__doc__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 @ sf e Zd ZdZejZejZdZ dZ
ddd„Z 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 | ||¡ t | j| j¡| _|rPy| ¡ | ¡ W n | ¡ ‚ 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| j tjtjd¡ | j | j¡ | j ¡ | _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 rR Ê s zTCPServer.server_bindc C s | j | j¡ dS )zSCalled by constructor to activate the server.
May be overridden.
N)r0 ZlistenÚrequest_queue_size)r r r r r Õ s zTCPServer.server_activatec C s | 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 ¡ S )zMReturn socket file number.
Interface required by selector.
)r0 Úfileno)r r r r rX å s zTCPServer.filenoc C s
| 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| tj¡ W n tk
r$ Y nX | |¡ 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 | ¡ dS )z)Called to clean up an individual request.N)rW )r r= r r r rA ÿ s zTCPServer.close_requestN)T)rK rL rM rN r0 ZAF_INETrP Z SOCK_STREAMrQ rV rT r rR r r@ rX 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 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 rN rT r0 Z
SOCK_DGRAMrQ rY r6 r r< rA r r r r r s c sV e Zd ZdZdZdZdZdZddœdd „Zd
d „ Z d d
„ Z
dd„ Z ‡ fdd„Z ‡ Z
S )r z5Mix-in class to handle each request in a new process.i, Né( TF)Úblockingc C sò | j dkrdS 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 dS )z7Internal routine to wait for children that have exited.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 | ¡ dS )zvWait for zombies after self.timeout seconds of inactivity.
May be extended, do not override.
N)rj )r r r r r4 K s zForkingMixIn.handle_timeoutc C s | ¡ dS )zCollect the zombie child processes regularly in the ForkingMixIn.
service_actions is called in the BaseServer's serve_forever loop.
N)rj )r r r r r) R s z ForkingMixIn.service_actionsc C sš t ¡ }|r8| jdkr tƒ | _| j |¡ | |¡ dS d}z:y| ||¡ d}W n tk
rr | ||¡ Y nX W dz| |¡ W dt
|¡ X X dS )z-Fork a new subprocess to process the request.NrS r ) ra r
r^ r* ÚaddrA r? r: r; r< Ú_exit)r r= r> rg Zstatusr r r r9 Y s
z ForkingMixIn.process_requestc s t ƒ ¡ | j| jd d S )N)r\ )Úsuperr@ rj Úblock_on_close)r )Ú __class__r r r@ r s
zForkingMixIn.server_close)rK rL rM rN r1 r^ r` rn rj r4 r) r9 r@ Ú
__classcell__r r )ro r r s #c s< e Zd ZdZdZdZdZdd„ Zdd„ Z‡ fd d
„Z ‡ Z
S ) r z4Mix-in class to handle each request in a new thread.FTNc C sH z6y| ||¡ W n tk
r2 | ||¡ Y nX W d| |¡ 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 sP t j| j||fd}| j|_|jsD| jrD| jdkr8g | _| j |¡ | ¡ dS )z*Start a new thread to process the request.)ÚtargetrI N) 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 rN 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 rP r r r r r ® s c @ s e Zd ZejZdS )r N)rK rL rM r0 r rP 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 @ 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 || _ || _|| _| ¡ 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 rN r rz r{ r| r r r r r ¸ s
c @ s0 e Zd ZdZdZdZdZdZdd„ Zdd „ Z dS )
r
z4Define self.rfile and self.wfile for stream sockets.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_algorithmrU 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 ÚerrorrW r )r r r r r| s
zStreamRequestHandler.finish)
rK rL rM rN r€ r‚ r1 r rz r| r r r r r
æ s
c @ s0 e Zd ZdZdd„ Zdd„ Zdd„ Zdd „ Zd
S ) rƒ z‚Simple 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 |¡ 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ˆ rX )r r r r rX # s z_SocketWriter.filenoN)rK rL rM rN r r‰ r rX 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 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 rN rz r| r r r r r & s )"rN Ú __version__r0 r% ra 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 Ú