+
    Dfj                    &   R t ^ RIHt ^ RIHt ^ RIHtHt ^ RIH	t	H
t
 ^ RIHt ^ RIHt ]! 4       t]! ]P                   4       ! R R4      4       t]! ]P$                  ]P&                  ]P(                  ]P*                  4       ! R	 R
4      4       tR# )zStandard 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
)annotations)implementer)
interfacesprocess)	IProtocolIReactorFDSet)Logger)Failurec                      ] tR t^tRtR# )PipeAddress N)__name__
__module____qualname____firstlineno____static_attributes__r       >/usr/lib/python3/dist-packages/twisted/internet/_posixstdio.pyr   r      s    r   r   c                      ] tR t^tRtRtRtRtRR R lltR t	R t
R tR tR	 tR
 tR R ltR R ltR tR R ltR R ltR tR tR tR tR tR tR tR tR tRtR# )
StandardIONFc               (    V ^8  d   QhRRRRRRRR/# )   protor   stdinintstdoutreactorzIReactorFDSet | Noner   )formats   "r   __annotate__StandardIO.__annotate__*   s2     + ++ + 	+
 &+r   c                	   Vf   ^ RI Hp Wn        \        P                  ! W@RV4      V n        \        P                  ! W@RV4      V n        V P                  P                  4        V P                  P                  V 4       R # )N)r   writeread)
twisted.internetr   protocolr   ProcessWriter_writerProcessReader_readerstartReadingmakeConnection)selfr   r   r   r   s   &&&&&r   __init__StandardIO.__init__*   s_     ?0#(,,WGVL,,WFEJ!!#$$T*r   c                	Z    V P                   e   V P                   P                  4        R # R # N)r&   loseConnectionr+   s   &r   loseWriteConnectionStandardIO.loseWriteConnection=   !    <<#LL'') $r   c                	\    V P                   e   V P                   P                  V4       R # R # r/   )r&   r!   r+   datas   &&r   r!   StandardIO.writeA   s#    <<#LLt$ $r   c                	\    V P                   e   V P                   P                  V4       R # R # r/   )r&   writeSequencer6   s   &&r   r:   StandardIO.writeSequenceE   s#    <<#LL&&t, $r   c                	    R V n         V P                  e   V P                  P                  4        V P                  e   V P                  P	                  4        R# R# )TN)disconnectingr&   r0   r(   stopReadingr1   s   &r   r0   StandardIO.loseConnectionI   sC    !<<#LL'')<<#LL$$& $r   c                	    \        4       # r/   r   r1   s   &r   getPeerStandardIO.getPeerR   
    }r   c                	    \        4       # r/   rA   r1   s   &r   getHostStandardIO.getHostU   rD   r   c               $    V ^8  d   QhRRRRRR/# )r   fdstrr7   bytesreturnNoner   )r   s   "r   r   r   Y   s!     ) )C )u ) )r   c                	<    V P                   P                  V4       R # r/   )r$   dataReceived)r+   rI   r7   s   &&&r   childDataReceivedStandardIO.childDataReceivedY   s    ""4(r   c               $    V ^8  d   QhRRRRRR/# )r   rI   rJ   reasonr	   rL   rM   r   )r   s   "r   r   r   \   s!     . .c .7 .t .r   c                	    V P                   '       d   R # VR8X  d   V P                  V4       R # V P                  V4       R # )Nr"   )disconnected_readConnectionLost_writeConnectionLost)r+   rI   rS   s   &&&r   childConnectionLostStandardIO.childConnectionLost\   s4    <$$V,%%f-r   c                	   R V n         V P                  pV P                  pV P                  pR;V n        V n        RV n        Ve$   VP                   '       g   VP	                  V4       Ve$   VP                   '       g   VP	                  V4       \
        P                  R4      ;_uu_ 4        VP	                  V4       RRR4       R#   + '       g   i     R# ; i)TNz#while calling stdio connectionLost:)rU   r(   r&   r$   connectionLost_logfailuresHandled)r+   rS   r(   r&   r$   s   &&   r   r[   StandardIO.connectionLostd   s      ,,,,==&**t|w';';';""6*w';';';""6*!!"GHH##F+ IHHHs   ,CC	c                    V ^8  d   QhRRRR/# r   rS   r	   rL   rM   r   )r   s   "r   r   r   w   s     1 17 1t 1r   c                	   R V n         V P                  '       d   V P                  V4       R # \        P                  ! V P
                  R 4      pV'       dh   \        P                  R4      ;_uu_ 4       pVP                  4        R R R 4       XP                  '       d   V P                  VP                  4       R # R # R #   + '       g   i     LC; i)Nz(while calling stdio writeConnectionLost:)r&   r=   r[   r   IHalfCloseableProtocolr$   r\   r]   writeConnectionLostfailedfailure)r+   rS   pwcls   &&  r   rW   StandardIO._writeConnectionLostw   s    '--dmmTB%%: %%' zzz##CKK0   s   3B??C	c                    V ^8  d   QhRRRR/# r`   r   )r   s   "r   r   r      s     	( 	(' 	(d 	(r   c                	|   R V n         \        P                  ! V P                  R 4      pV'       dh   \        P                  R4      ;_uu_ 4       pVP                  4        R R R 4       XP                  '       d   V P                  VP                  4       R # R # V P                  V4       R #   + '       g   i     LT; i)Nz'while calling stdio readConnectionLost:)
r(   r   rb   r$   r\   r]   readConnectionLostrd   r[   re   )r+   rS   rf   rcls   &&  r   rV   StandardIO._readConnectionLost   s    --dmmTB%%&OPPTW$$& Qzzz##CKK0  ' QPs   B++B;	c                	|    V P                   f   VP                  4        R # V P                   P                  W4       R # r/   )r&   stopProducingregisterProducer)r+   producer	streamings   &&&r   rp   StandardIO.registerProducer   s*    <<""$LL))(>r   c                	Z    V P                   e   V P                   P                  4        R # R # r/   )r&   unregisterProducerr1   s   &r   ru   StandardIO.unregisterProducer   s!    <<#LL++- $r   c                	&    V P                  4        R # r/   )r0   r1   s   &r   ro   StandardIO.stopProducing   s    r   c                	Z    V P                   e   V P                   P                  4        R # R # r/   )r(   pauseProducingr1   s   &r   rz   StandardIO.pauseProducing   r4   r   c                	Z    V P                   e   V P                   P                  4        R # R # r/   )r(   resumeProducingr1   s   &r   r}   StandardIO.resumeProducing   s!    <<#LL((* $r   c                &    V P                  4        R# )z3Compatibility only, don't use. Call pauseProducing.N)rz   r1   s   &r   r>   StandardIO.stopReading   s    r   c                &    V P                  4        R# )z4Compatibility only, don't use. Call resumeProducing.N)r}   r1   s   &r   r)   StandardIO.startReading   s    r   c                	    \        4       hr/   NotImplementedErrorr+   rS   s   &&r   rk   StandardIO.readConnectionLost       !##r   c                	    \        4       hr/   r   r   s   &&r   rc   StandardIO.writeConnectionLost   r   r   )r(   r&   rU   r=   r$   )       N)r   r   r   r   r(   r&   rU   r=   r,   r2   r!   r:   r0   rB   rF   rP   rX   r[   rW   rV   rp   ru   ro   rz   r}   r>   r)   rk   rc   r   r   r   r   r   r      s     GGLM+&*%-').,&1	(?.
*+$$r   r   N)__doc__
__future__r   zope.interfacer   r#   r   r   twisted.internet.interfacesr   r   twisted.loggerr   twisted.python.failurer	   r\   IAddressr   
ITransport	IProducer	IConsumerIHalfCloseableDescriptorr   r   r   r   <module>r      s   	 # & 0 @ ! *x Z  !	 	 "	 ''	R$ R$R$r   