+
    üÐj¥  ã                   óî   € R t ^ RIt^ RIt^ RIHt ^ RIt^ RIHtHt ^ RI	H
t
HtHtHtHt ^ RIHt ^ RIHt ]! 4       t]! ]
4       ! R R4      4       t]! ]]]4       ! R	 R
]P*                  4      4       tR# )zM
Windows-specific implementation of the L{twisted.internet.stdio} interface.
N)Úimplementer)Ú_pollingfileÚmain)ÚIAddressÚ	IConsumerÚIHalfCloseableProtocolÚIPushProducerÚ
ITransport)ÚLogger)ÚFailurec                   ó   € ] tR t^tRtR# )ÚWin32PipeAddress© N)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__static_attributes__r   ó    Ú>/usr/lib/python3/dist-packages/twisted/internet/_win32stdio.pyr   r      s   † ãr   r   c                   óŠ   a € ] tR t^"t o RtRtRR ltR tR tR t	^ t
R tR tR	 tR
 tR tR tR tR tR tR tR tRtV tR# )Ú
StandardIOFNc                ó²  € Vf   ^ RI Hp \        ^ ^^4       F(  p\        P                  ! V\
        P                  4       K*  	  \        P                  P                  W4       Wn
        \        P                  ! \        P                  4      p\        P                  ! \        P                  4      p\        P                  ! W@P                   V P"                  4      V n        \        P&                  ! WPP(                  4      V n        V P-                  V P$                  4       V P-                  V P*                  4       V P                  P/                  V 4       R# )zk
Start talking to standard IO with the given protocol.

Also, put it stdin/stdout/stderr into binary mode.
N)Úreactor)Útwisted.internetr   ÚrangeÚmsvcrtÚsetmodeÚosÚO_BINARYr   Ú_PollingTimerÚ__init__ÚprotoÚwin32apiÚGetStdHandleÚSTD_INPUT_HANDLEÚSTD_OUTPUT_HANDLEÚ_PollableReadPipeÚdataReceivedÚreadConnectionLostÚstdinÚ_PollableWritePipeÚwriteConnectionLostÚstdoutÚ_addPollableResourceÚmakeConnection)Úselfr"   r   ÚstdfdÚhstdinÚhstdouts   &&&   r   r!   ÚStandardIO.__init__'   sê   € ð Š?Ý0ä˜1˜a –^ˆEÜ�NŠN˜5¤"§+¡+Ö.ñ $ô 	×"Ñ"×+Ñ+¨DÔ:ØŒ
ä×&Ò&¤x×'@Ñ'@ÓAˆÜ×'Ò'¬×(BÑ(BÓCˆä!×3Ò3Ø×%Ñ% t×'>Ñ'>ó
ˆŒ
ô #×5Ò5°g×?WÑ?WÓXˆŒà×!Ñ! $§*¡*Ô-Ø×!Ñ! $§+¡+Ô.à�
‰
×!Ñ! $Ö'r   c                ó<   € V P                   P                  V4       R # ©N)r"   r(   ©r0   Údatas   &&r   r(   ÚStandardIO.dataReceivedD   s   € Ø�
‰
×Ñ Ö%r   c                óˆ  € \         P                  R 4      ;_uu_ 4       p\        P                  ! V P                  4      '       d   V P                  P                  4        RRR4       V P                  4        XP                  '       g'   V P                  '       g   V P                  4        R# R# R#   + '       g   i     LZ; i)zread connection lostN)
Ú_logÚfailuresHandledr   Ú
providedByr"   r)   ÚcheckConnLostÚ	succeededÚdisconnectingÚloseConnection©r0   Úops   & r   r)   ÚStandardIO.readConnectionLostG   s~   € Ü×!Ñ!Ð"8×9Ô9¸RÜ%×0Ò0°·±×<Ò<Ø—
‘
×-Ñ-Ô/÷ :ð 	×ÑÔØ�|�|ˆ| D×$6×$6Ð$6Ø×ÑÖ!ñ %7‰|÷	 :×9úó   žAB1Â1C	c                óˆ  € \         P                  R 4      ;_uu_ 4       p\        P                  ! V P                  4      '       d   V P                  P                  4        RRR4       V P                  4        XP                  '       g'   V P                  '       g   V P                  4        R# R# R#   + '       g   i     LZ; i)zwrite connection lostN)
r;   r<   r   r=   r"   r,   r>   r?   r@   rA   rB   s   & r   r,   ÚStandardIO.writeConnectionLostO   s~   € Ü×!Ñ!Ð"9×:Ô:¸bÜ%×0Ò0°·±×<Ò<Ø—
‘
×.Ñ.Ô0÷ ;ð 	×ÑÔØ�|�|ˆ| D×$6×$6Ð$6Ø×ÑÖ!ñ %7‰|÷	 ;×:úrE   c                óÞ   € V ;P                   ^,          un         V P                   ^8¼  dC   RV n        RV n        V P                  P	                  \        \        P                  4      4       R# R# )é   TN)Ú	connsLostr@   Údisconnectedr"   ÚconnectionLostr   r   ÚCONNECTION_DONE©r0   s   &r   r>   ÚStandardIO.checkConnLostY   sN   € Ø�Š˜!Õ�Ø�>‰>˜QÔØ!%ˆDÔØ $ˆDÔØ�J‰J×%Ñ%¤g¬d×.BÑ.BÓ&CÖDñ r   c                ó<   € V P                   P                  V4       R # r6   )r-   Úwriter7   s   &&r   rQ   ÚStandardIO.writeb   s   € Ø�‰×Ñ˜$Ör   c                óZ   € V P                   P                  R P                  V4      4       R# )r   N)r-   rQ   Újoin)r0   Úseqs   &&r   ÚwriteSequenceÚStandardIO.writeSequencee   s   € Ø�‰×Ñ˜#Ÿ(™( 3›-Ö(r   c                ó|   € R V n         V P                  P                  4        V P                  P                  4        R# )TN)r@   r*   Úcloser-   rN   s   &r   rA   ÚStandardIO.loseConnectionh   s*   € Ø!ˆÔØ�
‰
×ÑÔØ�‰×ÑÖr   c                ó   € \        4       # r6   ©r   rN   s   &r   ÚgetPeerÚStandardIO.getPeerm   ó   € ÜÓ!Ð!r   c                ó   € \        4       # r6   r\   rN   s   &r   ÚgetHostÚStandardIO.getHostp   r_   r   c                ó8   € V P                   P                  W4      # r6   )r-   ÚregisterProducer)r0   ÚproducerÚ	streamings   &&&r   rd   ÚStandardIO.registerProduceru   s   € Ø�{‰{×+Ñ+¨HÓ@Ð@r   c                ó6   € V P                   P                  4       # r6   )r-   ÚunregisterProducerrN   s   &r   ri   ÚStandardIO.unregisterProducerx   s   € Ø�{‰{×-Ñ-Ó/Ð/r   c                ó:   € V P                   P                  4        R # r6   )r*   ÚstopProducingrN   s   &r   rl   ÚStandardIO.stopProducing   s   € Ø�
‰
× Ñ Ö"r   c                ó:   € V P                   P                  4        R # r6   )r*   ÚpauseProducingrN   s   &r   ro   ÚStandardIO.pauseProducing„   s   € Ø�
‰
×!Ñ!Ö#r   c                ó:   € V P                   P                  4        R # r6   )r*   ÚresumeProducingrN   s   &r   rr   ÚStandardIO.resumeProducing‡   s   € Ø�
‰
×"Ñ"Ö$r   )rK   r@   r"   r*   r-   r6   )r   r   r   r   r@   rK   r!   r(   r)   r,   rJ   r>   rQ   rV   rA   r]   ra   rd   ri   rl   ro   rr   r   Ú__classdictcell__)Ú__classdict__s   @r   r   r   "   sh   ø‡ € à€MØ€Lô(ò:&ò"ò"ð €IòEò ò)òò
"ò"ò
Aò0ò#ò
$÷%ð %r   r   )Ú__doc__r   r   Úzope.interfacer   r#   r   r   r   Útwisted.internet.interfacesr   r   r   r   r	   Útwisted.loggerr
   Útwisted.python.failurer   r;   r   r    r   r   r   r   Ú<module>r{      s   ðñó
 Û 	å &ã ç /÷õ õ "Ý *áƒx€ñ ˆXÓ÷	ð 	ó ð	ñ ˆZ˜ MÓ2ôe%�×+Ñ+ó e%ó 3òe%r   