← Back
Editing: socketserver.cpython-38.opt-2.pyc
U e5d�j � @ 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 e�ZG d d � d �ZG d d � d �Ze ed��rJG d!d� dee�ZG d"d� dee�ZG d#d� dee�ZG d$d � d ee�Ze ed��r�G d%d� de�Z G d&d� de�Z G d'd� dee �Z G 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� threadingZEvent�_BaseServer__is_shut_down� _BaseServer__shutdown_request)�selfr r � r �$/usr/lib64/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 ) �socketZ gettimeout�timeout�min�timer' r( r) r* r+ r, �handle_timeout)r r5 Zdeadliner. r/ 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 r8 F s zBaseServer.handle_timeoutc C s dS r1 r rA r r r r< M s zBaseServer.verify_requestc C s | � ||� | �|� d S r! )�finish_requestr@ rA 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 rA r r r rD f s zBaseServer.finish_requestc C s | � |� d S r! �� close_request�r rB r r r r@ j s zBaseServer.shutdown_requestc C s d S r! r rH r r r rG 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 rB rC rM r r r r? r s �zBaseServer.handle_errorc C s | S r! r r" r r r � __enter__ s zBaseServer.__enter__c G s | � � d S r! )rE )r �argsr r r �__exit__� s zBaseServer.__exit__)r$ )�__name__� __module__� __qualname__r5 r r# r0 r3 r- r9 r, r8 r< r= rE rD r@ rG r? rO rQ 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 r4 �address_family� socket_type� server_bindr# rE )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_addressr4 � setsockoptZ SOL_SOCKETZ SO_REUSEADDRZbindr Z getsocknamer" r r r rX � s zTCPServer.server_bindc C s | j �| j� d S r! )r4 Zlisten�request_queue_sizer" r r r r# � s zTCPServer.server_activatec C s | j �� d S r! )r4 �closer" r r r rE � s zTCPServer.server_closec C s | j �� S r! )r4 �filenor" r r r r^ � s zTCPServer.filenoc C s | j �� S r! )r4 Zacceptr" r r r r: � s zTCPServer.get_requestc C s4 z|� tj� W n tk r$ Y nX | �|� d S r! )r3 r4 ZSHUT_WRr; rG rH r r r r@ � s zTCPServer.shutdown_requestc C s |� � d S r! )r] rH r r r rG � s zTCPServer.close_requestN)T)rR rS rT r4 ZAF_INETrV Z SOCK_STREAMrW r\ rZ r rX r# rE r^ r: r@ rG 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! )r4 Zrecvfrom�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! rF rH r r r r@ s zUDPServer.shutdown_requestc C s d S r! r rH r r r rG s zUDPServer.close_requestN) rR rS rT rZ r4 Z SOCK_DGRAMrW r_ r: r# r@ rG 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 rc �pid�_�flagsr r r �collect_children( s& z ForkingMixIn.collect_childrenc C s | � � d S r! �rq r" r r r r8 K s zForkingMixIn.handle_timeoutc C s | � � d S r! rr 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 )NrY r ) rh r re r& �addrG �_exitr@ rD r> r? )r rB rC rn Zstatusr r r r= Y s z ForkingMixIn.process_requestc s t � �� | j| jd� d S )Nrb )�superrE rq �block_on_closer" �� __class__r r rE r s zForkingMixIn.server_close) rR rS rT r5 re rg rv rq r8 r- r= rE � __classcell__r r rw r r s #c s4 e Zd Z� fdd�Zdd� Zdd� Zdd� Z� ZS ) �_Threadsc s" | � � |jrd S t� �|� d S r! )�reap�daemonru �append�r �threadrw 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! )Zis_alive)�.0r r r r � <genexpr>� s z _Threads.reap.<locals>.<genexpr>r r" r r r r{ � s z _Threads.reap)rR rS rT r} r� r� r{ ry r r rw r rz w s rz 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)rR rS rT r} r� r r r r r� � s r� c s: e Zd ZdZdZe� Zdd� Zdd� Z� fdd�Z � Z S ) r FTc C sH z6z| �||� W n tk r2 | �||� Y nX W 5 | � |� X d S r! )r@ rD r> r? rA 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)�targetrP ) rv �vars� setdefaultrz r ZThreadr� �daemon_threadsr| r� r} �start)r rB rC �tr r r r= � s � z ThreadingMixIn.process_requestc s t � �� | j�� d S r! )ru rE r� r� r" rw r r rE � s zThreadingMixIn.server_close) rR rS rT r� rv r� r� r� r= rE ry r r rw r r � s c @ s e Zd ZdS )r N�rR rS rT 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�rR rS rT r4 r rV 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! )rB rC �server�setup�finish�handle)r rB rC 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)rR rS rT r r� r� r� r r r r r � s c @ s, e Zd ZdZdZdZdZdd� Zdd� ZdS ) r rd 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)rB Z connectionr5 Z settimeout�disable_nagle_algorithmr[ r4 Z IPPROTO_TCPZ TCP_NODELAYZmakefile�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�flushr4 �errorr] r� r" r r r r� # s zStreamRequestHandler.finish) rR rS rT r� r� r5 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 Zsockr r r r 3 s z_SocketWriter.__init__c C s dS r1 r r" r r r �writable6 s z_SocketWriter.writablec C s2 | j �|� t|��}|jW 5 Q R � S Q R X d S r! )r� Zsendall� memoryview�nbytes)r �bZviewr r r �write9 s z_SocketWriter.writec C s | j �� S r! )r� r^ r" r r r r^ > s z_SocketWriter.filenoN)rR rS rT r r� r� r^ 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� rB Zpacketr4 r� r� )r r� r r r r� E s z DatagramRequestHandler.setupc C s | j �| j�� | j� d S r! )r4 Zsendtor� �getvaluerC r" r r r r� K s z DatagramRequestHandler.finishN)rR rS rT r� r� r r r r r A s )$� __version__r4 r) rh rK r r� r r7 r �__all__�hasattr�extendr r' ZSelectSelectorr r r r �listrz r� r r r r r r r r r r r r� r r r r r �<module>{ s` � � n~ X ( .-
Save File
Cancel