OwlCyberSecurity - MANAGER
Edit File: _posixstdio.pyc
� `��ac @ s� d Z d d l m Z d d l m Z m Z m Z d d l m Z m Z e e j � d e f d � � Y� Z e e j e j e j e j � d e f d � � Y� Z d S( s� Standard input/out/err support. Future Plans:: support for stderr, perhaps Rewrite to use the reactor instead of an ad-hoc mechanism for connecting protocols to transport. Maintainer: James Y Knight i����( t implementer( t processt errort interfaces( t logt failuret PipeAddressc B s e Z RS( ( t __name__t __module__( ( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyR s t StandardIOc B s� e Z d Z d Z e Z e Z d 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 � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( i i c C s | d k r d d l m } n | | _ t j | | d | � | _ t j | | d | � | _ | j j � | j j | � d S( Ni����( t reactort writet read( t Nonet twisted.internetR t protocolR t ProcessWritert _writert ProcessReadert _readert startReadingt makeConnection( t selft protot stdint stdoutR ( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyt __init__" s c C s# | j d k r | j j � n d S( N( R R t loseConnection( R ( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyt loseWriteConnection/ s c C s& | j d k r" | j j | � n d S( N( R R R ( R t data( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyR 3 s c C s& | j d k r" | j j | � n d S( N( R R t writeSequence( R R ( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyR 7 s c C sK t | _ | j d k r( | j j � n | j d k rG | j j � n d S( N( t Truet disconnectingR R R R t stopReading( R ( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyR ; s c C s t � S( N( R ( R ( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyt getPeerD s c C s t � S( N( R ( R ( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyt getHostG s c C s | j j | � d S( N( R t dataReceived( R t fdR ( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyt childDataReceivedL s c C s_ | j r d S| j j t j k rN | d k r> | j | � q[ | j | � n | j | � d S( NR ( t disconnectedt valuet __class__R t ConnectionDonet _readConnectionLostt _writeConnectionLostt connectionLost( R R% t reason( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyt childConnectionLostO s c C s� t | _ | j } | j } | j } d | _ | _ d | _ | d k rc | j rc | j | � n | d k r� | j r� | j | � n y | j | � Wn t j � n Xd S( N( R R' R R R R R- R t err( R R. R R R ( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyR- \ s c C sz d | _ | j r# | j | � d St j | j d � } | rv y | j � Wqv t j � | j t j � � qv Xn d S( N( R R R R- R t IHalfCloseableProtocolR t writeConnectionLostR R0 R t Failure( R R. t p( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyR, q s c C sm d | _ t j | j d � } | r\ y | j � Wqi t j � | j t j � � qi Xn | j | � d S( N( R R R R1 R t readConnectionLostR R0 R- R R3 ( R R. R4 ( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyR+ s c C s3 | j d k r | j � n | j j | | � d S( N( R R t stopProducingt registerProducer( R t producert streaming( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyR7 � s c C s# | j d k r | j j � n d S( N( R R t unregisterProducer( R ( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyR: � s c C s | j � d S( N( R ( R ( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyR6 � s c C s# | j d k r | j j � n d S( N( R R t pauseProducing( R ( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyR; � s c C s# | j d k r | j j � n d S( N( R R t resumeProducing( R ( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyR< � s c C s | j � d S( s3 Compatibility only, don't use. Call pauseProducing.N( R; ( R ( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyR! � s c C s | j � d S( s4 Compatibility only, don't use. Call resumeProducing.N( R< ( R ( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyR � s N( R R R R R t FalseR' R R R R R R R" R# R& R/ R- R, R+ R7 R: R6 R; R< R! R ( ( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyR s. N( t __doc__t zope.interfaceR R R R R t twisted.pythonR R t IAddresst objectR t ITransportt IProducert IConsumert IHalfCloseableDescriptorR ( ( ( s_ /opt/cpanel-ccs/.develop/virtualenv/lib/python2.7/site-packages/twisted/internet/_posixstdio.pyt <module> s