File: //usr/lib/python3/dist-packages/twisted/internet/iocpreactor/__pycache__/abstract.cpython-38.pyc
U
W[:3 � @ s� d Z ddlmZmZmZ ddlmZmZ ddlm Z ddl
m Z ddl m
Z
ddlZddlmZ dd lmZ dd
lmZ e
ejejejej�G d d � d ee��Zd gZdS )
z
Abstract file handle class
� )�main�error�
interfaces)�_ConsumerMixin� _LogOwner)�failure)�unicode)� implementerN)�ERROR_HANDLE_EOF)�ERROR_IO_PENDING)� iocpsupportc @ s^ 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-dHd8d9�Z.d:d;� Z/d<d=� Z0e1�2e3j4�fd>d?�Z5d@dA� Z6dBdC� Z7dDdE� Z8dFdG� Z9dS )I�
FileHandlez<
File handle that can read and write asynchronously
� i FTr Nc C s4 | j �| � | js0| js0d| _| j �d| j�| _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 s | j r| j �� d | _ d| _d S �NF)r �cancelr r r r r � stopReading. s
zFileHandle.stopReadingc C s d | _ | �� r | js | �� d S �N)r �
_dispatchData�_readScheduledInOS�doReadr r r r r 5 s zFileHandle._resumeReadingc C s� | j s | jS | j }|| j }| j|k rR| �| j| j � | jd7 _| js dS q || j }|rx| �| j| d|� � | jr�| jt| j� }||| j k r�| jd= n*||kr�t| j�| jk r�| 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 �sizeZ full_buffersZ remainderZtotal_buffer_sizer r r r ; s.
�zFileHandle._dispatchDatac C s d| _ | �|||�r | �� d S r )r � _handleReadr! �r �rc�data�evtr r r �_cbReadZ s zFileHandle._cbReadc C s� | j r
dS |s|r |tjtfkrB| j�| � | �t�t j
�� dS |rr| � t�t �
dtj�|d�|f ��� dS | jdks�t�| jdks�t�|| _| �� S dS )zA
Returns False if we should stop reading for now
Fzread error -- %s (%s)�unknownr N)� disconnected�errnoZ
WSAEDISCONr
r �removeActiveHandle�readConnectionLostr �Failurer �CONNECTION_DONE�connectionLostr �ConnectionLost� errorcode�getr$ �AssertionErrorr& r r0 r r r r/ ` s" ��zFileHandle._handleReadc C sP t �| j| �}| j |_}| �||�\}}|r6|tkr>d| _n| �|||� d S �NT) �_iocp�Eventr4 r( �buff�readFromHandler r r/ )r r3 rD r1 Z numBytesReadr r r r! y s zFileHandle.doReadc C s
t � �d S r ��NotImplementedError)r Zbufflistr3 r r r rE � s zFileHandle.readFromHandlec C s t �d S r rF �r r2 r r r r' � s zFileHandle.dataReceivedc C s | � |� d S r �r< �r �reasonr r r r9 � s z FileHandle.readConnectionLost� i c C s d| _ | �� d S rA )�_writeDisconnecting� startWritingr r r r �loseWriteConnection� s z FileHandle.loseWriteConnectionc C s d S r r r r r r �_closeWriteConnection� s z FileHandle._closeWriteConnectionc C s | � |� d S r rI rJ r r r �writeConnectionLost� s z FileHandle.writeConnectionLostc C s. | j �| � d| _| js*| j �d| j�| _d S r )r r �writing�_writeScheduledr �_resumeWritingr r r r rN � s �zFileHandle.startWritingc C s | j r| j �� d | _ d| _d S r )rS r rR r r r r � stopWriting� s
zFileHandle.stopWritingc C s d | _ | �� d S r )rS �doWriter r r r rT � s zFileHandle._resumeWritingc C s | � |||�r| �� d S r )� _handleWriterV �r r1 ZnumBytesWrittenr3 r r r �_cbWrite� s zFileHandle._cbWritec C s� | j s | jrdS |r@| �t�t�dtj� |d�|f ��� dS | j
|7 _
| j
t | j �kr�| j
s�d| _ d| _
| �� | jdk r�| jr�| jr�d| _| j�� n.| jr�| �t�tj�� n| jr�d| _| �� dS dS dS )zA
Returns false if we should stop writing for now
Fzwrite error -- %s (%s)r5 rL r NT)r6 �_writeDisconnectedr< r r: r r= r7 r> r? �offsetr* �
dataBuffer� _tempDataLenrU �producer�streamingProducer�producerPaused�resumeProducing�
disconnectingr r; rM rP rX r r r rW � s4 ��� zFileHandle._handleWritec C s� t | j�| j | jk rF| j| jd � d�| j� | _d| _g | _d| _t�| j | �}| jrzt
| j�}|| jd � |_ }n | j |_ }| � ||�\}}|r�|t
kr�| �|||� d S )NrL r )r* r\ r[ �
SEND_LIMIT�join�_tempDataBufferr] rB rC rY �
memoryviewrD �
writeToHandler rW )r r3 ZsendViewrD r1 r2 r r r rV � s
�
zFileHandle.doWritec C s
t � �d S r rF )r rD r3 r r r rg s zFileHandle.writeToHandlec C s� t |t�rtd��| jr | jr"dS |r�| j�|� | jt|�7 _| j dk rz| j
rzt| j �| j | j krzd| _
| j �� | �� dS )zpReliably write some data.
The data is buffered until his file descriptor is ready for writing.
�Data must not be unicodeNT)�
isinstancer � TypeError� connectedrZ re r, r] r* r^ r_ r\ �writeBufferSizer` �pauseProducingrN rH r r r �write s
�
zFileHandle.writec C s� |D ]}t |t�rtd��q| jr,|r,| jr0d S | j�|� |D ]}| jt|�7 _q@| j d k r�| j
r�t| j �| j | j kr�d| _
| j �� | �� d S )Nrh T)ri r rj rk rZ re �extendr] r* r^ r_ r\ rl r` rm rN )r Ziovec�ir r r �
writeSequence s
zFileHandle.writeSequenceZ
Uninitializedi c C s4 |sddl m} || _g | _d| _t| j�g| _d S )Nr )r )�twisted.internetr re r] r- r% r( )r r r r r �__init__3 s zFileHandle.__init__c C sF d| _ d| _| jdk r&| 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)r6 rk r^ �
stopProducingr rU r r8 rJ r r r r< < s
zFileHandle.connectionLostc C s dS )Nr# r r r r r �
getFileHandleR s zFileHandle.getFileHandlec C sF | j rB| jsB| jr,| �� | j | �|� n| �� | �� d| _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)rk rb rZ r rU r< rN )r Z _connDoner r r �loseConnectionV 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)ZunregisterProducerrv r r r r �
stopConsumings s zFileHandle.stopConsumingc C s | j r| js| �� d S r )rk rb r r r r r ra � s zFileHandle.resumeProducingc C s | � � d S r )r r r r r rm � s zFileHandle.pauseProducingc C s | � � d S r )rv r r r r rt � s zFileHandle.stopProducing)N):�__name__�
__module__� __qualname__�__doc__r+ r% r r) r& r$ r r r r r r r4 r/ r! rE r' r9 r\ r[ rR rS rM rZ rl rO rP rQ rN rU rT rY rW rV rg rn rq rk r6 rb Zlogstrrc rs r< ru r r: r r; rv rw ra rm rt r r r r r
sf (
r
)r{ rr r r r Ztwisted.internet.abstractr r Ztwisted.pythonr Ztwisted.python.compatr Zzope.interfacer r7 Z"twisted.internet.iocpreactor.constr
r Z twisted.internet.iocpreactorr rB Z
IPushProducerZ IConsumerZ
ITransportZIHalfCloseableDescriptorr
�__all__r r r r �<module> s"
� y