← Back
Editing: stream.cpython-312.opt-1.pyc
� 2�i- � �� � d dl Z d dlZd dlZd dlZd dlmZ ddlmZmZ ddl m Z m Z m Z m Z mZmZmZmZ ddlmZmZmZ ej, e� Z G d� de� Z G d � d ee� Zy) � N)�Dict� )� ChannelError�ProtocolChannel)�JsonDict� JsonObject�get_bool�get_enum�get_int� get_object�get_str�get_strv)�SubprocessProtocol�SubprocessTransport� WindowSizec �L � e Zd ZdZdej dedej fd�Zy)�SocketStreamChannel�stream�loop�options�returnc � �L � K � d|v rd|v r t dd�� � d|v r2t |d� }d|� �}|j � fd�|� � d { ��� \ }}nTd|v rCt |d� }t |dd � }d |� d |� �}|j � fd �||� � d { ��� \ }}n t dd �� �t j d|� � j � |S 7 ��7 �?# t $ rH} t j d| � t | t � rd} nd} t | t | � �� | �d } ~ ww xY w�w)N�unix�port�protocol-errorz-cannot specify both "port" and "unix" options��messagez Unix socket c � �� � S �N� ��selfs ��</usr/lib/python3.12/site-packages/cockpit/channels/stream.py�<lambda>z6SocketStreamChannel.create_transport.<locals>.<lambda> s �� �� �address� localhostz TCP socket �:c � �� � S r r r! s �r# r$ z6SocketStreamChannel.create_transport.<locals>.<lambda>' s �� �Dr% z7no "port" or "unix" or other address option for channelz$SocketStreamChannel: connected to %sz0SocketStreamChannel: connecting to %s failed: %s� not-found� terminated) r r �create_unix_connectionr �create_connection�logger�debug�OSError�info� isinstance�ConnectionRefusedError�str� close_on_eof) r" r r �path�label� transport�_r �host�error�problems ` r# �create_transportz$SocketStreamChannel.create_transport sJ �� �� � �W� ��7�!2� � /�9h�i� i� G��� � �w��/��&�t�f�-��%)�%@�%@� �t�%T� T� � �1� �7�"� �w��/�� �w� �;�?��%�d�V�1�T�F�3��%)�%;�%;�L�$�PT�%U� U� � �1�"�#3�+d�f� f� �L�L�?�� G� ������/ U�� V�� � G� �K�K�J�E�SX� Y��%�!7�8�%��&�� �w��E� �;�� F�� G�sN �D$�-C �C �AC �C�+C �:D$� C �C � D!�AD � D!�!D$N) �__name__� __module__� __qualname__�payload�asyncio�AbstractEventLoopr � Transportr= r r% r# r r s. � ��G� �7�+D�+D� �z� �^e�^o�^o� r% r c �` � e Zd ZdZdZd d�Zdefd�Zdeddfd�Zd e j dede fd �Z y) �SubprocessStreamChannelr ))�spawnNr Nc �$ � | j � y r )r5 r! s r# �process_exitedz&SubprocessStreamChannel.process_exited= s � � ���r% c � � d| j j � i}| j j � }|�||d< |S )Nz exit-statusr )� _transport�get_returncode� get_stderr)r" �args�stderrs r# �_get_close_argsz'SubprocessStreamChannel._get_close_args@ s? � �'�� � �)G�)G�)I�J��� � �+�+�-�� � � $�D��O�� r% r c �d � t |dt d � }|� | j j |� y y )N�window)r r rK �set_window_size)r" r rR s r# � do_optionsz"SubprocessStreamChannel.do_optionsH s/ � ��G�X�z�4�@�� � � �O�O� +� +�F� 3� r% r c � �. K � t |d� }t |dg d�d� }t |dd� }t |dd� � }t |d t d � }t |d g � }|d k( rt j } n&|d k( rt j } nt j } t t j � } | j t d� |D � � � t! || |||| || �� } | j# � } d| i| _ t& j) d|| � | S # t $ r t dd�� d �w xY w# t* $ r} t d� | �d } ~ wt, $ r} t d� | �d } ~ wt. $ r(} t& j1 d|| � t d� | �d } ~ ww xY w�w)NrG �err)�out�ignorer r � directory�.�ptyF)�defaultrR �environrW rX c 3 �@ K � | ] }|j d d� �� � y�w)�=� N)�split)�.0�es r# � <genexpr>z;SubprocessStreamChannel.create_transport.<locals>.<genexpr>_ s � �� �=�W��A�G�G�C��O�W�s � r z+invalid "environ" option for stream channelr )r[ rR �env�cwdrO �pidz Spawned process args=%s pid=%ir* z access-deniedzFailed to spawn %s: %szinternal-error)r r r r r r � subprocess�STDOUT�DEVNULL�PIPE�dict�osr] �update� ValueErrorr r �get_pid� _ready_infor. r/ �FileNotFoundError�PermissionErrorr0 r1 )r" r r rN rV rf r[ rR r] rO re r8 rg r; s r# r= z(SubprocessStreamChannel.create_transportN s� � �� ����)���w��'C�Y�O���g�{�C�0���w��u�5���G�X�z�4�@���7�I�r�2�� �%�<� �&�&�F� �H�_� �'�'�F� �_�_�F� "�2�:�:� .�� r� �J�J�t�=�W�=�=� >� <�+�D�$��#�f�Z]�cf�ou�v�I��#�#�%�C� %�s�|�D� � �L�L�9�4�� E� � �� � r� � /�9f�g�mq� q� r�� !� 7� �{�+�� 6�� � ;� ��/�U� :��� <� �K�K�0�$�� >� � /�0�e� ;�� <�sU �B,F�/!D �AD1 �F�D.�.F�1 F�: E� F� E � F�*#F � F�F)r N) r> r? r@ rA � restrictionsrI r rP rT rB rC r r= r r% r# rF rF 9 sQ � ��G�%�L� ��� �4�*� 4�� 4� !<�7�+D�+D� !<�z� !<�^q� !<r% rF )rB �loggingrm rh �typingr �channelr r �jsonutilr r r r r r r r � transportsr r r � getLoggerr> r. r rF r r% r# �<module>r{ sV �� � � � � � 3� g� g� g� L� L� �� � �8� $��#�/� #�L6<�o�/A� 6<r%
Save File
Cancel