lib64
/
python3.9
/
__pycache__
➕ New
📤 Upload
✎ Editing:
socketserver.cpython-39.opt-2.pyc
← Back
a �DOg�j � @ s� d Z ddlZddlZddlZddlZddlZddlmZ ddlm Z g d�Z e ed�rde � g d�� e ed�r|e � g d �� e ed �r�ej ZnejZG d d � d �ZG d d� de�ZG dd� de�Ze ed�r�G dd� d�ZG dd� de�ZG dd� d�ZG dd� d�Ze ed��r6G 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 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 �$/usr/lib64/python3.9/socketserver.py�__init__� s zBaseServer.__init__c C s d S �Nr �r r r r �server_activate� s zBaseServer.server_activate� �?c C s� | j �� zvt� �L}|�| tj� | jsP|�|�}| jr:qP|rF| �� | � � q"W d � n1 sd0 Y W d| _| j � � nd| _| j � � 0 d S 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 s d S r" r r# r r r r- � s zBaseServer.service_actionsc C s� | j �� }|d u r| j}n| jd ur0t|| j�}|d urBt� | }t� �t}|�| tj� |� |�}|r|| � � W d � S |d urX|t� }|dk rX| � � W d � S qXW d � n1 s�0 Y 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 ty$ Y d S 0 | �||�r�z| �||� W q� tyj | �||� | �|� Y q� | �|� � Y q�0 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 occurred 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$ - r 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 n0 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 s2 z|� tj� W n ty" Y n0 | �|� 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 / r 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 r 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 u rd S t| j �| jkrrz t�dd�\}}| j �|� W q tyZ | j �� Y q tyn Y qrY q0 q| j � � D ]b}z.|r�dntj }t�||�\}}| j �|� W q| ty� | j �|� Y q| ty� Y q|0 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 u r t� | _| j�|� | �|� d S d}z^z| �||� d}W n typ | �||� Y n0 W z| � |� W t � |� q�t � |� 0 n(z| � |� W t � |� n t � |� 0 0 d S )Nr\ r ) rv r rs r. �addrJ rG rA rB rC �_exit)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 #r c s4 e Zd Z� fdd�Zdd� Zdd� Zdd� Z� ZS ) �_Threadsc s" | � � |jrd 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>� � z _Threads.reap.<locals>.<genexpr>r r# r r r r� � s z _Threads.reap)rU rV rW r� r� r� r� r� r r r� r r� w s r� c @ s e Zd Zdd� Zdd� ZdS )� _NoThreadsc C s d S r" r r� r r r r� � s z_NoThreads.appendc C s d S r" r r# r r r r� � s z_NoThreads.joinN)rU rV rW r� r� r r r r r� � s r� c s: e Zd ZdZdZe� Zdd� Zdd� Z� fdd�Z � Z S ) r FTc C sP z>z| � ||� W n ty0 | �||� Y n0 W | �|� n | �|� 0 d S r" )rG rA rB rC rD r r r �process_request_thread� s z%ThreadingMixIn.process_request_threadc C sL | j rt| ��dt� � tj| j||fd�}| j|_| j � |� |� � d S )N�_threads)�targetrS ) r� �vars� setdefaultr� r �Threadr� �daemon_threadsr� r� r� �start)r rE rF �tr r r r@ � s � z ThreadingMixIn.process_requestc s t � �� | j�� d S r" )r� rH r� r� r# r� r r rH � s zThreadingMixIn.server_close) rU rV rW r� r� r� r� r� r@ rH r� r r r� r r � s r c @ s e Zd ZdS )r N�rU rV rW r r r r r � r� r c @ s e Zd ZdS )r Nr� r r r r r � r� r c @ s e Zd ZdS )r Nr� r r r r r � r� r c @ s e Zd ZdS )r Nr� r r r r r � r� r c @ s e Zd ZejZdS )r N�rU rV rW r5 r rY r r r r r � s r c @ s e Zd ZejZdS )r Nr� r r r r r � s r c @ s e Zd ZdS )r Nr� r r r r r � r� r c @ s e Zd ZdS )r Nr� r r r r r � r� r c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) r c C s> || _ || _|| _| �� z| �� W | �� n | �� 0 d S r" )rE rF �server�setup�handle�finish)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 r c @ s, e Zd ZdZdZdZdZdd� Zdd� ZdS ) r rr r NFc C sz | j | _| jd ur | 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 sD | j js,z| j �� W n tjy* Y n0 | 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 r c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) r� c C s || _ d S r" )�_sock)r �sockr r r r! 3 s z_SocketWriter.__init__c C s dS r2 r r# r r r �writable6 s z_SocketWriter.writablec C s> | j �|� t|��}|jW d � S 1 s00 Y d S r" )r� �sendall� memoryview�nbytes)r �b�viewr r r �write9 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� E s z DatagramRequestHandler.setupc C s | j �| j�� | j� d S r" )r5 �sendtor� �getvaluerF r# r r r r� K s z DatagramRequestHandler.finishN)rU rV rW r� r� r r r r r A s r )$� __version__r5 r) rv rN r r� r r9 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>{ sL n~ X ( .-
💾 Save Changes
Cancel
📤 Upload File
×
Select File
Upload
Cancel
➕ Create New
×
Type
📄 File
📁 Folder
Name
Create
Cancel
✎ Rename Item
×
Current Name
New Name
Rename
Cancel
🔐 Change Permissions
×
Target File
Permission (e.g., 0755, 0644)
0755
0644
0777
Apply
Cancel