OwlCyberSecurity - MANAGER
Edit File: posixbase.pyc
� `��ac @` s� d Z d d l m Z m Z d d l Z d d l Z d d l Z d d l Z d d l m Z m Z d d l m Z m Z m Z d d l m Z m Z d d l m Z m Z d d l m Z m Z m Z m Z m Z m Z m Z m Z m Z m Z d d l m! Z! m" Z" m# Z# d d l$ m% Z% m& Z& e j' d � Z( e j' d � Z) y d d l* m+ Z+ WnE e, k r�e- Z+ y d d l m. Z. Wn e, k r�e- Z. n Xn Xe% d k Z/ e0 Z1 e/ r�d d l m2 Z2 m3 Z3 d d l m4 Z4 m5 Z5 e6 Z1 n e& j7 � r(y d d l8 Z8 e6 Z1 Wn e, k r$e- Z8 n Xn d e! j9 f d � � YZ: d e! j9 e; f d � � YZ< d e< f d � � YZ= e% d k r�e= Z> n e: Z> d e< f d � � YZ? d e; f d � � YZ@ e e e e � d e e@ e f d � � Y� ZA d e; f d � � YZB e e � d eB e@ f d! � � Y� ZC e+ e- k p8e. e- k rKe eA e � n e/ rde eA e e � n e1 rze eA e � n eD e d" e- � e- k r�e eA e � n d g ZE d S(# s Posix reactor base class i ( t divisiont absolute_importN( t implementert classImplements( t errort udpt tcp( t ReactorBaset _SignalReactorMixin( t CONNECTION_DONEt CONNECTION_LOST( t IReactorUNIXt IReactorUNIXDatagramt IReactorTCPt IReactorUDPt IReactorSSLt IReactorSockett IHalfCloseableDescriptort IReactorProcesst IReactorMulticastt IReactorFDSet( t logt failuret util( t platformTypet platforms Handler has no fileno methods File descriptor lost( t tls( t sslt posix( t fdesct unix( t processt _signalst _SocketWakerc B` s8 e Z d Z d Z d � Z d � Z d � Z d � Z RS( s� The I{self-pipe trick<http://cr.yp.to/docs/selfpipe.html>}, implemented using a pair of sockets rather than pipes (due to the lack of support in select() on Windows for pipes), used to wake up the main loop from another thread. i c C` s� | | _ t j t j t j � } t j t j t j � } | j t j t j d � | j d � | j d � | j | j � � | j � \ } } | j d � | j d � | | _ | | _ | j j | _ d S( s Initialize. i s 127.0.0.1i N( s 127.0.0.1i ( t reactort sockett AF_INETt SOCK_STREAMt setsockoptt IPPROTO_TCPt TCP_NODELAYt bindt listent connectt getsocknamet acceptt setblockingt rt wt fileno( t selfR" t servert clientt readert clientaddr( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt __init__E s c C` sS y t j | j j d � Wn2 t j k rN } | j d t j k rO � qO n Xd S( s& Send a byte to my connection. t xi N( R t untilConcludesR0 t sendR# R t argst errnot WSAEWOULDBLOCK( R2 t e( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt wakeUpW s c C` s/ y | j j d � Wn t j k r* n Xd S( s+ Read some data from my connection. i N( R/ t recvR# R ( R2 ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt doRead` s c C` s | j j � | j j � d S( N( R/ t closeR0 ( R2 t reason( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt connectionLosth s ( t __name__t __module__t __doc__t disconnectedR7 R? RA RD ( ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyR! < s t _FDWakerc B` s; e Z d Z d Z d Z d Z d � Z d � Z d � Z RS( s� The I{self-pipe trick<http://cr.yp.to/docs/selfpipe.html>}, used to wake up the main loop from another thread or a signal handler. L{_FDWaker} is a base class for waker implementations based on writing to a pipe being monitored by the reactor. @ivar o: The file descriptor for the end of the pipe which can be written to wake up a reactor monitoring this waker. @ivar i: The file descriptor which should be monitored in order to be awoken by this waker. i c ` sw | � _ t j � \ � _ � _ t j � j � t j � j � t j � j � t j � j � � f d � � _ d S( s Initialize. c ` s � j S( N( t i( ( R2 ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt <lambda>� t N( R" t ost pipeRJ t oR t setNonBlockingt _setCloseOnExecR1 ( R2 R" ( ( R2 s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyR7 � s c C` s t j | j � d � � d S( sA Read some bytes from the pipe and discard them. c S` s d S( N( t None( t data( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyRK � RL N( R t readFromFDR1 ( R2 ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyRA � s c C` se t | d � s d Sx? | j | j f D]+ } y t j | � Wq& t k rP q& Xq& W| ` | ` d S( s$ Close both ends of my pipe. RO N( t hasattrRJ RO RM RB t IOError( R2 RC t fd( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyRD � s N( RE RF RG RH RR RJ RO R7 RA RD ( ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyRI n s t _UnixWakerc B` s e Z d Z d � Z RS( s� This class provides a simple interface to wake up the event loop. This is used by threads or signals to wake up the event loop. c C` sa | j d k r] y t j t j | j d � Wq] t k rY } | j t j k rZ � qZ q] Xn d S( s2 Write one byte to the pipe, and flush it. R8 N( RO RR R R9 RM t writet OSErrorR< t EAGAIN( R2 R> ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyR? � s ( RE RF RG R? ( ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyRX � s t _SIGCHLDWakerc B` s2 e Z d Z d � Z d � Z d � Z d � Z RS( s} L{_SIGCHLDWaker} can wake up a reactor whenever C{SIGCHLD} is received. @see: L{twisted.internet._signals} c C` s t j | | � d S( N( RI R7 ( R2 R" ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyR7 � s c C` s t j | j � d S( sJ Install the handler necessary to make this waker active. N( R t installHandlerRO ( R2 ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt install� s c C` s t j d � d S( sC Remove the handler which makes this waker active. i����N( R R] ( R2 ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt uninstall� s c C` s t j | � t j � d S( s Having woken up the reactor in response to receipt of C{SIGCHLD}, reap the process which exited. This is called whenever the reactor notices the waker pipe is writeable, which happens soon after any call to the C{wakeUp} method. N( RI RA R t reapAllProcesses( R2 ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyRA � s ( RE RF RG R7 R^ R_ RA ( ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyR\ � s t _DisconnectSelectableMixinc B` sL e Z d Z i e j e j � � e j 6e j e j � � e j 6d � Z RS( s> Mixin providing the C{_disconnectSelectable} method. c C` s� | j | � | j | j � } | ry | r\ | j t j k r\ t j | � r\ | j | � q� | j | � | j | � n# | j | � | j t j | � � d S( s� Utility function for disconnecting a selectable. Supports half-close notification, isRead should be boolean indicating whether error resulted from doRead(). N( t removeReadert gett __class__R t ConnectionDoneR t providedByt readConnectionLostt removeWriterRD R t Failure( R2 t selectablet whyt isReadt faildictt f( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt _disconnectSelectable� s ( RE RF RG R Ri R Re t ConnectionLostRo ( ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyRa � s t PosixReactorBasec B` sL e Z d Z e Z d � Z d Z d � Z d � Z d i d d d d d d � Z d d d � Z d d e d � Z d d d � Z d d d d � Z d d d � Z d d d d � Z e r� e j e j e j f Z n e j e j f Z d � Z d � Z d d � Z d d d � Z d d d � Z d d d � Z d d d � Z d � Z RS( s� A basis for reactors that use file descriptors. @ivar _childWaker: L{None} or a reference to the L{_SIGCHLDWaker} which is used to properly notice child process termination. c C` sE | j sA | j | � | _ | j j | j � | j | j � n d S( s� Install a `waker' to allow threads and signals to wake up the IO thread. We use the self-pipe trick (http://cr.yp.to/docs/selfpipe.html) to wake the reactor. On Windows we use a pair of sockets. N( t wakert _wakerFactoryt _internalReaderst addt addReader( R2 ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt installWaker s c C` s{ t j | � t d k rw t rw | j s] t | � | _ | j j | j � | j | j � n | j j � t j � n d S( s� Extend the basic signal handling logic to also support handling SIGCHLD to know when to try to reap child processes. R N( R t _handleSignalsR t processEnabledt _childWakerR\ Rt Ru Rv R^ R R` ( R2 ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyRx " s c C` s | j r | j j � n d S( s� If a child waker was created and installed, uninstall it now. Since this disables reactor functionality and is only called when the reactor is stopping, it doesn't provide any directly useful functionality, but the cleanup of reactor-related process-global state that it does helps in unit tests involving multiple reactors and is generally just a nice thing. N( Rz R_ ( R2 ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt _uninstallHandler5 s i c C` sL | j | | � \ } } t d k r� | rj | d k rE t d � � n t j | | | | | | | | | � St j | | | | | | | | | � Sn� t d k r<| d k r� t d � � n | d k r� t d � � n | r� t d � � n | r� t d � � n t r-d d l m } | | | | | | | � St d � � n t d � � d S( NR s1 Using childFDs is not supported with usePTY=True.t win32s, Setting UID is unsupported on this platform.s, Setting GID is unsupported on this platform.s1 The usePTY parameter is not supported on Windows.s1 Customizing childFDs is not supported on Windows.i ( t Processs: spawnProcess not available since pywin32 is not installed.s0 spawnProcess only available on Windows or POSIX.( t _checkProcessArgsR RR t ValueErrorR t PTYProcessR} t win32processt twisted.internet._dumbwin32proct NotImplementedError( R2 t processProtocolt executableR; t envt patht uidt gidt usePTYt childFDsR} ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt spawnProcessH s2 RL i c C` s) t j | | | | | � } | j � | S( s� Connects a given L{DatagramProtocol} to the given numeric UDP port. @returns: object conforming to L{IListeningPort}. ( R t Portt startListening( R2 t portt protocolt interfacet maxPacketSizet p( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt listenUDPk s c C` s, t j | | | | | | � } | j � | S( s� Connects a given DatagramProtocol to the given numeric UDP port. EXPERIMENTAL. @returns: object conforming to IListeningPort. ( R t MulticastPortR� ( R2 R� R� R� R� t listenMultipleR� ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt listenMulticastv s i c C` s; t s t d � � t j | | | | | � } | j � | S( Ns UNIX support is not present( t unixEnabledt AssertionErrorR t ConnectorR+ ( R2 t addresst factoryt timeoutt checkPIDt c( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt connectUNIX� s i2 i� c C` s> t s t d � � t j | | | | | | � } | j � | S( Ns UNIX support is not present( R� R� R R� R� ( R2 R� R� t backlogt modet wantPIDR� ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt listenUNIX� s c C` s; t s t d � � t j | | | | | � } | j � | S( s� Connects a given L{DatagramProtocol} to the given path. EXPERIMENTAL. @returns: object conforming to L{IListeningPort}. s UNIX support is not present( R� R� R t DatagramPortR� ( R2 R� R� R� R� R� ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt listenUNIXDatagram� s c C` s> t s t d � � t j | | | | | | � } | j � | S( sd Connects a L{ConnectedDatagramProtocol} instance to a path. EXPERIMENTAL. s UNIX support is not present( R� R� R t ConnectedDatagramPortR� ( R2 R� R� R� R� t bindAddressR� ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt connectUNIXDatagram� s c C` sz | | j k r! t j | � � n t rQ | t j k rQ t j j | | | � } n t j j | | | | � } | j � | S( s0 Create a new L{IListeningPort} from an already-initialized socket. This just dispatches to a suitable port implementation (eg from L{IReactorTCP}, etc) based on the specified C{addressFamily}. @see: L{twisted.internet.interfaces.IReactorSocket.adoptStreamPort} ( t _supportedAddressFamiliesR t UnsupportedAddressFamilyR� R# t AF_UNIXR R� t _fromListeningDescriptorR R� ( R2 t fileDescriptort addressFamilyR� R� ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt adoptStreamPort� s c C` si | | j k r! t j | � � n t rL | t j k rL t j j | | | � St j j | | | | � Sd S( sg @see: L{twisted.internet.interfaces.IReactorSocket.adoptStreamConnection} N( R� R R� R� R# R� R t Servert _fromConnectedSocketR ( R2 R� R� R� ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt adoptStreamConnection� s c C` sY | t j t j f k r* t j | � � n t j j | | | | d | �} | j � | S( NR� ( R# R$ t AF_INET6R R� R R� R� R� ( R2 R� R� R� R� R� ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt adoptDatagramPort� s c C` s) t j | | | | | � } | j � | S( N( R R� R� ( R2 R� R� R� R� R� ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt listenTCP� s c C` s, t j | | | | | | � } | j � | S( N( R R� R+ ( R2 t hostR� R� R� R� R� ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt connectTCP� s c C` s� t d k r: t j | t | � } | j | | | | | � St d k ru t j | | | | | | | � } | j � | St s� t d � � d S( Ns SSL support is not present( R RR t TLSMemoryBIOFactoryt TrueR� R R� R+ t FalseR� ( R2 R� R� R� t contextFactoryR� R� t tlsFactoryR� ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt connectSSL� s c C` s� t d k rF t j | t | � } | j | | | | � } d | _ | St d k r~ t j | | | | | | � } | j � | St s� t d � � d S( Nt TLSs SSL support is not present( R RR R� R� R� t _typeR R� R� R� ( R2 R� R� R� R� R� R� R� ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt listenSSL s c C` si t | � | j } x | D] } | j | � q Wt | � } x | D] } | j | � qD Wt | | B� S( sg Remove all readers and writers, and list of removed L{IReadDescriptor}s and L{IWriteDescriptor}s. Meant for calling from subclasses, to implement removeAll, like:: def removeAll(self): return self._removeAll(self._reads, self._writes) where C{self._reads} and C{self._writes} are iterables. ( t setRt Rb Rh t list( R2 t readerst writerst removedReadersR5 t removedWriterst writer( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt _removeAll s N( ( RE RF RG t _WakerRs Rw RR Rz Rx R{ R� R� R� R� R� R� R� R� R� R# R$ R� R� R� R� R� R� R� R� R� R� R� ( ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyRq s8 ! t _PollLikeMixinc B` s e Z d Z d � Z RS( s� Mixin for poll-like reactors. Subclasses must define the following attributes:: - _POLL_DISCONNECTED - Bitmask for events indicating a connection was lost. - _POLL_IN - Bitmask for events indicating there is input to read. - _POLL_OUT - Bitmask for events indicating output can be written. Must be mixed in to a subclass of PosixReactorBase (for _disconnectSelectable). c C` s� d } t } | | j @rN | | j @ rN | | j k rE t } t } q� t } n� yj | j � d k rl t } nK | | j @r� | j � } t } n | r� | | j @r� | j � } t } n Wn! t j � d } t j � n X| r� | j | | | � n d S( sg fd is available for read or write, do the work and raise errors if necessary. i����i N( RR R� t _POLL_DISCONNECTEDt _POLL_INt _readsR� R R R1 t _NO_FILEDESCRA t _POLL_OUTt doWritet syst exc_infoR t errRo ( R2 Rj RW t eventRk t inRead( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt _doReadOrWrite< s* ( RE RF RG R� ( ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyR� - s t _ContinuousPollingc B` s� 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 d � Z d � Z d � Z d � Z RS( s� Schedule reads and writes based on the passage of time, rather than notification. This is useful for supporting polling filesystem files, which C{epoll(7)} does not support. The implementation uses L{_PollLikeMixin}, which is a bit hacky, but re-implementing and testing the relevant code yet again is unappealing. @ivar _reactor: The L{EPollReactor} that is using this instance. @ivar _loop: A C{LoopingCall} that drives the polling, or L{None}. @ivar _readers: A C{set} of C{FileDescriptor} objects that should be read from. @ivar _writers: A C{set} of C{FileDescriptor} objects that should be written to. i i i c C` s. | | _ d | _ t � | _ t � | _ d S( N( t _reactorRR t _loopR� t _readerst _writers( R2 R" ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyR7 � s c C` s� | j s | j rt | j d k r� d d l m } m } | | j � | _ | j | j _ | j j | d t �q� n" | j r� | j j � d | _ n d S( sh Start or stop a C{LoopingCall} based on whether there are readers and writers. i ( t LoopingCallt _EPSILONt nowN( R� R� R� RR t twisted.internet.taskR� R� t iterateR� t clockt startR� t stop( R2 R� R� ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt _checkLoop� s c C` sd x- t | j � D] } | j | | | j � q Wx- t | j � D] } | j | | | j � q@ Wd S( sX Call C{doRead} and C{doWrite} on all readers and writers respectively. N( R� R� R� R� R� R� ( R2 R5 R� ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyR� � s c C` s | j j | � | j � d S( sU Add a C{FileDescriptor} for notification of data available to read. N( R� Ru R� ( R2 R5 ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyRv � s c C` s | j j | � | j � d S( sV Add a C{FileDescriptor} for notification of data available to write. N( R� Ru R� ( R2 R� ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt addWriter� s c C` s7 y | j j | � Wn t k r( d SX| j � d S( sY Remove a C{FileDescriptor} from notification of data available to read. N( R� t removet KeyErrorR� ( R2 R5 ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyRb � s c C` s7 y | j j | � Wn t k r( d SX| j � d S( sb Remove a C{FileDescriptor} from notification of data available to write. N( R� R� R� R� ( R2 R� ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyRh � s c C` s4 t | j | j B� } | j j � | j j � | S( s1 Remove all readers and writers. ( R� R� R� t clear( R2 t result( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt removeAll� s c C` s t | j � S( s/ Return a list of the readers. ( R� R� ( R2 ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt getReaders� s c C` s t | j � S( s/ Return a list of the writers. ( R� R� ( R2 ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt getWriters� s c C` s | | j k S( sj Checks if the file descriptor is currently being observed for read readiness. @param fd: The file descriptor being checked. @type fd: L{twisted.internet.abstract.FileDescriptor} @return: C{True} if the file descriptor is being observed for read readiness, C{False} otherwise. @rtype: C{bool} ( R� ( R2 RW ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt isReading� s c C` s | | j k S( sl Checks if the file descriptor is currently being observed for write readiness. @param fd: The file descriptor being checked. @type fd: L{twisted.internet.abstract.FileDescriptor} @return: C{True} if the file descriptor is being observed for write readiness, C{False} otherwise. @rtype: C{bool} ( R� ( R2 RW ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt isWriting s ( RE RF RG R� R� R� R7 R� R� Rv R� Rb Rh R� R� R� R� R� ( ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyR� w s t fromfd(F RG t __future__R R R# R< RM R� t zope.interfaceR R t twisted.internetR R R t twisted.internet.baseR R t twisted.internet.mainR R t twisted.internet.interfacesR R R R R R R R R R t twisted.pythonR R R t twisted.python.runtimeR R t ConnectionFdescWentAwayt _NO_FILENOR� t twisted.protocolsR t ImportErrorRR R R� R� Ry R R R R R� t isWindowsR� t LoggerR! t objectRI RX R� R\ Ra Rq R� R� t getattrt __all__( ( ( s] /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/posixbase.pyt <module> st F 2 4 ( � &J �