| Server IP : 138.197.176.125 / Your IP : 216.73.217.55 Web Server : Apache/2.4.41 (Ubuntu) System : Linux SuiteCRM-8 5.4.0-216-generic #236-Ubuntu SMP Fri Apr 11 19:53:21 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.3.19 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /lib/python3/dist-packages/twisted/internet/iocpreactor/__pycache__/ |
Upload File : |
U
��W[�# � @ s@ d Z ddlZddlZddlZddlmZ ddlmZmZm Z m
Z
ddl m Z m
Z
ddlmZ ddlmZ ddlmZ dd lmZ dd
lmZmZ zdd lmZ W n& ek
r� dZd Z e� d
� Y n
X ej fZ dZ dZ e!d�\Z"Z#e
�$d�Z%e
�$d�Z&eej'ej(ej)ej*fe �� G dd� dej+ej,e��Z-dd� Z.ddgZ/dS )z'
Reactor that uses IO completion ports
� N)� implementer)�base�
interfaces�main�error)�log�failure)�Process)�_ThreadedWin32EventsMixin)� iocpsupport)� WAIT_TIMEOUT)�tcp�udp)�TLSMemoryBIOFactory� z|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�Zedk r�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 �F/usr/lib/python3/dist-packages/twisted/internet/iocpreactor/reactor.pyr 9 s
zIOCPReactor.__init__c C s | j �|� d S r )r �add�r Zhandler r r �addActiveHandle? s zIOCPReactor.addActiveHandlec C s | j �|� d S r )r �discardr r r r �removeActiveHandleC s z IOCPReactor.removeActiveHandlec C s� d}|dkrt }ntt td| ��}| j�|�\}}}}|tkrBq�|tkrt|tksVt�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_NORMAL�AssertionErrorr ZcallWithLogger�owner�_callEventCallback�EVENTS_PER_LOOP)r �timeoutZprocessed_events�rc�numBytes�key�evtr r r � doIterationG s$ �zIOCPReactor.doIterationc C s� |j }d }z@|�|||� t|dd �}|s0t}n|� dkr>t}|rHW d S W n t�� d }t�� Y nX |r�|� t
� |�� d S )NZ
getFileHandle���r# ) r* �callback�getattr�
_NO_GETHANDLE� _NO_FILEDESC�sys�exc_infor �errZloseConnectionr ZFailure)r r. r/ r1 r* ZwhyZhandfnr r r r+ s 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 )�socketr= �fileno)r Zaf�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 ConnectorZconnect)r �hostr rF r- � bindAddress�cr r r �
connectTCP� s zIOCPReactor.connectTCPc C s" | � |t|d|�||�}d|_|S )zQ
@see: twisted.internet.interfaces.IReactorSSL.listenSSL
FZTLS)rJ r Z_type�r r rF �contextFactoryrG rH r r r � listenSSL� s
�zIOCPReactor.listenSSLc C s | � ||t|d|�||�S )zR
@see: twisted.internet.interfaces.IReactorSSL.connectSSL
T)rO r �r rL r rF rQ r- rM 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��NotImplementedErrorrP r r r rR � 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}.
rU NrV rS r r r rT � 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 rD rE )r r �protocolrH �
maxPacketSizerI 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
MulticastPortrE )r r rY rH rZ ZlistenMultiplerI r r r �listenMulticast� s
�zIOCPReactor.listenMulticastr r c
C s^ |dk rt d��|dk r t d��|r,t d��| dk r<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.)�
ValueErrorZ_checkProcessArgsr )
r ZprocessProtocol�
executable�args�env�pathZuid�gidZusePTYZchildFDsr r r � spawnProcess� s �zIOCPReactor.spawnProcessc C s t | j�}| j�� |S r )�listr �clear)r �resr r r � removeAll s
zIOCPReactor.removeAll)rB rC )rK N)rB rC )rK N)rB rC )rK N)rC rX )rC rX F)�__name__�
__module__� __qualname__r r r r" r2 r+ r; r< r= rA rJ rO r rR rT r[ r\ rc rg r r r r r 0 s: ,
�
�
r c C s t � } t�| � d S r )r r ZinstallReactor)�rr r r �install s rl )0�__doc__�warningsr> r8 Zzope.interfacer Ztwisted.internetr r r r Ztwisted.pythonr r Z twisted.internet._dumbwin32procr Z"twisted.internet.win32eventreactorr
Z twisted.internet.iocpreactorr r Z"twisted.internet.iocpreactor.constr r
r Ztwisted.protocols.tlsr � ImportErrorZ_extraInterfaces�warnZ IReactorSSLr$ r, �ranger( r' ZConnectionFdescWentAwayr6 r7 Z IReactorTCPZ IReactorUDPZIReactorMulticastZIReactorProcessZ_SignalReactorMixinr r rl �__all__r r r r �<module> sJ �
�
��� Z