| Server IP : 61.19.30.66 / Your IP : 216.73.216.15 Web Server : Apache/2.2.22 (Ubuntu) System : Linux klw 3.11.0-15-generic #25~precise1-Ubuntu SMP Thu Jan 30 17:39:31 UTC 2014 x86_64 User : www-data ( 33) PHP Version : 5.3.10-1ubuntu3.48 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority, MySQL : ON | cURL : OFF | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : OFF Directory : /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/ |
Upload File : |
˪Nc @ s d Z d d l m Z m Z m Z d d l m Z m Z d d l m Z d d l
m Z d d l Z d d l
m Z d d l
m Z d d l m Z d
e e f d YZ d
g Z d S( s
Abstract file handle class
i( t maint errort
interfaces( t _ConsumerMixint _LogOwner( t failure( t
implementsN( t ERROR_HANDLE_EOF( t ERROR_IO_PENDING( t iocpsupportt
FileHandlec B s e Z d Z e e j e j e j e j d Z d Z
e Z e
Z d Z d Z d' Z e Z d Z d Z d Z d Z d Z d Z d
Z d Z d Z d
Z d Z d Z e Z d' Z! e Z" e Z# d d d( Z$ d Z% d Z& d Z' d Z( d Z) d Z* d Z+ d Z, d Z- d Z. d Z/ d Z0 e Z1 e Z2 e Z3 d Z4 d) Z5 d' d Z6 d Z7 d! Z8 e9 j: e; j< d" Z= d# Z> d$ Z? d% Z@ d& ZA RS(* s<
File handle that can read and write asynchronously
i i i c C sO | j j | | j rK | j rK t | _ | j j d | j | _ n d S( Ni ( t reactort addActiveHandlet _readScheduledt readingt Truet callLatert _resumeReading( t self( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyt startReading& s
c C s/ | j r" | j j d | _ n t | _ d S( N( R
t cancelt Nonet FalseR ( R ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyt stopReading. s
c C s0 d | _ | j r, | j r, | j n d S( N( R R
t
_dispatchDatat _readScheduledInOSt doRead( R ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyR 5 s c C sC | j s | j S| j } | | j } xF | j | k rn | j | j | j | j d 7_ | j s) t Sq) W| | j } | r | j t | j | d | n | j r*| j t | j } | | | j k r | j d =q*| | k r*t | j | j
k r*| j j t j
| j q*n d | _ d | _ | j S( st
Dispatch previously read data. Return True if self.reading and we don't
have any more data
i i i( t _readSizeR t readBufferSizet _readNextBuffert dataReceivedt _readBuffersR t buffert dynamicReadBufferst lent maxReadBufferst appendt _iocpt AllocateReadBuffer( R t sizet full_bufferst remaindert total_buffer_size( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyR ; s0
c C s/ t | _ | j | | | r+ | j n d S( N( R R t _handleReadR ( R t rct bytest evt( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyt _cbRead\ s c C s | j r
t S| p | s/ | t j t f k r\ | j j | | j t j t
j t S| r | j t j t
j d t j j | d | f t S| j d k s t | j d k s t | | _ | j Sd S( sA
Returns False if we should stop reading for now
s read error -- %s (%s)t unknowni N( t disconnectedR t errnot
WSAEDISCONR R t removeActiveHandlet readConnectionLostR t FailureR t CONNECTION_DONEt connectionLostR t ConnectionLostt errorcodet getR t AssertionErrorR R ( R R, R- R. ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyR+ b s " # c C ss t j | j | } | j | _ } | j | | \ } } | sP | t k r\ t | _ n | j | | | d S( N(
R% t EventR/ R t bufft readFromHandleR R R R+ ( R R. R> R, R- ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyR { s c C s
t d S( N( t NotImplementedError( R t bufflistR. ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyR? s c C s
t d S( N( R@ ( R t data( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyR s c C s | j | d S( N( R8 ( R t reason( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyR5 s t i c C s t | _ | j d S( N( R t _writeDisconnectingt startWriting( R ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyt loseWriteConnection s c C s d S( N( ( R ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyt _closeWriteConnection s c C s | j | d S( N( R8 ( R RC ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyt writeConnectionLost s c C sD | j j | t | _ | j s@ | j j d | j | _ n d S( Ni ( R R R t writingt _writeScheduledR t _resumeWriting( R ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyRF s
c C s/ | j r" | j j d | _ n t | _ d S( N( RK R R R RJ ( R ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyt stopWriting s
c C s d | _ | j d S( N( R RK t doWrite( R ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyRL s c C s& | j | | | r" | j n d S( N( t _handleWriteRN ( R R, R- R. ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyt _cbWrite s c C s0 | j s | j r t S| rX | j t j t j d t j j
| d | f t S| j | 7_ | j t | j
k r(| j r(d | _
d | _ | j | j d k r | j s | j r t | _ | j j nD | j r| j t j t j n | j r$| j t | _ n t St Sd S( sA
Returns false if we should stop writing for now
s write error -- %s (%s)R0 RD i N( R1 t _writeDisconnectedR R8 R R6 R R9 R2 R: R; t offsetR" t
dataBuffert _tempDataLenRM t producerR t streamingProducert producerPausedR t resumeProducingt
disconnectingR R7 RE RH ( R R, R- R. ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyRO s. #"
c C s t | j | j | j k re t | j | j d j | j | _ d | _ g | _ d | _ n t j | j
| } | j r t | j | j | _ } n | j | _ } | j | | \ } } | r | t
k r | j | | | n d S( NRD i ( R" RS RR t
SEND_LIMITR t joint _tempDataBufferRT R% R= RP R> t
writeToHandleR RO ( R R. R> R, R- ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyRN s c C s
t d S( N( R@ ( R R> R. ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyR] s c C s t | t r t d n | j s1 | j r5 d S| r | j j | | j t | 7_ | j d k r | j r t | j | j | j
k r t | _ | j j q n | j n d S( sp Reliably write some data.
The data is buffered until his file descriptor is ready for writing.
s Data must not be unicodeN( t
isinstancet unicodet TypeErrort connectedRQ R\ R$ RT R" RU R RV RS t writeBufferSizeR RW t pauseProducingRF ( R RB ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyt write s c C s x, | D]$ } t | t r t d q q W| j sI | sI | j rM d S| j j | x# | D] } | j t | 7_ qd W| j d k r | j r t | j | j | j
k r t | _ | j j q n | j d S( Ns Data must not be unicode( R^ R_ R` Ra RQ R\ t extendRT R" RU R RV RS Rb R RW Rc RF ( R t iovect i( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyt
writeSequence s
t
Uninitializedi i c C sP | s d d l m } n | | _ g | _ d | _ t j | j g | _ d S( Ni( R i ( t twisted.internetR R\ RT R% R& R R ( R R ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyt __init__4 s c C sb t | _ t | _ | j d k r: | j j d | _ n | j | j | j j
| d S( s
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.
N( R R1 R Ra RU R t
stopProducingR RM R R4 ( R RC ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyR8 = s
c C s d S( Ni( ( R ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyt
getFileHandleS s c C sa | j r] | j r] | j r= | j | j | j | q] | j | j d | _ n d S( sd
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.
i N( Ra RY RQ R RM R8 RF ( R t _connDone( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyt loseConnectionW s
c C s | j | j d S( s
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( t unregisterProducerRo ( R ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyt
stopConsumingt s
c C s' | j r | j s t | j d S( N( Ra RY R< R ( R ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyRX s c C s | j d S( N( R ( R ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyRc s c C s | j d S( N( Ro ( R ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyRl s Ni i (B t __name__t
__module__t __doc__R R t IProducert IConsumert
ITransportt IHalfCloseableDescriptorR# R R R R R! R R R R
R R R R R R/ R+ R R? R R5 RS RR RJ RK RE RQ Rb RG RH RI RF RM RL RP RO RN R] Rd Rh Ra R1 RY t logstrRZ Rk R8 Rm R R6 R R7 Ro Rq RX Rc Rl ( ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyR
sj ! ( ( Rt Rj R R R t twisted.internet.abstractR R t twisted.pythonR t zope.interfaceR R2 t" twisted.internet.iocpreactor.constR R t twisted.internet.iocpreactorR R% R
t __all__( ( ( sI /usr/lib/python2.7/dist-packages/twisted/internet/iocpreactor/abstract.pyt <module> s {