|
Server : Apache System : Linux 182.49.167.72.host.secureserver.net 4.18.0-553.92.1.el8_10.x86_64 #1 SMP Wed Jan 14 06:31:58 EST 2026 x86_64 User : kikai ( 1014) PHP Version : 8.3.30 Disable Function : NONE Directory : /proc/self/root/opt/python38/lib/python3.8/__pycache__/ |
Upload File : |
U
�i�_+i � @ s� d Z ddlZddlZddlZddlZddlZddlmZ ddlm Z ddddd d
d d d
g Z
e ed�rte
� dddg� e ed�r�e
� ddddg� e ed�r�ej
ZnejZG dd� d�ZG dd� de�ZG dd� de�Ze ed�r�G dd� d�ZG d d
� d
�Ze ed��r,G d d� dee�ZG d d� dee�ZG d d� dee�ZG d d � d ee�Ze ed��r�G d!d� de�ZG d"d� de�ZG d#d� dee�ZG d$d� dee�Z G d%d
� d
�Z G d&d � d e �Z G d'd(� d(e�Z G d)d � d e �Z dS )*z0.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 ZdZdd� 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 �+/opt/python38/lib/python3.8/socketserver.py�__init__� s
zBaseServer.__init__c C s d S �Nr �r r r r �server_activate� s zBaseServer.server_activate� �?c C st | j �� zRt� �B}|�| tj� | jsP|�|�}| jr:qP|rF| � � | �
� q"W 5 Q R X W 5 d| _| j �� X d S r ) r �clearr �set�_ServerSelector�register� selectors�
EVENT_READ�select�_handle_request_noblock�service_actions)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 s d S r" r r# r r r r. � s zBaseServer.service_actionsc
C s� | j �� }|d kr| j}n| jd k r0t|| j�}|d k rBt� | }t� �f}|�| tj� |� |�}|rz| �
� W 5 Q R � S |d k rX|t� }|dk rX| � � W 5 Q R � S qXW 5 Q R X d S )Nr ) �socket�
gettimeout�timeout�min�timer( r) r* r+ r, r- �handle_timeout)r r7 �deadliner/ r0 r r r �handle_request s
zBaseServer.handle_requestc C s� z| � � \}}W n tk
r& Y d S X | �||�r�z| �||� W q� tk
rn | �||� | �|� Y q� | �|� � Y q�X n
| �|� 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 s d S r" r r# r r r r: F s zBaseServer.handle_timeoutc C s dS r2 r rD r r r r? M s zBaseServer.verify_requestc C s | � ||� | �|� d S r" )�finish_requestrC rD r r r r@ U s zBaseServer.process_requestc C s d S r" r r# r r r � server_close^ s zBaseServer.server_closec C s | � ||| � d S r" )r rD r r r rG f s zBaseServer.finish_requestc C s | � |� d S r" ��
close_request�r rE r r r rC j s zBaseServer.shutdown_requestc C s d S r" r rK r r r rJ 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 rE rF rP r r r rB r s �zBaseServer.handle_errorc C s | S r" r r# r r r � __enter__ s zBaseServer.__enter__c G s | � � d S r" )rH )r �argsr r r �__exit__� s zBaseServer.__exit__)r% )�__name__�
__module__� __qualname__r7 r! r$ r1 r4 r. r< r- r: r? r@ rH rG rC rJ rB rR rT 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�| _|rPz| �� | �� W n | �� � Y nX d S r" )r r! r5 �address_family� socket_type� server_bindr$ rH )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_addressr5 �
setsockopt�
SOL_SOCKET� SO_REUSEADDR�bindr � getsocknamer# r r r r[ � s zTCPServer.server_bindc C s | j �| j� d S r" )r5 �listen�request_queue_sizer# r r r r$ � s zTCPServer.server_activatec C s | j �� d S r" )r5 �closer# r r r rH � s zTCPServer.server_closec C s
| j �� S r" )r5 �filenor# r r r rf � s zTCPServer.filenoc C s
| j �� S r" )r5 �acceptr# r r r r= � s zTCPServer.get_requestc C s4 z|� tj� W n tk
r$ Y nX | �|� d S r" )r4 r5 �SHUT_WRr> rJ rK r r r rC � s
zTCPServer.shutdown_requestc C s |� � d S r" )re rK r r r rJ � s zTCPServer.close_requestN)T)rU rV rW r5 �AF_INETrY � SOCK_STREAMrZ rd r] r! r[ r$ rH rf r= rC rJ 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 r" )r5 �recvfrom�max_packet_size)r �dataZ client_addrr r r r= s zUDPServer.get_requestc C s d S r" r r# r r r r$ s zUDPServer.server_activatec C s | � |� d S r" rI rK r r r rC s zUDPServer.shutdown_requestc C s d S r" r rK r r r rJ s zUDPServer.close_requestN) rU rV rW r] r5 �
SOCK_DGRAMrZ rl r= r$ rC rJ 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 t| j �| jkrvz t�dd�\}}| j �|� W q tk
r\ | j �� Y q tk
rr Y qvY qX q| j � � D ]f}z.|r�dntj
}t�||�\}}| j �|� W q� tk
r� | j �|� Y q� tk
r� Y q�X q�d S )N���r ) �active_children�len� max_children�os�waitpid�discard�ChildProcessErrorr& r> �copy�WNOHANG)r rq �pid�_�flagsr r r �collect_children( s&
z ForkingMixIn.collect_childrenc C s | � � d S r" �r r# r r r r: K s zForkingMixIn.handle_timeoutc C s | � � d S r" r� r# r r r r. R s z ForkingMixIn.service_actionsc C s� t �� }|r8| jd kr t� | _| j�|� | �|� d S d}z:z| �||� d}W n t k
rr | �
||� Y nX W 5 z| �|� W 5 t �|� X X d S )Nr\ r ) rv r
rs r' �addrJ �_exitrC rG rA rB )r rE rF r| �statusr r r r@ Y s
z ForkingMixIn.process_requestc s t � �� | j| jd� d S )Nrp )�superrH r �block_on_closer# �� __class__r r rH r s
zForkingMixIn.server_close)
rU rV rW r7 rs ru r� r r: r. r@ rH �
__classcell__r r r� r r s #c s8 e Zd ZdZdZdZdd� Zdd� Z� fdd �Z� Z S )
r FTNc C sH z6z| �||� W n tk
r2 | �||� Y nX W 5 | � |� X d S r" )rC rG rA rB rD 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)�targetrS ) r �Threadr� �daemon_threads�daemonr� �_threads�append�start)r rE rF �tr r r r@ � s �
z ThreadingMixIn.process_requestc s6 t � �� | jr2| j}d | _|r2|D ] }|�� q$d S r" )r� rH r� r� �join)r �threads�threadr� r r rH � s
zThreadingMixIn.server_close)
rU rV rW r� r� r� r� r@ rH r� r r r� r r w s
c @ s e Zd ZdS )r N�rU rV rW r r r r r � s c @ s e Zd ZdS )r Nr� r r r r r � s c @ s e Zd ZdS )r Nr� r r r r r � s c @ s e Zd ZdS )r Nr� r r r r r � s c @ s e Zd ZejZdS )r N�rU rV rW r5 r rY r r r r r � s c @ s e Zd ZejZdS )r Nr� r r r r r � s c @ s e Zd ZdS )r Nr� r r r r r � s c @ s e Zd ZdS )r Nr� r r r r r � s c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
r c C s6 || _ || _|| _| �� z | �� W 5 | �� X d S r" )rE rF �server�setup�finish�handle)r rE rF r� r r r r! � s zBaseRequestHandler.__init__c C s d S r" r r# r r r r� � s zBaseRequestHandler.setupc C s d S r" r r# r r r r� � s zBaseRequestHandler.handlec C s d S r" r r# r r r r� � s zBaseRequestHandler.finishN)rU rV rW r! r� r� r� r r r r r � s
c @ s, e Zd ZdZdZdZdZdd� Zdd� ZdS ) r
rr 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)rE �
connectionr7 �
settimeout�disable_nagle_algorithmr^ r5 � IPPROTO_TCP� TCP_NODELAY�makefile�rbufsize�rfile�wbufsize�
_SocketWriter�wfiler# r r r r� � s
�
zStreamRequestHandler.setupc C sF | j js.z| j �� W n tjk
r, Y nX | j �� | j�� d S r" )r� �closed�flushr5 �errorre r� r# r r r r� s
zStreamRequestHandler.finish) rU rV rW r� r� r7 r� r� r� r r r r r
� s
c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
r� c C s
|| _ d S r" )�_sock)r �sockr r r r! s z_SocketWriter.__init__c C s dS r2 r r# r r r �writable s z_SocketWriter.writablec
C s2 | j �|� t|��}|jW 5 Q R � S Q R X d S r" )r� �sendall�
memoryview�nbytes)r �b�viewr r r �write s
z_SocketWriter.writec C s
| j �� S r" )r� rf r# r r r rf # s z_SocketWriter.filenoN)rU rV rW r! r� r� rf 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� rE Zpacketr5 r� r� )r r� r r r r� * s z DatagramRequestHandler.setupc C s | j �| j�� | j� d S r" )r5 �sendtor� �getvaluerF r# r r r r� 0 s z DatagramRequestHandler.finishN)rU rV rW r� r� r r r r r & s )!� __version__r5 r* rv rN r r� r r9 r �__all__�hasattr�extendr r( �SelectSelectorr r r r r r r r r r r r r r r
r� r r r r r �<module>{ s\ �
�
n~
X. .-XYZEAZ - Cyber Alpha Wolf © All Rights Reserved