ó ®$¤Oc@s„dZddlZddlmZddlmZmZmZddlm Z m Z de fd„ƒYZ de fd „ƒYZ dS( 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ÿÿÿÿN(t implements(tprocessterrort interfaces(tlogtfailuret PipeAddresscBseZeejƒRS((t__name__t __module__RRtIAddress(((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pyRst StandardIOcBsüeZeejejejejƒdZ dZ e Z e Z dddd„Zd„Zd„Zd„Zd„Zd„Zd„Zd „Zd „Zd „Zd „Zd „Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z!RS(iicCs|dkrddlm}n||_tj||d|ƒ|_tj||d|ƒ|_|jj ƒ|jj |ƒdS(Niÿÿÿÿ(treactortwritetread( tNonettwisted.internetR tprotocolRt ProcessWritert_writert ProcessReadert_readert startReadingtmakeConnection(tselftprototstdintstdoutR ((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pyt__init__"s   cCs#|jdk r|jjƒndS(N(RRtloseConnection(R((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pytloseWriteConnection/scCs&|jdk r"|jj|ƒndS(N(RRR (Rtdata((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pyR 3scCs&|jdk r"|jj|ƒndS(N(RRt writeSequence(RR((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pyR7scCsKt|_|jdk r(|jjƒn|jdk rG|jjƒndS(N(tTruet disconnectingRRRRt stopReading(R((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pyR;s  cCstƒS(N(R(R((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pytgetPeerDscCstƒS(N(R(R((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pytgetHostGscCs|jj|ƒdS(N(Rt dataReceived(RtfdR((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pytchildDataReceivedLscCs_|jr dS|jjtjkrN|dkr>|j|ƒq[|j|ƒn |j|ƒdS(NR (t disconnectedtvaluet __class__RtConnectionDonet_readConnectionLostt_writeConnectionLosttconnectionLost(RR&treason((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pytchildConnectionLostOs  cCs²t|_|j}|j}|j}d|_|_d|_|dk rc|j rc|j|ƒn|dk r‰|j r‰|j|ƒny|j|ƒWntjƒnXdS(N( R R(RRRRR.Rterr(RR/RRR((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pyR.\s     cCszd|_|jr#|j|ƒdStj|jdƒ}|rvy|jƒWqvtj ƒ|jt j ƒƒqvXndS(N( RRR!R.RtIHalfCloseableProtocolRtwriteConnectionLostRR1RtFailure(RR/tp((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pyR-qs    cCsmd|_tj|jdƒ}|r\y|jƒWqitjƒ|jt j ƒƒqiXn |j|ƒdS(N( RRRR2RtreadConnectionLostRR1R.RR4(RR/R5((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pyR,s  cCs3|jdkr|jƒn|jj||ƒdS(N(RRt stopProducingtregisterProducer(Rtproducert streaming((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pyR8Œs cCs#|jdk r|jjƒndS(N(RRtunregisterProducer(R((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pyR;’scCs|jƒdS(N(R(R((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pyR7—scCs#|jdk r|jjƒndS(N(RRtpauseProducing(R((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pyR<šscCs#|jdk r|jjƒndS(N(RRtresumeProducing(R((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pyR=žscCs'tjddtddƒ|jƒdS(s;Compatibility only, don't use. Same as loseWriteConnection.s=This function is deprecated, use loseWriteConnection instead.tcategoryt stackleveliN(twarningstwarntDeprecationWarningR(R((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pyt closeStdin£s  cCs|jƒdS(s3Compatibility only, don't use. Call pauseProducing.N(R<(R((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pyR"©scCs|jƒdS(s4Compatibility only, don't use. Call resumeProducing.N(R=(R((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pyR­sN("RRRRt ITransportt IProducert IConsumertIHalfCloseableDescriptorRRRtFalseR(R!RRR RRR#R$R'R0R.R-R,R8R;R7R<R=RCR"R(((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pyR s4               (t__doc__R@tzope.interfaceRRRRRttwisted.pythonRRtobjectRR (((sN/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/internet/_posixstdio.pyt s