+
    üÐ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# )zÚ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
)Ú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Ø#(Œä×,Ò,¨W¸GÀVÓLˆŒÜ×,Ò,¨W¸FÀEÓJˆŒØ�‰×!Ñ!Ô#Ø�‰×$Ñ$ TÖ*r   c                	óZ   € V P                   e   V P                   P                  4        R # R # ©N)r&   ÚloseConnection©r+   s   &r   ÚloseWriteConnectionÚStandardIO.loseWriteConnection=   ó!   € Ø�<‰<Ò#Ø�L‰L×'Ñ'Ö)ñ $r   c                	ó\   € V P                   e   V P                   P                  V4       R # R # r/   )r&   r!   ©r+   Údatas   &&r   r!   ÚStandardIO.writeA   s#   € Ø�<‰<Ò#Ø�L‰L×Ñ˜tÖ$ñ $r   c                	ó\   € V P                   e   V P                   P                  V4       R # R # r/   )r&   ÚwriteSequencer6   s   &&r   r:   ÚStandardIO.writeSequenceE   s#   € Ø�<‰<Ò#Ø�L‰L×&Ñ& 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   € Ø!ˆÔà�<‰<Ò#Ø�L‰L×'Ñ'Ô)Ø�<‰<Ò#à�L‰L×$Ñ$Ö&ñ $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ÒHús   Â,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ñ 1¨7ð 1°tñ 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›   € ØˆŒØ××ÐØ×Ñ Ô'Ùä×-Ò-¨d¯m©m¸TÓBˆßÜ×%Ñ%Ø:÷ô àØ×%Ñ%Ô'÷ð �z�zˆzØ×#Ñ# C§K¡KÖ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ƒ   € ØˆŒÜ×-Ò-¨d¯m©m¸TÓBˆßÜ×%Ñ%Ð&O×PÔPÐTWØ×$Ñ$Ô&÷ Qà�z�zˆzØ×#Ñ# C§K¡KÖ0ñ ð ×Ñ Ö'÷ Q×Pús   Á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*   € Ø�<‰<ÒØ×"Ñ"Ö$à�L‰L×)Ñ)¨(Ö>r   c                	óZ   € V P                   e   V P                   P                  4        R # R # r/   )r&   ÚunregisterProducerr1   s   &r   ru   ÚStandardIO.unregisterProducer˜   s!   € Ø�<‰<Ò#Ø�L‰L×+Ñ+Ö-ñ $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!   € Ø�<‰<Ò#Ø�L‰L×(Ñ(Ö*ñ $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   