File: //usr/lib/python3/dist-packages/twisted/internet/iocpreactor/__pycache__/abstract.cpython-310.pyc
o
�b3 � @ s� d Z ddlZddlmZ ddlmZmZmZ ddlm Z m
Z
m Z ddl m
Z ddlmZmZ ddlmZ eejejejej�G d d
� d
e e ��Zd
gZdS ) z
Abstract file handle class
� N)� implementer)�error�
interfaces�main)�_ConsumerMixin�_dataMustBeBytes� _LogOwner)� iocpsupport)�ERROR_HANDLE_EOF�ERROR_IO_PENDING)�failurec @ sn e Zd ZdZdZdZdZdZdZdZ dZ
dZ dd � Z d
d � Z
d d
� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd ZdZdZdZdZdZd Z d d � Z d d!� Z d"d#� Z d$d%� Z d&d'� Z!d(d)� Z"d*d+� Z#d,d-� Z$d.d/� Z%d0d1� Z&d2d3� Z'd4d5� Z(dZ)dZ*dZ+d6Z,d7Z-dLd8d9�Z.d:d;� Z/d<d=� Z0e1�2e3j4�fd>d?�Z5d@dA� Z6dBdC� Z7dDdE� Z8dFdG� Z9dHdI� Z:dJdK� Z;dS )M�
FileHandlez<
File handle that can read and write asynchronously
� i FTr Nc C �< | j �| � | js| js d| _| j �d| j�| _d S d S d S �NTr )�reactor�addActiveHandle�_readScheduled�reading� callLater�_resumeReading��self� r �G/usr/lib/python3/dist-packages/twisted/internet/iocpreactor/abstract.py� startReading( s
�zFileHandle.startReadingc C � | j r | j �� d | _ d| _d S �NF)r �cancelr r r r r � stopReading. �
zFileHandle.stopReadingc C s( d | _ | �� r| js| �� d S d S d S �N)r �
_dispatchData�_readScheduledInOS�doReadr r r r r 4 s �zFileHandle._resumeReadingc C s� | j s| jS | j }|| j }| j|k r-| �| j| j � | jd7 _| js(dS | j|k s|| j }|r@| �| j| d|� � | jrl| jt| j� }||| j k rW| jd= n||krlt| j�| jk rl| j� t
| j�� d| _d| _ | jS )zt
Dispatch previously read data. Return True if self.reading and we don't
have any more data
� Fr ���) � _readSizer �readBufferSize�_readNextBuffer� dataReceived� _readBuffers�dynamicReadBuffers�len�maxReadBuffers�append� bytearray)r �size� full_buffers� remainder�total_buffer_sizer r r r" 9 s.
�
zFileHandle._dispatchDatac C s$ d| _ | �|||�r| �� d S d S r )r# � _handleReadr$ �r �rc�data�evtr r r �_cbReadY s �zFileHandle._cbReadc C s� | j rdS |s |r|tjtfv r!| j�| � | �t�t j
�� dS |r9| � t�t �
dtj�|d�|f ��� dS | jdks@J �| jdksGJ �|| _| �� S )zA
Returns False if we should stop reading for now
Fzread error -- %s (%s)�unknownr )� disconnected�errno�
WSAEDISCONr
r �removeActiveHandle�readConnectionLostr �Failurer �CONNECTION_DONE�connectionLostr �ConnectionLost� errorcode�getr' r) r" r6 r r r r5 ^ s* ����zFileHandle._handleReadc C sR t �| j| �}| j |_}| �||�\}}|r|tkr d| _d S | �|||� d S �NT) �_iocp�Eventr: r+ �buff�readFromHandler r# r5 )r r9 rJ r7 � numBytesReadr r r r$ { s
zFileHandle.doReadc C � t � �r! ��NotImplementedError)r �bufflistr9 r r r rK � � zFileHandle.readFromHandlec C s t �r! rN �r r8 r r r r* � � zFileHandle.dataReceivedc C � | � |� d S r! �rC �r �reasonr r r r@ � s z FileHandle.readConnectionLost� i c C s d| _ | �� d S rG )�_writeDisconnecting� startWritingr r r r �loseWriteConnection� � z FileHandle.loseWriteConnectionc C s d S r! r r r r r �_closeWriteConnection� s z FileHandle._closeWriteConnectionc C rT r! rU rV r r r �writeConnectionLost� s z FileHandle.writeConnectionLostc C r r )r r �_writeScheduled�writingr �_resumeWritingr r r r rZ � s
�zFileHandle.startWritingc C r r )r_ r r` r r r r � stopWriting� r zFileHandle.stopWritingc C s d | _ | �� d S r! )r_ �doWriter r r r ra � r\ zFileHandle._resumeWritingc C s | � |||�r
| �� d S d S r! )� _handleWriterc �r r7 �numBytesWrittenr9 r r r �_cbWrite� s �zFileHandle._cbWritec C s� | j s| jrdS |r | �t�t�dtj� |d�|f ��� dS | j
|7 _
| j
t | j �krk| j
skd| _ d| _
| �� | jdurQ| jrG| jrQd| _| j�� dS | jr_| �t�tj�� dS | jrid| _| �� dS dS )zA
Returns false if we should stop writing for now
Fzwrite error -- %s (%s)r; rX r NT)r< �_writeDisconnectedrC r rA r rD r= rE rF �offsetr- �
dataBuffer� _tempDataLenrb �producer�streamingProducer�producerPaused�resumeProducing�
disconnectingr rB rY r] re r r r rd � sD ����
��
��zFileHandle._handleWritec C s� t | j�| j | jk r#| j| jd � d�| j� | _d| _g | _d| _t�| j | �}| jr=t
| j�}|| jd � |_ }n| j |_ }| � ||�\}}|rZ|t
kr\| �|||� d S d S d S )NrX r )r- rj ri �
SEND_LIMIT�join�_tempDataBufferrk rH rI rg �
memoryviewrJ �
writeToHandler rd )r r9 �sendViewrJ r7 r8 r r r rc � s �
�zFileHandle.doWritec C rM r! rN )r rJ r9 r r r ru � rQ zFileHandle.writeToHandlec C s� t |� | jr
| jr dS |r>| j�|� | jt|�7 _| jdur8| jr8t| j �| j | j
kr8d| _ | j� � | �
� dS dS )zpReliably write some data.
The data is buffered until his file descriptor is ready for writing.
NT)r � connectedrh rs r/ rk r- rl rm rj �writeBufferSizern �pauseProducingrZ rR r r r �write s
�zFileHandle.writec C s� |D ]}t |� q| jr|r| jrd S | j�|� |D ] }| jt|�7 _q| jd urB| jrBt| j �| j | j
krBd| _ | j� � | �
� d S rG )r rw rh rs �extendrk r- rl rm rj rx rn ry rZ )r �iovec�ir r r �
writeSequence s
zFileHandle.writeSequence�
Uninitializedi c C s4 |sddl m} || _g | _d| _t| j�g| _d S )Nr )r )�twisted.internetr rs rk r0 r( r+ )r r r r r �__init__' s zFileHandle.__init__c C sF d| _ d| _| jdur| j�� d| _| �� | �� | j�| � dS )a�
The connection was lost.
This is called when the connection on a selectable object has been
lost. It will be called whether the connection was closed explicitly,
an exception occurred in an event handler, or the other end of the
connection closed it first.
Clean up state here, but make sure to call back up to FileDescriptor.
TFN)r< rw rl �
stopProducingr rb r r? rV r r r rC / s
zFileHandle.connectionLostc C s dS )Nr& r r r r r �
getFileHandleD rS zFileHandle.getFileHandlec C sP | j r$| js&| jr| �� | j | �|� dS | �� | �� d| _dS dS dS )ad
Close the connection at the next available opportunity.
Call this to cause this FileDescriptor to lose its connection. It will
first write any data that it has buffered.
If there is data buffered yet to be written, this method will cause the
transport to lose its connection as soon as it's done flushing its
write buffer. If you have a producer registered, the connection won't
be closed until the producer is finished. Therefore, make sure you
unregister your producer when it's finished, or the connection will
never close.
r% N)rw rp rh r rb rC rZ )r � _connDoner r r �loseConnectionG s
�zFileHandle.loseConnectionc C s | � � | �� dS )z�
Stop consuming data.
This is called when a producer has lost its connection, to tell the
consumer to go lose its connection (and break potential circular
references).
N)�unregisterProducerr� r r r r �
stopConsumingc s zFileHandle.stopConsumingc C s | j r | js| �� d S d S d S r! )rw rp r r r r r ro p s �zFileHandle.resumeProducingc C � | � � d S r! )r r r r r ry t � zFileHandle.pauseProducingc C r� r! )r� r r r r r� w r� zFileHandle.stopProducingc C rM r! rN r r r r �getHostz � zFileHandle.getHostc C rM r! rN r r r r �getPeer~ r� zFileHandle.getPeerr! )<�__name__�
__module__� __qualname__�__doc__r. r( r r, r) r' r r# r r r r" r: r5 r$ rK r* r@ rj ri r` r_ rY rh rx r[ r] r^ rZ rb ra rg rd rc ru rz r~ rw r< rp �logstrrq r� rC r� r rA r rB r� r� ro ry r� r� r� r r r r r
sl -
r
)r� r= �zope.interfacer r� r r r �twisted.internet.abstractr r r � twisted.internet.iocpreactorr rH �"twisted.internet.iocpreactor.constr
r �twisted.pythonr �
IPushProducer� IConsumer�
ITransport�IHalfCloseableDescriptorr
�__all__r r r r �<module> s$ �
l