ó B[~Mc@sGdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ej ƒZ de _ ddl mZddlmZmZmZddlmZddlmZddlmZdd lmZd „Zd ejfd „ƒYZd „Zd„Zdejefd„ƒYZ dS(s4 http://isometric.sixsided.org/_/gates_in_the_head/ iÿÿÿÿNi(t implements(tIProcessTransportt IConsumert IProducer(tquoteArguments(terror(t _pollingfile(t BaseProcesscCs"ddl}|GH|jjƒdS(Niÿÿÿÿ(tsyststdouttflush(tmsgR((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pytdebug$s t_ReapercBseZd„Zd„ZRS(cCs ||_dS(N(tproc(tselfR((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyt__init__+scCsXtj|jjdƒtjkr%dStj|jjƒ}|jƒ|jj|ƒdS(Ni( t win32eventtWaitForSingleObjectRthProcesst WAIT_OBJECT_0t win32processtGetExitCodeProcesst deactivatet processEnded(RtexitCode((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyt checkWork.s ! (t__name__t __module__RR(((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyR )s cCsDt|dƒ}|jdƒdkr@|jdƒjdƒ}|SdS(s  Look for a #! line, and return the value following the #! if one exists, or None if this file is not a script. I don't know if there are any conventions for quoting in Windows shebang lines, so this doesn't support any; therefore, you may not pass any arguments to scripts invoked as filters. That's probably wrong, so if somebody knows more about the cultural expectations on Windows, please feel free to fix. This shebang line support was added in support of the CGI tests; appropriately enough, I determined that shebang lines are culturally accepted in the Windows world through this page:: http://www.cgi101.com/learn/connect/winxp.html @param filename: str representing a filename @return: a str representing another filename. trUis#!is N(tfiletreadtreadlinetstrip(tfilenametftexe((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyt _findShebang7scCs|jddkS(sù Determine if a pywintypes.error is telling us that the given process is 'not a valid win32 application', i.e. not a PE format executable. @param pywinerr: a pywintypes.error instance raised by CreateProcess @return: a boolean iiÁ(targs(tpywinerr((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyt_invalidWin32AppQstProcesscBsáeZdZeeeeƒdZd„Zd„Z d„Z d„Z d„Z d„Z d„Zd „Zd „Zd „Zd „Zd „Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„ZRS(s•A process that integrates with the Twisted event loop. If your subprocess is a python program, you need to: - Run python.exe with the '-u' command line option - this turns on unbuffered I/O. Buffering stdout/err/in can cause problems, see e.g. http://support.microsoft.com/default.aspx?scid=kb;EN-US;q1903 - If you don't want Windows messing with data passed over stdin/out/err, set the pipes to be in binary mode:: import os, sys, mscvrt msvcrt.setmode(sys.stdin.fileno(), os.O_BINARY) msvcrt.setmode(sys.stdout.fileno(), os.O_BINARY) msvcrt.setmode(sys.stderr.fileno(), os.O_BINARY) ics6tjjˆ|ƒtjˆ|ƒtjƒ}d|_tj|dƒ\ˆ_ }tj|dƒ\ˆ_ } tj|dƒ\} ˆ_ tj ˆj tj d d ƒtjƒ‰|ˆ_| ˆ_| ˆ_tjˆ_tjƒ} tj| ˆj | ddtjƒ} tjˆj ƒ| ˆ_ tj| ˆj | ddtjƒ} tjˆj ƒ| ˆ_ tj| ˆj | ddtjƒ} tjˆj ƒ| ˆ_ tjjƒ‰ˆj |p¹iƒt!|ƒ‰‡‡‡‡‡‡fd†} y€y | ƒWnnt"k re}|j#d kr‚ni}x0ˆj$ƒD]"\}}t%|ƒ|t%|ƒæscsˆjjd|ƒS(Ni(R5R6(R7(R(sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyR8ësN(s<All dictionary items must be strings, or all must be unicode(9Rt _PollingTimerRRt win32securitytSECURITY_ATTRIBUTEStbInheritHandlet win32pipet CreatePipethStdoutRthStderrRthStdinWtSetNamedPipeHandleStatet PIPE_NOWAITR+Rt STARTUPINFOt hStdOutputt hStdErrort hStdInputtSTARTF_USESTDHANDLEStdwFlagstwin32apitGetCurrentProcesstDuplicateHandletwin32contDUPLICATE_SAME_ACCESSt win32filet CloseHandletostenvirontcopytupdateRt TypeErrorR&titemstunicodet pywintypesRR(tOSErrorR%tlisttinsertt_PollableReadPipetoutConnectionLostR terrConnectionLosttstderrt_PollableWritePipetinConnectionLosttstdint_addPollableResourceR5tmakeConnectionR (RtreactortprotocolR1R&t environmentR3tsAttrsthStdoutWthStderrWthStdinRt currentPidttmpR4tetnewenvtkeytvaluetpwtetshebtorigcmdtpwte2t pipewatcher((R0R/RR2R1R3sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyRws¤                              cCsD|jdkrtjƒ‚n|dkr@tj|jdƒndS(NtINTtTERMtKILLi(RwRxRy(R-R+RtProcessExitedAlreadyRtTerminateProcessR(RtsignalID((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyt signalProcessûs cCs&|dkrtj|ƒStj|ƒS(Ni(Rt ProcessDonetProcessTerminated(Rtstatus((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyt _getReasons  cCs|jj|ƒdS(s!Write data to the process' stdin.N(Rbtwrite(RR7((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyR‚scCs|jj|ƒdS(s!Write data to the process' stdin.N(Rbt writeSequence(Rtseq((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyRƒ scCs[|dkr|jƒn>|dkr2|jƒn%|dkrK|jƒn tdƒ‚dS(Niiis4Only standard-IO file descriptors available on win32(t closeStdint closeStdoutt closeStderrtNotImplementedError(Rtfd((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyt closeChildFDs      cCs|jjƒdS(s"Close the process' stdin. N(Rbtclose(R((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyR…scCs|jjƒdS(N(R_R‹(R((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyR‡scCs|jjƒdS(N(R R‹(R((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyR†"scCs"|jƒ|jƒ|jƒdS(s&Close the process' stdout, in and err.N(R…R†R‡(R((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pytloseConnection%s  cCs|jjdƒ|jƒdS(Ni(R5tchildConnectionLosttconnectionLostNotify(R((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyR],scCs|jjdƒ|jƒdS(Ni(R5RRŽ(R((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyR^1scCs|jjdƒ|jƒdS(Ni(R5RRŽ(R((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyRa6scCs|jd7_|jƒdS(sS Will be called 3 times, by stdout/err threads and process handle. iN(tclosedNotifiestmaybeCallProcessEnded(R((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyRŽ;scCs^|jdkrZ|jrZtj|jƒtj|jƒd|_d|_tj|ƒndS(Ni( Rt lostProcessRORPRR,R+RR(R((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyRCs   cCs|jj||ƒdS(N(RbtregisterProducer(Rtproducert streaming((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyR’MscCs|jjƒdS(N(RbtunregisterProducer(R((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyR•PscCs|jƒdS(N(t_pause(R((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pytpauseProducingTscCs|jƒdS(N(t_unpause(R((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pytresumeProducingWscCs|jƒdS(N(RŒ(R((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyt stopProducingZscCsd|jj|jfS(s@ Return a string representation of the process. s <%s pid=%s>(t __class__RR-(R((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyt__repr__^s(RRt__doc__RRRRRRR}RR‚RƒRŠR…R‡R†RŒR]R^RaRŽRR’R•R—R™RšRœ(((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyR)as0 „                 (!RRQRJRMRROR=RR:RXR;tPIPE_ATTRS_INHERITABLER<tzope.interfaceRttwisted.internet.interfacesRRRttwisted.python.win32Rttwisted.internetRRttwisted.internet._baseprocessRR t_PollableResourceR R%R(R9R)(((sC/usr/lib/python2.7/dist-packages/twisted/internet/_dumbwin32proc.pyts,