Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/internet/__pycache__/_dumbwin32proc.cpython-39.pyc
Ðазад
a k�h�1 � @ s� d Z ddlZddlZddlmZ ddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl mZmZ ddlmZ ddlmZmZmZ ddlmZ e �� Zde_d d � ZG d d � d ej �Z d d� Z dd� Z eeee�G dd� dej e��Z!dS )z< Windows Process Management, used with reactor.spawnProcess � N)� implementer)� _pollingfile�error)� BaseProcess)� IConsumer�IProcessTransport� IProducer)�quoteArguments� c C s t | � tj�� d S �N)�print�sys�stdout�flush)�msg� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/internet/_dumbwin32proc.py�debug$ s r c @ s e Zd Zdd� Zdd� ZdS )�_Reaperc C s || _ d S r )�proc)�selfr r r r �__init__* s z_Reaper.__init__c C s@ t �| jjd�t jkrdS t�| jj�}| �� | j�|� dS �Nr ) � win32eventZWaitForSingleObjectr �hProcessZ WAIT_OBJECT_0� win32processZGetExitCodeProcessZ deactivateZ processEnded)r ZexitCoder r r � checkWork- s �� z_Reaper.checkWorkN)�__name__� __module__� __qualname__r r r r r r r ) s r c C s\ t | ��@}|�d�dkr:|�d��d�}|W d � S W d � n1 sN0 Y dS )a 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. � z#!i � N)�open�read�readline�strip)�filename�f�exer r r � _findShebang9 s r) c C s | j d dkS )z� 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 r � )�args)Zpywinerrr r r �_invalidWin32AppT s r, c @ s� e Zd ZdZdZdd� Zdd� Zdd� Zd d � Zd d � Z d d� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Ze d1�d2d3�Z d4S )5�Processa� 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) r c s$ t j��|� t��|� t�� }d|_t�|d�\�_ }t�|d�\�_ } t�|d�\} �_ t� �j tj dd� t�� � |� _| � _| � _tj� _t�� } t�| �j | ddtj�} t��j � | �_ t�| �j | ddtj�} t��j � | �_ t�| �j | ddtj�} t��j � | �_ t j � � ��� |�p0i � dd� �� � D ��dd� |D �}t!|����rlt �"��n����r�t �"��n��� �����fdd �} z | � W n� t#j$�yz } z�t%|��s�t&|��n�t'��}|du �r�t&d � ��nzt(|�}|�)d�� t!|���}|�z | � W nJ t#j$�yd } z.t%|��rHt&d ||f ��t&|��W Y d}~n d}~0 0 W Y d}~n d}~0 0 t�| � t�|� t�| � t �*�j �fd d ��j+��_,t �*�j �fdd ��j-��_.t �/�j �j0��_1�j,�j.�j1fD ]}��2|� �q�j3�4�� ��2t5��� dS )z- Create a new child process. r r Nc S s" i | ]\}}t �|�t �|��qS r ��os�fsdecode)�.0�key�valuer r r � <dictcomp>� � z$Process.__init__.<locals>.<dictcomp>c S s g | ]}t �|��qS r r. )r1 �xr r r � <listcomp>� r5 z$Process.__init__.<locals>.<listcomp>c s2 t j} t���d d d| ��� � \�_�_�_}d S �Nr )�win32conZCREATE_NO_WINDOWr Z CreateProcessr �hThread�pid)�flagsZdwTid�Z StartupInfoZcmdline�command�env�pathr r r �doCreate� s �z"Process.__init__.<locals>.doCreatezD%r is neither a Windows executable, nor a script with a shebang linez<%r has an invalid shebang line: %r is not a valid executablec s � j �d| �S r8 ��protoZchildDataReceived��data�r r r �<lambda>� r5 z"Process.__init__.<locals>.<lambda>c s � j �d| �S �Nr rB rD rF r r rG � r5 )6r � _PollingTimerr r � win32security�SECURITY_ATTRIBUTES�bInheritHandle� win32pipeZ CreatePipeZhStdoutRZhStderrRZhStdinWZSetNamedPipeHandleStateZ PIPE_NOWAITr Z STARTUPINFOZ hStdOutputZ hStdErrorZ hStdInputZSTARTF_USESTDHANDLESZdwFlags�win32apiZGetCurrentProcessZDuplicateHandler9 ZDUPLICATE_SAME_ACCESS� win32file� CloseHandler/ �environ�copy�update�itemsr r0 � pywintypesr r, �OSErrorr) �list�insertZ_PollableReadPipe�outConnectionLostr �errConnectionLost�stderrZ_PollableWritePipe�inConnectionLost�stdinZ_addPollableResourcerC ZmakeConnectionr )r Zreactor�protocolr> r+ � environmentr@ ZsAttrsZhStdoutWZhStderrWZhStdinRZ currentPid�tmprA ZpwteZshebZorigcmdZpwte2Z pipewatcherr r= r r | s� �� � � �� ��4 � �� zProcess.__init__c C s, | j d u rt�� �|dv r(t�| jd� d S )N)�INT�TERMZKILLr )r; r ZProcessExitedAlreadyr ZTerminateProcessr )r ZsignalIDr r r � signalProcess s zProcess.signalProcessc C s |dkrt �|�S t �|�S r )r Z ProcessDoneZProcessTerminated)r �statusr r r � _getReason s zProcess._getReasonc C s | j �|� dS )zQ Write data to the process' stdin. @type data: C{bytes} N)r] �write)r rE r r r rf s z Process.writec C s | j �|� dS )z[ Write data to the process' stdin. @type seq: C{list} of C{bytes} N)r] � writeSequence)r �seqr r r rg s zProcess.writeSequencec C s" |dkr| j �|� nt|��dS )a; Similar to L{ITransport.write} but also allows the file descriptor in the child process which will receive the bytes to be specified. This implementation is limited to writing to the child's standard input. @param fd: The file descriptor to which to write. Only stdin (C{0}) is supported. @type fd: C{int} @param data: The bytes to write. @type data: C{bytes} @return: L{None} @raise KeyError: If C{fd} is anything other than the stdin file descriptor (C{0}). r N)r] rf �KeyError)r �fdrE r r r � writeToChild s zProcess.writeToChildc C sB |dkr| � � n,|dkr$| �� n|dkr6| �� ntd��d S )Nr r r z4Only standard-IO file descriptors available on win32)� closeStdin� closeStdout� closeStderr�NotImplementedError)r rj r r r � closeChildFD7 s �zProcess.closeChildFDc C s | j �� dS )zClose the process' stdin.N)r] �closerF r r r rl C s zProcess.closeStdinc C s | j �� d S r )r[ rq rF r r r rn G s zProcess.closeStderrc C s | j �� d S r )r rq rF r r r rm J s zProcess.closeStdoutc C s | � � | �� | �� dS )z8 Close the process' stdout, in and err. N)rl rm rn rF r r r �loseConnectionM s zProcess.loseConnectionc C s | j �d� | �� d S r8 �rC ZchildConnectionLost�connectionLostNotifyrF r r r rY U s zProcess.outConnectionLostc C s | j �d� | �� d S rH rs rF r r r rZ Y s zProcess.errConnectionLostc C s | j �d� | �� d S r rs rF r r r r\ ] s zProcess.inConnectionLostc C s | j d7 _ | �� dS )zS Will be called 3 times, by stdout/err threads and process handle. r N)�closedNotifies�maybeCallProcessEndedrF r r r rt a s z Process.connectionLostNotifyc C sB | j dkr>| jr>t�| j� t�| j� d | _d | _t�| � d S )N� )ru Z lostProcessrO rP r r: r rv rF r r r rv h s z Process.maybeCallProcessEndedc C s | j �||� d S r )r] �registerProducer)r ZproducerZ streamingr r r rx q s zProcess.registerProducerc C s | j �� d S r )r] �unregisterProducerrF r r r ry t s zProcess.unregisterProducerc C s | � � d S r )Z_pauserF r r r �pauseProducingx s zProcess.pauseProducingc C s | � � d S r )Z_unpauserF r r r �resumeProducing{ s zProcess.resumeProducingc C s | � � d S r )rr rF r r r � stopProducing~ s zProcess.stopProducingc C s t d��d S )Nz Unimplemented: Process.getHost�ro rF r r r �getHost� s zProcess.getHostc C s t d��d S )Nz Unimplemented: Process.getPeerr} rF r r r �getPeer� s zProcess.getPeer)�returnc C s d| j j� d| j� d�S )z@ Return a string representation of the process. �<z pid=�>)� __class__r r; rF r r r �__repr__� s zProcess.__repr__N) r r r �__doc__ru r rc re rf rg rk rp rl rn rm rr rY rZ r\ rt rv rx ry rz r{ r| r~ r �strr� r r r r r- e s6 r- )"r� r/ r Zzope.interfacer rU rN r9 r rO rM r rJ Ztwisted.internetr r Z twisted.internet._baseprocessr Ztwisted.internet.interfacesr r r Ztwisted.python.win32r rK ZPIPE_ATTRS_INHERITABLErL r Z_PollableResourcer r) r, rI r- r r r r �<module> s.
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка