/usr/lib/python3/dist-packages/twisted/internet/iocpreactor/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/internet/iocpreactor/__pycache__/abstract.cpython-310.pyc (10433B)
o
b3 @ s d Z ddlZddlmZ ddlmZmZmZ ddlm Z m
Z
m Z ddl m
Z ddlmZmZ ddlmZ eejejejejG d d
d
e e Zd
gZdS ) z
Abstract file handle class
N) implementer)error
interfacesmain)_ConsumerMixin_dataMustBeBytes _LogOwner) iocpsupport)ERROR_HANDLE_EOFERROR_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-dLd8d9Z.d:d; Z/d
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 )reactoraddActiveHandle_readScheduledreading callLater_resumeReadingself 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_readScheduledInOSdoReadr 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 _readBuffersdynamicReadBufferslenmaxReadBuffersappend bytearray)r size full_buffers remaindertotal_buffer_sizer r r r" 9 s.
zFileHandle._dispatchDatac C s$ d| _ | |||r| d S d S r )r# _handleReadr$ r rcdataevtr r r _cbReadY s zFileHandle._cbReadc C s | j rdS |s |r|tjtfv r!| j| | tt j
dS |r9| tt
dtj|d|f dS | jdks@J | jdksGJ || _| S )zA
Returns False if we should stop reading for now
Fzread error -- %s (%s)unknownr ) disconnectederrno
WSAEDISCONr
r removeActiveHandlereadConnectionLostr Failurer CONNECTION_DONEconnectionLostr ConnectionLost errorcodegetr' r) r" r6 r r r r5 ^ s* zFileHandle._handleReadc C sR t | j| }| j |_}| ||\}}|r|tkr d| _d S | ||| d S NT) _iocpEventr: r+ buffreadFromHandler 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 _writeScheduledwritingr _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 | ttdtj |d|f dS | j
|7 _
| j
t | j krk| j
skd| _ d| _
| | jdurQ| jrG| jrQd| _| j dS | jr_| ttj 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 producerstreamingProducerproducerPausedresumeProducing
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_LIMITjoin_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 iovecir r r
writeSequence s
zFileHandle.writeSequence
Uninitializedi c C s4 |sddl m} || _g | _d| _t| jg| _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
ITransportIHalfCloseableDescriptorr
__all__r r r r s$
l