← Back
Editing: popen_spawn.cpython-312.pyc
� �ae � � � d Z ddlZddlZddlZddlZddlZddlZddlZ ddlm Z m Z ddl m Z mZ ddlmZ ddlmZ G d� d e � Zy# e $ r ddl m Z m Z Y �/w xY w) zJProvides an interface like pexpect.spawn interface using subprocess.Popen � N)�Queue�Empty� )� SpawnBase�PY3)�EOF)� string_typesc �b � � e Zd Z d � fd� ZdZd� Zd� Zd� Zd� Zd� Z d d�Z d � Z d � Z d � Z � xZS )� PopenSpawnc � �� t t | � |||||| �� |�%t j j d� | _ n$| j t j � | _ t dt j t j t j || |�� } t j dk( rOt j � } | xj t j z c_ | | d< t j" | d< t% |t& � r;t j dk7 r(t) j* |t j, dk( � � }t j. |fi | ��| _ | j0 j2 | _ d | _ | j � | _ t9 � | _ t= j> | j@ � � | _! d | jB _" | jB jG � y ) N)�timeout�maxread�searchwindowsize�logfile�encoding� codec_errors�asciir )�bufsize�stdin�stderr�stdout�cwd� preexec_fn�env�win32� startupinfo� creationflags�posix)r F)�targetT)$�superr �__init__�os�linesep�encode�crlf� string_type�dict� subprocess�PIPE�STDOUT�sys�platform� STARTUPINFO�dwFlags�STARTF_USESHOWWINDOW�CREATE_NEW_PROCESS_GROUP� isinstancer �shlex�split�name�Popen�proc�pid�closed�_bufr � _read_queue� threading�Thread�_read_incoming� _read_thread�daemon�start)�self�cmdr r r r r r r r r �kwargsr � __class__s ��8/usr/lib/python3.12/site-packages/pexpect/popen_spawn.pyr! zPopenSpawn.__init__ s~ �� � �j�$�(��'�!1�7�!� � )� >� � �� � �)�)�7�3�D�I� �(�(�"�*�*�5�D�I��a�z��� '� .� .�z��� �*�#�?�� �<�<�7� "�$�0�0�2�K� � � �:�#B�#B� B� �$/�F�=� !�&0�&I�&I�F�?� #� �c�<� (�S�\�\�W�-D��+�+�c����G�);�<�C� �$�$�S�3�F�3�� ��9�9�=�=����� ��$�$�&�� � �7��� %� ,� ,�D�4G�4G� H���#'���� � ��� � �!� Fc �f � | j }| j r#|r||d | _ |d | S d| _ t d� �|dk( r | j }n|�d}t j � }t j � |z |k r�|r~t |� |k rp | j j � }|�d| _ nK|| j j |d�� z }t j � |z |k r|rt |� |k r�p|d | ||d c}| _ | j |d� |S # t $ r Y �/w xY w)NTzEnd Of File (EOF).���g ��.AF��final�read) r9 �_read_reached_eof�flag_eofr r �time�lenr: � get_nowait�_decoder�decoder �_log)rA �sizer �buf�t0�incoming�rs rE �read_nonblockingzPopenSpawn.read_nonblockingA s7 � ��i�i�� � !� !� � ���J�� ��5�D�z�!� $�� ��.�/�/� �b�=��l�l�G� �_��G� �Y�Y�[���y�y�{�R� �7�*�t��C��4�� C� �+�+�6�6�8�� �#�-1�D�*���t�}�}�+�+�H�E�+�B�B�� �y�y�{�R� �7�*�t��C��4�� �5�D�z�3�t�u�:� ��4�9� � � �!�V� ���� � �� �s �D$ �$ D0�/D0c �B � | j j j � } d} t j |d� }|s | j j d� y| j j |� �S# t $ r }| j |d� Y d}~�Zd}~ww xY w)z6Run in a thread to move output from a pipe to a queue.rF i rK N) r6 r �filenor" rK �OSErrorrS r: �put)rA r[ rU �es rE r= zPopenSpawn._read_incomingd s� � ����!�!�(�(�*����C� %��g�g�f�d�+�� �� � �$�$�T�*�� � � � � �� %� �� � %�� � �!�V�$�$�� %�s �A9 �9 B �B�B c �& � | j |� y)zHThis is similar to send() except that there is no return value. N��send)rA �ss rE �writezPopenSpawn.writeu s � � � � �!� rF c �4 � |D ] }| j |� � y)z�This calls write() for each element in the sequence. The sequence can be any iterable object producing strings, typically a list of strings. This does not add line separators. There is no return value. Nr` )rA �sequencerb s rE � writelineszPopenSpawn.writelinesz s � � �A� �I�I�a�L� rF c �8 � | j |� }| j |d� | j j |d�� }t r%| j j j |� S | j j j |� t |� S )zZSend data to the subprocess' stdin. Returns the number of bytes written. ra FrI ) �_coerce_send_stringrS �_encoderr$ r r6 r rc rO )rA rb �bs rE ra zPopenSpawn.send� sx � � � $� $�Q� '�� � � �!�V� � �M�M� � ��%� � 0�� ��9�9�?�?�(�(��+� +� �I�I�O�O� !� !�!� $��q�6�MrF c �` � | j |� }|| j | j � z S )z�Wraps send(), sending string ``s`` to child process, with os.linesep automatically appended. Returns number of bytes written. )ra r# )rA rb �ns rE �sendlinezPopenSpawn.sendline� s) � � �I�I�a�L���4�9�9�T�\�\�*�*�*rF c � � | j j � }|dk\ r|| _ d| _ nd| _ | | _ d| _ |S )zKWait for the subprocess to finish. Returns the exit code. r NT)r6 �wait� exitstatus� signalstatus� terminated)rA �statuss rE ro zPopenSpawn.wait� sG � � ��� � �!�� �Q�;� $�D�O� $�D� � "�D�O�!'��D� � ���� rF c �j � t j dk( rv|t j t j fv rt j }nC|t j t j fv rt j }nt j }t j | j j |� y)z}Sends a Unix signal to the subprocess. Use constants from the :mod:`signal` module to specify which signal. r N) r+ r, �signal�SIGINT� CTRL_C_EVENT�SIGBREAK�CTRL_BREAK_EVENT�SIGTERMr" �killr6 r7 )rA �sigs rE r{ zPopenSpawn.kill� ss � � �<�<�7� "��v�}�}�f�&9�&9�:�:� �)�)���� � �&�*A�*A�B�B� �-�-�� �n�n�� ���� � � � �s�#rF c �L � | j j j � y)z+Closes the stdin pipe from the writing end.N)r6 r �close)rA s rE �sendeofzPopenSpawn.sendeof� s � � � � ��� � � rF ) � i� NNNNN�strictN)� )�__name__� __module__� __qualname__r! rL rY r= rc rf ra rm ro r{ r � __classcell__)rD s @rE r r sH �� �GK�<@�37�("�T ��!�F&�"� ��"+� � $� rF r )�__doc__r" r; r( r+ rN ru r2 �queuer r � ImportError� spawnbaser r � exceptionsr �utilsr r � rF rE �<module>r� sW ��� � � � � � � �#�"� &� � �h �� h �� � #�"�"�#�s �A � A�A
Save File
Cancel