ó {íKc@sœdZddlZddlZddlZddlmZddlmZmZm Z ddl m Z m Z de fd„ƒYZde fd „ƒYZdS( 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(((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pyRst StandardIOcBsùeZeejejejejƒdZ dZ e Z e Z ddd„Zd„Zd„Zd„Zd„Zd„Zd„Zd „Zd „Zd „Zd „Zd „Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z!RS(iicCsÑddlm}||_tj||d|ƒ|_y|jjƒWnMtk r”}|jtj krŽt d|t j |ƒj fƒ‚n‚nXtj||d|ƒ|_|jjƒ|jj|ƒdS(Niÿÿÿÿ(treactortwrites’This reactor does not support this type of file descriptor (fd %d, mode %d) (for example, epollreactor does not support normal files. See #4429).tread(ttwisted.internetR tprotocolRt ProcessWritert_writert startReadingtIOErrorterrnotEPERMt RuntimeErrortostfstattst_modet ProcessReadert_readertmakeConnection(tselftprototstdintstdoutR te((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pyt__init__ s  cCs#|jdk r|jjƒndS(N(RtNonetloseConnection(R((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pytloseWriteConnection:scCs&|jdk r"|jj|ƒndS(N(RR#R (Rtdata((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pyR >scCs&|jdk r"|jj|ƒndS(N(RR#t writeSequence(RR&((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pyR'BscCsKt|_|jdk r(|jjƒn|jdk rG|jjƒndS(N(tTruet disconnectingRR#R$Rt stopReading(R((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pyR$Fs  cCstƒS(N(R(R((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pytgetPeerOscCstƒS(N(R(R((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pytgetHostRscCs|jj|ƒdS(N(Rt dataReceived(RtfdR&((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pytchildDataReceivedWscCs_|jr dS|jjtjkrN|dkr>|j|ƒq[|j|ƒn |j|ƒdS(NR (t disconnectedtvaluet __class__RtConnectionDonet_readConnectionLostt_writeConnectionLosttconnectionLost(RR.treason((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pytchildConnectionLostZs  cCs²t|_|j}|j}|j}d|_|_d|_|dk rc|j rc|j|ƒn|dk r‰|j r‰|j|ƒny|j|ƒWntjƒnXdS(N( R(R0RRRR#R6Rterr(RR7RRR((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pyR6gs     cCszd|_|jr#|j|ƒdStj|jdƒ}|rvy|jƒWqvtj ƒ|jt j ƒƒqvXndS(N( R#RR)R6RtIHalfCloseableProtocolRtwriteConnectionLostRR9RtFailure(RR7tp((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pyR5|s    cCsmd|_tj|jdƒ}|r\y|jƒWqitjƒ|jt j ƒƒqiXn |j|ƒdS(N( R#RRR:RtreadConnectionLostRR9R6RR<(RR7R=((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pyR4Šs  cCs3|jdkr|jƒn|jj||ƒdS(N(RR#t stopProducingtregisterProducer(Rtproducert streaming((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pyR@—s cCs#|jdk r|jjƒndS(N(RR#tunregisterProducer(R((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pyRCscCs|jƒdS(N(R$(R((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pyR?¢scCs#|jdk r|jjƒndS(N(RR#tpauseProducing(R((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pyRD¥scCs#|jdk r|jjƒndS(N(RR#tresumeProducing(R((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pyRE©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((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pyt closeStdin®s  cCs|jƒdS(s3Compatibility only, don't use. Call pauseProducing.N(RD(R((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pyR*´scCs|jƒdS(s4Compatibility only, don't use. Call resumeProducing.N(RE(R((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pyR¸sN("RRRRt ITransportt IProducert IConsumertIHalfCloseableDescriptorR#RRtFalseR0R)R"R%R R'R$R+R,R/R8R6R5R4R@RCR?RDRERKR*R(((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pyR s2               (t__doc__RHRRtzope.interfaceRRRRRttwisted.pythonRRtobjectRR (((s@/usr/lib/python2.7/dist-packages/twisted/internet/_posixstdio.pyt s $