File: //proc/thread-self/root/usr/local/lib/python3.10/__pycache__/socketserver.cpython-310.opt-2.pyc
o
�i�j � @ s� d Z ddlZddlZddlZddlZddlZddlmZ ddlm Z g d�Z
e ed�r3e
� g d�� e ed�r?e
� g d �� e ed
�rHej
ZnejZG d d � d �ZG d
d� de�ZG dd� de�Ze ed�rnG dd� d�ZG dd� de�ZG dd� d�ZG dd� d�Ze ed�r�G dd� dee�ZG dd � d ee�ZG d d � d ee�ZG d d � d ee�Ze ed�r�G d!d"� d"e�Z G d#d$� d$e�Z G d%d&� d&ee �Z G d'd(� d(ee �Z G d)d*� d*�Z G d+d,� d,e �Z!G d-d.� d.e�Z"G d/d0� d0e �Z#dS )1z0.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 Z dZdd� 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� threading�Event�_BaseServer__is_shut_down� _BaseServer__shutdown_request)�selfr r � r �)/usr/local/lib/python3.10/socketserver.py�__init__� s
zBaseServer.__init__c C � d S �Nr �r r r r �server_activate� � zBaseServer.server_activate� �?c C s� | j �� zIt� �(}|�| tj� | js+|�|�}| jr n
|r$| �� | � � | jrW d � n1 s5w Y W d| _| j �
� d S W d| _| j �
� d S d| _| j �
� w r ) r �clear�_ServerSelector�register� selectors�
EVENT_READr �select�_handle_request_noblock�service_actions�set)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 r" r# r r$ r r r r/ � r& zBaseServer.service_actionsc C s� | j �� }|d u r| j}n | jd urt|| j�}|d ur"t� | }t� �4}|�| tj� |� |�}|r@| �
� W d � S |d urX|t� }|dk rX| � � W d � S q.1 s\w Y d S )NTr ) �socket�
gettimeout�timeout�min�timer) r* r+ r, r- r. �handle_timeout)r r9 �deadliner1 r2 r r r �handle_request s,
�
��zBaseServer.handle_requestc C s� z| � � \}}W n
ty Y d S w | �||�rAz | �||� W d S ty8 | �||� | �|� Y d S | �|� � | �|� 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 r" r# r r$ r r r r< F s zBaseServer.handle_timeoutc C s dS r4 r rF r r r rA M r& zBaseServer.verify_requestc C s | � ||� | �|� d S r# )�finish_requestrE rF r r r rB U s zBaseServer.process_requestc C r" r# r r$ r r r � server_close^ r& zBaseServer.server_closec C s | � ||| � d S r# )r rF r r r rI f s zBaseServer.finish_requestc C s | � |� d S r# ��
close_request�r rG r r r rE j s zBaseServer.shutdown_requestc C r" r# r rM r r r rL n s zBaseServer.close_requestc C sB t dtjd� t d|tjd� dd l}|�� t dtjd� d S )Nz(----------------------------------------)�filez4Exception occurred during processing of request fromr )�print�sys�stderr� traceback� print_exc)r rG rH rR r r r rD r s �zBaseServer.handle_errorc C s | S r# r r$ r r r � __enter__ � zBaseServer.__enter__c G s | � � d S r# )rJ )r �argsr r r �__exit__� s zBaseServer.__exit__)r' )�__name__�
__module__� __qualname__r9 r! r% r3 r6 r/ r> r. r< rA rB rJ rI rE rL rD rT rW r r r r r � s( +
r c @ sd e Zd Z ejZejZdZdZ ddd�Z
dd� Z dd � Z d
d � Z
d d
� Zdd� Zdd� Zdd� ZdS )r � FTc C sR t �| ||� t�| j| j�| _|r'z | �� | �� W d S | �� � d S r# )r r! r7 �address_family� socket_type� server_bindr% rJ )r r r Zbind_and_activater r r r! � s ��zTCPServer.__init__c C s: | j r| j�tjtjd� | j�| j� | j�� | _d S )N� )�allow_reuse_addressr7 �
setsockopt�
SOL_SOCKET� SO_REUSEADDR�bindr � getsocknamer$ r r r r^ � s
zTCPServer.server_bindc C s | j �| j� d S r# )r7 �listen�request_queue_sizer$ r r r r% � s zTCPServer.server_activatec C s | j �� d S r# )r7 �closer$ r r r rJ � s zTCPServer.server_closec C � | j �� S r# )r7 �filenor$ r r r rj � �
zTCPServer.filenoc C ri r# )r7 �acceptr$ r r r r? � rk zTCPServer.get_requestc C s4 z|� tj� W n ty Y nw | �|� d S r# )r6 r7 �SHUT_WRr@ rL rM r r r rE � s �zTCPServer.shutdown_requestc C s |� � d S r# )rh rM r r r rL � s zTCPServer.close_requestN)T)rX rY rZ r7 �AF_INETr\ � SOCK_STREAMr] rg r` r! r^ r% rJ rj r? rE rL r r r r r � s -
r c @ s< e Zd Z dZejZdZdd� Zdd� Z dd� Z
d d
� Z d S ) r Fi c C s | j �| j�\}}|| j f|fS r# )r7 �recvfrom�max_packet_size)r �dataZ client_addrr r r r? s zUDPServer.get_requestc C � d S r# r r$ r r r r% � zUDPServer.server_activatec C s | � |� d S r# rK rM r r r rE s zUDPServer.shutdown_requestc C rs r# r rM r r r rL rt zUDPServer.close_requestN) rX rY rZ r` r7 �
SOCK_DGRAMr] rq r? r% rE rL r r r r r s r c sT e Zd Z dZdZdZdZdd�dd�Zd d
� Zd d � Z d
d� Z
� fdd�Z � Z S )r i, N�( TF��blockingc C s� | j d u rd S t| j �| jkr?zt�dd�\}}| j �|� W n ty. | j �� Y n ty6 Y n w t| j �| jks| j � � D ]0}z|rKdntj
}t�||�\}}| j �|� W qD tyl | j �|� Y qD tyt Y qDw d S )N���r ) �active_children�len� max_children�os�waitpid�discard�ChildProcessErrorr( r@ �copy�WNOHANG)r rx �pid�_�flagsr r r �collect_children( s0
�� ��z ForkingMixIn.collect_childrenc C � | � � d S r# �r� r$ r r r r< K � zForkingMixIn.handle_timeoutc C r� r# r� r$ r r r r/ R r� z ForkingMixIn.service_actionsc C s� t �� }|r | jd u rt� | _| j�|� | �|� d S d}z/z
| �||� d}W n ty9 | �||� Y nw W z
| � |� W t �
|� d S t �
|� w z | � |� W t �
|� w t �
|� w )Nr_ r ) r} r
rz r0 �addrL rI rC rD rE �_exit)r rG rH r� �statusr r r rB Y s,
�� � z ForkingMixIn.process_requestc s t � �� | j| jd� d S )Nrw )�superrJ r� �block_on_closer$ �� __class__r r rJ r s
zForkingMixIn.server_close)
rX rY rZ r9 rz r| r� r� r< r/ rB rJ �
__classcell__r r r� r r s #r c s6 e Zd Z � fdd�Zdd� Zdd� Zdd� Z� ZS ) �_Threadsc s" | � � |jr d S t� �|� d S r# )�reap�daemonr� �append�r �threadr� 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# )�is_alive)�.0r� r r r � <genexpr>� s � z _Threads.reap.<locals>.<genexpr>r r$ r r r r� � � z
_Threads.reap)rX rY rZ r� r� r� r� r� r r r� r r� w s r� c @ � e Zd Z dd� Zdd� ZdS )�
_NoThreadsc C rs r# r r� r r r r� � rU z_NoThreads.appendc C rs r# r r$ r r r r� � rU z_NoThreads.joinN)rX rY rZ r� r� r r r r r� � s r� c s< e Zd Z dZdZe� Zdd� Zdd� Z� fdd�Z � Z
S ) r FTc C s` z(z| � ||� W n ty | �||� Y n w W | �|� d S W | �|� d S | �|� w r# )rI rC rD rE rF r r r �process_request_thread� s ���z%ThreadingMixIn.process_request_threadc C sN | j r
t| ��dt� � tj| j||fd�}| j|_| j �
|� |� � d S )N�_threads)�targetrV ) r� �vars�
setdefaultr� r �Threadr� �daemon_threadsr� r� r� �start)r rG rH �tr r r rB � s � z ThreadingMixIn.process_requestc s t � �� | j�� d S r# )r� rJ r� r� r$ r� r r rJ � s
zThreadingMixIn.server_close) rX rY rZ r� r� r� r� r� rB rJ r� r r r� r r � s
r c @ � e Zd ZdS )r N�rX rY rZ r r r r r � � r c @ r� )r Nr� r r r r r � r� r c @ r� )r Nr� r r r r r � r� r c @ r� )r Nr� r r r r r � r� r c @ � e Zd ZejZdS )r N�rX rY rZ r7 r r\ r r r r r � �
r c @ r� )r Nr� r r r r r � r� r c @ r� )r Nr� r r r r r � r� r c @ r� )r Nr� r r r r r � r� r c @ �. e Zd Z dd� Zdd� Zdd� Zdd� Zd S )
r c C s< || _ || _|| _| �� z | �� W | �� d S | �� w r# )rG rH �server�setup�handle�finish)r rG rH r� r r r r! � s
zBaseRequestHandler.__init__c C rs r# r r$ r r r r� � rU zBaseRequestHandler.setupc C rs r# r r$ r r r r� � rU zBaseRequestHandler.handlec C rs r# r r$ r r r r� � rU zBaseRequestHandler.finishN)rX rY rZ r! r� r� r� r r r r r � s
r c @ s. e Zd Z dZdZdZdZdd� Zdd� ZdS ) r
ry r NFc C s| | j | _| jd ur| j�| j� | jr | j�tjtjd� | j� d| j
�| _ | j dkr3t
| j�| _d S | j� d| j �| _d S )NT�rbr �wb)rG �
connectionr9 �
settimeout�disable_nagle_algorithmra r7 � IPPROTO_TCP� TCP_NODELAY�makefile�rbufsize�rfile�wbufsize�
_SocketWriter�wfiler$ r r r r� s
�
zStreamRequestHandler.setupc C sD | j jsz| j �� W n
tjy Y nw | j �� | j�� d S r# )r� �closed�flushr7 �errorrh r� r$ r r r r� # s �
zStreamRequestHandler.finish) rX rY rZ r� r� r9 r� r� r� r r r r r
s
r
c @ r� )
r� c C s
|| _ d S r# )�_sock)r �sockr r r r! 3 �
z_SocketWriter.__init__c C s dS r4 r r$ r r r �writable6 rU z_SocketWriter.writablec C s> | j �|� t|�� }|jW d � S 1 sw Y d S r# )r� �sendall�
memoryview�nbytes)r �b�viewr r r �write9 s
$�z_SocketWriter.writec C s
| j �� S r# )r� rj r$ r r r rj > r� z_SocketWriter.filenoN)rX rY rZ r! r� r� rj r r r r r� . s r� c @ r� )r c C s2 ddl m} | j\| _| _|| j�| _|� | _d S )Nr )�BytesIO)�ior� rG Zpacketr7 r� r� )r r� r r r r� E s z DatagramRequestHandler.setupc C s | j �| j�� | j� d S r# )r7 �sendtor� �getvaluerH r$ r r r r� K r� z DatagramRequestHandler.finishN)rX rY rZ r� r� r r r r r A s r )$� __version__r7 r+ r} rP r r� r r; r �__all__�hasattr�extendr r) �SelectSelectorr r r r �listr� r� r r r r r r r r r r r
r� r r r r r �<module> sP z
n~
X
(
.-