File manager - Edit - /usr/local/CyberCP/lib/python3.10/site-packages/docker/utils/__pycache__/socket.cpython-310.pyc
Back
o �h� � @ s� d dl Z d dlZd dlZd dlZd dlZzddlmZ W n ey) e d�ZY nw dZ dZ G dd� de �Z dZdd d �Zd d � Zd d� Zdd� Zdd� Zdd� Zddd�Zdd� ZdS ) � N� )� NpipeSocket� c @ s e Zd ZdS )� SocketErrorN)�__name__� __module__� __qualname__� r r �F/usr/local/CyberCP/lib/python3.10/site-packages/docker/utils/socket.pyr s r �m � c C s t jt jt jf}t| t�s-ttd�st�| gg g � nt�� }|� | tj tj B � |�� z t| d�r9| � |�W S t| t j�rE| �|�W S t�| �� |�W S tyf } z |j |vr[� W Y d}~dS d}~w ty� } z t| t�ot|j�dko|jd tk}|r�W Y d}~dS � d}~ww )z+ Reads at most n bytes from socket �poll�recvNr � )�errno�EINTR�EDEADLK� EWOULDBLOCK� isinstancer �hasattr�selectr �register�POLLIN�POLLPRIr �pysocket�SocketIO�read�os�fileno�OSError� Exception�len�args� NPIPE_ENDED)�socket�n�recoverable_errorsr �e� is_pipe_endedr r r r s: �� � ���r c C sF d}t |�|k r!t| |t |� �}|std��||7 }t |�|k s|S )z] Reads exactly n bytes from socket Raises SocketError if there isn't enough data � zUnexpected EOF)r! r r )r$ r% �data� next_datar r r � read_exactly> s �r, c C s< zt | d�}W n ty Y dS w t�d|�\}}||fS )z� Returns the stream and size of the next frame of data waiting to be read from socket, according to the protocol defined here: https://docs.docker.com/engine/api/v1.24/#attach-to-a-container � )���r. z>BxxxL)r, r �struct�unpack)r$ r* �stream�actualr r r �next_frame_headerL s �r3 c C s |r dd� t | �D �S t| �S )z� Return a generator of frames read from socket. A frame is a tuple where the first item is the stream number and the second item is a chunk of data. If the tty setting is enabled, the streams are multiplexed into the stdout stream. c s s � | ]}t |fV qd S )N)�STDOUT)�.0�framer r r � <genexpr>e s � z frames_iter.<locals>.<genexpr>)�frames_iter_tty�frames_iter_no_tty)r$ �ttyr r r � frames_iter\ s r; c c sh � t | �\}}|dk rdS |dkr3t| |�}|du r qt|�}|dkr&dS ||8 }||fV |dksq)zc Returns a generator of data read from the socket when the tty setting is not enabled. Tr N)r3 r r! )r$ r1 r% �result� data_lengthr r r r9 j s � ��r9 c c s$ � t | �}t|�dkrdS |V q)z^ Return a generator of data read from the socket when the tty setting is enabled. Tr N)r r! )r$ r< r r r r8 s � �r8 Fc C s� |du r d� | �S ddg}| D ]=}|dksJ �|d dur5|d du r*|d |d< q|d |d 7 < q|d du rB|d |d< q|d |d 7 < qt|�S )a� Iterate through frames read from the socket and return the result. Args: demux (bool): If False, stdout and stderr are multiplexed, and the result is the concatenation of all the frames. If True, the streams are demultiplexed, and the result is a 2-tuple where each item is the concatenation of frames belonging to the same stream. Fr) N)NNr r )�join�tuple)�frames�demux�outr6 r r r �consume_socket_output� s rC c C s. | t kr|dfS | tkrd|fS t| � d���)z[ Utility to demultiplex stdout and stderr when reading frames from the socket. Nz is not a valid stream)r4 �STDERR� ValueError)� stream_idr* r r r � demux_adaptor� s rG )r )F)r r r r$ r r/ � transportr � ImportError�typer4 rD r r r# r r, r3 r; r9 r8 rC rG r r r r �<module> s, � $ %
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.02 |
proxy
|
phpinfo
|
Settings