Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/internet/iocpreactor/__pycache__/reactor.cpython-39.pyc
Ðазад
a k�h�$ � @ sd U d Z ddlZddlZddlZddlmZmZ ddlmZ ddl m Z m Z m Z m Z ddlmZ ddlmZmZmZ ddlmZ dd lmZ dd lmZmZ zdd l m Z W n: e y� dZ d Z eee j! d f e"d< e�#d� Y n0 e Z e j!fZ dZ$dZ%e&d�\Z'Z(e �)d�Z*e �)d�Z+ee j,e j-e j.e j/ge �R � G dd� de j0e j1e��Z2dd� Z3ddgZ4dS )z' Reactor that uses IO completion ports � N)�Tuple�Type)� implementer)�base�error� interfaces�main)�Process)� iocpsupport�tcp�udp)� WAIT_TIMEOUT)�_ThreadedWin32EventsMixin)�failure�log)�TLSMemoryBIOFactory� .�_extraInterfacesz|pyOpenSSL 0.10 or newer is required for SSL support in iocpreactor. It is missing, so the reactor will not support SSL APIs.i� �� � z#Handler has no getFileHandle methodzFiledescriptor went awayc @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z d-dd�Z d.dd�Zedur�d/dd �Zd0d d �Znd1d d �Zd2d d �Zd3d"d#�Zd4d%d&�Zd'i dddd(dfd)d*�Zd+d,� ZdS )5� IOCPReactorNc C s" t j�| � t�� | _t� | _d S �N)r � ReactorBase�__init__�_iocpZCompletionPort�port�set�handles��selfr r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/internet/iocpreactor/reactor.pyr ? s zIOCPReactor.__init__c C s | j �|� d S r )r �add�r �handler r r �addActiveHandleD s zIOCPReactor.addActiveHandlec C s | j �|� d S r )r �discardr" r r r �removeActiveHandleG s z IOCPReactor.removeActiveHandlec C s� d}|du rt }ntt td| ��}| j�|�\}}}}|tkrBq�|tkrt|tksVJ �t� |j | j |||� |d7 }|t kr~q�| j�d�\}}}}q8dS )z= Poll the IO completion port for new events. r Nr � ) � MAX_TIMEOUT�min�intr ZgetEventr � KEY_WAKEUP� KEY_NORMALr ZcallWithLogger�owner�_callEventCallback�EVENTS_PER_LOOP)r �timeoutZprocessed_events�rc�numBytes�key�evtr r r � doIterationJ s �zIOCPReactor.doIterationc C s� |j }d }z@|�|||� t|dd �}|s0t}n|� dkr>t}|rHW d S W n& typ t�� d }t� � Y n0 |r�|� t � |�� d S )NZ getFileHandle���r' ) r- �callback�getattr� _NO_GETHANDLE� _NO_FILEDESC� BaseException�sys�exc_infor �errZloseConnectionr ZFailure)r r1 r2 r4 r- �whyZhandfnr r r r. v s z IOCPReactor._callEventCallbackc C s d S r r r r r r � installWaker� s zIOCPReactor.installWakerc C s | j �dtd � d S )Nr )r Z postEventr+ r r r r �wakeUp� s zIOCPReactor.wakeUpc C s | j �|t� d S r )r Z addHandler, r" r r r �registerHandle� s zIOCPReactor.registerHandlec C s t � ||�}| �|�� � |S r )�socketrB �fileno)r �af�stypeZsktr r r � createSocket� s zIOCPReactor.createSocket�2 � c C s t �||||| �}|�� |S )zI @see: twisted.internet.interfaces.IReactorTCP.listenTCP )r �Port�startListening)r r �factory�backlog� interface�pr r r � listenTCP� s zIOCPReactor.listenTCP� c C s t �|||||| �}|�� |S )zJ @see: twisted.internet.interfaces.IReactorTCP.connectTCP )r Z Connector�connect)r �hostr rL r0 � bindAddress�cr r r � connectTCP� s zIOCPReactor.connectTCPc C s" | � |t|d|�||�}d|_|S )zQ @see: twisted.internet.interfaces.IReactorSSL.listenSSL FZTLS)rP r �_type�r r rL �contextFactoryrM rN r r r � listenSSL� s �zIOCPReactor.listenSSLc C s | � ||t|d|�||�S )zR @see: twisted.internet.interfaces.IReactorSSL.connectSSL T)rV r �r rS r rL rY r0 rT r r r � connectSSL� s �zIOCPReactor.connectSSLc C s t d��dS )z� Non-implementation of L{IReactorSSL.listenSSL}. Some dependency is not satisfied. This implementation always raises L{NotImplementedError}. �|pyOpenSSL 0.10 or newer is required for SSL support in iocpreactor. It is missing, so the reactor does not support SSL APIs.N��NotImplementedErrorrX r r r rZ � s �c C s t d��dS )z� Non-implementation of L{IReactorSSL.connectSSL}. Some dependency is not satisfied. This implementation always raises L{NotImplementedError}. r] Nr^ r[ r r r r\ � s �� c C s t �||||| �}|�� |S )z� Connects a given L{DatagramProtocol} to the given numeric UDP port. @returns: object conforming to L{IListeningPort}. )r rJ rK )r r �protocolrN � maxPacketSizerO r r r � listenUDP� s zIOCPReactor.listenUDPFc C s t �||||| |�}|�� |S )z� Connects a given DatagramProtocol to the given numeric UDP port. EXPERIMENTAL. @returns: object conforming to IListeningPort. )r Z MulticastPortrK )r r ra rN rb ZlistenMultiplerO r r r �listenMulticast� s �zIOCPReactor.listenMulticastr r c C sN |durt d��|dur t d��|r,t d��| dur<t d��t| |||||�S )z" Spawn a process. Nz,Setting UID is unsupported on this platform.z,Setting GID is unsupported on this platform.z&PTYs are unsupported on this platform.zGCustom child file descriptor mappings are unsupported on this platform.)� ValueErrorr ) r ZprocessProtocol� executable�args�env�path�uid�gidZusePTYZchildFDsr r r � spawnProcess� s �zIOCPReactor.spawnProcessc C s t | j�}| j�� |S r )�listr �clear)r �resr r r � removeAll s zIOCPReactor.removeAll)rH rI )rQ N)rH rI )rQ N)rH rI )rQ N)rI r` )rI r` F)�__name__� __module__� __qualname__r r r$ r& r5 r. r@ rA rB rG rP rV r rZ r\ rc rd rl rp r r r r r 2 s> , � � � � r c C s t � } t�| � d S r )r r ZinstallReactor)�rr r r �install s ru )5�__doc__rC r< �warnings�typingr r Zzope.interfacer Ztwisted.internetr r r r Z twisted.internet._dumbwin32procr Z twisted.internet.iocpreactorr r r r Z"twisted.internet.iocpreactor.constr Z"twisted.internet.win32eventreactorr Ztwisted.pythonr r Ztwisted.protocols.tlsr Z_TLSMemoryBIOFactory� ImportErrorr Z IReactorSSL�__annotations__�warnr( r/ �ranger, r+ ZConnectionFdescWentAwayr9 r: Z IReactorTCPZ IReactorUDPZIReactorMulticastZIReactorProcessZ_SignalReactorMixinr r ru �__all__r r r r �<module> sP � �� � c
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка