Website : rimsha.abasa.com
backdoor
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
proc
/
self
/
root
/
lib
/
python3
/
dist-packages
/
docker
/
utils
/
__pycache__
/
Filename :
socket.cpython-310.pyc
back
Copy
o �2.a � @ s� d dl Z d dlZd dlZd dlZd dlZzddlmZ W n ey) e d�ZY nw dZ dZ G dd� de �Z ddd �Zd d � Zd d � Zdd� Zdd� Zdd� Zddd�Zdd� ZdS )� N� )� NpipeSocket� c @ s e Zd ZdS )� SocketErrorN)�__name__� __module__� __qualname__� r r �5/usr/lib/python3/dist-packages/docker/utils/socket.pyr s r � c C s� t jt jt jf}t| t�st�| gg g � z"t| d�r!| �|�W S t| t t d��r/| � |�W S t � | � � |�W S tyP } z |j |vrE� W Y d}~dS d}~ww )z+ Reads at most n bytes from socket �recv�SocketION)�errno�EINTR�EDEADLK� EWOULDBLOCK� isinstancer �select�hasattrr �getattr�pysocket�read�os�fileno�OSError)�socket�n�recoverable_errors�er r r r s ���r c C sH t � }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)�bytes�lenr 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_header8 s �r* 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>Q s � z frames_iter.<locals>.<genexpr>)�frames_iter_tty�frames_iter_no_tty)r �ttyr r r � frames_iterH s r2 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)r* r r )r r( r �result� data_lengthr r r r0 V s � ��r0 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 r3 r r r r/ k s � �r/ Fc C s� |du r t � �| �S ddg}| D ]=}|dksJ �|d dur6|d du r+|d |d< q|d |d 7 < q|d du rC|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. FN)NNr r )r �join�tuple)�frames�demux�outr- r r r �consume_socket_outputx s r: 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)r+ �STDERR� ValueError)� stream_idr! r r r � demux_adaptor� s r> )r )F)r r r r r r& � transportr � ImportError�typer+ r; � Exceptionr r r# r* r2 r0 r/ r: r> r r r r �<module> s* � %